summaryrefslogtreecommitdiff
path: root/TAO/tao/Synch_Reply_Dispatcher.h
diff options
context:
space:
mode:
authorcoryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2001-08-01 23:39:57 +0000
committercoryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2001-08-01 23:39:57 +0000
commit28f2b1eecfab765469d97d38b686bffdea53114c (patch)
treee11d110b2f6e69f07a780756276cc735be3e8fa9 /TAO/tao/Synch_Reply_Dispatcher.h
parent545c5cb11c374d0333e7d0f1c88f12694ad2eaee (diff)
downloadATCD-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.h29
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 &params);
- // 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"