Function rtpengine_connect_node

modules/rtpengine/rtpengine.c:1784–1866

}

static inline int rtpengine_connect_node(struct rtpe_node *pnode)
{
	int n;
	char *cp, *start, *end;
	char *hostname;
	struct addrinfo hints, *res;

	if (pnode->rn_umode == 0) {
		rtpe_socks[pnode->idx] = -1;
		return 1;
	}

	start = pnode->rn_address;

	cp = strrchr(pnode->rn_address, ':');
	if (cp == NULL) {
		/* no explicit port, use the default one */
		cp = CPORT;
		end = start + strlen(pnode->rn_address);
	} else {
		end = cp++;
		if (pnode->rn_umode == 6) {
			/* if IPv6 mode, port should be right after ] */
			if (end > start && *(end - 1) != ']') {
				/* if it is not, then it is part of the address */
				cp = CPORT;
				end = start + strlen(pnode->rn_address);
			}
		}
	}
	if (pnode->rn_umode == 6 && *start == '[') {
		start++;
		if (end > start && *(end - 1) == ']')
			end--;
	}

	hostname = (char*)pkg_malloc(end - start + 1);
	if (hostname==NULL) {
		LM_ERR("no more pkg memory\n");
		return 0;
	}
	memcpy(hostname, start, end - start);
	hostname[end-start] = '\0';

	memset(&hints, 0, sizeof(hints));
	hints.ai_flags = 0;
	hints.ai_family = (pnode->rn_umode == 6) ? AF_INET6 : AF_INET;
	hints.ai_socktype = SOCK_DGRAM;
	if ((n = getaddrinfo(hostname, cp, &hints, &res)) != 0) {
		LM_ERR("%s\n", gai_strerror(n));
		pkg_free(hostname);
		return 0;
	}
	pkg_free(hostname);

	if (res->ai_addrlen > sizeof(pnode->ai_addr)) {
		LM_ERR("RTP proxy address is too large\n");
		freeaddrinfo(res);