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
|
// This may look like C, but it's really -*- C++ -*-
// $Id$
//============================================================================
//
// = LIBRARY
// TAO
//
// = FILENAME
// IIOP_Acceptor.h
//
// = DESCRIPTION
// IIOP specific acceptor processing
//
// = AUTHOR
// Fred Kuhns <fredk@cs.wustl.edu>
// Ossama Othman <ossama@uci.edu>
//
//============================================================================
#ifndef TAO_IIOP_ACCEPTOR_H
#define TAO_IIOP_ACCEPTOR_H
#include "ace/pre.h"
#include "tao/Pluggable.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/IIOP_Connect.h"
#include "tao/Acceptor_Impl.h"
#include "ace/Acceptor.h"
#include "ace/SOCK_Acceptor.h"
// TAO IIOP_Acceptor concrete call defination
class TAO_Export TAO_IIOP_Acceptor : public TAO_Acceptor
{
// = TITLE
// TAO_IIOP_Acceptor
//
// = DESCRIPTION
// The IIOP-specific bridge class for the concrete acceptor.
//
public:
TAO_IIOP_Acceptor (CORBA::Boolean flag = 0);
// Constructor.
~TAO_IIOP_Acceptor (void);
// Destructor.
const ACE_INET_Addr& address (void) const;
// @@ Helper method for the implementation repository, should go
// away
typedef ACE_Strategy_Acceptor<TAO_IIOP_Server_Connection_Handler, ACE_SOCK_ACCEPTOR> TAO_IIOP_BASE_ACCEPTOR;
typedef TAO_Creation_Strategy<TAO_IIOP_Server_Connection_Handler> TAO_IIOP_CREATION_STRATEGY;
typedef TAO_Concurrency_Strategy<TAO_IIOP_Server_Connection_Handler> TAO_IIOP_CONCURRENCY_STRATEGY;
typedef TAO_Accept_Strategy<TAO_IIOP_Server_Connection_Handler, ACE_SOCK_ACCEPTOR> TAO_IIOP_ACCEPT_STRATEGY;
// = The TAO_Acceptor methods, check the documentation in
// Pluggable.h for details.
virtual int open (TAO_ORB_Core *orb_core,
int version_major,
int version_minor,
const char *address,
const char *options = 0);
virtual int open_default (TAO_ORB_Core *orb_core,
int version_major,
int version_minor,
const char *options = 0);
virtual int close (void);
virtual int create_mprofile (const TAO_ObjectKey &object_key,
TAO_MProfile &mprofile);
virtual int is_collocated (const TAO_Endpoint *endpoint);
virtual CORBA::ULong endpoint_count (void);
virtual int object_key (IOP::TaggedProfile &profile,
TAO_ObjectKey &key);
private:
int open_i (const ACE_INET_Addr &addr);
// Implement the common part of the open*() methods.
int hostname (TAO_ORB_Core *orb_core,
ACE_INET_Addr &addr,
char *&host);
// Set the host name for the given addr.
int probe_interfaces (TAO_ORB_Core *orb_core);
// Probe the system for available network interfaces, and initialize
// the <addrs_> array with an ACE_INET_Addr for each network
// interface. The port for each initialized ACE_INET_Addr will be
// set in the open_i() method. This method only gets invoked when
// no explicit hostname is provided in the specified endpoint.
virtual int parse_options (const char *options);
// Parse protocol specific options.
int init_tcp_properties (void);
// Obtain tcp properties that must be used by this acceptor, i.e.,
// initialize <tcp_properties_>.
int create_rt_mprofile (const TAO_ObjectKey &object_key,
TAO_MProfile &mprofile);
// Rather than creating a separate profile for each endpoint, this
// version of <create_mprofile> method adds all endpoints to a
// single IIOP profile, i.e., <mprofile> will not contain more than
// one IIOP_Profile, no matter how many acceptors there are.
protected:
ACE_INET_Addr *addrs_;
char **hosts_;
// Cache the information about the endpoints serviced by this
// acceptor.
// There may in fact be multiple hostnames for this endpoint. For
// example, if the IP address is INADDR_ANY (0.0.0.0) then there
// will be possibly a different hostname for each interface.
size_t endpoint_count_;
// The number of host names cached in the hosts_ array (equivalent
// to the number of endpoints opened by this Acceptor).
TAO_GIOP_Version version_;
// The GIOP version for this endpoint
TAO_ORB_Core *orb_core_;
// ORB Core.
TAO_IIOP_Handler_Base::TCP_Properties tcp_properties_;
// TCP configuration properties to be used for all
// connections opened by this acceptor.
private:
TAO_IIOP_BASE_ACCEPTOR base_acceptor_;
// the concrete acceptor, as a pointer to it's base class.
TAO_IIOP_CREATION_STRATEGY *creation_strategy_;
TAO_IIOP_CONCURRENCY_STRATEGY *concurrency_strategy_;
TAO_IIOP_ACCEPT_STRATEGY *accept_strategy_;
// Acceptor strategies.
CORBA::Boolean lite_flag_;
// Should we use GIOP lite??
};
#if defined(__ACE_INLINE__)
#include "tao/IIOP_Acceptor.i"
#endif /* __ACE_INLINE__ */
#include "ace/post.h"
#endif /* TAO_IIOP_ACCEPTOR_H */
|
