blob: 2b296599d05060e214269dd3fa2749ba2042d8f3 (
plain)
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
|
/**
* @file Loopback.cpp
*
* $Id$
*
* @author Carlos O'Ryan <coryan@uci.edu>
*/
#include "Loopback.h"
#include "ECFL_Configuration.h"
ACE_RCSID(EC_Federated_Latency, Loopback, "$Id$")
ECFL_Loopback::ECFL_Loopback (void)
{
}
void
ECFL_Loopback::init (CORBA::Long experiment_id,
RtecEventChannelAdmin::EventChannel_ptr ec
TAO_ENV_ARG_DECL)
{
this->supplier_ =
Servant_var<ECFL_Loopback_Supplier> (
new ECFL_Loopback_Supplier (experiment_id)
);
this->supplier_->connect (ec TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
this->consumer_ =
Servant_var<ECFL_Loopback_Consumer> (
new ECFL_Loopback_Consumer (experiment_id,
this->supplier_.in ())
);
this->consumer_->connect (ec TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
}
void
ECFL_Loopback::destroy (TAO_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
ACE_TRY
{
this->consumer_->disconnect (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
this->supplier_->disconnect (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY {} ACE_ENDTRY;
PortableServer::POA_var poa = this->_default_POA (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
PortableServer::ObjectId_var id = poa->servant_to_id (this
TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
poa->deactivate_object (id.in () TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
}
#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
template class Servant_var<ECFL_Loopback_Consumer>;
template class Servant_var<ECFL_Loopback_Supplier>;
#elif defined(ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
#pragma instantiate Servant_var<ECFL_Loopback_Consumer>
#pragma instantiate Servant_var<ECFL_Loopback_Supplier>
#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
|
