TAO/orbsvcs/examples/LoadBalancing/ServerRequestInterceptor.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  * @file    ServerRequestInterceptor.h
   6  *
   7  * @author  Ossama Othman <ossama@dre.vanderbilt.edu>
   8  */
   9 //=============================================================================
  10
  11
  12 #ifndef TAO_SERVER_REQUEST_INTERCEPTOR_H
  13 #define TAO_SERVER_REQUEST_INTERCEPTOR_H
  14
  15 #include "ace/config-all.h"
  16
  17 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  18 # pragma once
  19 #endif /* ACE_LACKS_PRAGMA_ONCE */
  20
  21 #include "tao/PI_Server/PI_Server.h"
  22 #include "tao/PortableInterceptorC.h"
  23 #include "tao/LocalObject.h"
  24
  25 #include "ace/Atomic_Op.h"
  26
  27 #if defined(_MSC_VER)
  28 #pragma warning(push)
  29 #pragma warning(disable:4250)
  30 #endif /* _MSC_VER */
  31
  32 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  33 class TAO_LB_LoadAlert;
  34 TAO_END_VERSIONED_NAMESPACE_DECL
  35
  36 /**
  37  * @class ServerRequestInterceptor
  38  *
  39  * @brief ServerRequestInterceptor that calculates the number of
  40  *        requests arriving per second.
  41  *
  42  * This ServerRequestInterceptor is responsible for redirecting
  43  * requests back to the LoadManager.
  44  */
  45 class ServerRequestInterceptor
  46   : public virtual PortableInterceptor::ServerRequestInterceptor,
  47     public virtual ::CORBA::LocalObject
  48 {
  49 public:
  50
  51   /// Constructor.
  52   ServerRequestInterceptor (void);
  53
  54   /**
  55    * @name Methods Required by the ServerRequestInterceptor
  56    *       Interface
  57    *
  58    * These are the canonical methods required for all
  59    * ServerRequestInterceptors.
  60    */
  61   //@{
  62   virtual char * name (void);
  63
  64   virtual void destroy (void);
  65
  66   virtual void receive_request_service_contexts (
  67       PortableInterceptor::ServerRequestInfo_ptr ri);
  68
  69   virtual void receive_request (
  70       PortableInterceptor::ServerRequestInfo_ptr ri);
  71
  72   virtual void send_reply (
  73       PortableInterceptor::ServerRequestInfo_ptr ri);
  74
  75   virtual void send_exception (
  76       PortableInterceptor::ServerRequestInfo_ptr ri);
  77
  78   virtual void send_other (
  79       PortableInterceptor::ServerRequestInfo_ptr ri);
  80   //@}
  81
  82   CORBA::Long request_count (void);
  83
  84 protected:
  85
  86   /// Destructor.
  87   /**
  88    * Protected destructor to enforce correct memory management via
  89    * reference counting.
  90    */
  91   ~ServerRequestInterceptor (void);
  92
  93 private:
  94
  95   /// The number of requests that have arrived on the server.
  96   ACE_Atomic_Op<TAO_SYNCH_MUTEX, long> request_count_;
  97
  98 };
  99
 100 #if defined(_MSC_VER)
 101 #pragma warning(pop)
 102 #endif /* _MSC_VER */
 103
 104
 105 #endif  /* TAO_SERVER_REQUEST_INTERCEPTOR_H */