死循环@APG中的第一个例子

peakzhang

初学ACE，照猫画虎，把 APG书上的例子server / client稍微改了一下。结果在server的while(
(bytes_received = peer.recv(buffer, sizeof(buffer)) ) != -1)这一句遇到意想不到结果。

2. //client
3. #include "ace/INET_Addr.h"
4. #include "ace/SOCK_Stream.h"
5. #include "ace/SOCK_Connector.h"
6. #include "ace/Log_Msg.h"
8. int ACE_TMAIN(int, ACE_TCHAR * [])
9. {
10.     ACE_INET_Addr srvr(50000, ACE_LOCALHOST);
12.     ACE_SOCK_Connector connector;
13.     ACE_SOCK_Stream peer;
15.     if (-1 == connector.connect(peer, srvr))
16.     {
17.         ACE_ERROR_RETURN(  (LM_ERROR, ACE_TEXT("%p\n"), ACE_TEXT("connect") ),  1);
18.     }
20.     int bc;
21.     char buf[64];
23.     peer.send_n("uptime\n", 7);
24.     bc = peer.recv(buf, sizeof(buf));
25.     write(1, buf, bc);//输出到屏幕
26.     peer.close();
28.     return (0);
29. }
30. //server
31. #include <iostream>
33. #include "ace/INET_Addr.h"
34. #include "ace/Log_Msg.h"
35. #include "ace/SOCK_Acceptor.h"
36. #include "ace/SOCK_Stream.h"
37. #include "ace/Time_Value.h"
38. #include "ace/os_include/os_netdb.h"
40. using namespace std;
42. int ACE_TMAIN (int, ACE_TCHAR * [])
43. {
44.     ACE_INET_Addr port_to_listen (50000, ACE_LOCALHOST);
45.     ACE_SOCK_Acceptor acceptor;
47.     if (acceptor.open(port_to_listen, 1) == -1)
48.     {
49.         ACE_ERROR_RETURN( (LM_ERROR, ACE_TEXT("%p\n")ACE_TEXT("acceptor.open")), 100);
50.     }
52.     while (1)
53.     {
54.         ACE_SOCK_Stream peer;
55.         ACE_INET_Addr peer_addr;
56.         ACE_Time_Value timeout(10, 0);
58. #if 0
59.         if (acceptor.accept(peer) == -1)
60.         {
61.             ACE_ERROR_RETURN( (LM_ERROR, ACE_TEXT("(%P|%t) Failed to accept client connection\n")), 100);
62.         }
63. #endif
65.         if (acceptor.accept(peer, &peer_addr, &timeout, 0) == -1)
66.         {
67.             if (ACE_OS::last_error() == EINTR)
68.             {
69.                 ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) Interrupted while waiting for connection\n")));
70.             }
71.             else if (ACE_OS::last_error() == ETIMEDOUT)
72.             {
73.                 ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) Timeout while waiting for connection\n")));
74.             }
75.         }
76.         else
77.         {
78.             ACE_TCHAR peer_name[MAXHOSTNAMELEN];
79.             peer_addr.addr_to_string(peer_name, MAXHOSTNAMELEN);
80.             ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) Connection from %s \n"), peer_name));
82.             char buffer[4096];
83.             ssize_t bytes_received;
85.             while( (bytes_received = peer.recv(buffer, sizeof(buffer)) ) != -1) //此处有个死循环
86.             {
87.                 ACE_DEBUG((LM_DEBUG, ACE_TEXT("%s \n"), buffer));
89.                 peer.send_n (buffer, bytes_received);//原样返回给客户端
90.                 ACE_OS::sleep(20);
91.             }
92.             peer.close();
93.             ACE_DEBUG((LM_DEBUG, ACE_TEXT("peer.close\n")));
94.         }
95.     }
97.     return (0);
98. }

复制代码

peakzhang

不关buffer的事。我把上面的while语句中的 != -1改成 >0就不再死循环了。
另外请教大家一个问题，我在本机收发(Client发，Server收)，同时运行。我发现server端显示的端口号一直在递增，这是什么原因呢？难道我没有及时地关闭不用的连接？