Function udp_request

lib_fiber/c/src/dns/resolver.c:396–454

static int __wait_timeout = 5000;

static int udp_request(const char *ip, unsigned short port,
	const char *data, size_t dlen, char *buf, size_t size)
{
	int ret;
	struct sockaddr_in addr, from_addr;
	socklen_t len;
	socket_t sock = acl_fiber_socket(AF_INET, SOCK_DGRAM, 0);

	if (sock == INVALID_SOCKET) {
		msg_error("%s(%d): create socket error %s",
			  __FUNCTION__ , __LINE__, last_serror());
		return -1;
	}

	memset(&addr, 0, sizeof(addr));
	addr.sin_family      = AF_INET;
	addr.sin_port        = htons(port);
	addr.sin_addr.s_addr = inet_addr(ip);

#if defined(_WIN32) || defined(_WIN64)
	ret = acl_fiber_sendto(sock, data, (int) dlen, 0, (struct sockaddr *) &addr,
		     (socklen_t) sizeof(addr));
#else
	ret = (int) acl_fiber_sendto(sock, data, dlen, 0, (struct sockaddr *) &addr,
		     (socklen_t) sizeof(addr));
#endif

	if (ret < 0) {
		msg_error("%s(%d): send error %s",
			__FUNCTION__ , __LINE__, last_serror());
		acl_fiber_close(sock);
		return -1;
	}

	if (read_wait(sock, __wait_timeout) < 0) {
		acl_fiber_close(sock);
		msg_warn("%s(%d), %s: read timeout",
			__FILE__, __LINE__, __FUNCTION__);
		return -1;
	}

	len = (socklen_t) sizeof(from_addr);

#if defined(_WIN32) || defined(_WIN64)
	ret = acl_fiber_recvfrom(sock, buf, (int) size, 0,
		(struct sockaddr*) &from_addr, &len);
#else
	ret = (int) acl_fiber_recvfrom(sock, buf, size, 0,
		(struct sockaddr*) &from_addr, &len);
#endif

	acl_fiber_close(sock);
	if (ret <= 0) {
		msg_error("%s(%d): read error %s",
			__FUNCTION__ , __LINE__, last_serror());
		return -1;
	}
	return ret;