Function send_rtpp_command

modules/rtpproxy/rtpproxy.c:2173–2371

#define OSIP_IOV_MAX 1024

char *
send_rtpp_command(struct rtpp_node *node, struct rtpproxy_vcmd *vcmd, int vcnt)
{
	struct sockaddr_un addr;
	int fd, len, i;
	int max_vcnt=OSIP_IOV_MAX;
	char *cp;
	static char buf[RTPPROXY_BUF_SIZE];
	struct pollfd fds[1];

	DASSERT(vcnt <= vcmd->useritems);
	DASSERT(vcmd->vu == vcmd->vs + 1);

#ifdef IOV_MAX
	if (IOV_MAX < OSIP_IOV_MAX)
		max_vcnt = IOV_MAX;
#endif

	if (rtpp_socks[node->idx].fd == -1 && node->rn_umode != CM_UNIX &&
	    node->rn_umode != CM_RTPIO) {
		rtpp_socks[node->idx].fd = connect_rtpp_node(node);
		if (rtpp_socks[node->idx].fd == -1) {
			LM_ERR("connect_rtpp_node() failed\n");
			return (NULL);
		}
	}
	/* normalize vcntl to max_vcnt, as on some systems this limit is very low (16 on Solaris) */
	if (vcnt + 1 > max_vcnt) {
		int i, vec_len = 0;
		/* use buf if possible :) */
		for (i = max_vcnt - 1; i < (vcnt + 1); i++)
			vec_len += vcmd->vs[i].iov_len;
		/* use buf, error otherwise */
		if (vec_len > RTPPROXY_BUF_SIZE) {
			LM_ERR("Command too big %d - max %d\n", vec_len, RTPPROXY_BUF_SIZE);
			return NULL;
		}
		cp = buf;
		for (i = max_vcnt - 1; i < (vcnt + 1); i++) {
			memcpy(cp, vcmd->vs[i].iov_base, vcmd->vs[i].iov_len);
			cp += vcmd->vs[i].iov_len;
		}
		i = max_vcnt - 1;
		vcmd->vs[i].iov_len = vec_len;
		vcmd->vs[i].iov_base = buf;
		/* finally solve the problem */
		vcnt = max_vcnt;

	}

	len = 0;
	cp = buf;

	if (node->rn_umode == CM_UNIX) {
		int s_errno, nretry;

		nretry = 1;
		memset(&addr, 0, sizeof(addr));