TAO/tao/Strategies/Optimized_Connection_Endpoint_Selector.h

   1 //=============================================================================
   2 /**
   3  *  @file   Optimized_Connection_Endpoint_Selector.h
   4  *
   5  * Strategies for selecting profile/endpoint from an IOR for making an
   6  * invocation.
   7  *
   8  *  @author Phil Mesnier <mesnier_p@ociweb.com>
   9  */
  10 //=============================================================================
  11
  12 #ifndef TAO_OPTIMIZED_CONNECTION_ENDPOINT_SELECTOR_H
  13 #define TAO_OPTIMIZED_CONNECTION_ENDPOINT_SELECTOR_H
  14
  15 #include /**/ "ace/pre.h"
  16
  17 #include "tao/corbafwd.h"
  18
  19 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  20 # pragma once
  21 #endif /* ACE_LACKS_PRAGMA_ONCE */
  22
  23 #include "tao/Strategies/strategies_export.h"
  24
  25 #include "tao/Invocation_Endpoint_Selectors.h"
  26 #include "ace/Time_Value.h"
  27
  28 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  29
  30 class TAO_GIOP_Invocation;
  31 class TAO_ORB_Core;
  32 class TAO_Stub;
  33 class TAO_Profile;
  34
  35 /**
  36  * @class TAO_Optimized_Connection_Endpoint_Selector
  37  *
  38  * @brief More efficient connection strategy for endpoint selection.
  39  *
  40  * This strategy builds on the default by first querying the connection
  41  * cache for all potential endpoints before iterating over the list to
  42  * attempt to create new connections.
  43  */
  44
  45 class TAO_Strategies_Export TAO_Optimized_Connection_Endpoint_Selector
  46  : public TAO_Default_Endpoint_Selector
  47 {
  48 public:
  49   /// Constructor.
  50   TAO_Optimized_Connection_Endpoint_Selector (const ACE_Time_Value& tv);
  51
  52   /// Destructor.
  53   virtual ~TAO_Optimized_Connection_Endpoint_Selector ();
  54
  55   static void hook (TAO_ORB_Core *,
  56                     TAO_Stub *,
  57                     bool &has_timeout,
  58                     ACE_Time_Value &tv);
  59
  60   virtual void select_endpoint (TAO::Profile_Transport_Resolver *,
  61                                 ACE_Time_Value *max_wait_time);
  62 private:
  63   int check_profile (TAO_Profile *,
  64                      TAO::Profile_Transport_Resolver *);
  65
  66   static ACE_Time_Value timeout_;
  67 };
  68
  69 TAO_END_VERSIONED_NAMESPACE_DECL
  70
  71 #include /**/ "ace/post.h"
  72 #endif  /* TAO_OPTIMIZED_CONNECTION_ENDPOINT_SELECTOR_H */