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
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
|
// $Id$
#include "TestC.h"
#include "Client_Task.h"
#include "orbsvcs/FaultTolerance/FT_ClientService_Activate.h"
//////////////////////////////////////////////////////////////////////////
ACE_CString file_prefix("file://");
/// Constructor
Client_Task::Client_Task (CORBA::ORB_ptr corb,
ACE_Thread_Manager *thr_mgr,
const ACE_CString& collocated_ior_file,
const ACE_CString& server_ior_file)
: ACE_Task_Base (thr_mgr)
, corb_ (CORBA::ORB::_duplicate (corb))
, collocated_ior_file_(collocated_ior_file)
, server_ior_file_(server_ior_file)
{
}
CORBA::Object_ptr
Client_Task::make_iogr (const char* domain_id, CORBA::ULongLong group_id, CORBA::ULong group_version ACE_ENV_ARG_DECL)
{
CORBA::Object_var remote_server(
corb_->string_to_object (ACE_CString(file_prefix + this->server_ior_file_).c_str()));
if (CORBA::is_nil (remote_server.in ()))
{
ACE_ERROR ((LM_ERROR, "Error: Remote server is not started.\n"));
ACE_TRY_THROW (CORBA::INTERNAL ());
}
CORBA::Object_var collocated_server(
corb_->string_to_object (ACE_CString(file_prefix + this->collocated_ior_file_).c_str()));
if (CORBA::is_nil (collocated_server.in ()))
{
ACE_ERROR ((LM_ERROR, "Error: Collocated server is not started.\n"));
ACE_TRY_THROW (CORBA::INTERNAL ());
}
FT::TagFTGroupTaggedComponent ft_tag_component;
// Create the list
TAO_IOP::TAO_IOR_Manipulation::IORList iors (1);
iors.length (2);
iors [0] = CORBA::Object::_duplicate (remote_server.ptr());
iors [1] = CORBA::Object::_duplicate (collocated_server.ptr());
CORBA::Object_var new_ref =
this->iorm_->merge_iors (iors ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
// Property values
// Major and Minor revision numbers
ft_tag_component.component_version.major = (CORBA::Octet) 1;
ft_tag_component.component_version.minor = (CORBA::Octet) 0;
// Domain id
ft_tag_component.group_domain_id = domain_id;
// Object group id
ft_tag_component.object_group_id = group_id;
// Version
ft_tag_component.object_group_ref_version = group_version;
// Construct the IOGR Property class
TAO_FT_IOGR_Property iogr_prop (ft_tag_component);
// Set the property
CORBA::Boolean retval = this->iorm_->set_property (&iogr_prop,
new_ref.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
// Set the primary
// See we are setting the second ior as the primary
retval = this->iorm_->set_primary (&iogr_prop,
remote_server.in (),
new_ref.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
return new_ref._retn ();
}
/// Thread entry point
int Client_Task::svc (void)
{
ACE_TRY_NEW_ENV
{
// Get a ref to the IORManipulation object
CORBA::Object_var IORM =
corb_->resolve_initial_references (TAO_OBJID_IORMANIPULATION,
0
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Narrow
this->iorm_ =
TAO_IOP::TAO_IOR_Manipulation::_narrow (IORM.in() ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
CORBA::Object_var iogr = make_iogr ("Domain_1", 1, 1 ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
CORBA::String_var iorgr_string =
corb_->object_to_string (iogr.in () ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
CORBA::Object_var object =
corb_->string_to_object (iorgr_string.in () ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
Test_var server =
Test::_narrow (object.in () ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (CORBA::is_nil (server.in ()))
{
ACE_ERROR_RETURN ((LM_ERROR,
"Object reference <%s> is nil\n", iorgr_string.in()), 1);
}
CORBA::Object_var remote_server(
corb_->string_to_object (ACE_CString(file_prefix + this->server_ior_file_).c_str()));
Test_var remote_server_as_test =
Test::_narrow (remote_server.in () ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
CORBA::Object_var collocated_server(
corb_->string_to_object (ACE_CString(file_prefix + this->collocated_ior_file_).c_str()));
Test_var collocated_server_as_test =
Test::_narrow (collocated_server.in () ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (!collocated_server->_is_collocated())
{ // Collocation is disabled, just skip the test - it has no sense.
ACE_DEBUG ((LM_ERROR, "Test has no sense, because collocation is disabled.\n") );
}
else
{
ACE_TRY_NEW_ENV
{
// Following call will fail if the problem is not fixed.
// Because we are using TRANSIENT objects with the SYSTEM_ID policy
// the object keys won't match so the POA won't be able to dispatch locally.
// This wouldn't work with 'direct' collocation strategy but the default is 'through poa'.
server->myMethod (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
"Exception caught in client task:");
}
ACE_ENDTRY;
}
remote_server_as_test->shutdown(ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
collocated_server_as_test->shutdown(ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
"Exception caught in client task:");
return 1;
}
ACE_ENDTRY;
return 0;
}
|
