Linux: ¿hay una lectura o una recepción del socket con tiempo de espera?

¿Cómo puedo intentar leer datos del socket con tiempo de espera? Lo sé, select, pselect, poll, tiene un campo de tiempo de espera, pero su uso desactiva "tcp fast-path" en tcp reno stack.

La única idea que tengo es usar recv (fd, ..., MSG_DONTWAIT) en un bucle

Puede utilizar la función setsockopt para establecer un tiempo de espera en las operaciones de recepción:

SO_RCVTIMEO

Establece el valor de tiempo de espera que especifica la cantidad máxima de tiempo que espera una función de entrada hasta que se completa. Acepta una estructura de valores de tiempo con la cantidad de segundos y microsegundos que especifican el límite de cuánto tiempo esperar para que se complete una operación de entrada. Si una operación de recepción se ha bloqueado durante tanto tiempo sin recibir datos adicionales, volverá con un recuento parcial o errno establecido en [EAGAIN] o [EWOULDBLOCK] si no se reciben datos. El valor predeterminado para esta opción es cero, lo que indica que una operación de recepción no se agotará. Esta opción tiene una estructura de tiempo. Tenga en cuenta que no todas las implementaciones permiten configurar esta opción.

// LINUX
struct timeval tv;
tv.tv_sec = timeout_in_seconds;
tv.tv_usec = 0;
setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, (const char*)&tv, sizeof tv);

// WINDOWS
DWORD timeout = timeout_in_seconds * 1000;
setsockopt(socket, SOL_SOCKET, SO_RCVTIMEO, (const char*)&timeout, sizeof timeout);

// MAC OS X (identical to Linux)
struct timeval tv;
tv.tv_sec = timeout_in_seconds;
tv.tv_usec = 0;
setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, (const char*)&tv, sizeof tv);

Según se informa, en Windows, esto debe hacerse antes de llamar bind. He verificado mediante un experimento que se puede hacer antes o después binden Linux y OS X.

Aquí hay un código simple para agregar un tiempo de espera a su recvfunción usando pollen C:

struct pollfd fd;
int ret;

fd.fd = mySocket; // your socket handler 
fd.events = POLLIN;
ret = poll(&fd, 1, 1000); // 1 second for timeout
switch (ret) {
    case -1:
        // Error
        break;
    case 0:
        // Timeout 
        break;
    default:
        recv(mySocket,buf,sizeof(buf), 0); // get your data
        break;
}

// funciona también después de la operación de vinculación para WINDOWS

DWORD timeout = timeout_in_seconds * 1000;
setsockopt(socket, SOL_SOCKET, SO_RCVTIMEO, (const char*)&timeout, sizeof timeout);

Instale un controlador para SIGALRM, luego use alarm()o ualarm()antes de un bloqueo regular recv(). Si la alarma se dispara, recv()devolverá un error con el errnoajuste a EINTR.

LINUX

struct timeval tv;
tv.tv_sec = 30;        // 30 Secs Timeout
tv.tv_usec = 0;        // Not init'ing this can cause strange errors
setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, (const char*)&tv,sizeof(struct timeval));

VENTANAS

DWORD timeout = SOCKET_READ_TIMEOUT_SEC * 1000;
setsockopt(socket, SOL_SOCKET, SO_RCVTIMEO, (const char*)&timeout, sizeof(timeout));

NOTA : ha puesto esta configuración antes de la bind()llamada de función para una ejecución adecuada