accept的问题，求助！

andyY

.h

1. 
   
2. #ifndef __SOCK_ACCEPTOR_H
   
3. #define __SOCK_ACCEPTOR_H
   
4. 
   
5. #include "Sock_Stream.h"
   
6. #include "Net_Addr.h"
   
7. #include "Sock.h"
   
8. 
   
9. class CNF_Sock_Acceptor : public CNF_Sock
   
10. {
    
11. public:
    
12.   enum
    
13.   {
    
14.     DEFAULT_BACKLOG = 3
    
15.   };
    
16. 
    
17.   bool valid();
    
18. 
    
19.   CNF_HANDLE get_handle();
    
20. 
    
21.   int open( const CNF_Net_Addr& addr,
    
22.             bool reuse = true,
    
23.             int backlog = DEFAULT_BACKLOG);
    
24. 
    
25.   int close(void);
    
26.   
    
27.   // timeout_sec: >0   select
    
28.   //              <=0  directly
    
29.   // return:  0 successful
    
30.   //         -1 failed
    
31.   int accept( CNF_Sock_Stream& stream,
    
32.               CNF_Net_Addr* peer = NULL,
    
33.               int timeout_sec = 0);
    
34. };
    
35. 
    
36. #endif
    

复制代码

.cpp

1. 
   
2. #include "Sock_Acceptor.h"
   
3. 
   
4. #include <sys/select.h>
   
5. #include <sys/socket.h>
   
6. #include <sys/types.h>
   
7. #include <sys/time.h>
   
8. #include <unistd.h>
   
9. #include <string.h>
   
10. #include <stdio.h>
    
11. 
    
12. #include <iostream>
    
13. #include <string.h>
    
14. #include <errno.h>
    
15. 
    
16. bool CNF_Sock_Acceptor::valid()
    
17. {
    
18.   return INVALID_HANDLE != handle();
    
19. }
    
20. 
    
21. CNF_HANDLE CNF_Sock_Acceptor::get_handle()
    
22. {
    
23.   return handle();
    
24. }
    
25. 
    
26. int CNF_Sock_Acceptor::open( const CNF_Net_Addr& addr, bool reuse, int backlog)
    
27. {
    
28.   //check
    
29.   if( valid() )
    
30.     close();
    
31. 
    
32.   //socket
    
33.   int ret = socket( PF_INET, SOCK_STREAM, 0);
    
34.   if( 0>ret )
    
35.     return -1;
    
36. 
    
37.   handle( ret );
    
38. 
    
39.   set_option( MASK_REUSE_ADDR, reuse ? 1 : 0);
    
40. 
    
41.   //bind
    
42.   struct sockaddr_in sa = addr;
    
43.   ret = bind( handle(), (struct sockaddr*)&sa, sizeof(sa) );
    
44.   if( 0>ret )
    
45.     return -1;
    
46. 
    
47.   //listen
    
48.   return listen( handle(), backlog);
    
49. }
    
50. 
    
51. int CNF_Sock_Acceptor::close(void)
    
52. {
    
53.   int h = handle();
    
54.   return ::close( h );
    
55. }
    
56. 
    
57. int CNF_Sock_Acceptor::accept( CNF_Sock_Stream& stream,
    
58.                                CNF_Net_Addr* addr,
    
59.                                int timeout_sec)
    
60. {
    
61.   //check
    
62.   if( !valid() )
    
63.     return -1;
    
64. 
    
65.   // address
    
66.   struct sockaddr_in peer;
    
67.   socklen_t len = sizeof(peer);
    
68. 
    
69.   //handle
    
70.   CNF_HANDLE h = handle();
    
71. 
    
72.   //timeout
    
73.   struct timeval tv;
    
74.   tv.tv_sec = timeout_sec>0 ? timeout_sec : 0;
    
75.   tv.tv_usec = 0;
    
76.    
    
77.   //select
    
78.   fd_set rd;
    
79.   FD_ZERO( &rd );
    
80.   FD_SET( h, &rd);
    
81. 
    
82.   while(true)
    
83.   {
    
84.     // 检查有效事件
    
85.     FD_SET( h, &rd);
    
86.     int ret = select( h+1, &rd, NULL, NULL, &tv);
    
87.     if( 0>ret )
    
88.     {
    
89.       if( EINTR == errno )
    
90.         continue; // select: 打断，继续
    
91.       else
    
92.       {
    
93.         perror( "select failed" );
    
94.         return -1;// select: 失败
    
95.       }
    
96. 
    
97.     }else if( 0 == ret)
    
98.     {
    
99.       std::cout<<"accept @ "<<h<<": timeout"<<std::endl;
    
100.       return -1;  // select: 超时
     
101.     }
     
102. 
     
103.     // 检查有效连接
     
104.     int new_handle = ::accept( h, (struct sockaddr*)&peer, &len);
     
105.     std::cerr<<"accept @ "<<h<<" return "<<new_handle<<std::endl;
     
106.     if( 0 > new_handle)
     
107.     {
     
108.       perror("accept failed");
     
109.       return -1;  // accept：失败
     
110.     }
     
111. 
     
112.     if ( 0 == stream.set_handle( new_handle ) )
     
113.     {
     
114.       if( addr )
     
115.       {
     
116.         *addr = peer;
     
117.       }
     
118. 
     
119.       return 0;   // 设置：成功
     
120.     }
     
121. 
     
122.     std::cerr<<"stream.set_handle() failed"<<std::endl;
     
123.     break;        // 设置: 失败
     
124.   }
     
125. 
     
126.   return -1;
     
127. }
     

复制代码

andyY

运行后程序的输出

.........

//VB 客户端第一次

process() @ 9 @ handle_input()
accept @ 9 return 10

recv @ 10 get 50 bytes

send: part1 = 33, part2 = 28

process() @ 10 @ handle_input()
recv @ 10: peer closed
process() @ 10 @ handle_close()

// VB 客户端第二次

process() @ 9 @ handle_input()
accept @ 9 return 0


send: part1 = -1, part2 = -1
send @ 0 failed: Bad file descriptor


// VC 客户端

process() @ 9 @ handle_input()
accept @ 9 return 0

process() @ 0 @ handle_input()
recv @ 0 get 101 bytes

send: part1 = 33, part2 = 0

process() @ 0 @ handle_input()
recv @ 0 get 33 bytes

process() @ 0 @ handle_input()
recv @ 0 get 33 bytes

send: part1 = 33, part2 = 896

......

andyY

有人能帮我看看吗？

isnowran

handle 是怎么定义的？

andyY

typedef int CNF_HANDLE;

CNF_HANDLE CNF_Sock::handle();

isnowran

原帖由 andyY 于 2007-3-29 13:08 发表
typedef int CNF_HANDLE;

CNF_HANDLE CNF_Sock::handle();

据我所知，这玩意叫声明，非定义

soul_of_moon

我怎么越看那个select和accept，越感到别扭。

deadlylight

每轮循环都应该执行FD_ZERO( &rd );

soul_of_moon

原帖由 deadlylight 于 2007-4-2 10:34 发表
每轮循环都应该执行FD_ZERO( &rd );

no

deadlylight

select返回之后应该用FD_ISSET看看是不是你想要的那个fd