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
|
// $Id$
#include "IOGR_Maker.h"
#include "Replication_Service.h"
#include "ace/Synch_T.h"
template <class EC_PROXY_ADMIN, class Proxy,
class ProxyInterface, class State>
FT_ProxyAdmin<EC_PROXY_ADMIN, Proxy, ProxyInterface, State>::FT_ProxyAdmin(
EC_PROXY_ADMIN* admin, PortableServer::POA_var poa)
: FT_ProxyAdmin_Base(admin, poa), admin_(admin)
{
}
template <class EC_PROXY_ADMIN, class Proxy,
class ProxyInterface, class State>
void
FT_ProxyAdmin<EC_PROXY_ADMIN, Proxy, ProxyInterface,State>::obtain_proxy (
const FtRtecEventChannelAdmin::Operation& op
ACE_ENV_ARG_DECL)
{
Request_Context_Repository().set_object_id(op.object_id
ACE_ENV_ARG_PARAMETER);
ProxyInterface_var result
= admin_->obtain(ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
FTRTEC::Replication_Service* svc = FTRTEC::Replication_Service::instance();
ACE_TRY {
ACE_Read_Guard<FTRTEC::Replication_Service> locker(*svc);
svc->replicate_request(op,
Proxy::rollback_obtain
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHALL {
admin_->disconnect(result.in());
ACE_RE_THROW;
}
ACE_ENDTRY;
ACE_CHECK;
}
template <class EC_PROXY_ADMIN, class Proxy,
class ProxyInterface, class State>
typename FT_ProxyAdmin<EC_PROXY_ADMIN, Proxy, ProxyInterface, State>::ProxyInterface_ptr
FT_ProxyAdmin<EC_PROXY_ADMIN, Proxy, ProxyInterface, State>::obtain_proxy (ACE_ENV_SINGLE_ARG_DECL)
{
CORBA::Any_var any = Request_Context_Repository().get_cached_result(ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN(0);
CORBA::Object_var obj;
if (any >>= CORBA::Any::to_object(obj))
return ProxyInterface::_narrow(obj.in() ACE_ENV_ARG_PARAMETER);
FtRtecEventChannelAdmin::ObjectId oid;
Request_Context_Repository().generate_object_id(oid
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN(0);
FtRtecEventChannelAdmin::Operation update;
update.object_id = oid;
update.param._d(EC_PROXY_ADMIN::OBTAIN_ID);
ProxyInterface_var result
= admin_->obtain(ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN(0);
ACE_TRY {
FTRTEC::Replication_Service* svc = FTRTEC::Replication_Service::instance();
ACE_Read_Guard<FTRTEC::Replication_Service> locker(*svc);
obj = IOGR_Maker::instance()->forge_iogr(result.in()
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
result = ProxyInterface::_narrow(obj.in() ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
svc->replicate_request(update,
Proxy::rollback_obtain
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHALL {
admin_->disconnect(result.in());
ACE_RE_THROW;
}
ACE_ENDTRY;
return result._retn();
}
template <class EC_PROXY_ADMIN, class Proxy,
class ProxyInterface, class State>
void FT_ProxyAdmin<EC_PROXY_ADMIN, Proxy, ProxyInterface, State>::get_state(
State& state
ACE_ENV_ARG_DECL)
{
typename EC_PROXY_ADMIN::StateWorker worker(state.proxies);
admin_->for_each(&worker ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
template <class EC_PROXY_ADMIN, class Proxy,
class ProxyInterface, class State>
void FT_ProxyAdmin<EC_PROXY_ADMIN, Proxy, ProxyInterface, State>::set_state(
const State& state
ACE_ENV_ARG_DECL)
{
for (size_t i =0; i < state.proxies.length(); ++i)
{
const typename Proxy::State& proxy_state
= state.proxies[i];
Request_Context_Repository().set_object_id(proxy_state.object_id
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
ProxyInterface_var
proxy_ior = admin_->obtain(ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
typedef typename Proxy::Skeleton Skeleton;
const PortableServer::Servant servant = poa_->id_to_servant(
ACE_reinterpret_cast(const PortableServer::ObjectId& ,proxy_state.object_id)
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
Skeleton skeleton = ACE_reinterpret_cast(Skeleton,
servant->_downcast(proxy_ior->_interface_repository_id()));
ACE_CHECK;
ACE_static_cast(Proxy* , skeleton)->set_state(proxy_state
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
}
|
