diff options
Diffstat (limited to 'TAO/tao/GIOP.cpp')
| -rw-r--r-- | TAO/tao/GIOP.cpp | 17 |
1 files changed, 5 insertions, 12 deletions
diff --git a/TAO/tao/GIOP.cpp b/TAO/tao/GIOP.cpp index 4236a7c2151..fa32476251b 100644 --- a/TAO/tao/GIOP.cpp +++ b/TAO/tao/GIOP.cpp @@ -905,13 +905,10 @@ TAO_GIOP_Invocation::invoke (CORBA::ExceptionList &exceptions, TAO_SVC_HANDLER *handler = this->handler_; TAO_GIOP::Message_Type m = TAO_GIOP::recv_request (handler, this->inp_stream_); - { - //ACE_Guard<ACE_SYNCH_MUTEX> g (TAO_ORB_Core_instance ()->leader_follower_lock ()); - TAO_ORB_Core_instance ()->reactor ()->resume_handler (this->handler_); - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) GIOP: resume.\n")); - } + TAO_ORB_Core_instance ()->reactor ()->resume_handler (this->handler_); + // suspend was called in TAO_Client_Connection_Handler::handle_input + switch (m) { case TAO_GIOP::Reply: @@ -1287,12 +1284,8 @@ TAO_GIOP_Invocation::invoke (TAO_Exception_Data *excepts, TAO_GIOP::Message_Type m = TAO_GIOP::recv_request (handler, this->inp_stream_); - { - //ACE_Guard<ACE_SYNCH_MUTEX> g (TAO_ORB_Core_instance ()->leader_follower_lock ()); - TAO_ORB_Core_instance ()->reactor ()->resume_handler (this->handler_); - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) GIOP: resume.\n")); - } + TAO_ORB_Core_instance ()->reactor ()->resume_handler (this->handler_); + // suspend was called in TAO_Client_Connection_Handler::handle_input switch (m) { |