diff options
| author | irfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-05-17 05:45:52 +0000 |
|---|---|---|
| committer | irfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-05-17 05:45:52 +0000 |
| commit | da2402c11467b71ab449244ada7cbfc34f2d4fe5 (patch) | |
| tree | 951f84b312645a797e8f1ab4e2a8b82b5075cbb7 /apps/Gateway/Gateway/Event_Channel.cpp | |
| parent | b6290c4dba13d4e7cf92c972b6c2b4946ec46ddc (diff) | |
| download | ATCD-da2402c11467b71ab449244ada7cbfc34f2d4fe5.tar.gz | |
*** empty log message ***
Diffstat (limited to 'apps/Gateway/Gateway/Event_Channel.cpp')
| -rw-r--r-- | apps/Gateway/Gateway/Event_Channel.cpp | 17 |
1 files changed, 11 insertions, 6 deletions
diff --git a/apps/Gateway/Gateway/Event_Channel.cpp b/apps/Gateway/Gateway/Event_Channel.cpp index 71d3a322373..186f686006b 100644 --- a/apps/Gateway/Gateway/Event_Channel.cpp +++ b/apps/Gateway/Gateway/Event_Channel.cpp @@ -214,12 +214,13 @@ ACE_Event_Channel::complete_proxy_connection (Proxy_Handler *proxy_handler) int option = proxy_handler->proxy_role () == 'S' ? SO_RCVBUF : SO_SNDBUF; int socket_queue_size = this->options ().socket_queue_size_; - if (proxy_handler->peer ().set_option (SOL_SOCKET, - option, - &socket_queue_size, - sizeof (int)) == -1) - ACE_ERROR ((LM_ERROR, "(%t) %p\n", "set_option")); - + if (socket_queue_size > 0) + if (proxy_handler->peer ().set_option (SOL_SOCKET, + option, + &socket_queue_size, + sizeof (int)) == -1) + ACE_ERROR ((LM_ERROR, "(%t) %p\n", "set_option")); + proxy_handler->thr_mgr (ACE_Service_Config::thr_mgr ()); // Our state is now "established." @@ -247,6 +248,10 @@ ACE_Event_Channel::complete_proxy_connection (Proxy_Handler *proxy_handler) int ACE_Event_Channel::reinitiate_proxy_connection (Proxy_Handler *proxy_handler) { + int result = this->proxy_map_.unbind (proxy_handler->id ()); + if (result != 0) + ACE_ERROR ((LM_ERROR, "Could not remove proxy from map, potential trouble\n")); + // Skip over proxies with deactivated handles. if (proxy_handler->get_handle () != ACE_INVALID_HANDLE) { |