diff options
author | parsons <parsons@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2000-11-13 20:38:58 +0000 |
---|---|---|
committer | parsons <parsons@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2000-11-13 20:38:58 +0000 |
commit | d9120dc9d13ba1f0d94cd1c210b9c3107c6f3776 (patch) | |
tree | 78a7e42e4b96b81006e73b5eb3cdfdc0c2a1000e /TAO/tao/Synch_Reply_Dispatcher.cpp | |
parent | f2fa842812a44f3ab1554bdafa203b17fd95bfc9 (diff) | |
download | ATCD-d9120dc9d13ba1f0d94cd1c210b9c3107c6f3776.tar.gz |
ChangeLogTag: Mon Nov 13 14:35:33 2000 Jeff Parsons <parsons@cs.wustl.edu>
Diffstat (limited to 'TAO/tao/Synch_Reply_Dispatcher.cpp')
-rw-r--r-- | TAO/tao/Synch_Reply_Dispatcher.cpp | 37 |
1 files changed, 20 insertions, 17 deletions
diff --git a/TAO/tao/Synch_Reply_Dispatcher.cpp b/TAO/tao/Synch_Reply_Dispatcher.cpp index fdb5722cf92..647174d02dd 100644 --- a/TAO/tao/Synch_Reply_Dispatcher.cpp +++ b/TAO/tao/Synch_Reply_Dispatcher.cpp @@ -4,17 +4,14 @@ #include "tao/ORB_Core.h" #include "tao/Wait_Strategy.h" -#if !defined (__ACE_INLINE__) -#include "tao/Synch_Reply_Dispatcher.i" -#endif /* __ACE_INLINE__ */ - ACE_RCSID(tao, Synch_Reply_Dispatcher, "$Id$") // Constructor. -TAO_Synch_Reply_Dispatcher::TAO_Synch_Reply_Dispatcher (TAO_ORB_Core *orb_core, - IOP::ServiceContextList &sc) +TAO_Synch_Reply_Dispatcher::TAO_Synch_Reply_Dispatcher ( + TAO_ORB_Core *orb_core, + IOP::ServiceContextList &sc + ) : reply_service_info_ (sc), - reply_status_ (100), //Just a invalid reply status message_state_ (orb_core), reply_received_ (0), orb_core_ (orb_core), @@ -41,13 +38,14 @@ TAO_Synch_Reply_Dispatcher::reply_received (void) } int -TAO_Synch_Reply_Dispatcher::dispatch_reply (CORBA::ULong reply_status, - const TAO_GIOP_Version & /*version*/, - IOP::ServiceContextList &reply_ctx, - TAO_GIOP_Message_State *message_state) +TAO_Synch_Reply_Dispatcher::dispatch_reply ( + CORBA::ULong reply_status, + const TAO_GIOP_Version & /* version */, + IOP::ServiceContextList &reply_ctx, + TAO_GIOP_Message_State *message_state + ) { this->reply_status_ = reply_status; - //this->version_ = version; // Steal the buffer, that way we don't do any unnecesary copies of // this data. @@ -75,9 +73,13 @@ TAO_Synch_Reply_Dispatcher::dispatch_reply (CORBA::ULong reply_status, if (this->wait_strategy_ != 0) { if (this->wait_strategy_->reply_dispatched ( - this->reply_received_, - this->leader_follower_condition_variable_) == -1) - return -1; + this->reply_received_, + this->leader_follower_condition_variable_ + ) + == -1) + { + return -1; + } } return 1; @@ -103,7 +105,8 @@ TAO_Synch_Reply_Dispatcher::connection_closed (void) if (this->wait_strategy_ != 0) { this->wait_strategy_->connection_closed ( - this->reply_received_, - this->leader_follower_condition_variable_); + this->reply_received_, + this->leader_follower_condition_variable_ + ); } } |