winsock-pakiety

for( i = 0; i <= fdmax; i++ ) {
    if( FD_ISSET( i, & read_fds ) ) { // mamy jednego!!
        if( i == listener ) {
            // obsłuż nowe połączenie
            addrlen = sizeof( remoteaddr );
            if(( newfd = accept( listener,( struct sockaddr * ) & remoteaddr,
            & addrlen ) ) == - 1 ) {
                perror( "accept" );
            } else {
                FD_SET( newfd, & master ); // dodaj do głównego zestawu
                if( newfd > fdmax ) { // śledź maksymalny
                    fdmax = newfd;
                }
                printf( "selectserver: new connection from %s on "
                "socket %d\n", inet_ntoa( remoteaddr.sin_addr ), newfd );
            }
        } else {
            // obsłuż dane od klienta
            if(( nbytes = recv( i, buf, sizeof( buf ), 0 ) ) <= 0 ) {
                // błąd lub połączenie zostało zerwane
                if( nbytes == 0 ) {
                    // połączenie zerwera
                    printf( "selectserver: socket %d hung up\n", i );
                } else {
                    perror( "recv" );
                }
                close( i ); // papa!
                FD_CLR( i, & master ); // usuń z głównego zestawu
            } else {
                // mamy trochę danych od klienta
                for( j = 0; j <= fdmax; j++ ) {
                    // wyślij do wszystkich!
                    if( FD_ISSET( j, & master ) ) {
                        // oprócz nas i gniazda nasłuchującego
                        if( j != listener && j != i ) {
                            if( send( j, buf, nbytes, 0 ) == - 1 ) {
                                perror( "send" );
                            }
                        }
                    }
                }
            }
        }

int recvtimeout( int s, char * buf, int len, int timeout )
{
    fd_set fds;
    int n;
    struct timeval tv;
   
    // ustaw zestaw deskryptorów plików
    FD_ZERO( & fds );
    FD_SET( s, & fds );
   
    // ustaw strukturę timeval dla przedawnienia
    tv.tv_sec = timeout;
    tv.tv_usec = 0;
   
    // czekaj na przedawnienie lub na odczytanie danych
    n = select( s + 1, & fds, NULL, NULL, & tv );
    if( n == 0 ) return - 2; // przedawnienie!
   
    if( n == - 1 ) return - 1; // błąd
    // danę już muszą być, więc wywołaj normalnie recv()
    return recv( s, buf, len, 0 );
}

#define MAX_MESSAGE_SIZE 4096
char buffer[ MAX_MESSAGE_SIZE ];
ret = recvtimeout( sClient, buffer, MAX_MESSAGE_SIZE, 1 );