Function dm_receive_req

modules/aaa_diameter/dm_impl.c:545–627

static int dm_receive_req(struct msg **_req, struct avp * avp, struct session * sess, void * data, enum disp_action * act)
{
	cJSON *avps = NULL, *it;
	struct msg *req = *_req;
	struct msg_hdr *hdr = NULL;
	str tid = STR_NULL, avp_arr = STR_NULL;

	FD_CHECK(fd_msg_hdr(req, &hdr));
	LM_DBG("received Diameter request (appl: %u, cmd: %u)\n", hdr->msg_appl, hdr->msg_code);

	cJSON_InitHooks(&shm_mem_hooks);
	avps = cJSON_CreateArray();
	if (!avps) {
		LM_ERR("oom 1\n");
		goto error;
	}

	if (dm_avps2json(req, avps) != 0) {
		LM_ERR("failed to pack request AVPs as JSON string\n");
		goto error;
	}

	/* search for any "transaction identifier" in the request */
	for (it = avps->child; it; it = it->next) {
		if (it->type != cJSON_Object || !it->child || it->child->next || it->child->type != cJSON_String)
			continue;

		if (sess) {
			if (!strcmp(it->child->string, "Session-Id")) {
				LM_DBG("found Session-id: %s\n", it->child->valuestring);
				init_str(&tid, it->child->valuestring);
				break;
			}
		} else if (!strcmp(it->child->string, "Transaction-Id")) {
			LM_DBG("found Transaction-id: %s\n", it->child->valuestring);
			init_str(&tid, it->child->valuestring);
			break;
		}
	}

	avp_arr.s = cJSON_PrintUnformatted(avps);
	if (!avp_arr.s) {
		LM_ERR("cJSON_PrintUnformatted failed\n");
		goto error;
	}
	avp_arr.len = strlen(avp_arr.s);

	/* keep the request for a while in order to be able to generate the answer */
	if (!dm_server_autoreply_error)
		dm_update_unreplied_req(req);

	if (dm_dispatch_event_req(req, &tid, hdr->msg_appl, hdr->msg_code, &avp_arr))
		LM_ERR("failed to dispatch DM Request (tid: %.*s, %d/%d)\n", tid.len,
		        tid.s, hdr->msg_appl, hdr->msg_code);

	if (dm_server_autoreply_error) {
		struct dm_message dm;