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
|
// -*- C++ -*-
//=============================================================================
/**
* @file UIPMC_Acceptor.h
*
* $Id$
*
* MIOP specific acceptor processing
*
* @author Frank Hunleth <fhunleth@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_UIPMC_ACCEPTOR_H
#define TAO_UIPMC_ACCEPTOR_H
#include /**/ "ace/pre.h"
#include "UIPMC_Connection_Handler.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/Transport_Acceptor.h"
#include "tao/Acceptor_Impl.h"
#include "tao/GIOP_Message_State.h"
#include "ace/Acceptor.h"
#include "ace/SOCK_Acceptor.h"
#include "portablegroup_export.h"
// TAO UIPMC_Acceptor concrete call defination
/**
* @class TAO_UIPMC_Acceptor
*
* @brief TAO_UIPMC_Acceptor
*
* The UIPMC-specific bridge class for the concrete acceptor.
*/
class TAO_PortableGroup_Export TAO_UIPMC_Acceptor : public TAO_Acceptor
{
public:
/// Constructor.
TAO_UIPMC_Acceptor (CORBA::Boolean flag = 0);
/// Destructor.
~TAO_UIPMC_Acceptor (void);
/// @@ Helper method for the implementation repository, should go
/// away
const ACE_INET_Addr& address (void) const;
/// Returns the array of endpoints in this acceptor
const ACE_INET_Addr *endpoints (void);
/**
* The TAO_Acceptor methods, check the documentation in
* Pluggable.h for details.
*/
virtual int open (TAO_ORB_Core *orb_core,
ACE_Reactor *reactor,
int version_major,
int version_minor,
const char *address,
const char *options = 0);
virtual int open_default (TAO_ORB_Core *orb_core,
ACE_Reactor *reactor,
int version_major,
int version_minor,
const char *options = 0);
virtual int close (void);
virtual int create_profile (const TAO::ObjectKey &object_key,
TAO_MProfile &mprofile,
CORBA::Short priority);
virtual int is_collocated (const TAO_Endpoint *endpoint);
virtual CORBA::ULong endpoint_count (void);
virtual int object_key (IOP::TaggedProfile &profile,
TAO::ObjectKey &key);
/**
* Set the host name for the given addr.
* A hostname may be forced by using specified_hostname. This
* is useful if the given address corresponds to more than one
* hostname and the desired one cannot be determined in any
* other way.
*/
int hostname (TAO_ORB_Core *orb_core,
ACE_INET_Addr &addr,
char *&host,
const char *specified_hostname = 0);
/**
* Set the host name for the given address using the dotted decimal
* format.
*/
int dotted_decimal_address (ACE_INET_Addr &addr,
char *&host);
protected:
/**
* Implement the common part of the open*() methods. This method is
* virtual to allow a derived class implementation to be invoked
* instead.
*/
virtual int open_i (const ACE_INET_Addr &addr,
ACE_Reactor *reactor);
/// Parse protocol specific options.
virtual int parse_options (const char *options);
protected:
/// Array of ACE_INET_Addr instances, each one corresponding to a
/// given network interface.
ACE_INET_Addr *addrs_;
/**
* 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.
*/
char **hosts_;
/// The number of host names cached in the hosts_ array (equivalent
/// to the number of endpoints opened by this Acceptor).
CORBA::ULong endpoint_count_;
/**
* The GIOP version for this endpoint
* @@ Theoretically this shouldn't be here!! We need to look at a
* way to move this out
*/
TAO_GIOP_Message_Version version_;
/// ORB Core.
TAO_ORB_Core *orb_core_;
private:
TAO_UIPMC_Connection_Handler *connection_handler_;
};
#if defined(__ACE_INLINE__)
#include "UIPMC_Acceptor.i"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_UIPMC_ACCEPTOR_H */
|
