diff options
author | coryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2001-08-01 23:39:57 +0000 |
---|---|---|
committer | coryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2001-08-01 23:39:57 +0000 |
commit | 28f2b1eecfab765469d97d38b686bffdea53114c (patch) | |
tree | e11d110b2f6e69f07a780756276cc735be3e8fa9 /TAO/tao/Synch_Reply_Dispatcher.h | |
parent | 545c5cb11c374d0333e7d0f1c88f12694ad2eaee (diff) | |
download | ATCD-28f2b1eecfab765469d97d38b686bffdea53114c.tar.gz |
ChangeLogTag:Wed Aug 1 16:05:36 2001 Carlos O'Ryan <coryan@uci.edu>
Diffstat (limited to 'TAO/tao/Synch_Reply_Dispatcher.h')
-rw-r--r-- | TAO/tao/Synch_Reply_Dispatcher.h | 29 |
1 files changed, 4 insertions, 25 deletions
diff --git a/TAO/tao/Synch_Reply_Dispatcher.h b/TAO/tao/Synch_Reply_Dispatcher.h index ec6aabe157b..536096b2041 100644 --- a/TAO/tao/Synch_Reply_Dispatcher.h +++ b/TAO/tao/Synch_Reply_Dispatcher.h @@ -20,13 +20,13 @@ #include "ace/pre.h" #include "tao/Reply_Dispatcher.h" +#include "tao/LF_Event.h" #include "tao/GIOP_Message_Version.h" #if !defined (ACE_LACKS_PRAGMA_ONCE) # pragma once #endif /* ACE_LACKS_PRAGMA_ONCE */ -class TAO_Wait_Strategy; class TAO_Pluggable_Reply_Params; /** @@ -35,7 +35,9 @@ class TAO_Pluggable_Reply_Params; * @brief Reply dispatcher for Synchoronous Method Invocation (SMI)s. * */ -class TAO_Export TAO_Synch_Reply_Dispatcher : public TAO_Reply_Dispatcher +class TAO_Export TAO_Synch_Reply_Dispatcher + : public TAO_Reply_Dispatcher + , public TAO_LF_Event { public: @@ -49,16 +51,8 @@ public: /// Return the reply CDR. TAO_InputCDR &reply_cdr (void); - /// A flag to check if the reply - int &reply_received (void); - virtual int dispatch_reply (TAO_Pluggable_Reply_Params ¶ms); - // Commented for the time being - Bala - // virtual TAO_GIOP_Message_State *message_state (void); - - virtual void dispatcher_bound (TAO_Transport *); - virtual void connection_closed (void); protected: @@ -66,16 +60,9 @@ protected: IOP::ServiceContextList &reply_service_info_; private: - /// Flag that indicates the reply has been received. - int reply_received_; - /// Cache the ORB Core pointer. TAO_ORB_Core *orb_core_; - /// Save the wait strategy to signal the waiting threads (if - /// appropriate). - TAO_Wait_Strategy *wait_strategy_; - /* @@todo: At some point of time we are going to get to a situation where TAO has huge stack sizes. Need to think on how we would deal with that. One idea would be to push these things on TSS as @@ -93,14 +80,6 @@ private: /// CDR stream which has the reply information that needs to be /// demarshalled by the stubs TAO_InputCDR reply_cdr_; - - /** - * The condition variable used to signal the waiting thread in the - * Leader/Followers model. The variable is acquired in the thread - * that binds the Reply_Dispatcher to its transport, and then passed - * to the Waiting_Strategy to do the signalling, if needed. - */ - TAO_SYNCH_CONDITION *leader_follower_condition_variable_; }; #include "ace/post.h" |