TAO/tao/Strategies/SCIOP_Connector.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  *  @file    SCIOP_Connector.h
   6  *
   7  *  SCIOP specific connector processing
   8  *
   9  *  @author  Jason Cohen, Lockheed Martin ATL  <jcohen@atl.lmco.com>
  10  *  @author  Keith O'Hara, Lockheed Martin ATL
  11  */
  12 //=============================================================================
  13
  14 #ifndef TAO_SCIOP_CONNECTOR_H
  15 #define TAO_SCIOP_CONNECTOR_H
  16
  17 #include /**/ "ace/pre.h"
  18 #include "tao/orbconf.h"
  19
  20 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  21 # pragma once
  22 #endif /* ACE_LACKS_PRAGMA_ONCE */
  23
  24 #if TAO_HAS_SCIOP == 1
  25
  26 #include "tao/Transport_Connector.h"
  27 #include "tao/Connector_Impl.h"
  28 #include "tao/Strategies/SCIOP_Connection_Handler.h"
  29 #include "ace/SOCK_SEQPACK_Connector.h"
  30 #include "ace/Connector.h"
  31
  32 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  33
  34 class TAO_SCIOP_Endpoint;
  35
  36 // ****************************************************************
  37
  38 /**
  39  * @class TAO_SCIOP_Connector
  40  *
  41  * @brief SCIOP-specific Connector bridge for pluggable protocols.
  42  *
  43  * Concrete instance of the TAO_Connector class.  Responsible
  44  * for establishing a connection with a server and is called from the
  45  * Connector_Registory.
  46  */
  47 class TAO_Strategies_Export TAO_SCIOP_Connector : public TAO_Connector
  48 {
  49 public:
  50   /// Constructor.
  51   TAO_SCIOP_Connector ();
  52
  53   /// Destructor.
  54   ~TAO_SCIOP_Connector ();
  55
  56   // = The TAO_Connector methods, please check the documentation on
  57   // Transport_Connector.h
  58   int open (TAO_ORB_Core *orb_core);
  59   int close ();
  60   TAO_Profile *create_profile (TAO_InputCDR& cdr);
  61
  62   virtual int check_prefix (const char *endpoint);
  63
  64   virtual char object_key_delimiter () const;
  65
  66 public:
  67   typedef TAO_Connect_Concurrency_Strategy<TAO_SCIOP_Connection_Handler>
  68           TAO_SCIOP_CONNECT_CONCURRENCY_STRATEGY;
  69
  70   typedef TAO_Connect_Creation_Strategy<TAO_SCIOP_Connection_Handler>
  71           TAO_SCIOP_CONNECT_CREATION_STRATEGY;
  72
  73   typedef ACE_Connect_Strategy<TAO_SCIOP_Connection_Handler,
  74                                ACE_SOCK_SEQPACK_CONNECTOR>
  75           TAO_SCIOP_CONNECT_STRATEGY;
  76
  77   typedef ACE_Strategy_Connector<TAO_SCIOP_Connection_Handler,
  78                                  ACE_SOCK_SEQPACK_CONNECTOR>
  79           TAO_SCIOP_BASE_CONNECTOR;
  80
  81 protected:
  82   // = The TAO_Connector methods, please check the documentation on
  83   // Transport_Connector.h
  84   int set_validate_endpoint (TAO_Endpoint *ep);
  85
  86   TAO_Transport *make_connection (TAO::Profile_Transport_Resolver *r,
  87                                   TAO_Transport_Descriptor_Interface &desc,
  88                                   ACE_Time_Value *timeout = 0);
  89
  90   /// More TAO_Connector methods, please check the documentation on
  91   /// Transport_Connector.h
  92   virtual TAO_Profile *make_profile ();
  93
  94   /// Cancel the passed cvs handler from the connector
  95   int cancel_svc_handler (TAO_Connection_Handler * svc_handler);
  96
  97 private:
  98   /// Return the remote endpoint, a helper function
  99   TAO_SCIOP_Endpoint *remote_endpoint (TAO_Endpoint *ep);
 100
 101   /// Try to make a connection to the next endpoint in the list.
 102   TAO_Transport *make_connection_i (TAO::Profile_Transport_Resolver *r,
 103                                     TAO_Transport_Descriptor_Interface &desc,
 104                                     ACE_Time_Value *timeout,
 105                                     TAO_SCIOP_Endpoint *sciop_endpoint);
 106
 107 private:
 108   /// Our connect strategy
 109   TAO_SCIOP_CONNECT_STRATEGY connect_strategy_;
 110
 111   /// The connector initiating connection requests for SCIOP.
 112   TAO_SCIOP_BASE_CONNECTOR base_connector_;
 113 };
 114
 115 TAO_END_VERSIONED_NAMESPACE_DECL
 116
 117 #endif /* TAO_HAS_SCIOP == 1 */
 118
 119
 120 #include /**/ "ace/post.h"
 121
 122 #endif  /* TAO_SCIOP_CONNECTOR_H */