socket select 问题

liuchang8877

我在  客户端 ，与 服务端 都设置了 select（），  一个监听可读  一个监听可写
client — select(sockId, NULL,fdset,NULL,&timeOut); (timeOut 设置超时时间) 监听可写
server — select(workersock,fdset,NULL.NULL,NULL) (timeout 设置为NULL，持续等待数据) 监听可读

为什么   server端 阻塞在了select  ，  直到  client 端 超时 重连后 才能读到数据。？
希望大牛 给点指示。

xiyoulaoyuanjia

建议你看看

1. int select(int nfds, fd_set *readfds, fd_set *writefds,
   
2.                   fd_set *exceptfds, struct timeval *timeout);
   

复制代码

nfds is the highest-numbered file descriptor in any of the three sets, plus 1.

liuchang8877

回复 2# xiyoulaoyuanjia


嗯 这个+1 了，似乎不是这里的问题，在判断可读 可写时，总是 阻塞在哪里，直到timeOut  后 第一次连接才有数据。

xiyoulaoyuanjia

把代码贴出来看看吧~

liuchang8877

//这是客户端

1. while (1)
   
2.     {
   
3.         struct in_addr              addr;
   
4.         char *                      serverIpStr;
   
5.         char *                      tmpPort;
   
6.         int                         initFlag = 1;
   
7.         status = 0;
   
8.         timeOutCount = 0;
   
9. 
   
10.         if(sockId >= 0){
    
11.             safeclose(sockId);
    
12.             sockId = -1;
    
13.             sleep(1);
    
14.         }
    
15. 
    
16.         serverIpStr = ipSever;
    
17.         tmpPort     = Port;
    
18. 
    
19.         for(count = 0; count < 3; count++){
    
20.             sockId = clientconnect(serverIpStr,tmpPort,Proto);
    
21. 
    
22.             printf("sockId: %d\n",sockId);
    
23.             if(sockId >= 0) break;
    
24.             sleep(1);
    
25.         }
    
26.         if(sockId < 0){
    
27.             printf("fail,connect ip is %s,port id %s,try times is %d NOW GO TO  TRY_OTHER",serverIpStr,tmpPort,count);
    
28.             continue;
    
29.         }
    
30. 
    
31.         printf("success,connect ip :%s,port %s,sockId %d\n",serverIpStr,tmpPort,sockId);
    
32. 
    
33.         FD_ZERO(&oriSelectSet);
    
34.         FD_SET(sockId,&oriSelectSet);
    
35.         do{
    
36.                 read_size = readRingShm(sem_id,shm_buff,cTemp,&read_count);
    
37.         }while(!read_size);
    
38. 
    
39.         while(initFlag){
    
40.             memcpy(&selectSet,&oriSelectSet,sizeof(selectSet));
    
41.             timeOut.tv_sec = 3;
    
42.             timeOut.tv_sec = 3;
    
43.             timeOut.tv_usec = 0;
    
44. 
    
45.             selectRvalue = select(sockId+1,NULL,&selectSet,NULL,&timeOut);
    
46. 
    
47.             if(selectRvalue > 0){
    
48.                 timeOutCount = 0;
    
49.                 if(FD_ISSET(sockId,&selectSet)){//success
    
50.                     send_size = 0;
    
51.                     send_count = 0;
    
52.                 //  do{
    
53.                         read_size = readRingShm(sem_id,shm_buff,cTemp,&read_count);
    
54.                 //   }while(!read_size);
    
55.             //printf("read_size:%d\n",read_size);
    
56. 
    
57.                 //char str[10];
    
58. 
    
59.                 //memset(cTemp,sui,CARD_DATA_SIZE);
    
60.                  //sui++;
    
61.                     /*
    
62.                     while(1){
    
63.                             i_left =  read_size - send_count;
    
64.                             if(i_left <= 0)
    
65.                             break;
    
66.                             send_size = write_buffer_send(sockId,cTemp+send_count,i_left,25);
    
67.                            
    
68.                             if(send_size < 0){
    
69.                                 printf("send fail \n");
    
70.                             }else if(0 == send_size){
    
71.                            
    
72.                                 printf("send time out\n");
    
73.                                 usleep(2000);
    
74.                             }else{
    
75.                                 send_count += send_size;
    
76.                                 if(send_count  == CARD_DATA_SIZE){
    
77.                                     break;
    
78.                                 }
    
79.                            
    
80.                             }
    
81.                         */
    
82.                             send(sockId,cTemp,CARD_DATA_SIZE,0);
    
83.                     //}
    
84.                   close(sockId);
    
85.                 }
    
86.             }else if(selectRvalue == 0){
    
87. 
    
88. 
    
89.             //timeOut
    
90.                 //sleep(2);
    
91.                 if(++timeOutCount >= TIMEOUT){
    
92.                     printf("time out\n");
    
93.                     initFlag = 0;
    
94.                 }
    
95.                 FD_CLR(sockId,&oriSelectSet);
    
96.                 continue;
    
97.             }else{
    
98.             // system error
    
99.                 if(errno != EINTR)
    
100.                 printf("error sockId :%d",sockId);
     
101.                 initFlag =0;
     
102.                 //sleep(2);
     
103.                 FD_CLR(sockId,&oriSelectSet);
     
104.                 continue;
     
105.             }
     
106.         }
     
107. 
     
108.     }
     

复制代码

liuchang8877

这是服务端

1. while(1){
   
2.         bcopy(&orig_fdset,&fdset,sizeof(orig_fdset));
   
3.         timeOut.tv_sec = tvLimit.tv_sec - tvCurr.tv_sec;
   
4.         timeOut.tv_usec = 0;
   
5.         printf("select ....\n");
   
6.         selectVal = select(mastersock+1,&fdset,NULL,NULL,0);
   
7. 
   
8.         if(selectVal > 0){
   
9.             if(FD_ISSET(mastersock,&fdset)){
   
10.                 workersock = accept(mastersock,(struct sockaddr *)&socketaddr,(socklen_t *)&addrlen);
    
11. 
    
12.                 if(workersock > 0){
    
13.                     int result = recv(workersock,cefBuff,CARD_DATA_SIZE,0);
    
14.                     printf("result :%d\n",result);
    
15.                     if(result){
    
16.                         memcpy(cMiddleBuff+lMiddLen,cefBuff,result);
    
17.                         lMiddLen += result;
    
18.                         if(lMiddLen > CARD_DATA_SIZE){
    
19.                             printf("do\n");
    
20.                               do{
    
21.                                 iWriteCacheSuccess = writeRingShm(semId[pchannel->cardid],buffer[pchannel->cardid],
    
22.                                                     (char *)cMiddleBuff,CARD_DATA_SIZE);
    
23.                                 }while(0 == iWriteCacheSuccess);
    
24.                                 memcpy(cTemp,cMiddleBuff+CARD_DATA_SIZE,lMiddLen - CARD_DATA_SIZE);
    
25.                                 memcpy(cMiddleBuff,cTemp,lMiddLen - CARD_DATA_SIZE);
    
26.                                 lMiddLen -= CARD_DATA_SIZE;
    
27.                         }
    
28.                         //close(workersock);
    
29.                      }else{
    
30.                         printf("recive server's data error\n");
    
31.                         continue;
    
32.                      }
    
33.                     //close(workersock);
    
34.                 }
    
35.              // FD_SET(workersock,&orig_fdset);
    
36.             }
    
37.        }else if(0 == selectVal){
    
38.             printf("waring :select  rerturn 0");\
    
39.             continue;
    
40.        }else{
    
41.             printf("error:select return error\n");
    
42. }
    
43. }

复制代码

麻烦给点指点

liuchang8877

回复 4# xiyoulaoyuanjia
麻烦给看下

   

liuchang8877

客户端的 connect

1. int clientconnect(const char *host, const char *port, const char *proto)
   
2. {
   
3.     int sockid = -1;
   
4.     int nProto = resolveproto(proto);
   
5.     if(nProto == 17)
   
6.     {
   
7.         sockid = serverinit(port, proto);
   
8.     }
   
9.     else
   
10.     {
    
11.         unsigned long non_blocking = 1;
    
12.         unsigned long blocking = 0;
    
13.         struct sockaddr_in socketaddr;
    
14.         socketaddr_init(&socketaddr);
    
15.         socketaddr_service(&socketaddr, port, proto);
    
16.         socketaddr_host(&socketaddr, host);
    
17.         sockid = socket(PF_INET, prototype(proto), nProto);
    
18.         if (sockid < 0)
    
19.         {
    
20.             //HandleError(errno, "clientconnect", "socket failed");
    
21.             return -1;
    
22.         }   
    
23.             
    
24.         ioctl(sockid,FIONBIO,&non_blocking);
    
25.         if (connect(sockid, (struct sockaddr *)&socketaddr, sizeof(socketaddr)) == -1){
    
26.             struct timeval tv;
    
27.             fd_set writefds;
    
28.             int error;
    
29.    
    
30.             tv.tv_sec = 3;
    
31.             tv.tv_usec = 0;
    
32.             FD_ZERO(&writefds);
    
33.             FD_SET(sockid, &writefds);
    
34.             if(select(sockid+1,NULL,&writefds,NULL,&tv) != 0){
    
35.                 if(FD_ISSET(sockid,&writefds)){
    
36.                     int len=sizeof(error);
    
37.                     if(getsockopt(sockid, SOL_SOCKET, SO_ERROR,  (char *)&error,(unsigned int *)&len) < 0)
    
38.                         goto error_ret;
    
39.                     if(error != 0)
    
40.                         goto error_ret;
    
41.                 }
    
42.               else
    
43.                     goto error_ret; //timeout or error happen
    
44.             }
    
45.             else goto error_ret; ;
    
46.             ioctl(sockid,FIONBIO,&blocking);
    
47.         }
    
48.         else
    
49.         {
    
50. error_ret:
    
51.             safeclose(sockid);
    
52.             return -1;
    
53.         }
    
54.     }
    
55.     return sockid;
    
56. }
    
57. 
    
58. 
    

复制代码

liuchang8877

dingqi

xiyoulaoyuanjia

这个是完整的吗？ 而且不写注释看得我头疼～～