blob: b314b80feebae00fc14be74a641864926af992e1 (
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 "ECFS_Configuration.h"
ACE_RCSID(EC_Federated_Scalability, Loopback, "$Id")
ECFS_Loopback::ECFS_Loopback (void)
{
}
void
ECFS_Loopback::init (CORBA::Long experiment_id,
RtecEventChannelAdmin::EventChannel_ptr ec,
CORBA::Environment &ACE_TRY_ENV)
{
this->supplier_ =
Servant_var<ECFS_Loopback_Supplier> (
new ECFS_Loopback_Supplier (experiment_id)
);
this->supplier_->connect (ec, ACE_TRY_ENV);
ACE_CHECK;
this->consumer_ =
Servant_var<ECFS_Loopback_Consumer> (
new ECFS_Loopback_Consumer (experiment_id,
this->supplier_.in ())
);
this->consumer_->connect (ec, ACE_TRY_ENV);
ACE_CHECK;
}
void
ECFS_Loopback::destroy (CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException))
{
ACE_TRY
{
this->consumer_->disconnect (ACE_TRY_ENV);
ACE_TRY_CHECK;
this->supplier_->disconnect (ACE_TRY_ENV);
ACE_TRY_CHECK;
}
ACE_CATCHANY {} ACE_ENDTRY;
PortableServer::POA_var poa = this->_default_POA (ACE_TRY_ENV);
ACE_CHECK;
PortableServer::ObjectId_var id = poa->servant_to_id (this,
ACE_TRY_ENV);
ACE_CHECK;
poa->deactivate_object (id.in (), ACE_TRY_ENV);
ACE_CHECK;
}
#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
template class Servant_var<ECFS_Loopback_Consumer>;
template class Servant_var<ECFS_Loopback_Supplier>;
#elif defined(ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
#pragma instantiate Servant_var<ECFS_Loopback_Consumer>
#pragma instantiate Servant_var<ECFS_Loopback_Supplier>
#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
|
