多线程和epoll 问题， epoll_wait 不返回

benjiam

多线程和epoll 问题， epoll_wait 不返回
设计的思想是这样的。

起一个子线程，这个线程称会不断建立与服务器的连接。

主线程则会 不断在epoll_wait 等待返回然后处理。  我这里epoll_wait 不返回。


通过网络监控 发现 子线程的的连接应该建立起来了

有三步握手了。 但我的程序一直不返回


还有2点 read write 的 阻塞和非阻塞有什么区别吗？

connect 的阻塞和非阻塞有什么区别？

1. #include <pthread.h>
   
2. #include <stdio.h>
   
3. #include <sys/epoll.h>
   
4. 
   
5. #include <sys/types.h>
   
6. #include <sys/socket.h>
   
7. #include <arpa/inet.h>
   
8. #include <netdb.h>
   
9. #include <unistd.h>
   
10. #include <fcntl.h>
    
11. 
    
12. 
    
13. #define maxevents 65535
    
14. #define max_thread 6000
    
15. 
    
16. void *work(void *arg);
    
17. void setnonblocking(int sock);
    
18. void do_use_fd(struct epoll_event   *events);
    
19. 
    
20. int lines ;
    
21. int epollfd = 0;
    
22. int main(){
    
23.         pthread_t pid_t;
    
24.         struct epoll_event ev, *events;
    
25. 
    
26.         int nfds = 0;       
    
27.         int n = 0;
    
28.         int status;
    
29.                
    
30.                 status = pthread_create(&pid_t, NULL, work, NULL);  // 起一个线称建立连接
    
31.                
    
32.                 if (status == 0) {               
    
33.            printf(" %d created \n", n);
    
34.                 } else {
    
35.                                         printf(" %d create fail\n", n);
    
36.           exit(0);
    
37.    }
    
38.    
    
39.    epollfd  = epoll_create(maxevents);                   // 建立epoll
    
40.    
    
41.    if (-1 == epollfd){          
    
42.       printf("error cannot epoll_create\n");
    
43.       return 0;
    
44.   }
    
45.   
    
46.   for (;;){
    
47.            nfds = epoll_wait(epollfd, events, maxevents, -1); // 开始抓回复
    
48.            for(n = 0; n < nfds; ++n) {
    
49.                      printf("do do_use \n");              
    
50.               do_use_fd(events+n);
    
51.            }         
    
52.   }       
    
53.         return 0;
    
54. }
    
55. 
    
56. void *work(void *arg){  // 这个就是工作线称主要发起连接
    
57.         int i = 0 ;
    
58.         struct sockaddr_in clientadd;
    
59.         int client;
    
60.         struct epoll_event ev;
    
61.         pthread_detach(pthread_self());  // this
    
62.         int len = 0;
    
63.         for (i = 0 ; i < 5 ;i ++){
    
64.                
    
65.                 sleep(10);
    
66.           client = socket(AF_INET , SOCK_STREAM, 0);
    
67.           if (client < 0){                 
    
68.                   continue;       
    
69.           }
    
70.           printf("begin memset \n");
    
71.           memset(&clientadd,0 , sizeof(clientadd));
    
72.           clientadd.sin_family = AF_INET;
    
73.           clientadd.sin_addr.s_addr  =  inet_addr("192.168.1.150");  
    
74.           clientadd.sin_port  = htons(80);
    
75.           setnonblocking(client);
    
76.           
    
77.           ev.events = EPOLLIN|EPOLLOUT |EPOLLERR;
    
78.     ev.data.fd = client;
    
79.     if (epoll_ctl(epollfd, EPOLL_CTL_ADD, client, &ev) < 0) {
    
80.        fprintf(stderr, "epoll set insertion error: fd=%d",client);
    
81.        return NULL;
    
82.     }
    
83.     printf("begin connect \n");
    
84.     connect(client, (struct sockaddr*)&clientadd, sizeof(clientadd));
    
85.     printf("begin connect \n");
    
86.     sleep(5);
    
87.        
    
88.         }
    
89. }
    
90. 
    
91. void setnonblocking(int sock){
    
92.         int opts;
    
93.         opts=fcntl(sock,F_GETFL);
    
94.         if(opts<0)
    
95.         {
    
96.                 perror("fcntl(sock,GETFL)");
    
97.                 exit(1);
    
98.         }
    
99. 
    
100.         opts = opts|O_NONBLOCK;
     
101.         if(fcntl(sock,F_SETFL,opts)<0)
     
102.         {
     
103.                 perror("fcntl(sock,SETFL,opts)");
     
104.                 exit(1);
     
105.         }
     
106. }
     
107. 
     
108. void do_use_fd(struct epoll_event   *events){
     
109.         struct epoll_event ev;
     
110.         int n ;
     
111.         int client = events->data.fd;
     
112.         char buff[] ="get / http/1.1\r\n\r\n";
     
113.         char inbuff[1024] ={0};
     
114. 
     
115.         if (events->events |EPOLLIN){ // 可以读了
     
116.                 while (read(client, inbuff, 1024)){
     
117.                   printf("%d  get 1024 \n", events->data.fd);       
     
118.                 }
     
119.                 /*
     
120.                 ev.events = EPOLLOUT |EPOLLERR;
     
121.     ev.data.fd = client;
     
122.     if (epoll_ctl(epollfd, EPOLL_CTL_ADD, client, &ev) < 0) {
     
123.        fprintf(stderr, "epoll set insertion error: fd=%d",client);
     
124.        return -1;
     
125.          */       
     
126.                
     
127.         }        else if (events->events |EPOLLOUT) {
     
128.           write(events->data.fd, buff, strlen(buff));               
     
129.           return ;       
     
130.   }
     
131.   
     
132.   close(events->data.fd); //读完了 就短掉连接
     
133.        
     
134. }

复制代码

benjiam

好像明白了一点 epoll_ctl 要在epoll_Wait 以前执行

不然没有用


现在我的read 返回－1 。。。。。