Connection reset by peer, send error

liuchang8877

1，客户端发送，服务端接收
发送时 收到Connection reset by peer
2，单是 服务端 隐去  接收完数据写入共享内存这块代码，客户端就不会报错
3，服务端的例子是WRichardStevens   UNP   有关 select（）  讲解时的例子，除了 共享内存写入这块自己 添加的

希望大牛给点指点

1. int i = 0,maxi = 0,maxfd = -1;
   
2.     int listenfd = -1,connfd = -1,sockfd  = -1;
   
3.     int nready,client[FD_SETSIZE];
   
4.     ssize_t n = 0;
   
5.     fd_set rset,allset;
   
6.     char buf[CARD_DATA_SIZE];
   
7.     socklen_t clilen;
   
8.     struct  sockaddr_in cliaddr,servaddr;
   
9.     int bind_re = -1, listen_re = -1;
   
10.     char  cTemp[CARD_DATA_SIZE];
    
11.     char  cMiddleBuff[CARD_DATA_SIZE*2];
    
12.     long  lMiddLen = 0;
    
13.     int   iWriteCacheSuccess = 0;
    
14.     int   result;
    
15.     memset(cTemp,0,CARD_DATA_SIZE);
    
16.     memset(cMiddleBuff,0,CARD_DATA_SIZE*2);
    
17. 
    
18. 
    
19.     memset(buf,0,CARD_DATA_SIZE);
    
20. 
    
21.     listenfd = socket(AF_INET,SOCK_STREAM,0);
    
22.     memset(&servaddr,0,sizeof(servaddr));
    
23.     servaddr.sin_family = AF_INET;
    
24.     servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    
25.     servaddr.sin_port = htons(21000);
    
26. 
    
27.     printf("listenfd:%d\n",listenfd);
    
28.     bind_re = bind(listenfd,(struct sockaddr*)&servaddr,sizeof(servaddr));
    
29.     if(bind_re < 0){
    
30.         printf("bind error:%s\n",strerror(errno));
    
31.         exit(1);
    
32.     }
    
33.     printf("bind_re :%d\n",bind_re);
    
34. 
    
35.     listen_re = listen(listenfd,LISTENQ);
    
36.     if(listen_re < 0){
    
37.         printf("listen error:%s\n",strerror(errno));
    
38.         exit(1);
    
39.     }printf("listen_re:%d\n",listen_re);
    
40. 
    
41.     maxfd = listenfd;
    
42.     maxi = -1;
    
43.     for(i = 0 ; i < FD_SETSIZE; i++){
    
44.         client[i] = -1;
    
45.     }
    
46.     FD_ZERO(&allset);
    
47.     FD_SET(listenfd,&allset);
    
48. 
    
49.     for(;;){
    
50.         /*change*/
    
51.         //bcopy(&rset,&allset,sizeof(allset));
    
52.         rset = allset;
    
53.         printf("select...\n");
    
54.         nready = select(maxfd+1,&rset,NULL,NULL,NULL);
    
55. 
    
56.         if(FD_ISSET(listenfd,&rset)){
    
57.             clilen = sizeof(cliaddr);
    
58.             connfd = accept(listenfd,(struct sockaddr*)&cliaddr,&clilen);
    
59.             printf("accept :connfd:%d\n",connfd);
    
60.             for(i = 0; i < FD_SETSIZE; i++){
    
61.                 if(client[i] < 0){
    
62.                     client[i] = connfd;
    
63.                     break;
    
64.                 }
    
65.             }
    
66. 
    
67.         if(i == FD_SETSIZE){
    
68.             printf("too many clients");
    
69.             exit(1);
    
70.         }
    
71. 
    
72.         FD_SET(connfd,&allset);
    
73.         if(connfd > maxfd){
    
74.             maxfd = connfd;
    
75.         }
    
76.         if(i > maxi)
    
77.             maxi = i;
    
78.         if(--nready <= 0)         continue;
    
79.         }//FD_ISSET
    
80. 
    
81.     for(i = 0; i <= maxi; i++){
    
82.         if((sockfd = client[i]) < 0)
    
83.             continue;
    
84.         if(FD_ISSET(sockfd,&rset)){
    
85.             if((n = recv(sockfd,buf,CARD_DATA_SIZE,0)) == 0){
    
86.                 close(sockfd);
    
87.                 FD_CLR(sockfd,&allset);
    
88.                 client[i] = -1;
    
89.             }else{
    
90.                 printf("ok\n,result:%d\n",n);
    
91.                  /*this this to  write data to my Ringshm*/
    
92.                  /*if i donot save it in the Ring Shm */
    
93.                  /*the client will not get the error*/
    
94.                 memcpy(cMiddleBuff+lMiddLen,buf,n);
    
95.                 lMiddLen += n;
    
96.                 if(lMiddLen > CARD_DATA_SIZE){
    
97.                     do{
    
98.                             iWriteCacheSuccess =
    
99.                             writeRingShm(semId[pchannel->cardid],
    
100.                                        buffer[pchannel->cardid],
     
101.                                         (char *)cMiddleBuff,CARD_DATA_SIZE);
     
102.                     }while(0 == iWriteCacheSuccess);
     
103.                     memcpy(cTemp,cMiddleBuff+CARD_DATA_SIZE,
     
104.                            lMiddLen - CARD_DATA_SIZE);
     
105.                     memcpy(cMiddleBuff,cTemp,lMiddLen - CARD_DATA_SIZE);
     
106.                     lMiddLen -= CARD_DATA_SIZE;
     
107.                 }
     
108.             }
     
109. 
     
110.             if(--nready <= 0)
     
111.                 break;
     
112. 
     
113.         }//FD_ISSET
     
114.     }//for
     
115. }//for(;;)
     

复制代码

liuchang8877

自己顶顶  唉没人

liuchang8877

问题找到了。  不是 socket  连接的事情，是因为服务端 的异常 导致的  ，导致 客户端 得到  connect reset by peer 的报错

_Rayx

生活中绝大部分问题最后还是得靠自己解决。

liuchang8877

回复 4# _Rayx
是滴呀。。。