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
|
eval '(exit $?0)' && eval 'exec perl -S $0 ${1+"$@"}'
& eval 'exec perl -S $0 $argv:q'
if 0;
# $Id$
# -*- perl -*-
use lib "../../../../bin";
require ACEutils;
#event count
$ev_count = 2;
# setup CosEC params such that..
# cos event service name = "cosec1"
# for ConsumerQOS: EventID = 21, SourceID = 6
# for SupplierQOS: EventID = 20, SourceID = 5.
$CosEC1_params = "-n cosec1 -e 21 -o 6 -p \"5 20\"";
# setup another CosEC params such that..
# cos event service name = "cosec2"
# for ConsumerQOS: EventID = 20, SourceID = 5
# for SupplierQOS: EventID = 21, SourceID = 6.
$CosEC2_params = "-n cosec2 -e 20 -o 5 -p \"6 21\"";
sub cosec_multiple_test1
{
# first start the Naming service..
$SV1 = Process::Create ($EXEPREFIX."../../Naming_Service/Naming_Service".$Process::EXE_EXT,"");
sleep 10;
# now start the Rt EC..
$SV2 = Process::Create ($EXEPREFIX."../../Event_Service/Event_Service".$Process::EXE_EXT,"");
sleep 10;
# now start the CosEC1..
$SV3 = Process::Create ($EXEPREFIX."../../CosEvent_Service/CosEvent_Service".$Process::EXE_EXT,$CosEC1_params);
sleep 10;
# now start the CosEC2..
$SV4 = Process::Create ($EXEPREFIX."../../CosEvent_Service/CosEvent_Service".$Process::EXE_EXT,$CosEC2_params);
sleep 10;
#start 1 consumer that uses CosEC1 to receive events
$CONS = Process::Create ($EXEPREFIX."consumer".$Process::EXE_EXT,"-n cosec1 -c $ev_count");
sleep 10;
#start 1 supplier that uses CosEC2 to send events
$SUPP = Process::Create ($EXEPREFIX."supplier".$Process::EXE_EXT,"-n cosec2 -c $ev_count");
sleep 10;
#wait for the supplier to finish
$SUPP->Wait ();
#wait for the consumer to finish
$CONS->Wait ();
#----------
#start 1 consumer that uses CosEC1 to receive events
$CONS2 = Process::Create ($EXEPREFIX."consumer".$Process::EXE_EXT,"-n cosec2 -c $ev_count");
sleep 10;
#start 1 supplier that uses CosEC2 to send events
$SUPP2 = Process::Create ($EXEPREFIX."supplier".$Process::EXE_EXT,"-n cosec1 -c $ev_count");
sleep 10;
#wait for the supplier to finish
$SUPP2->Wait ();
#wait for the consumer to finish
$CONS2->Wait ();
#----------
# cleanup..
$SV1->Kill ();
$SV2->Kill ();
$SV3->Kill ();
$SV4->Kill ();
$SV1->Wait ();
$SV2->Wait ();
$SV3->Wait ();
$SV4->Wait ();
}
# Parse the arguments
for ($i = 0; $i <= $#ARGV; $i++)
{
SWITCH:
{
if ($ARGV[$i] eq "-h" || $ARGV[$i] eq "-?")
{
print "usage: run_test.pl -e event_count -h help\n";
exit;
}
if ($ARGV[$i] eq "-e")
{
$ev_count = $ARGV[$i + 1];
$i++;
last SWITCH;
}
}
}
cosec_multiple_test1 ();
|
