diff options
author | elliott_c <ocielliottc@users.noreply.github.com> | 2008-04-30 14:24:32 +0000 |
---|---|---|
committer | elliott_c <ocielliottc@users.noreply.github.com> | 2008-04-30 14:24:32 +0000 |
commit | 0b3174d0e39cac3e19dba29dd8302808968a7dc8 (patch) | |
tree | d533ebc3f8b639ba640800c8ddb9ddf4479b4cd6 | |
parent | 660273d4edf231cf4a07e287f65bd8ec7302caba (diff) | |
download | ATCD-0b3174d0e39cac3e19dba29dd8302808968a7dc8.tar.gz |
ChangeLogTag: Wed Apr 30 14:26:54 UTC 2008 ace <elliott_c@ociweb.com>
-rw-r--r-- | ACE/ATDChangeLog | 10 | ||||
-rw-r--r-- | ACE/ace/Acceptor.cpp | 6 | ||||
-rw-r--r-- | ACE/ace/Connector.cpp | 14 | ||||
-rw-r--r-- | ACE/ace/Strategies_T.cpp | 9 | ||||
-rw-r--r-- | ACE/ace/Svc_Handler.h | 4 |
5 files changed, 29 insertions, 14 deletions
diff --git a/ACE/ATDChangeLog b/ACE/ATDChangeLog index 5ed653971e6..7f0a0eec625 100644 --- a/ACE/ATDChangeLog +++ b/ACE/ATDChangeLog @@ -1,3 +1,13 @@ +Wed Apr 30 14:26:54 UTC 2008 ace <elliott_c@ociweb.com> + + * ace/Acceptor.cpp: + * ace/Connector.cpp: + * ace/Strategies_T.cpp: + * ace/Svc_Handler.h: + + Added an enum for use within the call to close() on a service + handler. + Mon Mar 31 15:46:35 UTC 2008 Chad Elliott <elliott_c@ociweb.com> * ace/Acceptor.cpp: diff --git a/ACE/ace/Acceptor.cpp b/ACE/ace/Acceptor.cpp index 7561f33f3eb..0b38c4113b9 100644 --- a/ACE/ace/Acceptor.cpp +++ b/ACE/ace/Acceptor.cpp @@ -294,7 +294,7 @@ ACE_Acceptor<SVC_HANDLER, ACE_PEER_ACCEPTOR_2>::accept_svc_handler ACE_Errno_Guard error(errno); // Close down handler to avoid memory leaks. - svc_handler->close (1); + svc_handler->close (CLOSE_DURING_NEW_CONNECTION); return -1; } @@ -334,7 +334,7 @@ ACE_Acceptor<SVC_HANDLER, ACE_PEER_ACCEPTOR_2>::activate_svc_handler result = -1; if (result == -1) - svc_handler->close (0); + svc_handler->close (CLOSE_DURING_NEW_CONNECTION); return result; } @@ -1046,7 +1046,7 @@ ACE_Oneshot_Acceptor<SVC_HANDLER, ACE_PEER_ACCEPTOR_2>::shared_accept // Check whether we just timed out or whether we failed... if (!(errno == EWOULDBLOCK || errno == ETIME)) // Close down handler to avoid memory leaks. - svc_handler->close (0); + svc_handler->close (CLOSE_DURING_NEW_CONNECTION); return -1; } // Activate the <svc_handler> using the designated concurrency diff --git a/ACE/ace/Connector.cpp b/ACE/ace/Connector.cpp index 514b7c31507..a9963edd3c3 100644 --- a/ACE/ace/Connector.cpp +++ b/ACE/ace/Connector.cpp @@ -145,7 +145,7 @@ ACE_NonBlocking_Connect_Handler<SVC_HANDLER>::handle_input (ACE_HANDLE) // Close Svc_Handler. if (svc_handler != 0) - svc_handler->close (0); + svc_handler->close (NORMAL_CLOSE_OPERATION); return retval; } @@ -233,7 +233,7 @@ ACE_Connector<SVC_HANDLER, ACE_PEER_CONNECTOR_2>::activate_svc_handler (SVC_HAND { // Make sure to close down the <svc_handler> to avoid descriptor // leaks. - svc_handler->close (1); + svc_handler->close (CLOSE_DURING_NEW_CONNECTION); return -1; } else @@ -431,10 +431,10 @@ ACE_Connector<SVC_HANDLER, ACE_PEER_CONNECTOR_2>::connect_i if (sh_copy == 0) { if (sh) - sh->close (0); + sh->close (CLOSE_DURING_NEW_CONNECTION); } else if (*sh_copy) - (*sh_copy)->close (0); + (*sh_copy)->close (CLOSE_DURING_NEW_CONNECTION); } return -1; @@ -571,7 +571,7 @@ ACE_Connector<SVC_HANDLER, ACE_PEER_CONNECTOR_2>::nonblocking_connect reactor_registration_failure: // Close the svc_handler - sh->close (0); + sh->close (CLOSE_DURING_NEW_CONNECTION); return -1; } @@ -617,7 +617,7 @@ ACE_Connector<SVC_HANDLER, ACE_PEER_CONNECTOR_2>::initialize_svc_handler this->activate_svc_handler (svc_handler); else // do the svc handler close below... #endif /* ACE_WIN32 */ - svc_handler->close (0); + svc_handler->close (NORMAL_CLOSE_OPERATION); } } @@ -692,7 +692,7 @@ ACE_Connector<SVC_HANDLER, ACE_PEER_CONNECTOR_2>::close (void) this->cancel (svc_handler); // Close the associated Svc_Handler. - svc_handler->close (0); + svc_handler->close (NORMAL_CLOSE_OPERATION); } return 0; diff --git a/ACE/ace/Strategies_T.cpp b/ACE/ace/Strategies_T.cpp index af218158e45..a3845f33237 100644 --- a/ACE/ace/Strategies_T.cpp +++ b/ACE/ace/Strategies_T.cpp @@ -17,6 +17,7 @@ #include "ace/OS_NS_dlfcn.h" #include "ace/OS_NS_string.h" #include "ace/OS_Errno.h" +#include "ace/Svc_Handler.h" #if defined (ACE_OPENVMS) # include "ace/Lib_Find.h" #endif @@ -197,7 +198,7 @@ ACE_Concurrency_Strategy<SVC_HANDLER>::activate_svc_handler (SVC_HANDLER *svc_ha result = -1; if (result == -1) - svc_handler->close (1); + svc_handler->close (CLOSE_DURING_NEW_CONNECTION); return result; } @@ -252,7 +253,7 @@ ACE_Reactive_Strategy<SVC_HANDLER>::activate_svc_handler (SVC_HANDLER *svc_handl return this->inherited::activate_svc_handler (svc_handler, arg); if (result == -1) - svc_handler->close (1); + svc_handler->close (CLOSE_DURING_NEW_CONNECTION); return result; } @@ -354,7 +355,7 @@ ACE_Accept_Strategy<SVC_HANDLER, ACE_PEER_ACCEPTOR_2>::accept_svc_handler ACE_Errno_Guard error(errno); // Close down handler to avoid memory leaks. - svc_handler->close (0); + svc_handler->close (CLOSE_DURING_NEW_CONNECTION); return -1; } @@ -777,7 +778,7 @@ ACE_Cached_Connect_Strategy<SVC_HANDLER, ACE_PEER_CONNECTOR_2, MUTEX>::find_or_c entry) == -1) { // Close the svc handler. - potential_handler->close (0); + potential_handler->close (CLOSE_DURING_NEW_CONNECTION); return -1; } diff --git a/ACE/ace/Svc_Handler.h b/ACE/ace/Svc_Handler.h index c366a30b2f7..25df1e2487c 100644 --- a/ACE/ace/Svc_Handler.h +++ b/ACE/ace/Svc_Handler.h @@ -31,6 +31,10 @@ ACE_BEGIN_VERSIONED_NAMESPACE_DECL // Forward decls. class ACE_Connection_Recycling_Strategy; +enum ACE_Svc_Handler_Close { NORMAL_CLOSE_OPERATION = 0x00, + CLOSE_DURING_NEW_CONNECTION = 0x01 + }; + /** * @class ACE_Svc_Handler * |