TAO/tao/DynamicInterface/DII_Reply_Dispatcher.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  *  @file    DII_Reply_Dispatcher.h
   6  *
   7  *  @brief Dispatch the reply appropriately.
   8  *
   9  *  @author Alexander Babu Arulanthu <alex@cs.wustl.edu>
  10  */
  11
  12 #ifndef TAO_DII_REPLY_DISPATCHER_H
  13 #define TAO_DII_REPLY_DISPATCHER_H
  14
  15 #include /**/ "ace/pre.h"
  16
  17 #include "tao/DynamicInterface/dynamicinterface_export.h"
  18
  19 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  20 # pragma once
  21 #endif /* ACE_LACKS_PRAGMA_ONCE */
  22
  23 #include "tao/orbconf.h"
  24 #include "tao/Asynch_Reply_Dispatcher_Base.h"
  25 #include "tao/DynamicInterface/Request.h"
  26
  27 #if defined (TAO_HAS_AMI)
  28 #include "tao/Messaging/Messaging.h"
  29 #endif /* TAO_HAS_AMI */
  30
  31 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  32
  33 class TAO_ORB_Core;
  34
  35 /**
  36  * @class TAO_DII_Deferred_Reply_Dispatcher
  37  *
  38  * @brief Reply dispatcher for DII deferred requests.
  39  */
  40 class TAO_DynamicInterface_Export TAO_DII_Deferred_Reply_Dispatcher
  41   : public TAO_Asynch_Reply_Dispatcher_Base
  42 {
  43 public:
  44   TAO_DII_Deferred_Reply_Dispatcher (CORBA::Request_ptr req,
  45                                      TAO_ORB_Core *orb_core);
  46
  47   /// The Reply_Dispatcher methods
  48   virtual int dispatch_reply (TAO_Pluggable_Reply_Params &param);
  49
  50   virtual void connection_closed ();
  51
  52   /// The following methods are not needed for this class..
  53   virtual void reply_timed_out () {}
  54   virtual long schedule_timer (CORBA::ULong , const ACE_Time_Value &)
  55   {
  56     return 0;
  57   }
  58
  59 protected:
  60   /// Destructor.
  61   ~TAO_DII_Deferred_Reply_Dispatcher () = default;
  62
  63 private:
  64   /// Where the reply needs to go.
  65   CORBA::Request_var req_;
  66 };
  67
  68 #if defined (TAO_HAS_AMI)
  69 /**
  70  * @class TAO_DII_Asynch_Reply_Dispatcher
  71  *
  72  * @brief Reply dispatcher for DII asynch requests.
  73  */
  74 class TAO_DynamicInterface_Export TAO_DII_Asynch_Reply_Dispatcher
  75   : public TAO_Asynch_Reply_Dispatcher_Base
  76 {
  77 public:
  78   TAO_DII_Asynch_Reply_Dispatcher (const Messaging::ReplyHandler_ptr callback,
  79                                      TAO_ORB_Core *orb_core);
  80   virtual ~TAO_DII_Asynch_Reply_Dispatcher ();
  81
  82   /// The Reply_Dispatcher methods
  83   virtual int dispatch_reply (TAO_Pluggable_Reply_Params &param);
  84
  85   virtual void connection_closed ();
  86
  87 private:
  88   /// The buffer that is used to initialise the data block
  89   char buf_[ACE_CDR::DEFAULT_BUFSIZE];
  90
  91   /// Datablock that is created on the stack to initialise the CDR
  92   /// stream underneath.
  93   ACE_Data_Block db_;
  94
  95   /// CDR stream for reading the input.
  96   TAO_InputCDR reply_cdr_;
  97
  98   /// Where the reply needs to go.
  99   const Messaging::ReplyHandler_ptr callback_;
 100 };
 101 #endif /* TAO_HAS_AMI */
 102
 103 TAO_END_VERSIONED_NAMESPACE_DECL
 104
 105 #include /**/ "ace/post.h"
 106
 107 #endif /* TAO_REPLY_DISPATCHER_H */