diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Invocation_Endpoint_Selectors.h')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Invocation_Endpoint_Selectors.h | 96 |
1 files changed, 96 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Invocation_Endpoint_Selectors.h b/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Invocation_Endpoint_Selectors.h new file mode 100644 index 00000000000..ae3a473ea34 --- /dev/null +++ b/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Invocation_Endpoint_Selectors.h @@ -0,0 +1,96 @@ +// -*- C++ -*- + +//============================================================================= +/** + * @file FT_Invocation_Endpoint_Selectors.h + * + * $Id$ + * + * Strategies for selecting profile/endpoint from an IOR for making an + * invocation. + * + * @author Balachandran Natarajan <bala@cs.wustl.edu> + */ +//============================================================================= + + +#ifndef TAO_FT_INVOCATION_ENDPOINT_SELECTOR_H +#define TAO_FT_INVOCATION_ENDPOINT_SELECTOR_H + +#include /**/ "ace/pre.h" + +#include "orbsvcs/FaultTolerance/FT_ClientORB_export.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +#include "tao/Invocation_Endpoint_Selectors.h" +#include "tao/Basic_Types.h" +#include "tao/ORB_Constants.h" + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +class TAO_Profile; + +/** + * @class TAO_FT_Invocation_Endpoint_Selector + * + * @brief Implementation specific for FT_Service. + * + * We inherit from the Default endpoint selector, as this would give + * us a chance to use the default endpoint selector options if + * needed. + * + */ + +class TAO_FT_ClientORB_Export TAO_FT_Invocation_Endpoint_Selector : + public TAO_Default_Endpoint_Selector +{ + +public: + /// Constructor. + TAO_FT_Invocation_Endpoint_Selector (void); + + /// Destructor. + virtual ~TAO_FT_Invocation_Endpoint_Selector (void); + + /// Implementation for FT. Please refer to + /// $TAO_ROOT/tao/Invocation_Endpoint_Selectors.h for details of + /// documentation. + virtual void select_endpoint (TAO::Profile_Transport_Resolver *r, + ACE_Time_Value *val + ACE_ENV_ARG_DECL); + +protected: + /// Select the primary and try connecting to it. + bool select_primary (TAO::Profile_Transport_Resolver *r, + ACE_Time_Value *val + ACE_ENV_ARG_DECL); + + /// Select the secondary and try connecting to it. Returns true if + /// successfull. + bool select_secondary (TAO::Profile_Transport_Resolver *r, + ACE_Time_Value *val + ACE_ENV_ARG_DECL); + + /// Helper method that tries to establish connections with all the + /// endpoints in the profile. + bool try_connect (TAO::Profile_Transport_Resolver *r, + TAO_Profile *profile, + ACE_Time_Value *max_wait_time + ACE_ENV_ARG_DECL); + + /// Helper method that checks whether the profile is a primary or + /// not. + bool check_profile_for_primary (TAO_Profile * + ACE_ENV_ARG_DECL); + + +}; + +TAO_END_VERSIONED_NAMESPACE_DECL + +#include /**/ "ace/post.h" + +#endif /* FT_TAO_INVOCATION_ENDPOINT_SELECTOR_H */ |