summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorelliott_c <ocielliottc@users.noreply.github.com>2008-04-30 14:24:32 +0000
committerelliott_c <ocielliottc@users.noreply.github.com>2008-04-30 14:24:32 +0000
commit0b3174d0e39cac3e19dba29dd8302808968a7dc8 (patch)
treed533ebc3f8b639ba640800c8ddb9ddf4479b4cd6
parent660273d4edf231cf4a07e287f65bd8ec7302caba (diff)
downloadATCD-0b3174d0e39cac3e19dba29dd8302808968a7dc8.tar.gz
ChangeLogTag: Wed Apr 30 14:26:54 UTC 2008 ace <elliott_c@ociweb.com>
-rw-r--r--ACE/ATDChangeLog10
-rw-r--r--ACE/ace/Acceptor.cpp6
-rw-r--r--ACE/ace/Connector.cpp14
-rw-r--r--ACE/ace/Strategies_T.cpp9
-rw-r--r--ACE/ace/Svc_Handler.h4
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
*