summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/performance-tests/Filter/run_test.pl
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/performance-tests/Filter/run_test.pl')
-rwxr-xr-xTAO/orbsvcs/tests/Notify/performance-tests/Filter/run_test.pl313
1 files changed, 137 insertions, 176 deletions
diff --git a/TAO/orbsvcs/tests/Notify/performance-tests/Filter/run_test.pl b/TAO/orbsvcs/tests/Notify/performance-tests/Filter/run_test.pl
index 00675644772..987280e3a79 100755
--- a/TAO/orbsvcs/tests/Notify/performance-tests/Filter/run_test.pl
+++ b/TAO/orbsvcs/tests/Notify/performance-tests/Filter/run_test.pl
@@ -6,210 +6,171 @@ eval '(exit $?0)' && eval 'exec perl -S $0 ${1+"$@"}'
# -*- perl -*-
use lib "$ENV{ACE_ROOT}/bin";
-use PerlACE::Run_Test;
-
-PerlACE::add_lib_path ('../../lib');
+use PerlACE::TestTarget;
PerlACE::check_privilege_group();
-$ior = PerlACE::LocalFile ("supplier.ior");
-$namingior = PerlACE::LocalFile ("naming.ior");
-$notifyior = PerlACE::LocalFile ("notify.ior");
-$notify_conf = PerlACE::LocalFile ("notify$PerlACE::svcconf_ext");
-$status = 0;
+my $nm_service = PerlACE::TestTarget::create_target (1) || die "Create target 1 failed\n";
+my $nt_service = PerlACE::TestTarget::create_target (2) || die "Create target 2 failed\n";
+my $consumer = PerlACE::TestTarget::create_target (3) || die "Create target 3 failed\n";
+my $supplier = PerlACE::TestTarget::create_target (4) || die "Create target 4 failed\n";
+$consumer->AddLibPath ("../../lib");
+$supplier->AddLibPath ("../../lib");
+
+my $supplier_ior = "supplier.ior";
+my $naming_ior = "naming.ior";
+my $notify_ior = "notify.ior";
+my $notify_conf = "notify$PerlACE::svcconf_ext";
+
+my $ns_naming_ior = $nm_service->LocalFile ($naming_ior);
+my $ts_notify_ior = $nt_service->LocalFile ($notify_ior);
+my $ts_notify_conf = $nt_service->LocalFile ($notify_conf);
+my $supplier_supplier_ior = $supplier->LocalFile ($supplier_ior);
+my $consumer_supplier_ior = $consumer->LocalFile ($supplier_ior);
+$nm_service->DeleteFile ($naming_ior);
+$nt_service->DeleteFile ($notify_ior);
+$supplier->DeleteFile ($supplier_ior);
+$consumer->DeleteFile ($supplier_ior);
-$port = PerlACE::uniqueid () + 10001;
-$NS = new PerlACE::Process ("../../../../Naming_Service/Naming_Service",
- "-ORBEndpoint iiop://localhost:$port " .
- "-o $namingior");
-$TS = new PerlACE::Process ("../../../../Notify_Service/Notify_Service",
- "-ORBInitRef NameService=iioploc://" .
- "localhost:$port/NameService " .
- "-IORoutput $notifyior -ORBSvcConf " .
- "$notify_conf");
-$STS = new PerlACE::Process ("Structured_Supplier",
- "-ORBInitRef NameService=iioploc://" .
- "localhost:$port/NameService");
-$STC = new PerlACE::Process ("Structured_Consumer");
-
-$SES = new PerlACE::Process ("Sequence_Supplier",
- "-ORBInitRef NameService=iioploc://" .
- "localhost:$port/NameService");
-$SEC = new PerlACE::Process ("Sequence_Consumer");
-
-unlink $ior;
-unlink $notifyior;
-unlink $namingior;
-
-$client_args = "-ORBInitRef NameService=iioploc://localhost:" .
- "$port/NameService";
-
-$NS->Spawn ();
-if (PerlACE::waitforfile_timed ($namingior, $PerlACE::wait_interval_for_process_creation) == -1) {
- print STDERR "ERROR: waiting for the naming service to start\n";
- $NS->Kill ();
- exit 1;
-}
+$status = 0;
-$TS->Spawn ();
-if (PerlACE::waitforfile_timed ($notifyior, $PerlACE::wait_interval_for_process_creation) == -1) {
- print STDERR "ERROR: waiting for the notify service to start\n";
- $TS->Kill ();
- $NS->Kill ();
+my $port = $nm_service->RandomPort();
+my $host = $nm_service->HostName();
+
+my $initref = "-ORBInitRef NameService=iioploc://$host:$port/NameService ";
+
+$NS = $nm_service->CreateProcess ("../../../../Naming_Service/Naming_Service",
+ "-ORBEndpoint iiop://$host:$port -o $ns_naming_ior");
+$TS = $nt_service->CreateProcess ("../../../../Notify_Service/Notify_Service", $initref.
+ "-IORoutput $ts_notify_ior -ORBSvcConf $ts_notify_conf");
+$STS = $supplier->CreateProcess ("Structured_Supplier", $initref.
+ "-o $supplier_supplier_ior");
+$STC = $consumer->CreateProcess ("Structured_Consumer");
+$SES = $supplier->CreateProcess ("Sequence_Supplier", $initref."-o $supplier_supplier_ior");
+$SEC = $consumer->CreateProcess ("Sequence_Consumer");
+
+my $consumer_args = $initref; # ."-k $consumer_supplier_ior";
+
+sub run_test {
+ local($name, $args_suffix, $SP, $CN, $tm) = @_;
+ print $name;
+
+ $supplier->DeleteFile ($supplier_ior);
+ $consumer->DeleteFile ($supplier_ior);
+
+ my $test_status = 0;
+
+ my $result = $SP->Spawn ();
+ if ($result != 0) {
+ print STDERR "ERROR: supplier returned $result\n";
+ return 1;
+ }
+
+ if ($supplier->WaitForFileTimed ($supplier_ior, $supplier->ProcessStartWaitInterval()) == -1) {
+ print STDERR "ERROR: waiting for the supplier to start\n";
+ $SP->Kill (); $SP->TimedWait (1);
+ return 1;
+ }
+
+ if ($supplier->GetFile ($supplier_ior) == -1) {
+ print STDERR "ERROR: cannot retrieve file <$supplier_supplier_ior>\n";
+ $SP->Kill (); $SP->TimedWait (1);
+ return 1;
+ }
+
+ if ($consumer->PutFile ($supplier_ior) == -1) {
+ print STDERR "ERROR: cannot set file <$consumer_supplier_ior>\n";
+ $SP->Kill (); $SP->TimedWait (1);
+ return 1;
+ }
+
+ $CN->Arguments ($consumer_args.$args_suffix);
+ print $tm."\n";
+ print $CN->CommandLine ()."\n";
+ $result = $CN->SpawnWaitKill ($consumer->ProcessStartWaitInterval() + $tm);
+ print "\n";
+ if ($result != 0) {
+ print STDERR "ERROR: consumer returned $result\n";
+ $test_status = 1;
+ }
+
+ $result = $SP->WaitKill ($supplier->ProcessStopWaitInterval());
+
+ if ($result != 0) {
+ print STDERR "ERROR: supplier returned $result\n";
+ $test_status = 1;
+ }
+
+ return $test_status;
+}
+
+my $result = $NS->Spawn ();
+
+if ($result != 0) {
+ print STDERR "ERROR: naming service returned $result\n";
exit 1;
}
-######################################################################
-print "**** Structured Supplier -> 2 Structured Consumers ****\n";
-$STS->Spawn ();
-if (PerlACE::waitforfile_timed ($ior, $PerlACE::wait_interval_for_process_creation) == -1) {
- print STDERR "ERROR: waiting for the supplier to start\n";
- $STS->Kill ();
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
-}
-$STC->Arguments($client_args);
-print $STC->CommandLine ()."\n";
-$client = $STC->SpawnWaitKill (300);
-print "\n";
-if ($client != 0) {
- $STS->Kill ();
- $TS->Kill ();
- $NS->Kill ();
+if ($nm_service->WaitForFileTimed ($naming_ior, $nm_service->ProcessStartWaitInterval()) == -1) {
+ print STDERR "ERROR: waiting for the naming service to start\n";
+ $NS->Kill (); $NS->TimedWait (1);
exit 1;
}
-$server = $STS->WaitKill(5);
-if ($server != 0) {
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
-}
-
-######################################################################
-print "**** Structured Supplier -> Structured Consumer (filtered) ****\n";
+$result = $TS->Spawn ();
-unlink $ior;
-$STS->Spawn ();
-if (PerlACE::waitforfile_timed ($ior, $PerlACE::wait_interval_for_process_creation) == -1) {
- print STDERR "ERROR: waiting for the supplier to start\n";
- $STS->Kill ();
- $TS->Kill ();
- $NS->Kill ();
+if ($result != 0) {
+ print STDERR "ERROR: notify service returned $result\n";
+ $NS->Kill (); $NS->TimedWait (1);
exit 1;
}
-$STC->Arguments($client_args . " -f -c 1");
-$client = $STC->SpawnWaitKill (60);
-print "\n";
-if ($client != 0) {
- $STS->Kill ();
- $TS->Kill ();
- $NS->Kill ();
+if ($nt_service->WaitForFileTimed ($notify_ior, $nt_service->ProcessStartWaitInterval()) == -1) {
+ print STDERR "ERROR: waiting for the notify service to start\n";
+ $TS->Kill (); $TS->TimedWait (1);
+ $NS->Kill (); $NS->TimedWait (1);
exit 1;
}
-$server = $STS->WaitKill(5);
-if ($server != 0) {
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
-}
-######################################################################
-print "**** Structured Supplier -> Sequence Consumer (filtered) ****\n";
-
-unlink $ior;
-$STS->Spawn ();
-if (PerlACE::waitforfile_timed ($ior, $PerlACE::wait_interval_for_process_creation) == -1) {
- print STDERR "ERROR: waiting for the supplier to start\n";
- $STS->Kill ();
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
-}
-
-$SEC->Arguments($client_args . " -f -c 1");
-$client = $SEC->SpawnWaitKill (60);
-print "\n";
-if ($client != 0) {
- $STS->Kill ();
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
-}
-$server = $STS->WaitKill(5);
-if ($server != 0) {
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
-}
-
-######################################################################
-print "**** Sequence Supplier -> 2 Sequence Consumers ****\n";
-
-unlink $ior;
-$SES->Spawn ();
-if (PerlACE::waitforfile_timed ($ior, $PerlACE::wait_interval_for_process_creation) == -1) {
- print STDERR "ERROR: waiting for the supplier to start\n";
- $SES->Kill ();
- $TS->Kill ();
- $NS->Kill ();
+$result = run_test ("**** Structured Supplier -> 2 Structured Consumers ****\n",
+ "", $STS, $STC, 285);
+if ($result != 0) {
+ $TS->Kill (); $TS->TimedWait (1);
+ $NS->Kill (); $NS->TimedWait (1);
exit 1;
}
-$SEC->Arguments($client_args);
-$client = $SEC->SpawnWaitKill (60);
-print "\n";
-if ($client != 0) {
- $SES->Kill ();
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
-}
-$server = $SES->WaitKill(5);
-if ($server != 0) {
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
+$result = run_test ("**** Structured Supplier -> Structured Consumer (filtered) ****\n",
+ " -f -c 1", $STS, $STC, 45);
+if ($result != 0) {
+ $TS->Kill (); $TS->TimedWait (1);
+ $NS->Kill (); $NS->TimedWait (1);
+ exit 1;
}
-######################################################################
-print "**** Sequence Supplier -> Sequence Consumer (filtered) ****\n";
-
-unlink $ior;
-$SES->Spawn ();
-if (PerlACE::waitforfile_timed ($ior, $PerlACE::wait_interval_for_process_creation) == -1) {
- print STDERR "ERROR: waiting for the supplier to start\n";
- $SES->Kill ();
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
+$result = run_test ("**** Sequence Supplier -> 2 Sequence Consumers ****\n",
+ "", $SES, $SEC, 45);
+if ($result != 0) {
+ $TS->Kill (); $TS->TimedWait (1);
+ $NS->Kill (); $NS->TimedWait (1);
+ exit 1;
}
-$SEC->Arguments($client_args . " -f -c 1");
-$client = $SEC->SpawnWaitKill (60);
-print "\n";
-if ($client != 0) {
- $SES->Kill ();
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
-}
-$server = $SES->WaitKill(5);
-if ($server != 0) {
- $TS->Kill ();
- $NS->Kill ();
- exit 1;
+$result = run_test ("**** Sequence Supplier -> Sequence Consumer (filtered) ****\n",
+ " -f -c 1", $SES, $SEC, 45);
+if ($result != 0) {
+ $TS->Kill (); $TS->TimedWait (1);
+ $NS->Kill (); $NS->TimedWait (1);
+ exit 1;
}
-$TS->Kill ();
-$NS->Kill ();
-
-unlink $ior;
-unlink $notifyior;
-unlink $namingior;
+$TS->Kill (); $TS->TimedWait (1);
+$NS->Kill (); $NS->TimedWait (1);
+$nm_service->DeleteFile ($naming_ior);
+$nt_service->DeleteFile ($notify_ior);
+$supplier->DeleteFile ($supplier_ior);
+$consumer->DeleteFile ($supplier_ior);
exit $status;
View Lorry Controller Status