diff options
Diffstat (limited to 'TAO/tao/Reply_Dispatcher.cpp')
| -rw-r--r-- | TAO/tao/Reply_Dispatcher.cpp | 25 |
1 files changed, 24 insertions, 1 deletions
diff --git a/TAO/tao/Reply_Dispatcher.cpp b/TAO/tao/Reply_Dispatcher.cpp index 2424db07777..2b494d61c3d 100644 --- a/TAO/tao/Reply_Dispatcher.cpp +++ b/TAO/tao/Reply_Dispatcher.cpp @@ -25,6 +25,12 @@ TAO_Reply_Dispatcher::message_state (void) const return 0; } +void +TAO_Reply_Dispatcher::leader_follower_condition_variable (TAO_Transport *) +{ + // no-op. +} + // ********************************************************************* // Constructor. @@ -33,7 +39,8 @@ TAO_Synch_Reply_Dispatcher::TAO_Synch_Reply_Dispatcher (TAO_ORB_Core *orb_core) reply_cdr_ (orb_core->create_input_cdr_data_block (ACE_CDR::DEFAULT_BUFSIZE), TAO_ENCAP_BYTE_ORDER, orb_core), - reply_received_ (0) + reply_received_ (0), + leader_follower_condition_variable_ (0) { } @@ -65,6 +72,15 @@ TAO_Synch_Reply_Dispatcher::dispatch_reply (CORBA::ULong reply_status, // Steal the buffer so that no copying is done. this->reply_cdr_.reset (message_state->cdr.steal_contents (), message_state->cdr.byte_order ()); + + + // If condition variable is present, signal it. + if (this->leader_follower_condition_variable_ != 0) + { + // @@ Carlos: Should we apply lock here? (Alex). + (void) this->leader_follower_condition_variable_->signal (); + } + return 1; } @@ -86,6 +102,13 @@ TAO_Synch_Reply_Dispatcher::reply_received (void) return reply_received_; } +void +TAO_Synch_Reply_Dispatcher::leader_follower_condition_variable (TAO_Transport *transport) +{ + this->leader_follower_condition_variable_ = + transport->leader_follower_condition_variable (); +} + // ********************************************************************* #if defined (TAO_HAS_CORBA_MESSAGING) && defined (TAO_POLLER) // Constructor. |