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
|
// This may look like C, but it's really -*- C++ -*-
// $Id$
// ============================================================================
//
// = LIBRARY
//
// = FILENAME
//
// = DESCRIPTION
//
// = AUTHOR
//
// ============================================================================
#include "tao/IIOP_Acceptor.h"
#include "tao/IIOP_Profile.h"
#include "tao/MProfile.h"
#include "tao/ORB_Core.h"
#include "tao/Server_Strategy_Factory.h"
#include "tao/GIOP.h"
ACE_RCSID(tao, IIOP_Acceptor, "$Id$")
// ****************************************************************
TAO_IIOP_Acceptor::TAO_IIOP_Acceptor (void)
: TAO_Acceptor (TAO_IOP_TAG_INTERNET_IOP),
base_acceptor_ ()
{
}
// @@ Fred&Ossama: Maybe not for the current round of changes, but
// shouldn't the acceptor know which version to create?
// And isn't this the right place to setup the tagged components of
// a v1.[12] profile?
// @@ Fred&Ossama: We need to check this interface: a single
// TAO_Acceptor may be bound to multiple addresses (think of a
// multihomed machine with an acceptor listening on the wildcard
// address), hence the "Right Thing" seems to be that we pass an
// MProfile that is filled up by the TAO_Acceptor class.
// @@ Right, I agree but for now we assume single endpoint. fredk
int
TAO_IIOP_Acceptor::create_mprofile (const TAO_ObjectKey &object_key,
TAO_MProfile &mprofile)
{
ACE_INET_Addr addr;
// do a getsockname () to get the address
if (base_acceptor_.acceptor ().get_local_addr (addr) == -1)
return 0;
// @@ we only make one for now
int count = mprofile.profile_count ();
if ((mprofile.size () - count) < 1)
{
if (mprofile.grow (count + 1) == -1)
return -1;
}
TAO_IIOP_Profile *pfile;
ACE_NEW_RETURN (pfile,
TAO_IIOP_Profile (this->host_.c_str (),
this->port_,
object_key,
addr),
-1);
if (mprofile.give_profile (pfile) == -1)
return -1;
return 0;
}
int
TAO_IIOP_Acceptor::is_collocated (const TAO_Profile* pfile)
{
const TAO_IIOP_Profile *profile =
ACE_dynamic_cast(const TAO_IIOP_Profile*, pfile);
// @@ We should probably cache this value, but then again some
// acceptors have multiple addresses.
// @@ Fred: any ideas on how to optimize that?
ACE_INET_Addr address;
if (this->base_acceptor_.acceptor ().get_local_addr (address) == -1)
return 0;
// @@ Ossama: can you verify that this operator does the right thing?
return profile->object_addr () == address;
}
ACE_Event_Handler *
TAO_IIOP_Acceptor::acceptor (void)
{
return &base_acceptor_;
}
int
TAO_IIOP_Acceptor::open (TAO_ORB_Core *orb_core,
ACE_CString &address)
{
ACE_INET_Addr addr (address.c_str ());
if (this->base_acceptor_.open (orb_core, addr) == -1)
return -1;
char tmp_host[MAXHOSTNAMELEN+1];
this->port_ = addr.get_port_number ();
if (orb_core->orb_params ()->use_dotted_decimal_addresses ())
{
const char *tmp;
if ((tmp = addr.get_host_addr ()) == 0)
return -1;
this->host_ = tmp;
}
else
{
if (addr.get_host_name (tmp_host, MAXHOSTNAMELEN + 1) != 0)
return -1;
this->host_ = tmp_host;
}
return 0;
}
CORBA::ULong
TAO_IIOP_Acceptor::endpoint_count (void)
{
// @@ for now just assume one!
// we should take a look at the local address, if it is zero then
// get the list of available IP interfaces and return this number.
return 1;
}
#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
template class ACE_Acceptor<TAO_Server_Connection_Handler, TAO_SOCK_ACCEPTOR>;
template class TAO_Acceptor_Impl<TAO_Server_Connection_Handler, TAO_SOCK_ACCEPTOR>;
#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
#pragma instantiate ACE_Acceptor<TAO_Server_Connection_Handler, TAO_SOCK_ACCEPTOR>
#pragma instantiate TAO_Acceptor_Impl<TAO_Server_Connection_Handler, TAO_SOCK_ACCEPTOR>
#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
|
