summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/run_test.pl
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/run_test.pl')
-rwxr-xr-xTAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/run_test.pl68
1 files changed, 38 insertions, 30 deletions
diff --git a/TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/run_test.pl b/TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/run_test.pl
index 490a0aa818c..3abd9a03714 100755
--- a/TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/run_test.pl
+++ b/TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/run_test.pl
@@ -13,6 +13,7 @@ $notifyior = PerlACE::LocalFile ("notify.ior");
$notify_conf = PerlACE::LocalFile ("notify$PerlACE::svcconf_ext");
$status = 0;
+unlink $notifyior;
$port = PerlACE::uniqueid () + 10001;
$NS = new PerlACE::Process ("../../../Naming_Service/Naming_Service",
@@ -30,9 +31,8 @@ $SEC = new PerlACE::Process ("Sequence_Consumer");
$client_args = "-ORBInitRef NameService=iioploc://localhost:" .
"$port/NameService";
$NS->Spawn ();
-
-unlink $notifyior;
$TS->Spawn ();
+
if (PerlACE::waitforfile_timed ($notifyior, 20) == -1) {
print STDERR "ERROR: waiting for the notify service to start\n";
$TS->Kill ();
@@ -40,46 +40,54 @@ if (PerlACE::waitforfile_timed ($notifyior, 20) == -1) {
exit 1;
}
-@low = (40, 20, 20, 20);
-@high = (40, 21, 21, 21);
+if ($status == 0) {
+ $discard_policy = fifo;
+
+@low = (6, 3, 6, 3, 1);
+@high = (7, 4, 7, 4, 2);
@constraintList = (
"\"Number == 20 or Number == 10\"",
"\"Number == 20 or Index == 7\"",
+ "\"Number == 20 or Number == 10\"",
"\"Number == 20 or Index == 4\"",
- "\"Number == 10 or (Number == 20 and Index == 1)\"",
+ "\"Number == 20 and Index == 1\"",
);
-$i = 0;
+ $i = 0;
+ print "************** Running Sequence Consumer with the " .
+ "$discard_policy policy ************\n";
foreach $constraintString (@constraintList) {
- print "<*><*><*> Constraint String: $constraintString <*><*><*>\n";
+ print "<*><*><*> Constraint String: $constraintString <*><*><*>\n";
- unlink $ior;
- $SES->Spawn ();
- if (PerlACE::waitforfile_timed ($ior, 20) == -1) {
- print STDERR "ERROR: waiting for the supplier to start\n";
- $SES->Kill ();
- $TS->Kill ();
- $NS->Kill ();
- $status = 1;
- last;
- }
+ unlink $ior;
+ $SES->Spawn ();
- $SEC->Arguments($client_args . " -l $low[$i] -h $high[$i] -c $constraintString");
+ if (PerlACE::waitforfile_timed ($ior, 20) == -1) {
+ print STDERR "ERROR: waiting for the supplier to start\n";
+ $SES->Kill ();
+ $TS->Kill ();
+ $NS->Kill ();
+ $status = 1;
+ last;
+ }
- $i = $i + 1;
+ $SEC->Arguments($client_args . " -l $low[$i] -h $high[$i] -d $discard_policy -c $constraintString");
- $client = $SEC->SpawnWaitKill (60);
- if ($client != 0) {
- print STDERR "ERROR: Sequence_Consumer did not run properly\n";
- $status = 1;
- last;
- }
- $server = $SES->WaitKill(5);
- if ($server != 0) {
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
+ $i = $i + 1;
+
+ $client = $SEC->SpawnWaitKill (60);
+ if ($client != 0) {
+ print STDERR "ERROR: Sequence_Consumer did not run properly\n";
+ $status = 1;
+ last;
+ }
+ $server = $SES->WaitKill(5);
+ if ($server != 0) {
+ $TS->Kill ();
+ $NS->Kill ();
+ exit 1;
+ }
}
}