blob: ef42a8bb4ac81552412130f77063df3f7591920b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
// This may look like C, but it's really -*- C++ -*-
//=============================================================================
/**
* @file IIOP_Connector.h
*
* $Id$
*
* IIOP specific connector processing
*
*
* @author Fred Kuhns <fredk@cs.wustl.edu>
* @author Ossama Othman <ossama@uci.edu>
* @author Balachandran Natarajan <bala@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_IIOP_CONNECTOR_H
#define TAO_IIOP_CONNECTOR_H
#include /**/ "ace/pre.h"
#include "ace/SOCK_Connector.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Connector.h"
#include "tao/Transport_Connector.h"
#include "tao/Connector_Impl.h"
#include "tao/IIOP_Connection_Handler.h"
class TAO_IIOP_Endpoint;
// ****************************************************************
/**
* @class TAO_IIOP_Connector
*
* @brief IIOP-specific Connector bridge for pluggable protocols.
*
* Concrete instance of the TAO_Connector class. Responsible
* for establishing a connection with a server and is called from the
* Connector_Registory.
*/
class TAO_Export TAO_IIOP_Connector : public TAO_Connector
{
public:
// = Initialization and termination methods.
/// Constructor.
TAO_IIOP_Connector (CORBA::Boolean flag = 0);
/// Destructor.
~TAO_IIOP_Connector (void);
//@@ TAO_CONNECTOR_SPL_PUBLIC_METHODS_COPY_HOOK_START
// = The TAO_Connector methods, please check the documentation on
// Transport_Connector.h
int open (TAO_ORB_Core *orb_core);
int close (void);
TAO_Profile *create_profile (TAO_InputCDR& cdr);
virtual int check_prefix (const char *endpoint);
virtual char object_key_delimiter (void) const;
public:
typedef TAO_Connect_Concurrency_Strategy<TAO_IIOP_Connection_Handler>
TAO_IIOP_CONNECT_CONCURRENCY_STRATEGY;
typedef TAO_Connect_Creation_Strategy<TAO_IIOP_Connection_Handler>
TAO_IIOP_CONNECT_CREATION_STRATEGY;
typedef ACE_Connect_Strategy<TAO_IIOP_Connection_Handler,
ACE_SOCK_CONNECTOR>
TAO_IIOP_CONNECT_STRATEGY ;
typedef ACE_Strategy_Connector<TAO_IIOP_Connection_Handler,
ACE_SOCK_CONNECTOR>
TAO_IIOP_BASE_CONNECTOR;
//@@ TAO_CONNECTOR_SPL_PUBLIC_METHODS_COPY_HOOK_END
protected:
// = The TAO_Connector methods, please check the documentation on
// Transport_Connector.h
int set_validate_endpoint (TAO_Endpoint *ep);
TAO_Transport *make_connection (TAO::Profile_Transport_Resolver *r,
TAO_Transport_Descriptor_Interface &desc,
ACE_Time_Value *timeout = 0);
/// More TAO_Connector methods, please check the documentation on
/// Transport_Connector.h
virtual TAO_Profile *make_profile (ACE_ENV_SINGLE_ARG_DECL);
/// Cancel the passed cvs handler from the connector
virtual int cancel_svc_handler (TAO_Connection_Handler * svc_handler);
/*
* Hook to copy over the protected and private data from this class to
* base Connector class.
*/
//@@ TAO_CONNECTOR_SPL_COPY_HOOK_START
protected:
/// Do we need to use a GIOP_Lite for sending messages?
const bool lite_flag_;
private:
/// Return the remote endpoint, a helper function
TAO_IIOP_Endpoint *remote_endpoint (TAO_Endpoint *ep);
private:
/// Our connect strategy
TAO_IIOP_CONNECT_STRATEGY connect_strategy_;
/// The connector initiating connection requests for IIOP.
TAO_IIOP_BASE_CONNECTOR base_connector_;
//@@ TAO_CONNECTOR_SPL_COPY_HOOK_END
};
#include /**/ "ace/post.h"
#endif /* TAO_IIOP_CONNECTOR_H */
|
