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   /// Constructor.
  51   ServerRequestInterceptor ();
  52
  53   /**
  54    * @name Methods Required by the ServerRequestInterceptor
  55    *       Interface
  56    *
  57    * These are the canonical methods required for all
  58    * ServerRequestInterceptors.
  59    */
  60   //@{
  61   virtual char * name ();
  62
  63   virtual void destroy ();
  64
  65   virtual void receive_request_service_contexts (
  66       PortableInterceptor::ServerRequestInfo_ptr ri);
  67
  68   virtual void receive_request (
  69       PortableInterceptor::ServerRequestInfo_ptr ri);
  70
  71   virtual void send_reply (
  72       PortableInterceptor::ServerRequestInfo_ptr ri);
  73
  74   virtual void send_exception (
  75       PortableInterceptor::ServerRequestInfo_ptr ri);
  76
  77   virtual void send_other (
  78       PortableInterceptor::ServerRequestInfo_ptr ri);
  79   //@}
  80
  81   CORBA::Long request_count ();
  82
  83 protected:
  84   /// Destructor.
  85   /**
  86    * Protected destructor to enforce correct memory management via
  87    * reference counting.
  88    */
  89   ~ServerRequestInterceptor ();
  90
  91 private:
  92   /// The number of requests that have arrived on the server.
  93   ACE_Atomic_Op<TAO_SYNCH_MUTEX, long> request_count_;
  94 };
  95
  96 #if defined(_MSC_VER)
  97 #pragma warning(pop)
  98 #endif /* _MSC_VER */
  99
 100
 101 #endif  /* TAO_SERVER_REQUEST_INTERCEPTOR_H */