//============================================================================= /** * @file Wait_On_Read.h * * @author Alexander Babu Arulanthu */ //============================================================================= #ifndef TAO_WAIT_ON_READ_H #define TAO_WAIT_ON_READ_H #include /**/ "ace/pre.h" #include "tao/Wait_Strategy.h" #if !defined (ACE_LACKS_PRAGMA_ONCE) # pragma once #endif /* ACE_LACKS_PRAGMA_ONCE */ TAO_BEGIN_VERSIONED_NAMESPACE_DECL /** * @class TAO_Wait_On_Read * * Simply block on read() to wait for the reply. */ class TAO_Wait_On_Read : public TAO_Wait_Strategy { public: /// Constructor. explicit TAO_Wait_On_Read (TAO_Transport *transport); /// Destructor. virtual ~TAO_Wait_On_Read (void); /*! @copydoc TAO_Wait_Strategy::sending_request() */ virtual int sending_request (TAO_ORB_Core *orb_core, TAO_Message_Semantics msg_semantics); /*! @copydoc TAO_Wait_Strategy::finished_request() */ virtual void finished_request (); /*! @copydoc TAO_Wait_Strategy::wait() */ virtual int wait (ACE_Time_Value *max_wait_time, TAO_Synch_Reply_Dispatcher &rd); /*! @copydoc TAO_Wait_Strategy::register_handler() */ virtual int register_handler (void); /*! @copydoc TAO_Wait_Strategy::non_blocking() */ virtual bool non_blocking () const; /*! @copydoc TAO_Wait_Strategy::can_process_upcalls() */ virtual bool can_process_upcalls () const; }; TAO_END_VERSIONED_NAMESPACE_DECL #include /**/ "ace/post.h" #endif /* TAO_WAIT_ON_READ_H */