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
|
/**
* @file Peer_Base.cpp
*
* $Id$
*
* @author Carlos O'Ryan <coryan@uci.edu>
*/
#include "Peer_Base.h"
#include "RTServer_Setup.h"
#include "RIR_Narrow.h"
#include "Servant_var.h"
#include "RTEC_Initializer.h"
#include "EC_Destroyer.h"
#include "Auto_Disconnect.h"
#include "Loopback.h"
#include "orbsvcs/Event/EC_Event_Channel.h"
#include "orbsvcs/Event/EC_Gateway_IIOP.h"
ACE_RCSID (TAO_RTEC_Perf,
Peer_Base,
"$Id$")
Peer_Base::Peer_Base (CORBA::ORB_ptr orb,
RTServer_Setup &rtserver_setup
ACE_ENV_ARG_DECL)
: orb_ (CORBA::ORB::_duplicate (orb))
, poa_ (rtserver_setup.poa ())
{
Servant_var<TAO_EC_Event_Channel> ec_impl (
RTEC_Initializer::create (this->poa_.in (),
this->poa_.in (),
rtserver_setup.rtcorba_setup ()
ACE_ENV_ARG_PARAMETER)
);
ACE_CHECK;
ec_impl->activate (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
PortableServer::ObjectId_var ec_id =
this->poa_->activate_object (ec_impl.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
CORBA::Object_var ec_object =
this->poa_->id_to_reference (ec_id.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
this->event_channel_ =
RtecEventChannelAdmin::EventChannel::_narrow (ec_object.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
Peer_Base::~Peer_Base (void)
{
}
void
Peer_Base::shutdown (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
{
EC_Destroyer ec_destroyer (this->event_channel_.in ());
this->event_channel_ =
RtecEventChannelAdmin::EventChannel::_nil ();
}
this->orb_->shutdown (0 ACE_ENV_ARG_PARAMETER);
}
CORBA::Object_ptr
Peer_Base::channel (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException))
{
return CORBA::Object::_duplicate (this->event_channel_.in ());
}
void
Peer_Base::connect (Federated_Test::Peer_ptr remote_peer
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
ACE_DEBUG ((LM_DEBUG, "(%P|%t) Connecting....\n"));
CORBA::Object_var remote_ec_object =
remote_peer->channel (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
RtecEventChannelAdmin::EventChannel_var remote_ec =
RtecEventChannelAdmin::EventChannel::_narrow (remote_ec_object.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
Servant_var<TAO_EC_Gateway_IIOP> gateway (new TAO_EC_Gateway_IIOP);
gateway->init (remote_ec.in (),
this->event_channel_.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
RtecEventChannelAdmin::Observer_var observer =
gateway->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
RtecEventChannelAdmin::Observer_Handle h =
this->event_channel_->append_observer (observer.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
gateway->observer_handle (h);
}
Federated_Test::Loopback_ptr
Peer_Base::setup_loopback (CORBA::Long experiment_id,
CORBA::Long base_event_type
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
Servant_var<Loopback> loopback (
new Loopback (experiment_id,
base_event_type,
this->poa_.in (),
this->poa_.in (),
this->event_channel_.in ()
ACE_ENV_ARG_PARAMETER));
ACE_CHECK_RETURN (Federated_Test::Loopback::_nil ());
Auto_Disconnect<Loopback> disconnect (loopback);
Federated_Test::Loopback_var lb =
loopback->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (Federated_Test::Loopback::_nil ());
disconnect.release ();
return lb._retn ();
}
PortableServer::POA_ptr
Peer_Base::_default_POA (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException))
{
return PortableServer::POA::_duplicate (this->poa_.in ());
}
|
