Async verbinden und trennen mit epoll (Linux)

Zu tun, ein nicht-blockierendes connect(), vorausgesetzt, die Steckdose wurde bereits non-blocking:

int res = connect(fd, ...);
if (res < 0 && errno != EINPROGRESS) {
    //error, fail somehow, close socket
    return;
}

if (res == 0) {
    //connection has succeeded immediately
} else {
    //connection attempt is in progress
}

Für den zweiten Fall, wo der connect () - failed with EINPROGRESS (und nur in diesem Fall), müssen Sie warten, bis der socket beschreibbar sein, z.B. für epoll angeben, dass Sie gewartet haben EPOLLOUT auf diesem sockel. Sobald Sie benachrichtigt werden, dass es beschreibbar (mit epoll auch erwarten, um eine EPOLLERR oder EPOLLHUP Ereignis), überprüfen Sie das Ergebnis des Verbindungsversuchs:

int result;
socklen_t result_len = sizeof(result);
if (getsockopt(fd, SOL_SOCKET, SO_ERROR, &result, &result_len) < 0) {
    //error, fail somehow, close socket
    return;
}

if (result != 0) {
    //connection failed; error code is in 'result'
    return;
}

//socket is ready for read()/write()

In meiner Erfahrung, die auf Linux, connect() nie sofort gelingt, und man muss immer warten, bis writability. Aber, zum Beispiel, auf FreeBSD, gesehen hab ich nicht-blockierendes connect() zu localhost erfolgreich sofort.

Habe ich eine "komplette" Antwort hier im Fall, jemand ist auf der Suche nach diesem:

#include <sys/epoll.h>
#include <errno.h>
....
....
int retVal = -1;
socklen_t retValLen = sizeof (retVal);

int status = connect(socketFD, ...);
if (status == 0)
 {
   //OK -- socket is ready for IO
 }
else if (errno == EINPROGRESS)
 {
    struct epoll_event newPeerConnectionEvent;
    int epollFD = -1;
    struct epoll_event processableEvents;
    unsigned int numEvents = -1;

    if ((epollFD = epoll_create (1)) == -1)
    {
       printf ("Could not create the epoll FD list. Aborting!");
       exit (2);
    }     

    newPeerConnectionEvent.data.fd = socketFD;
    newPeerConnectionEvent.events = EPOLLOUT | EPOLLIN | EPOLLERR;

    if (epoll_ctl (epollFD, EPOLL_CTL_ADD, socketFD, &newPeerConnectionEvent) == -1)
    {
       printf ("Could not add the socket FD to the epoll FD list. Aborting!");
       exit (2);
    }

    numEvents = epoll_wait (epollFD, &processableEvents, 1, -1);

    if (numEvents < 0)
    {
       printf ("Serious error in epoll setup: epoll_wait () returned < 0 status!");
       exit (2);
    }

    if (getsockopt (socketFD, SOL_SOCKET, SO_ERROR, &retVal, &retValLen) < 0)
    {
       //ERROR, fail somehow, close socket
    }

    if (retVal != 0) 
    {
       //ERROR: connect did not "go through"
    }   
}
else
{
   //ERROR: connect did not "go through" for other non-recoverable reasons.
   switch (errno)
   {
     ...
   }
}