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
|
// -*- C++ -*-
#include "ace/Get_Opt.h"
#include "testC.h"
#include "orbsvcs/FaultTolerance/FT_Service_Activate.h"
ACE_RCSID (Group_Ref_Manip,
client,
"$Id$")
const char *ior = 0;
int
parse_args (int argc, char *argv[])
{
ACE_Get_Opt get_opts (argc, argv, "k:");
int c;
while ((c = get_opts ()) != -1)
switch (c)
{
case 'k':
ior = get_opts.opt_arg ();
break;
default:
ACE_ERROR_RETURN ((LM_ERROR,
"Usage: %s "
"-k IOR_1 -k IOR_2\n",
argv[0]),
-1);
}
return 0;
}
int
main (int argc, char *argv[])
{
int status = 0;
ACE_DECLARE_NEW_CORBA_ENV;
ACE_TRY
{
CORBA::ORB_var orb = CORBA::ORB_init (argc,
argv,
"Client ORB"
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (::parse_args (argc, argv) != 0)
return -1;
// Start out with the first IOR. Interaction with the second
// IOR occurs during the various interceptions executed during
// this test.
CORBA::Object_var object =
orb->string_to_object (ior ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
ForwardRequestTest::test_var server =
ForwardRequestTest::test::_narrow (object.in () ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Before and after the LOCATION_FORWARD_PERM the marshaled
// object reference must differ.
// Create a stringified/marshaled snapshot of Object reference
CORBA::String_var marshaled_obj_snapshot1 =
orb->object_to_string (server.in () ACE_ENV_ARG_PARAMETER);
if (CORBA::is_nil (server.in ()))
{
ACE_ERROR_RETURN ((LM_ERROR,
"Object reference <%s> is nil\n",
ior),
1);
}
CORBA::ULong number = 0;
for (int i = 1; i <= 25; ++i)
{
ACE_DEBUG ((LM_INFO,
"CLIENT: Issuing request %d.\n",
i));
number += server->number (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
ACE_DEBUG ((LM_INFO,
"CLIENT: Number %d .\n",
number));
}
if (number < 250)
{
ACE_ERROR ((LM_ERROR,
"(%P|%t) ERROR: Did not forward to new location \n"));
ACE_OS::abort ();
}
// One of the request triggerd a LOCATION_FORWARD_PERM, in
// consequence the marshaled representation of "server" should
// look different now, compare to snapshot1.
CORBA::String_var marshaled_obj_snapshot2 =
orb->object_to_string (server.in () ACE_ENV_ARG_PARAMETER);
if (strcmp (marshaled_obj_snapshot1.in (), marshaled_obj_snapshot2.in ()) == 0)
{
// Error, before and after the marhaled object references look equal
ACE_ERROR ((LM_ERROR,
"(%P|%t) ERROR: Marshaled Object reference should differ after LOCATION_FORWARD_PERM\n"));
ACE_OS::abort ();
}
server->shutdown (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
"Caught exception:");
return -1;
}
ACE_ENDTRY;
ACE_DEBUG ((LM_INFO,
"Group_Ref_Manip Test passed.\n"));
return status;
}
|
