diff options
Diffstat (limited to 'TAO/tao/Wait_Strategy.h')
| -rw-r--r-- | TAO/tao/Wait_Strategy.h | 170 |
1 files changed, 0 insertions, 170 deletions
diff --git a/TAO/tao/Wait_Strategy.h b/TAO/tao/Wait_Strategy.h deleted file mode 100644 index 1433b5bd5cf..00000000000 --- a/TAO/tao/Wait_Strategy.h +++ /dev/null @@ -1,170 +0,0 @@ -// This may look like C, but it's really -*- C++ -*- -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// TAO -// -// = FILENAME -// Wait_Strategy.h -// -// = DESCRIPTION -// Classes to strategize waiting for reply. -// -// = AUTHOR -// Alexander Babu Arulanthu <alex@cs.wustl.edu> -// -// ============================================================================ - -#ifndef TAO_WAIT_STRATEGY_H -#define TAO_WAIT_STRATEGY_H - -#include "tao/corbafwd.h" - -class TAO_ORB_Core; -class TAO_Transport; -class TAO_Transport_Mux_Strategy; - -class TAO_Export TAO_Wait_Strategy -{ - // = TITLE - // - // Strategy for waiting for the reply. - // - // = DESCRIPTION - // - -public: - TAO_Wait_Strategy (TAO_Transport *transport); - // Constructor. - - virtual ~TAO_Wait_Strategy (void); - // Destructor. - - virtual int sending_request (TAO_ORB_Core *orb_core, - int two_way); - // The user is going to send a request, prepare any internal - // variables because the reply may arrive *before* the user calls - // wait. - - virtual int wait (ACE_Time_Value *max_wait_time) = 0; - // Base class virtual method. - - virtual int handle_input (void) = 0; - // Handle the input. - - virtual int register_handler (void) = 0; - // Register the handler with the Reactor if it makes sense for the - // strategy. - -protected: - TAO_Transport *transport_; - // Transport object. -}; - -// @@ Alex: we should consider moving these classes to separate files, -// that can minimize the footprint of systems that use only one of -// the strategies.... - -class TAO_Export TAO_Wait_On_Reactor : public TAO_Wait_Strategy -{ - // = TITLE - // - // Wait on the Reactor. Happens in s Single Threaded client - // environment. - // - // = DESCRIPTION - // - -public: - TAO_Wait_On_Reactor (TAO_Transport *transport); - // Constructor. - - virtual ~TAO_Wait_On_Reactor (void); - // Destructor. - - // = Documented in TAO_Wait_Strategy. - - virtual int wait (ACE_Time_Value *max_wait_time); - virtual int handle_input (void); - virtual int register_handler (void); - -private: - int reply_received_; - // This flag indicates if a *complete* reply has been received. Used - // to exit the event loop. -}; - -class TAO_Export TAO_Wait_On_Leader_Follower : public TAO_Wait_Strategy -{ - // = TITLE - // - // Wait according to the Leader-Follower model. Leader does the - // event loop of the Reactor and the Followers wait on the - // condition variable. - // - // = DESCRIPTION - // - -public: - TAO_Wait_On_Leader_Follower (TAO_Transport *transport); - // Constructor. - - virtual ~TAO_Wait_On_Leader_Follower (void); - // Destructor. - - // = Documented in TAO_Wait_Strategy. - - virtual int sending_request (TAO_ORB_Core *orb_core, - int two_way); - virtual int wait (ACE_Time_Value *max_wait_time); - virtual int handle_input (void); - virtual int register_handler (void); - -protected: - ACE_SYNCH_CONDITION* cond_response_available (void); - // Return the cond_response_available, initializing it if - // necessary. - - void wake_up (void); - // Helper method to wake us up when we are a follower... - -protected: - ACE_thread_t calling_thread_; - // the thread ID of the thread we were running in. - - ACE_SYNCH_CONDITION* cond_response_available_; - // wait on reponse if the leader-follower model is active. - - int expecting_response_; - // State flag which, if non-zero, indicates that we were expecting - // respose. Otherwise, any input received is unexpected. - - int reply_received_; - // This flag indicates if a *complete* reply was received. Until - // that happens we block on the leader/follower condition variable - // or the reactor event loop. -}; - -class TAO_Export TAO_Wait_On_Read : public TAO_Wait_Strategy -{ - // = TITLE - // - // = DESCRIPTION - // Simply block on read() to wait for the reply. - // - -public: - TAO_Wait_On_Read (TAO_Transport *transport); - // Constructor. - - virtual ~TAO_Wait_On_Read (void); - // Destructor. - - virtual int wait (ACE_Time_Value *max_wait_time); - virtual int handle_input (void); - virtual int register_handler (void); -}; - -#endif /* TAO_WAIT_STRATEGY_H */ |