TAO/tao/Reactive_Flushing_Strategy.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  *  @file Reactive_Flushing_Strategy.h
   6  *
   7  *  @author Carlos O'Ryan <coryan@uci.edu>
   8  */
   9 //=============================================================================
  10
  11 #ifndef TAO_REACTIVE_FLUSHING_STRATEGY_H
  12 #define TAO_REACTIVE_FLUSHING_STRATEGY_H
  13
  14 #include /**/ "ace/pre.h"
  15
  16 #include "tao/Flushing_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_Reactive_Flushing_Strategy
  26  *
  27  * @brief Implement a flushing strategy that uses the reactor.
  28  */
  29 class TAO_Reactive_Flushing_Strategy : public TAO_Flushing_Strategy
  30 {
  31 public:
  32   virtual int schedule_output (TAO_Transport *transport);
  33   virtual int cancel_output (TAO_Transport *transport);
  34   virtual int flush_message (TAO_Transport *transport,
  35                              TAO_Queued_Message *msg,
  36                              ACE_Time_Value *max_wait_time);
  37   virtual int flush_transport (TAO_Transport *transport
  38                                , ACE_Time_Value *max_wait_time);
  39 };
  40
  41 TAO_END_VERSIONED_NAMESPACE_DECL
  42
  43 #include /**/ "ace/post.h"
  44
  45 #endif  /* TAO_REACTIVE_FLUSHING_STRATEGY_H */