TAO/tao/Wait_On_Reactor.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  *  @file    Wait_On_Reactor.h
   6  *
   7  *  @author  Alexander Babu Arulanthu <alex@cs.wustl.edu>
   8  */
   9 //=============================================================================
  10
  11 #ifndef TAO_WAIT_ON_REACTOR_H
  12 #define TAO_WAIT_ON_REACTOR_H
  13
  14 #include /**/ "ace/pre.h"
  15
  16 #include "tao/Wait_Strategy.h"
  17
  18 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  19 # pragma once
  20 #endif /* ACE_LACKS_PRAGMA_ONCE */
  21
  22 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  23
  24 /**
  25  * @class TAO_Wait_On_Reactor
  26  *
  27  * Wait on the Reactor. Happens in a single threaded client environment.
  28  */
  29 class TAO_Wait_On_Reactor : public TAO_Wait_Strategy
  30 {
  31 public:
  32   /// Constructor.
  33   explicit TAO_Wait_On_Reactor (TAO_Transport *transport);
  34
  35   /// Destructor.
  36   ~TAO_Wait_On_Reactor () override = default;
  37
  38   /*! @copydoc TAO_Wait_Strategy::wait() */
  39   int wait (ACE_Time_Value *max_wait_time, TAO_Synch_Reply_Dispatcher &rd) override;
  40
  41   /*! @copydoc TAO_Wait_Strategy::register_handler() */
  42   int register_handler () override;
  43
  44   /*! @copydoc TAO_Wait_Strategy::non_blocking() */
  45   bool non_blocking () const override;
  46
  47   /*! @copydoc TAO_Wait_Strategy::can_process_upcalls() */
  48   bool can_process_upcalls () const override;
  49 };
  50
  51 TAO_END_VERSIONED_NAMESPACE_DECL
  52
  53 #include /**/ "ace/post.h"
  54
  55 #endif /* TAO_WAIT_ON_REACTOR_H */