TAO/tao/Messaging/Asynch_Timeout_Handler.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  *  @file   Asynch_Timeout_Handler.h
   6  *
   7  *  Timeout Handler for AMI timeouts
   8  *
   9  *  @author Michael Kircher <Michael.Kircher@mchp.siemens.de>
  10  */
  11 //=============================================================================
  12
  13
  14 #ifndef TAO_ASYNCH_TIMEOUT_HANDLER_H
  15 #define TAO_ASYNCH_TIMEOUT_HANDLER_H
  16
  17 #include /**/ "ace/pre.h"
  18
  19 #include "tao/Messaging/messaging_export.h"
  20
  21 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  22 #  pragma once
  23 #endif /* ACE_LACKS_PRAGMA_ONCE */
  24
  25 #include "tao/orbconf.h"
  26 #include "tao/Basic_Types.h"
  27
  28 #include "ace/Event_Handler.h"
  29
  30 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  31
  32 class TAO_Transport_Mux_Strategy;
  33
  34 /**
  35  * @class TAO_Asynch_Timeout_Handler
  36  *
  37  * @brief Handler registered with the reactor in case of AMI timeouts.
  38  */
  39 class TAO_Asynch_Timeout_Handler
  40   : public ACE_Event_Handler
  41 {
  42 public:
  43   TAO_Asynch_Timeout_Handler (ACE_Reactor *reactor);
  44
  45   ~TAO_Asynch_Timeout_Handler () = default;
  46
  47   /// Schedule a timer
  48   long schedule_timer (TAO_Transport_Mux_Strategy *tms,
  49                        CORBA::ULong request_id,
  50                        const ACE_Time_Value &max_wait_time);
  51
  52   /// Invoked by the reactor on timeout
  53   virtual int handle_timeout (const ACE_Time_Value &current_time,
  54                               const void *act);
  55
  56   /// Cancel this timer, remove it from the reactor
  57   virtual void cancel ();
  58
  59 public:
  60   /// The transport mux strategy dispatching the reply
  61   TAO_Transport_Mux_Strategy *tms_;
  62
  63   /// Remember the ID of the request.
  64   CORBA::ULong request_id_;
  65
  66   /// Our reactor
  67   ACE_Reactor *reactor_;
  68 };
  69
  70 TAO_END_VERSIONED_NAMESPACE_DECL
  71
  72 #include /**/ "ace/post.h"
  73
  74 #endif /* TAO_ASYNCH_TIMEOUT_HANDLER_H */