大家看看这段代码有什么问题?关于EPOLL的!

letion

麻烦大家看一下这段代码,客户端在断开时,服务器端有时能断开,有时不能!基本上是5~6个才能断开一个!

1. 
   
2. /*---------------------------------------------------------
   
3. * TestEpoll.cpp
   
4. ---------------------------------------------------------*/
   
5. 
   
6. #include <iostream>;
   
7. #include <string>;
   
8. #include <sys/epoll.h>;
   
9. #include <sys/time.h>;
   
10. #include <sys/types.h>;
    
11. #include <sys/socket.h>;
    
12. #include <sys/wait.h>;
    
13. #include <netdb.h>;
    
14. #include <ctype.h>;
    
15. #include <arpa/inet.h>;
    
16. #include <fcntl.h>;
    
17. #include <signal.h>;
    
18. #include <errno.h>;
    
19. 
    
20. using namespace std;
    
21. 
    
22. #define MAX_CLIENT   10000
    
23. #define PORT         8008
    
24. 
    
25. int ListenFd = -1;
    
26. 
    
27. void nonblock(int sockfd)
    
28. {
    
29.         int opts;
    
30.         opts = fcntl(sockfd, F_GETFL);
    
31.         if(opts < 0)
    
32.         {
    
33.                 cout<<" fcntl(F_GETFL)"<<endl;
    
34.                 exit(1);
    
35.         }
    
36.         opts = (opts | O_NONBLOCK);
    
37.         if(fcntl(sockfd, F_SETFL, opts) < 0)
    
38.         {
    
39.                 cout<<"fcntl(F_SETFL)"<<endl;
    
40.                 exit(1);
    
41.         }
    
42. }
    
43. 
    
44. int main()
    
45. {
    
46.         struct sockaddr_in srv;
    
47.         int clifd;
    
48. 
    
49.         if((ListenFd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    
50.         {
    
51.                 cout<<" Error Create Socket !"<<endl;
    
52.                 exit(1);
    
53.         }
    
54. 
    
55.         int flags, ling;
    
56.         setsockopt(ListenFd, SOL_SOCKET, SO_REUSEADDR, &flags, sizeof(flags));
    
57.         setsockopt(ListenFd, SOL_SOCKET, SO_KEEPALIVE, &flags, sizeof(flags));
    
58.         setsockopt(ListenFd, SOL_SOCKET, SO_LINGER, &ling, sizeof(ling));
    
59. 
    
60.         bzero(&srv, sizeof(srv));
    
61.         srv.sin_family = AF_INET;
    
62.         srv.sin_addr.s_addr = INADDR_ANY;
    
63.         srv.sin_port = htons(PORT);
    
64. 
    
65.         if(bind(ListenFd, (struct sockaddr*)&srv, sizeof(srv)) < 0)
    
66.         {
    
67.                 cout<<" Error Bind Port !"<<endl;
    
68.                 exit(1);
    
69.         }
    
70. 
    
71.         listen(ListenFd, 1024);
    
72. 
    
73.         int epfd = epoll_create(MAX_CLIENT);
    
74.         if(!epfd)
    
75.         {
    
76.                 cout<<" Error Create Epoll !"<<endl;
    
77.                 exit(1);
    
78.         }
    
79. 
    
80.         struct epoll_event ev;
    
81.         ev.events = EPOLLIN | EPOLLET;
    
82.         ev.data.fd = ListenFd;
    
83. 
    
84.         if(epoll_ctl(epfd, EPOLL_CTL_ADD, ListenFd, &ev) < 0)
    
85.         {
    
86.                 cout<<" Error Add ListenFd to Epoll !"<<endl;
    
87.                 exit(1);
    
88.         }
    
89. 
    
90.         char buffer[1024];
    
91. 
    
92.         for(;;)
    
93.         {
    
94.                 struct epoll_event *events =  new struct epoll_event;
    
95. 
    
96.                 int res = epoll_wait(epfd, events, MAX_CLIENT, -1);
    
97. 
    
98.                 for(int i=0; i<res; i++)
    
99.                 {
    
100.                         if(events[i].data.fd == ListenFd)
     
101.                         {
     
102.                                 clifd = accept(ListenFd, NULL, NULL);
     
103.                                 cout<<"LINK: "<<clifd<<endl;
     
104.                                 if(clifd >;= 0)
     
105.                                 {
     
106.                                         nonblock(clifd);
     
107.                                         ev.events = EPOLLIN | EPOLLET;
     
108.                                         ev.data.fd = clifd;
     
109.                                         if(epoll_ctl(epfd, EPOLL_CTL_ADD, clifd, &ev) < 0)
     
110.                                         {
     
111.                                                 cout<<" Error EPOLL_CTL_ADD !"<<endl;
     
112.                                                 exit(1);
     
113.                                         }
     
114.                                 }       
     
115.                         }          
     
116.                         else
     
117.                         {
     
118.                                 bzero(buffer, strlen(buffer));
     
119.                                 int n = recv(events[i].data.fd, buffer, 1024, 0);
     
120.                                 if(n == 0)
     
121.                                 {
     
122.                                         cout<<events[i].data.fd<<" Closeed Connection !"<<endl;
     
123.                                         epoll_ctl(epfd, EPOLL_CTL_DEL, events[i].data.fd, NULL);
     
124.                                         close(events[i].data.fd);
     
125.                                 }
     
126.                                 else if(n < 0)
     
127.                                 {
     
128.                                         epoll_ctl(epfd, EPOLL_CTL_DEL, events[i].data.fd, NULL);
     
129.                                         cout<<events[i].data.fd<<" Error !"<<endl;
     
130.                                         close(events[i].data.fd);
     
131.                                 }
     
132.                                 else
     
133.                                 {
     
134.                                         cout<<"SOCK: "<<events[i].data.fd<<"RECV: "<<buffer<<endl;
     
135.                                         bzero(&buffer, strlen(buffer));
     
136.                                         if(send(events[i].data.fd, buffer, strlen(buffer), 0) < 0)
     
137.                                                 cout<<"Send Error"<<endl;
     
138. 
     
139.                                 }
     
140.                         }
     
141.                 }
     
142.                 delete events;
     
143.         }
     
144. }
     

复制代码

letion

怎么缩进全没了???

xiaosuo

[quote]原帖由 "letion"]怎么缩进全没了???[/quote 发表：

楼主把这些全部装在代码按钮弹出的输入框里就行了！

letion

原来如此!多谢提醒!