blob: 4c010059ceba9c3acb2297087eeaf60146a7ffdd (
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
|
eval '(exit $?0)' && eval 'exec perl -S $0 ${1+"$@"}'
& eval 'exec perl -S $0 $argv:q'
if 0;
# $Id$
# -*- perl -*-
use Env (ACE_ROOT);
use lib "$ACE_ROOT/bin";
use PerlACE::Run_Test;
sub usage() {
print "Usage:\n";
print " run_test [-h] [-debug]\n\n";
print " -udp -- Federate using udp\n";
print " -mcast -- Federate using multicast (the default)\n";
print " -h -- Prints this information\n";
print " -debug -- Sets the debug flag for the test\n";
exit;
}
my $udp = 0;
my $i = 0;
my $flags = "";
while ($i <= $#ARGV) {
if ($ARGV[$i] eq "-h" || $ARGV[$i] eq "-help" ||
$ARGV[$i] eq "--help" || $ARGV[$i] eq "-?") {
usage ();
} elsif ($ARGV[$i] eq "-debug") {
$flags .= " -ORBDebugLevel 10 ";
} elsif ($ARGV[$i] eq "-udp") {
$udp = 1;
} elsif ($ARGV[$i] eq "-mcast") {
$udp = 0;
} else {
print "ERROR: Unknown Option: ".$ARGV[$i]."\n\n";
usage ();
}
$i++;
}
if ($udp) {
print "Using UDP to link the event channels.\n\n";
} else {
print "Using multicast to link the event channels.\n\n";
}
$nsiorfile = PerlACE::LocalFile ("ns.ior");
$ec1iorfile = PerlACE::LocalFile ("ec1.ior");
$ec2iorfile = PerlACE::LocalFile ("ec2.ior");
$arg_ns_ref = "-ORBInitRef NameService=file://$nsiorfile";
$end_point = "-ORBEndpoint iiop://localhost";
$ns_port = PerlACE::random_port();
unlink $nsiorfile;
unlink $ec1iorfile;
unlink $ec2iorfile;
# start Naming Service
$NameService = "$ENV{TAO_ROOT}/orbsvcs/Naming_Service/Naming_Service";
$NS = new PerlACE::Process($NameService, "$flags -o $nsiorfile $end_point:$ns_port");
$NS->Spawn();
if (PerlACE::waitforfile_timed ($nsiorfile, 5) == -1) {
print STDERR "ERROR: cannot find file <$nsiorfile>\n";
$NS->Kill();
exit 1;
}
# start EchoEventSupplier
my($port1) = 10001 + PerlACE::uniqueid() ;
my($port2) = 10001 + PerlACE::uniqueid() ;
my($mport) = 10001 + PerlACE::uniqueid() ;
if ( -e "supplier.conf" )
{
$supplier_conf_file = "supplier.conf";
}
else{
$supplier_conf_file = "../supplier.conf";
}
$args1 = "$flags $arg_ns_ref -ORBSvcConf $supplier_conf_file $end_point -iorfile $ec1iorfile";
if ($udp) {
$args1 .= " -udp -ecname ec1 -port $port1 -listenport $port2 ";
} else {
$args1 .= " -ecname ec1 -address 224.9.9.2 -port $mport ";
}
$S1 = new PerlACE::Process("EchoEventSupplier", $args1);
$S1->Spawn();
$args2 = "$flags $arg_ns_ref -ORBSvcConf $supplier_conf_file $end_point -iorfile $ec2iorfile";
if ($udp) {
$args2 .= " -udp -ecname ec2 -port $port2 -listenport $port1 ";
} else {
$args2 .= " -ecname ec2 -address 224.9.9.2 -port $mport ";
}
$S2 = new PerlACE::Process("EchoEventSupplier", $args2);
$S2->Spawn();
if ((PerlACE::waitforfile_timed ($ec1iorfile, 10) == -1) ||
(PerlACE::waitforfile_timed ($ec2iorfile, 2) == -1)) {
print STDERR "ERROR: cannot find files <$ec1iorfile> and <$ec2iorfile>\n";
$NS->Kill();
$S1->Kill();
$S2->Kill();
exit 1;
}
$args3 = "$flags $arg_ns_ref -ecname ec1 $end_point";
$C1 = new PerlACE::Process("EchoEventConsumer", $args3);
$C1->Spawn();
$args4 = "$flags $arg_ns_ref -ecname ec2 $end_point";
$C2 = new PerlACE::Process("EchoEventConsumer", $args4);
$C2->Spawn();
if ($C1->WaitKill(30) == -1) {
$S1->Kill();
$S2->Kill();
$NS->Kill();
$C2->Kill();
exit 1;
}
if ($C2->WaitKill(5) == -1) {
$S1->Kill();
$S2->Kill();
$NS->Kill();
exit 1;
}
$NS->Kill();
$S1->Kill();
$S2->Kill();
unlink $nsiorfile;
unlink $ec1iorfile;
unlink $ec2iorfile;
exit 0;
|
