2011-03-02 91 views
3

我有两个节点与套接字进行通信。每个节点都有一个读线程和一个写线程与另一个进行通信。下面给出的是读线程的代码。使用该代码的两个节点之间的通信正常工作。但我试图在这个线程中添加一个select函数,这给我带来了一些问题(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); 
} 

回答

3

必须在每个调用之前建立mastertvselect(),内环路。它们都被select()调用修改。

特别是,如果select()返回0,那么master现在将为空。

+0

是的。解决了这个问题。谢谢! – Romonov 2011-03-02 06:52:47