ChangeLogTag: Fri Nov 10 17:28:50 2000 Balachandran Natarajan <bala@cs.wustl.edu>

4 files changed, 24 insertions, 5 deletions

diff --git a/TAO/ChangeLogs/ChangeLog-02a b/TAO/ChangeLogs/ChangeLog-02a
index 72f391286bb..87f2ba4336e 100644
--- a/TAO/ChangeLogs/ChangeLog-02a
+++ b/TAO/ChangeLogs/ChangeLog-02a
@@ -1,3 +1,11 @@
+Fri Nov 10 17:28:50 2000  Balachandran Natarajan  <bala@cs.wustl.edu>
+
+	* tao/Strategies/SHMIOP_Connect.cpp:
+	* tao/Strategies/UIOP_Connect.cpp:
+	* tao/IIOP_Connect.cpp: Fixed a problem with thread-per-endpoint
+	  case. The event handler was getting destroyed before the ORB
+	  shuts down the Cache. This lead to cache  shutdown problem. 
+
 Fri Nov 10 13:06:27 2000  Darrell Brunsch <brunsch@uci.edu>
 
         * orbsvcs/ImplRepo_Service/NT_Service.cpp:
diff --git a/TAO/tao/IIOP_Connect.cpp b/TAO/tao/IIOP_Connect.cpp
index d4720f5a8c2..8209d941cd0 100644
--- a/TAO/tao/IIOP_Connect.cpp
+++ b/TAO/tao/IIOP_Connect.cpp
@@ -222,7 +222,8 @@ TAO_IIOP_Server_Connection_Handler::handle_close (ACE_HANDLE handle,
                  rm));
 
   --this->refcount_;
-  if (this->refcount_ == 0)
+  if (this->refcount_ == 0 &&
+      this->is_registered ())
     {
       // Set the flag to indicate that it is no longer registered with
       // the reactor, so that it isn't included in the set that is
diff --git a/TAO/tao/Strategies/SHMIOP_Connect.cpp b/TAO/tao/Strategies/SHMIOP_Connect.cpp
index ef00e89af7d..fe44967634e 100644
--- a/TAO/tao/Strategies/SHMIOP_Connect.cpp
+++ b/TAO/tao/Strategies/SHMIOP_Connect.cpp
@@ -210,7 +210,8 @@ TAO_SHMIOP_Server_Connection_Handler::handle_close (ACE_HANDLE handle,
                  rm));
 
   --this->refcount_;
-  if (this->refcount_ == 0)
+  if (this->refcount_ == 0 &&
+      this->is_registered ())
     {
       // Set the flag to indicate that it is no longer registered with
       // the reactor, so that it isn't included in the set that is
@@ -333,6 +334,14 @@ TAO_SHMIOP_Client_Connection_Handler (ACE_Thread_Manager *t,
 
 TAO_SHMIOP_Client_Connection_Handler::~TAO_SHMIOP_Client_Connection_Handler (void)
 {
+  // Cannot deal with errors, and therefore they are ignored.
+  this->transport_.send_buffered_messages ();
+
+  this->peer ().close ();
+
+  // Note that it also doesn't matter how much of the data was
+  // actually sent.
+  this->transport_.dequeue_all ();
 }
 
 int
@@ -477,7 +486,6 @@ TAO_SHMIOP_Client_Connection_Handler::handle_cleanup (void)
   // Now do the decrement of the ref count
   this->decr_ref_count ();
 
-  this->peer ().close ();
   return 0;
 }
 
diff --git a/TAO/tao/Strategies/UIOP_Connect.cpp b/TAO/tao/Strategies/UIOP_Connect.cpp
index a5d80dc17f0..62354d685e2 100644
--- a/TAO/tao/Strategies/UIOP_Connect.cpp
+++ b/TAO/tao/Strategies/UIOP_Connect.cpp
@@ -200,7 +200,8 @@ TAO_UIOP_Server_Connection_Handler::handle_close (ACE_HANDLE handle,
                  rm));
 
   --this->refcount_;
-  if (this->refcount_ == 0)
+  if (this->refcount_ == 0 &&
+      this->is_registered ())
     {
       // Set the flag to indicate that it is no longer registered with
       // the reactor, so that it isn't included in the set that is
@@ -341,6 +342,8 @@ TAO_UIOP_Client_Connection_Handler::~TAO_UIOP_Client_Connection_Handler (void)
     {
       // Cannot deal with errors, and therefore they are ignored.
       this->transport_.send_buffered_messages ();
+
+      this->peer ().close ();
     }
   else
     {
@@ -484,7 +487,6 @@ TAO_UIOP_Client_Connection_Handler::handle_cleanup (void)
   // Now do the decerment of the ref count
   this->decr_ref_count ();
 
-  this->peer ().close ();
   return 0;
 }