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
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
// This may look like C, but it's really -*- C++ -*-
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO
//
// = FILENAME
// IIOP_Connector.h
//
// = DESCRIPTION
// IIOP specific connector processing
//
// = AUTHOR
// Fred Kuhns <fredk@cs.wustl.edu>
//
// ============================================================================
#ifndef TAO_IIOP_CONNECTOR_H
#define TAO_IIOP_CONNECTOR_H
#include "ace/pre.h"
#include "ace/Connector.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/SOCK_Connector.h"
#include "tao/Pluggable.h"
#include "tao/IIOP_Connect.h"
#include "tao/Resource_Factory.h"
// ****************************************************************
class TAO_Export TAO_IIOP_Connect_Creation_Strategy : public ACE_Creation_Strategy<TAO_IIOP_Client_Connection_Handler>
{
// = TITLE
// Helper creation strategy
//
// = DESCRIPTION
// Creates UIOP_Client_Connection_Handler objects but satisfies
// the interface required by the
// ACE_Creation_Strategy<TAO_IIOP_Client_Connection_Handler>
//
public:
TAO_IIOP_Connect_Creation_Strategy (ACE_Thread_Manager * = 0,
TAO_ORB_Core* orb_core = 0,
void *arg = 0,
CORBA::Boolean flag = 0);
// Constructor. <arg> parameter is used to pass any special
// state/info to the service handler upon creation. Currently used
// by IIOP and UIOP to pass protocol configuration properties.
~TAO_IIOP_Connect_Creation_Strategy (void);
// Default destructor g++, 2.7.2 seems to be needing this
virtual int make_svc_handler (TAO_IIOP_Client_Connection_Handler *&sh);
// Makes TAO_IIOP_Client_Connection_Handlers
private:
TAO_ORB_Core* orb_core_;
// The ORB
void *arg_;
// Some info/state to be passed to the service handler we create.
CORBA::Boolean lite_flag_;
// Are we using GIOP lite?
};
// ****************************************************************
class TAO_Export TAO_IIOP_Connector : public TAO_Connector
{
// = TITLE
// IIOP-specific Connector bridge for pluggable protocols.
//
// = DESCRIPTION
// Concrete instance of the TAO_Connector class. Responsible
// for establishing a connection with a server and is called from the
// Connector_Registory.
//
public:
// = Initialization and termination methods.
TAO_IIOP_Connector (CORBA::Boolean flag = 0);
// Constructor.
~TAO_IIOP_Connector (void);
// Destructor.
// = The TAO_Connector methods, please check the documentation on
// Pluggable.h
int open (TAO_ORB_Core *orb_core);
int close (void);
int connect (TAO_Connection_Descriptor_Interface *desc,
TAO_Transport *&transport,
ACE_Time_Value *max_wait_time,
CORBA::Environment &ACE_TRY_ENV);
int preconnect (const char *preconnections);
TAO_Profile *create_profile (TAO_InputCDR& cdr);
virtual int check_prefix (const char *endpoint);
virtual char object_key_delimiter (void) const;
protected:
// = More TAO_Connector methods, please check the documentation on
// Pluggable.h
virtual void make_profile (const char *endpoint,
TAO_Profile *&,
CORBA::Environment &ACE_TRY_ENV = TAO_default_environment ());
int init_tcp_properties (void);
// Obtain tcp properties that must be used by this connector, i.e.,
// initialize <tcp_properties_>.
public:
typedef ACE_Concurrency_Strategy<TAO_IIOP_Client_Connection_Handler>
TAO_ACTIVATION_STRATEGY;
typedef ACE_Connect_Strategy<TAO_IIOP_Client_Connection_Handler,
ACE_SOCK_CONNECTOR>
TAO_CONNECT_STRATEGY ;
typedef ACE_Strategy_Connector<TAO_IIOP_Client_Connection_Handler,
ACE_SOCK_CONNECTOR>
TAO_IIOP_BASE_CONNECTOR;
protected:
TAO_IIOP_Properties tcp_properties_;
// TCP configuration properties to be used for all
// connections established by this connector.
CORBA::Boolean lite_flag_;
// Do we need to use a GIOP_Lite for sending messages?
private:
TAO_ACTIVATION_STRATEGY null_activation_strategy_;
// Our activation strategy
TAO_CONNECT_STRATEGY connect_strategy_;
// Our connect strategy
TAO_IIOP_BASE_CONNECTOR base_connector_;
// The connector initiating connection requests for IIOP.
};
#include "ace/post.h"
#endif /* TAO_IIOP_CONNECTOR_H */
|
