blob: 46b8699f5f098df4416ecaf7727ac8930a9ba75d (
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
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
|
eval '(exit $?0)' && eval 'exec perl -S $0 ${1+"$@"}'
& eval 'exec perl -S $0 $argv:q'
if 0;
# $Id$
# -*- perl -*-
use lib "$ENV{ACE_ROOT}/bin";
use PerlACE::TestTarget;
$status = 0;
$debug_level = '0';
## The LoadManager needs to register signals with the ORB's reactor (on
## Windows only) and thus can not use the TP Reactor since it doesn't
## support that kind of thing. So, we swith to the Select MT Reactor.
$lm_conf = "windows" . $PerlACE::svcconf_ext;
foreach $i (@ARGV) {
if ($i eq '-debug') {
$debug_level = '10';
}
}
my $server1 = PerlACE::TestTarget::create_target (1) || die "Create target 1 failed\n";
my $server2 = PerlACE::TestTarget::create_target (2) || die "Create target 2 failed\n";
my $client = PerlACE::TestTarget::create_target (3) || die "Create target 3 failed\n";
my $ior1file = "lm.ior";
my $ior2file = "obj.ior";
#Files which used by server1
my $server1_ior1file = $server1->LocalFile ($ior1file);
$server1->DeleteFile($ior1file);
#Files which used by server2
my $server2_ior1file = $server2->LocalFile ($ior1file);
$server2->DeleteFile($ior1file);
my $server2_ior2file = $server2->LocalFile ($ior2file);
$server2->DeleteFile($ior2file);
#Files which used by client2
my $client_ior2file = $client->LocalFile ($ior2file);
$client->DeleteFile($ior2file);
$SV1 = $server1->CreateProcess ("../../../../LoadBalancer/LoadManager",
"-ORBdebuglevel $debug_level " .
"-o $server1_ior1file " .
($^O eq 'MSWin32' ?
" -ORBSvcConf $lm_conf" : ''));
$SV2 = $server2->CreateProcess ("server",
"-ORBdebuglevel $debug_level " .
"-ORBInitRef LoadManager=file://$server2_ior1file " .
"-o $server2_ior2file");
$CL = $client->CreateProcess ("client",
"-ORBInitRef LoadManager=file://$client_ior2file");
print STDERR "\n\n======== Running Application Controlled Membership Test================\n";
print STDERR "\n";
print STDERR "This test uses the Random Load Balancing strategy in the Cygnus Load Balancer\n";
print STDERR "6 servers are created and added into a Object Group\n";
print STDERR "When the client makes an invocation, Random load balancing strategy\n";
print STDERR "selects one of the servers and then the client makes 5 invocations on\n";
print STDERR "the server. When done, the application has to delete the object from the\n";
print STDERR "object group. This is called the application controlled membership of\n";
print STDERR "object group.\n";
print STDERR "\n";
$server_status = $SV1->Spawn ();
if ($server_status != 0) {
print STDERR "ERROR: server returned $server_status\n";
exit 1;
}
if ($server1->WaitForFileTimed ($ior1file,
$server1->ProcessStartWaitInterval()) == -1) {
print STDERR "ERROR: cannot find file <$server1_ior1file>\n";
$SV1->Kill (); $SV1->TimedWait (1);
exit 1;
}
if ($server1->GetFile ($ior1file) == -1) {
print STDERR "ERROR: cannot retrieve file <$server1_ior1file>\n";
$SV1->Kill (); $SV1->TimedWait (1);
exit 1;
}
if ($server2->PutFile ($ior2file) == -1) {
print STDERR "ERROR: cannot set file <$server2_ior2file>\n";
$SV1->Kill (); $SV1->TimedWait (1);
exit 1;
}
$server_status = $SV2->Spawn ();
if ($server_status != 0) {
print STDERR "ERROR: server returned $server_status\n";
exit 1;
}
sub KillServers{
$SV1->Kill (); $SV1->TimedWait (1);
$SV2->Kill (); $SV2->TimedWait (1);
}
if ($server2->WaitForFileTimed ($ior2file,
$server2->ProcessStartWaitInterval()) == -1) {
print STDERR "ERROR: cannot find file <$server2_ior2file>\n";
KillServers ();
exit 1;
}
if ($server2->GetFile ($ior2file) == -1) {
print STDERR "ERROR: cannot retrieve file <$server2_ior2file>\n";
KillServers ();
exit 1;
}
if ($client->PutFile ($ior2file) == -1) {
print STDERR "ERROR: cannot set file <$client_ior2file>\n";
KillServers ();
exit 1;
}
$client_status = $CL->SpawnWaitKill ($client->ProcessStartWaitInterval() + 85);
if ($client_status != 0) {
print STDERR "ERROR: client returned $client_status\n";
$status = 1;
}
$server_status = $SV2->WaitKill ($server2->ProcessStopWaitInterval());
if ($server_status != 0) {
print STDERR "ERROR: server returned $server_status\n";
$status = 1;
}
$server_status = $SV1->TerminateWaitKill ($server1->ProcessStopWaitInterval());
if ($server_status != 0) {
print STDERR "ERROR: server returned $server_status\n";
$status = 1;
}
$server1->DeleteFile($ior1file);
$server2->DeleteFile($ior1file);
$server2->DeleteFile($ior2file);
$client->DeleteFile($ior2file);
exit $status;
|
