Function resume_async_send_rtpe_command

modules/rtpengine/rtpengine.c:3482–3619

}

enum async_ret_code resume_async_send_rtpe_command(int fd, struct sip_msg *msg, void *_param)
{
	int len = 0, cookielen = 0;
	static char buf[0x10000];
	char* cp = buf;
	bencode_item_t *dict;
	str oldbody = { 0, 0 };
	str newbody;
	struct lump *anchor;
	pv_value_t val;
	struct rtpe_ctx *ctx;
	rtpe_async_param *param = (rtpe_async_param *)_param;

	LM_DBG("Need to resume async rtpe call \n");

	if (param->node->rn_umode == 0) {
		do {
			len = read(fd, buf, sizeof(buf) - 1);
		} while (len == -1 && errno == EINTR);
		close(fd);
		if (len <= 0) {
			LM_ERR("can't read reply from a RTP Engine\n");
			goto error;
		}
	} else {
		/* UDP got triggered, wait for 1second max to read now */
		struct timeval tv;
		tv.tv_sec = 1;
		tv.tv_usec = 0;
		setsockopt(fd, SOL_SOCKET, SO_RCVTIMEO, (const char*)&tv, sizeof tv);

		len = recv(fd, buf, sizeof(buf)-1, 0);
		if (len <= 0) {
			LM_ERR("can't read reply from a RTP Engine (%d, %d)\n", len, errno);
			RTPE_IO_ERROR_CLOSE(param->node->idx);
			goto error;
		}
		cookielen = strlen(param->cookie);
		if (len >= (cookielen - 1) &&
		memcmp(buf, param->cookie, (cookielen - 1)) == 0) {
			len -= (cookielen - 1);
			cp += (cookielen - 1);
			if (len != 0) {
				len--;
				cp++;
			}
		} else {
			LM_ERR("read reply from a RTP Ending FD %d. Cookie does NOT match (%.*s <> %.*s)\n",
			fd, cookielen - 1, param->cookie, cookielen - 1, buf);
			goto error;
		}
	}

	/* store the value of the selected node */
	if (param->spvar) {
		memset(&val, 0, sizeof(pv_value_t));
		val.flags = PV_VAL_STR;
		val.rs = param->node->rn_url;