программирование сокетов с помощью select

У меня есть два узла, взаимодействующие с сокетом. Каждый узел имеет поток чтения и поток записи для связи с другим. Ниже приведен код для потока чтения. Связь работает нормально между двумя узлами с этим кодом. Но я пытаюсь добавить функцию выбора в этот поток, и это вызывает у меня проблемы (код для выбора находится в комментариях. Я просто раскомментирую его, чтобы добавить функциональность). Проблема в том, что один узел не получает сообщения и только делает тайм-аут. Другой узел получает сообщения от другого узла, но никогда не истечет время ожидания. Этой проблемы не существует (оба узла отправляют и получают сообщения) без выбора (с сохранением комментариев /* */).

Может ли кто-нибудь указать, в чем может быть проблема? Спасибо.

void *Read_Thread(void *arg_passed)
{   
    int numbytes;
    unsigned char *buf;
    buf = (unsigned char *)malloc(MAXDATASIZE);

    /*
    fd_set master;
    int fdmax;
    FD_ZERO(&master);
    */

    struct RWThread_args_template *my_args = (struct RWThread_args_template *)arg_passed;

    /*
    FD_SET(my_args->new_fd, &master);
    struct timeval tv;
    tv.tv_sec = 2;
    tv.tv_usec = 0;
    int s_rv = 0;
    fdmax = my_args->new_fd;
    */

    while(1)
    {
        /*
        s_rv = -1;
        if((s_rv = select(fdmax+1, &master, NULL, NULL, &tv)) == -1)
        {
            perror("select");
            exit(1);
        }
        if(s_rv == 0)
        {
            printf("Read: Timed out\n");
            continue;
        }
        else
        {
            printf("Read: Received msg\n");
        }
        */
        if( (numbytes = recv(my_args->new_fd, buf, MAXDATASIZE-1, 0)) == -1 )
        {
            perror("recv");
            exit(1);
        }
        buf[numbytes] = '\0';

        printf("Read: received '%s'\n", buf);
    }
    pthread_exit(NULL);
}

person Romonov    schedule 02.03.2011    source источник


Ответы (1)


Вы должны настроить master и tv перед каждым вызовом select() внутри цикла. Они оба изменяются вызовом select().

В частности, если select() вернуло 0, то master теперь будет пустым.

person caf    schedule 02.03.2011