Function sane_socketpair

lib_fiber/c/src/common/socketpair.c:156–229

#endif /* HAS_POLL */

int sane_socketpair(int domain, int type, int protocol, socket_t result[2])
{
	socket_t listener = inet_listen("127.0.0.1", 0, 10), client;
	struct sockaddr_in addr;
	struct sockaddr *sa = (struct sockaddr*) &addr;
	socklen_t len = sizeof(addr);

	if (listener == INVALID_SOCKET) {
		return -1;
	}

	result[0] = INVALID_SOCKET;
	result[1] = INVALID_SOCKET;

	if (listener  == INVALID_SOCKET) {
		msg_error("%s(%d), %s: listen error %s",
			__FILE__, __LINE__, __FUNCTION__, last_serror());
		return -1;
	}

	tcp_nodelay(listener, 1);
	if (getsockname(listener, sa, &len) < 0) {
		msg_error("%s(%d), %s: getoskname error %s",
			__FILE__, __LINE__, __FUNCTION__, last_serror());
		CLOSE_SOCKET(listener);
		return -1;
	}

	client = socket(AF_INET, SOCK_STREAM, 0);
	if (client == INVALID_SOCKET) {
		msg_error("%s(%d), %s: create socket %s error %s",
			__FILE__, __LINE__, __FUNCTION__, addr, last_serror());
		CLOSE_SOCKET(listener);
		return -1;
	}

	non_blocking(client, NON_BLOCKING);

	if (!var_hook_sys_api) {
		if (connect(client, sa, len) == -1) {
			int err = acl_fiber_last_error();
			if (err != FIBER_EINPROGRESS && !error_again(err)) {
				msg_error("%s(%d), %s: connect error %s",
					__FILE__, __LINE__, __FUNCTION__, last_serror());
				CLOSE_SOCKET(listener);
				CLOSE_SOCKET(client);
				return -1;
			}
		}
	} else if ((*sys_connect)(client, sa, len) == -1) {
		int err = acl_fiber_last_error();
		if (err != FIBER_EINPROGRESS && !error_again(err)) {
			msg_error("%s(%d), %s: connect error %s",
				__FILE__, __LINE__, __FUNCTION__, last_serror());
			CLOSE_SOCKET(listener);
			CLOSE_SOCKET(client);
			return -1;
		}