TAO/orbsvcs/performance-tests/LoadBalancing/LBPerf/RPS/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 #include "ace/Atomic_Op.h"
  25
  26 #if defined(_MSC_VER)
  27 #pragma warning(push)
  28 #pragma warning(disable:4250)
  29 #endif /* _MSC_VER */
  30
  31 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  32 class TAO_LB_LoadAlert;
  33 TAO_END_VERSIONED_NAMESPACE_DECL
  34
  35 /**
  36  * @class ServerRequestInterceptor
  37  *
  38  * @brief ServerRequestInterceptor that calculates the number of
  39  *        requests arriving per second.
  40  *
  41  * This ServerRequestInterceptor is responsible for redirecting
  42  * requests back to the LoadManager.
  43  */
  44 class ServerRequestInterceptor
  45   : public virtual PortableInterceptor::ServerRequestInterceptor,
  46     public virtual ::CORBA::LocalObject
  47 {
  48 public:
  49   /// Constructor.
  50   ServerRequestInterceptor ();
  51
  52   /**
  53    * @name Methods Required by the ServerRequestInterceptor
  54    *       Interface
  55    *
  56    * These are the canonical methods required for all
  57    * ServerRequestInterceptors.
  58    */
  59   //@{
  60   virtual char * name ();
  61
  62   virtual void destroy ();
  63
  64   virtual void receive_request_service_contexts (
  65       PortableInterceptor::ServerRequestInfo_ptr ri);
  66
  67   virtual void receive_request (
  68       PortableInterceptor::ServerRequestInfo_ptr ri);
  69
  70   virtual void send_reply (
  71       PortableInterceptor::ServerRequestInfo_ptr ri);
  72
  73   virtual void send_exception (
  74       PortableInterceptor::ServerRequestInfo_ptr ri);
  75
  76   virtual void send_other (
  77       PortableInterceptor::ServerRequestInfo_ptr ri);
  78   //@}
  79
  80   CORBA::Long request_count ();
  81
  82 protected:
  83   /// Destructor.
  84   /**
  85    * Protected destructor to enforce correct memory management via
  86    * reference counting.
  87    */
  88   ~ServerRequestInterceptor ();
  89
  90 private:
  91   /// The number of requests that have arrived on the server.
  92   ACE_Atomic_Op<TAO_SYNCH_MUTEX, long> request_count_;
  93 };
  94
  95 #if defined(_MSC_VER)
  96 #pragma warning(pop)
  97 #endif /* _MSC_VER */
  98
  99
 100 #endif  /* TAO_SERVER_REQUEST_INTERCEPTOR_H */