IP Networking

    printf("xyz\n");  // or sleep(100);
    delete pListenSocket; // Close and delete

int Socketpair (int domain, int type, int protocol, Socket ** ppReadSocket, Socket ** ppWriteSocket)
{
	Socket * pListenSocket = NULL;
	Socket * pConnectSocket = NULL;
	Socket * pAcceptSocket = NULL;
    IpAddress listenAddr;
    uint16 listenPort;
    IpAddress remoteAddr;
    uint16 remotePort;
	int saved_errno = -1;

    //
    // Create the listener socket
    //
	pListenSocket = SocketFactory::NewSocket (AF_INET, SOCK_STREAM, IPPROTO_TCP);
	if (pListenSocket == NULL)
    {
        gErrorMsg (fMessageLogSettings, __func__) << "failed to create listener\n";
		return -1;
    }
    if (pListenSocket->Bind (kSoftwareLoopbackIp, 0) < 0)
    {
        gErrorMsg (fMessageLogSettings, __func__) << "failed to bind listener\n";
		goto tidy_up_and_fail;
    }
    pListenSocket->Getsockname (listenAddr, listenPort);
    {
        char debugTxt[32];
        listenAddr.Get (debugTxt, sizeof (debugTxt));
        gAlwaysMsg(fMessageLogSettings, __func__) << "listener bound to " << debugTxt << ":" << listenPort << endl;
    }

	if (pListenSocket->Listen (1) < 0)
    {
        gErrorMsg (fMessageLogSettings, __func__) << "failed to listen\n";
		goto tidy_up_and_fail;
    }

    //
    // Create the connector socket
    //
	pConnectSocket = SocketFactory::NewSocket (AF_INET, SOCK_STREAM, IPPROTO_TCP);
	if (pConnectSocket == NULL)
    {
        gErrorMsg (fMessageLogSettings, __func__) << "failed to create connector\n";
		goto tidy_up_and_fail;
    }

    //
    // Connect. This would normally block, burt since this is on the lookback, it
    // should come right back
    //
	if (pConnectSocket->Connect(kSoftwareLoopbackIp, listenPort) < 0)
    {
        gErrorMsg (fMessageLogSettings, __func__) << "failed to connect to listener\n";
		goto tidy_up_and_fail;
    }

    //
    // Accept the connection we just tried
    //
	pAcceptSocket = pListenSocket->Accept (remoteAddr, remotePort);
	if (pAcceptSocket == NULL)
    {
        gErrorMsg (fMessageLogSettings, __func__) << "failed to accept\n";
		goto tidy_up_and_fail;
    }
    pAcceptSocket->Getsockname (remoteAddr, remotePort);
    {
        char debugTxt[32];
        remoteAddr.Get (debugTxt, sizeof (debugTxt));
        gAlwaysMsg (fMessageLogSettings, __func__) << "accepted connection from " << debugTxt << ":" << remotePort << endl;
    }

    delete pListenSocket; // Close and delete

    // We always make the connector non-blocking
    pConnectSocket->SetSocketNonBlocking (true);

    fSocketList.push_back (pConnectSocket);
    fSocketList.push_back (pAcceptSocket);
	*ppReadSocket = pConnectSocket;
	*ppWriteSocket = pAcceptSocket;
    gAlwaysMsg(fMessageLogSettings, __func__) << "returning sockets "
        << pConnectSocket->SocketDescriptor()
        << " and "
        << pAcceptSocket->SocketDescriptor()
        << endl;

	return 0;

 tidy_up_and_fail:
	if (saved_errno < 0)
		saved_errno = errno;
	if (pListenSocket != NULL)
    {
		delete pListenSocket;
    }
	if (pConnectSocket == NULL)
    {
		delete pConnectSocket;
    }
	if (pAcceptSocket == NULL)
    {
		delete pAcceptSocket;
    }

	EVUTIL_SET_SOCKET_ERROR(saved_errno);
	return -1;

}