diff options
Diffstat (limited to 'ACE/TAO/orbsvcs/tests/ImplRepo/run_test.pl')
| -rwxr-xr-x | ACE/TAO/orbsvcs/tests/ImplRepo/run_test.pl | 1576 |
1 files changed, 1576 insertions, 0 deletions
diff --git a/ACE/TAO/orbsvcs/tests/ImplRepo/run_test.pl b/ACE/TAO/orbsvcs/tests/ImplRepo/run_test.pl new file mode 100755 index 00000000000..40404e87ddd --- /dev/null +++ b/ACE/TAO/orbsvcs/tests/ImplRepo/run_test.pl @@ -0,0 +1,1576 @@ +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; +use File::Copy; + +$debug_level = '0'; + +foreach $i (@ARGV) { + if ($i eq '-debug') { + $debug_level = '10'; + } +} + +my $imr = PerlACE::TestTarget::create_target (1) || die "Create target 1 failed\n"; +my $act = PerlACE::TestTarget::create_target (2) || die "Create target 2 failed\n"; +my $ti = PerlACE::TestTarget::create_target (3) || die "Create target 3 failed\n"; +my $a_srv = PerlACE::TestTarget::create_target (4) || die "Create target 4 failed\n"; +my $a_cli = PerlACE::TestTarget::create_target (5) || die "Create target 5 failed\n"; +my $n_srv = PerlACE::TestTarget::create_target (6) || die "Create target 6 failed\n"; +my $n_cli = PerlACE::TestTarget::create_target (7) || die "Create target 7 failed\n"; +my $p_srv = PerlACE::TestTarget::create_target (8) || die "Create target 8 failed\n"; +my $bin_imr = PerlACE::TestTarget::create_target (9) || die "Create target 9 failed\n"; +my $bin_act = PerlACE::TestTarget::create_target (10) || die "Create target 10 failed\n"; + +$imr->AddLibPath ("$ENV{ACE_ROOT}/lib"); + +my $imriorfile = "imr_locator.ior"; +my $actiorfile = "imr_activator.ior"; +my $airplaneiorfile = "airplane.ior"; +my $nesteaiorfile = "nestea.ior"; +my $backing_store = "imr_backing_store.xml"; +my $nestea_dat = "nestea.dat"; + +my $a_cli_airplaneiorfile = $a_cli->LocalFile ($airplaneiorfile); +my $n_cli_nesteaiorfile = $n_cli->LocalFile ($nesteaiorfile); + +my $refstyle = " -ORBObjRefStyle URL"; +my $protocol = "iiop"; +my $imr_host = $imr->HostName (); +my $port = 12345; +my $endpoint = "-ORBEndpoint " . "$protocol" . "://:" . $port; + +$IMR = $imr->CreateProcess ("../../ImplRepo_Service/ImplRepo_Service"); +$ACT = $act->CreateProcess ("../../ImplRepo_Service/ImR_Activator"); +$TI = $ti->CreateProcess ("$ENV{ACE_ROOT}/bin/tao_imr"); + +# We want the tao_imr executable to be found exactly in the path +# given, without being modified by the value of -ExeSubDir. +# So, we tell its Process object to ignore the setting of -ExeSubDir. + +$TI->IgnoreExeSubDir (1); + +sub create_acli { + return $a_cli->CreateProcess ("airplane_client", " -k file://$a_cli_airplaneiorfile "); +} + +sub create_ncli { + return $n_cli->CreateProcess ("nestea_client", " -k file://$n_cli_nesteaiorfile "); +} + +my $A_SRV = $a_srv->CreateProcess ("airplane_server"); +my $A_CLI = create_acli(); +my $N_SRV = $a_cli->CreateProcess ("nestea_server"); +my $N_CLI = create_ncli(); +my $P_SRV = $p_srv->CreateProcess ("persist server"); + +my $A_SRV_cmd = $A_SRV->Executable(); +my $imr_A_SRV_cmd = $imr->LocalFile ($A_SRV_cmd); + +my $N_SRV_cmd = $N_SRV->Executable(); +my $imr_N_SRV_cmd = $imr->LocalFile ($N_SRV_cmd); + +my $P_SRV_cmd = $P_SRV->Executable(); +my $imr_P_SRV_cmd = $imr->LocalFile ($P_SRV_cmd); + +# The Tests + +############################################################################### + +sub airplane_test +{ + my $status = 0; + + my $a_srv_airplaneiorfile = $a_srv->LocalFile ($airplaneiorfile); + $a_srv->DeleteFile ($airplaneiorfile); + $a_cli->DeleteFile ($airplaneiorfile); + + $A_SRV->Arguments ("-o $a_srv_airplaneiorfile $refstyle -ORBDebugLevel $debug_level"); + $A_SRV_status = $A_SRV->Spawn (); + if ($A_SRV_status != 0) { + print STDERR "ERROR: Airplane Server returned $A_SRV_status\n"; + return 1; + } + if ($a_srv->WaitForFileTimed ($airplaneiorfile,$a_srv->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$a_srv_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + return 1; + } + if ($a_srv->GetFile ($airplaneiorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$a_srv_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + return 1; + } + if ($a_cli->PutFile ($airplaneiorfile) == -1) { + print STDERR "ERROR: cannot set file <$a_cli_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + return 1; + } + +#$A_CLI = $a_cli->CreateProcess ("airplane_client", " -k file://$a_cli_airplaneiorfile"); + $A_CLI_status = $A_CLI->SpawnWaitKill ($a_cli->ProcessStartWaitInterval()); + if ($A_CLI_status != 0) { + print STDERR "ERROR: Airplane Client returned $A_CLI_status\n"; + $status = 1; + } + + $A_SRV_status = $A_SRV->TerminateWaitKill ($a_srv->ProcessStopWaitInterval()); + if ($A_SRV_status != 0) { + print STDERR "ERROR: Airplane Server returned $A_SRV_status\n"; + $status = 1; + } + + $a_srv->DeleteFile ($airplaneiorfile); + $a_cli->DeleteFile ($airplaneiorfile); + + return $status; +} + +############################################################################### + +sub nestea_test +{ + my $status = 0; + + my $n_srv_nesteaiorfile = $n_srv->LocalFile ($nesteaiorfile); + $n_srv->DeleteFile ($nesteaiorfile); + $n_cli->DeleteFile ($nesteaiorfile); + + $N_SRV->Arguments ("-o $n_srv_nesteaiorfile $refstyle -ORBDebugLevel $debug_level"); + $N_SRV_status = $N_SRV->Spawn (); + if ($N_SRV_status != 0) { + print STDERR "ERROR: Nestea Server returned $N_SRV_status\n"; + return 1; + } + if ($n_srv->WaitForFileTimed ($nesteaiorfile,$n_srv->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$n_srv_nesteaiorfile>\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + return 1; + } + if ($n_srv->GetFile ($nesteaiorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$n_srv_nesteaiorfile>\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + return 1; + } + if ($n_cli->PutFile ($nesteaiorfile) == -1) { + print STDERR "ERROR: cannot set file <$n_cli_nesteaiorfile>\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + return 1; + } + + $N_CLI_status = $N_CLI->SpawnWaitKill ($n_cli->ProcessStartWaitInterval()); + if ($N_CLI_status != 0) { + print STDERR "ERROR: Nestea Client returned $N_CLI_status\n"; + $status = 1; + } + + $N_SRV_status = $N_SRV->TerminateWaitKill ($n_srv->ProcessStopWaitInterval()); + if ($N_SRV_status != 0) { + print STDERR "ERROR: Nestea Server returned $N_SRV_status\n"; + $status = 1; + } + + $n_srv->DeleteFile ($nesteaiorfile); + $n_cli->DeleteFile ($nesteaiorfile); + + return $status; +} + +sub nt_service_test_i +{ + my ($imr_initref, $BIN_ACT, $BIN_IMR) = @_; + + my $a_srv_airplaneiorfile = $a_srv->LocalFile ($airplaneiorfile); + + print "Installing TAO ImR Services\n"; + $BIN_ACT->Arguments ("-c install $imr_initref -d 0 -ORBDebugLevel $debug_level"); + $BIN_IMR->Arguments ("-c install -d 0 -orbendpoint iiop://:8888"); + + $BIN_IMR_status = $BIN_IMR->SpawnWaitKill ($bin_imr->ProcessStartWaitInterval()); + if ($BIN_IMR_status != 0) { + print STDERR "ERROR: ImR Service returned $BIN_IMR_status\n"; + return 1; + } + + $BIN_ACT_status = $BIN_ACT->SpawnWaitKill ($bin_act->ProcessStartWaitInterval()); + if ($BIN_ACT_status != 0) { + print STDERR "ERROR: ImR Activator returned $BIN_ACT_status\n"; + return 1; + } + + # Starting the activator will also start the locator + print "Starting TAO Implementation Repository Services\n"; + # Starting the activator should start the ImR automatically + #system("net start taoimr 2>&1"); + system("net start taoimractivator 2>&1"); + + # No need to specify imr_initref or -orbuseimr 1 for servers spawned by activator + $TI->Arguments ("$imr_initref add airplane_server -c \"$imr_A_SRV_cmd\" ". + "-w \"$ENV{ACE_ROOT}/lib\""); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr add airplane_server returned $TI_status\n"; + return 1; + } + + $TI->Arguments ("$imr_initref list -v"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr list -v returned $TI_status\n"; + return 1; + } + + $TI->Arguments ("$imr_initref ior airplane_server -f $a_srv_airplaneiorfile"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr ior airplane_server returned $TI_status\n"; + return 1; + } + if ($a_srv->WaitForFileTimed ($airplaneiorfile,$a_srv->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$a_srv_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + return 1; + } + if ($a_srv->GetFile ($airplaneiorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$a_srv_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + return 1; + } + if ($a_cli->PutFile ($airplaneiorfile) == -1) { + print STDERR "ERROR: cannot set file <$a_cli_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + return 1; + } + + $A_CLI_status = $A_CLI->SpawnWaitKill ($a_cli->ProcessStartWaitInterval()+5); + if ($A_CLI_status != 0) { + print STDERR "ERROR: airplane client returned $A_CLI_status\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + return 1; + } + + $TI->Arguments ("$imr_initref shutdown airplane_server"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()+5); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr shutdown airplane_server returned $TI_status\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + return 1; + } + + return 0; +} + +sub nt_service_test +{ + my $result = 0; + + my $a_srv_airplaneiorfile = $a_srv->LocalFile ($airplaneiorfile); + $a_srv->DeleteFile ($airplaneiorfile); + $a_cli->DeleteFile ($airplaneiorfile); + + my $bin_imr_host = $bin_imr->HostName (); + + # Just to show that it's possible, this test uses corbaloc instead of ior file. + my $imr_initref = "-orbinitref ImplRepoService=corbaloc::$bin_imr_host:8888/ImplRepoService"; + + # To avoid having to ensure that they LocalSystem account has the correct path + # we simply copy the imr executables to the same directory as the DLL's. + my $BIN_IMR = $bin_imr->CreateProcess ("$ENV{ACE_ROOT}/lib/ImplRepo_Service",""); + my $BIN_ACT = $bin_act->CreateProcess ("$ENV{ACE_ROOT}/lib/ImR_Activator",""); + $BIN_IMR->IgnoreExeSubDir(1); + $BIN_ACT->IgnoreExeSubDir(1); + + print "Copying ImplRepo services to the same location as the dlls.\n"; + $bin_imr->DeleteFile ($BIN_IMR->Executable ()); + copy ($IMR->Executable (), $BIN_IMR->Executable ()); +# chmod(0755, $BIN_IMR->Executable ()); + $bin_act->DeleteFile ($BIN_ACT->Executable ()); + copy ($ACT->Executable (), $BIN_ACT->Executable ()); +# chmod(0755, $BIN_ACT->Executable ()); + + print "Stopping any existing TAO ImR Services\n"; + system("net stop taoimractivator > nul 2>&1"); + system("net stop taoimr > nul 2>&1"); + + print "Removing any existing TAO ImR Services\n"; + $BIN_ACT->Arguments ("-c remove"); + $BIN_IMR->Arguments ("-c remove"); + $BIN_ACT_status = $BIN_ACT->SpawnWaitKill ($bin_act->ProcessStartWaitInterval()); + if ($BIN_ACT_status < 0) { + print STDERR "ERROR: BIN Activator returned $BIN_ACT_status\n"; + } + $BIN_IMR_status = $BIN_IMR->SpawnWaitKill ($bin_imr->ProcessStartWaitInterval()); + if ($BIN_IMR_status < 0) { + print STDERR "ERROR: BIN ImR Service returned $BIN_IMR_status\n"; + } + + $result = nt_service_test_i ($imr_initref, $BIN_ACT, $BIN_IMR); + + print "Stopping TAO Implementation Repository Service\n"; + system("net stop taoimractivator 2>&1"); + system("net stop taoimr 2>&1"); + + print "Removing TAO ImR Services\n"; + $BIN_ACT->Arguments ("-c remove"); + $BIN_ACT_status = $BIN_ACT->SpawnWaitKill ($bin_act->ProcessStartWaitInterval()); + if ($BIN_ACT_status != 0) { + print STDERR "ERROR: BIN Activator returned $BIN_ACT_status\n"; + } + $BIN_IMR->Arguments ("-c remove"); + $BIN_IMR_status = $BIN_IMR->SpawnWaitKill ($bin_imr->ProcessStartWaitInterval()); + if ($BIN_IMR_status != 0) { + print STDERR "ERROR: BIN ImR Service returned $BIN_IMR_status\n"; + } + + print "Removing ImplRepo_Service copy.\n"; + $bin_imr->DeleteFile ($BIN_IMR->Executable ()); + $bin_act->DeleteFile ($BIN_ACT->Executable ()); + + $a_srv->DeleteFile ($airplaneiorfile); + $a_cli->DeleteFile ($airplaneiorfile); + + return $result; +} + +############################################################################### + +sub airplane_ir_test +{ + my $status = 0; + + my $imr_imriorfile = $imr->LocalFile ($imriorfile); + my $act_imriorfile = $act->LocalFile ($imriorfile); + my $ti_imriorfile = $ti->LocalFile ($imriorfile); + my $a_srv_imriorfile = $a_srv->LocalFile ($imriorfile); + my $act_actiorfile = $act->LocalFile ($actiorfile); + my $imr_airplaneiorfile = $imr->LocalFile ($airplaneiorfile); + my $a_srv_airplaneiorfile = $a_srv->LocalFile ($airplaneiorfile); + $imr->DeleteFile ($imriorfile); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $a_srv->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $imr->DeleteFile ($airplaneiorfile); + $a_srv->DeleteFile ($airplaneiorfile); + $a_cli->DeleteFile ($airplaneiorfile); + + $IMR->Arguments ("-d 2 -o $imr_imriorfile $refstyle"); + $IMR_status = $IMR->Spawn (); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR Service returned $IMR_status\n"; + return 1; + } + if ($imr->WaitForFileTimed ($imriorfile,$imr->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($imr->GetFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($act->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$act_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($ti->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$ti_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($a_srv->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$a_srv_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $ACT->Arguments ("-d 2 -o $act_actiorfile -ORBInitRef ImplRepoService=file://$act_imriorfile"); + $ACT_status = $ACT->Spawn (); + if ($ACT_status != 0) { + print STDERR "ERROR: ImR Activator returned $ACT_status\n"; + return 1; + } + if ($act->WaitForFileTimed ($actiorfile,$act->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$act_actiorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + # No need to specify imr_initref or -orbuseimr 1 for servers spawned by activator + # Can use update to add servers. + $TI->Arguments ("-ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "update airplane_server -c \"$imr_A_SRV_cmd -o $imr_airplaneiorfile\""); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $A_SRV->Arguments ("-ORBUseIMR 1 -o $a_srv_airplaneiorfile ". + "-ORBInitRef ImplRepoService=file://$a_srv_imriorfile ". + "-ORBDebugLevel $debug_level"); + $A_SRV_status = $A_SRV->Spawn (); + if ($A_SRV_status != 0) { + print STDERR "ERROR: Airplane Server returned $A_SRV_status\n"; + return 1; + } + if ($a_srv->WaitForFileTimed ($airplaneiorfile,$a_srv->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$a_srv_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($a_srv->GetFile ($airplaneiorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$a_srv_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($a_cli->PutFile ($airplaneiorfile) == -1) { + print STDERR "ERROR: cannot set file <$a_cli_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $A_CLI_status = $A_CLI->SpawnWaitKill ($a_cli->ProcessStartWaitInterval()); + if ($A_CLI_status != 0) { + print STDERR "ERROR: Airplane Client 1 returned $A_CLI_status\n"; + $status = 1; + } + + $TI->Arguments ("-ORBInitRef ImplRepoService=file://$ti_imriorfile shutdown airplane_server"); + + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr 1 returned $TI_status\n"; + $status = 1; + } + + # This client should force a new airplane_server to be started + $A_CLI_status = $A_CLI->SpawnWaitKill ($a_cli->ProcessStartWaitInterval()); + if ($A_CLI_status != 0) { + print STDERR "ERROR: Airplane Client 2 returned $A_CLI_status\n"; + $status = 1; + } + + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr 2 returned $TI_status\n"; + $status = 1; + } + + $A_SRV_status = $A_SRV->WaitKill ($a_srv->ProcessStopWaitInterval()); + if ($A_SRV_status != 0) { + print STDERR "ERROR: Airplane Server returned $A_SRV_status\n"; + $status = 1; + } + + $ACT_status = $ACT->TerminateWaitKill ($act->ProcessStopWaitInterval()); + if ($ACT_status != 0) { + print STDERR "ERROR: Activator returned $ACT_status\n"; + $status = 1; + } + + $IMR_status = $IMR->TerminateWaitKill ($imr->ProcessStopWaitInterval()); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR returned $IMR_status\n"; + $status = 1; + } + + $imr->DeleteFile ($imriorfile); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $a_srv->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $imr->DeleteFile ($airplaneiorfile); + $a_srv->DeleteFile ($airplaneiorfile); + $a_cli->DeleteFile ($airplaneiorfile); + + return $status; +} + +############################################################################### + +sub nestea_ir_test +{ + my $status = 0; + + my $imr_imriorfile = $imr->LocalFile ($imriorfile); + my $act_imriorfile = $act->LocalFile ($imriorfile); + my $ti_imriorfile = $ti->LocalFile ($imriorfile); + my $n_srv_imriorfile = $n_srv->LocalFile ($imriorfile); + my $act_actiorfile = $act->LocalFile ($actiorfile); + my $imr_nesteaiorfile = $imr->LocalFile ($nesteaiorfile); + my $n_srv_nesteaiorfile = $n_srv->LocalFile ($nesteaiorfile); + $imr->DeleteFile ($imriorfile); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $n_srv->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $imr->DeleteFile ($nesteaiorfile); + $n_srv->DeleteFile ($nesteaiorfile); + $n_cli->DeleteFile ($nesteaiorfile); + + $IMR->Arguments ("-d 2 -o $imr_imriorfile $refstyle"); + $IMR_status = $IMR->Spawn (); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR Service returned $IMR_status\n"; + return 1; + } + if ($imr->WaitForFileTimed ($imriorfile,$imr->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($imr->GetFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($act->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$act_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($ti->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$ti_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($n_srv->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$n_srv_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $ACT->Arguments ("-d 2 -o $act_actiorfile ". + "-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$act_imriorfile"); + $ACT_status = $ACT->Spawn (); + if ($ACT_status != 0) { + print STDERR "ERROR: ImR Activator returned $ACT_status\n"; + return 1; + } + if ($act->WaitForFileTimed ($actiorfile,$act->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$act_actiorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $N_SRV->Arguments ("-ORBUseIMR 1 -o $n_srv_nesteaiorfile ". + "-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$n_srv_imriorfile ". + "-ORBDebugLevel $debug_level"); + $N_SRV_status = $N_SRV->Spawn (); + if ($N_SRV_status != 0) { + print STDERR "ERROR: Nestea Server returned $N_SRV_status\n"; + return 1; + } + if ($n_srv->WaitForFileTimed ($nesteaiorfile,$n_srv->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$n_srv_nesteaiorfile>\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($n_srv->GetFile ($nesteaiorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$n_srv_nesteaiorfile>\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($n_cli->PutFile ($nesteaiorfile) == -1) { + print STDERR "ERROR: cannot set file <$n_cli_nesteaiorfile>\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $N_CLI_status = $N_CLI->SpawnWaitKill ($n_cli->ProcessStartWaitInterval()); + if ($N_CLI_status != 0) { + print STDERR "ERROR: Nestea Client 1 returned $N_CLI_status\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $TI->Arguments ("-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$ti_imriorfile ". + " shutdown nestea_server"); + + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr 1 returned $TI_status\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $N_SRV_status = $N_SRV->WaitKill ($n_srv->ProcessStopWaitInterval()); + if ($N_SRV_status != 0) { + print STDERR "ERROR: Nestea Server returned $N_SRV_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + # No need to specify imr_initref or -orbuseimr 1 for servers spawned by activator + $TI->Arguments ("-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "update nestea_server -l $imr_host ". + "-c \"$imr_N_SRV_cmd -o $imr_nesteaiorfile\""); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + # This should cause the activator to spawn another server. + $N_CLI_status = $N_CLI->SpawnWaitKill ($n_cli->ProcessStartWaitInterval()+5); + if ($N_CLI_status != 0) { + print STDERR "ERROR: Nestea Client 2 returned $N_CLI_status\n"; + $status = 1; + } + + $TI->Arguments ("-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "shutdown nestea_server"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr 1 returned $TI_status\n"; + $status = 1; + } + + # This should destroy the POA, causing another to be created the next time + # the server is spawned. + $TI->Arguments ("-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "remove nestea_server"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr 1 returned $TI_status\n"; + $status = 1; + } + + # No need to specify imr_initref or -orbuseimr 1 for servers spawned by activator + $TI->Arguments ("-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "add nestea_server -c \"$imr_N_SRV_cmd -o $imr_nesteaiorfile\""); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr 1 returned $TI_status\n"; + $status = 1; + } + + # This should cause the activator to spawn another server. + $N_CLI_status = $N_CLI->SpawnWaitKill ($n_cli->ProcessStartWaitInterval()+5); + if ($N_CLI_status != 0) { + print STDERR "ERROR: Nestea Client 2 returned $N_CLI_status\n"; + $status = 1; + } + + # This call should block until the server shuts down + $TI->Arguments ("-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "shutdown nestea_server"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr 1 returned $TI_status\n"; + $status = 1; + } + + $ACT_status = $ACT->TerminateWaitKill ($act->ProcessStopWaitInterval()); + if ($ACT_status != 0) { + print STDERR "ERROR: Activator returned $ACT_status\n"; + $status = 1; + } + + $IMR_status = $IMR->TerminateWaitKill ($imr->ProcessStopWaitInterval()); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR returned $IMR_status\n"; + $status = 1; + } + + $imr->DeleteFile ($imriorfile); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $n_srv->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $imr->DeleteFile ($nesteaiorfile); + $n_srv->DeleteFile ($nesteaiorfile); + $n_cli->DeleteFile ($nesteaiorfile); + + return $status; +} + +############################################################################### + +sub perclient +{ + my $status = 0; + + my $imr_imriorfile = $imr->LocalFile ($imriorfile); + my $act_imriorfile = $act->LocalFile ($imriorfile); + my $ti_imriorfile = $ti->LocalFile ($imriorfile); + my $act_actiorfile = $act->LocalFile ($actiorfile); + my $imr_nesteaiorfile = $imr->LocalFile ($nesteaiorfile); + $imr->DeleteFile ($imriorfile); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $imr->DeleteFile ($nesteaiorfile); + $n_cli->DeleteFile ($nesteaiorfile); + + my $imr_host = $imr->HostName (); + + # specify an endpoint so that we can use corbaloc url for the client. + $IMR->Arguments ("-d 2 -orbendpoint iiop://:8888 -o $imr_imriorfile $refstyle ". + "-ORBDebugLevel $debug_level"); + $IMR_status = $IMR->Spawn (); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR Service returned $IMR_status\n"; + return 1; + } + if ($imr->WaitForFileTimed ($imriorfile,$imr->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($imr->GetFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($act->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$act_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($ti->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$ti_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $ACT->Arguments ("-d 2 -o $act_actiorfile ". + "-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$act_imriorfile"); + $ACT_status = $ACT->Spawn (); + if ($ACT_status != 0) { + print STDERR "ERROR: ImR Activator returned $ACT_status\n"; + return 1; + } + if ($act->WaitForFileTimed ($actiorfile,$act->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$act_actiorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + # No need to specify imr_initref or -orbuseimr 1 for servers spawned by activator + $TI->Arguments ("-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "add nestea_server -a PER_CLIENT ". + "-c \"$imr_N_SRV_cmd -o $imr_nesteaiorfile\""); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $N_CLI->Arguments("-k corbaloc::$imr_host:8888/nestea_server"); + + # Running the client should start a server instance + $N_CLI_status = $N_CLI->SpawnWaitKill ($n_cli->ProcessStartWaitInterval()+5); + if ($N_CLI_status != 0) { + print STDERR "ERROR: Nestea Client 1 returned $N_CLI_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($n_cli->WaitForFileTimed ($nesteaiorfile,$a_cli->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$a_cli_nesteaiorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $a_cli->DeleteFile ($nesteaiorfile); + + $N_CLI->Arguments("-s -k corbaloc::$imr_host:8888/nestea_server"); + + # Running the client again should start another server instance + $N_CLI_status = $N_CLI->SpawnWaitKill ($n_cli->ProcessStartWaitInterval()+5); + if ($N_CLI_status != 0) { + print STDERR "ERROR: Nestea Client 1 returned $N_CLI_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($n_cli->WaitForFileTimed ($nesteaiorfile,$a_cli->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$a_cli_nesteaiorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + # Note : We have to wait long enough for the first server to self-destruct + # or it will print out an exception when it can't notify the imr of its shutdown. + sleep 20; + + $ACT_status = $ACT->TerminateWaitKill ($act->ProcessStopWaitInterval()); + if ($ACT_status != 0) { + print STDERR "ERROR: Activator returned $ACT_status\n"; + $status = 1; + } + + $IMR_status = $IMR->TerminateWaitKill ($imr->ProcessStopWaitInterval()); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR returned $IMR_status\n"; + $status = 1; + } + + $imr->DeleteFile ($imriorfile); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $imr->DeleteFile ($nesteaiorfile); + $n_cli->DeleteFile ($nesteaiorfile); + + return $status; +} + +############################################################################### + +sub shutdown_repo +{ + my $status = 0; + + my $testrepo = "test.repo"; + + my $imr_imriorfile = $imr->LocalFile ($imriorfile); + my $act_imriorfile = $act->LocalFile ($imriorfile); + my $ti_imriorfile = $ti->LocalFile ($imriorfile); + my $act_actiorfile = $act->LocalFile ($actiorfile); + my $imr_testrepo = $imr->LocalFile ($testrepo); + $imr->DeleteFile ($imriorfile); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $imr->DeleteFile ($testrepo); + + # Specify an endpoint so that we can restart on the same port. + # Specify persistence so that we can test that shutdown-repo -a works after reconnect + $IMR->Arguments ("-p $imr_testrepo -d 1 -orbendpoint iiop://:8888 -o $imr_imriorfile $refstyle ". + "-ORBDebugLevel $debug_level"); + $IMR_status = $IMR->Spawn (); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR Service returned $IMR_status\n"; + return 1; + } + if ($imr->WaitForFileTimed ($imriorfile,$imr->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($imr->GetFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($act->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$act_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($ti->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$ti_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $ACT->Arguments ("-d 1 -o $act_actiorfile ". + "-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$act_imriorfile"); + $ACT_status = $ACT->Spawn (); + if ($ACT_status != 0) { + print STDERR "ERROR: ImR Activator returned $ACT_status\n"; + return 1; + } + if ($act->WaitForFileTimed ($actiorfile,$act->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$act_actiorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + # Kill the ImR, but leave the activator running + $TI->Arguments ("-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "shutdown-repo"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $IMR_status = $IMR->WaitKill ($imr->ProcessStopWaitInterval()); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR returned $IMR_status\n"; + return 1; + } + + $imr->DeleteFile ($imriorfile); + + $IMR_status = $IMR->Spawn (); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR Service returned $IMR_status\n"; + return 1; + } + if ($imr->WaitForFileTimed ($imriorfile,$imr->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($imr->GetFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($ti->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$ti_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $TI->Arguments ("-orbobjrefstyle URL -ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "shutdown-repo -a"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $status = 1; + } + + $ACT_status = $ACT->TerminateWaitKill ($act->ProcessStopWaitInterval()); + if ($ACT_status != 0) { + print STDERR "ERROR: Activator returned $ACT_status\n"; + $status = 1; + } + + $IMR_status = $IMR->TerminateWaitKill ($imr->ProcessStopWaitInterval()); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR returned $IMR_status\n"; + $status = 1; + } + + $imr->DeleteFile ($imriorfile); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $imr->DeleteFile ($testrepo); + + return $status; +} + +############################################################################### + +sub persistent_ir_test +{ + my $status = 0; + + my $imr_imriorfile = $imr->LocalFile ($imriorfile); + my $imr_storefile = $imr->LocalFile ($backing_store); + my $act_imriorfile = $act->LocalFile ($imriorfile); + my $ti_imriorfile = $ti->LocalFile ($imriorfile); + my $a_srv_imriorfile = $a_srv->LocalFile ($imriorfile); + my $act_actiorfile = $act->LocalFile ($actiorfile); + my $imr_airplaneiorfile = $imr->LocalFile ($airplaneiorfile); + my $a_srv_airplaneiorfile = $a_srv->LocalFile ($airplaneiorfile); + $imr->DeleteFile ($imriorfile); + $imr->DeleteFile ($backing_store); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $a_srv->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $imr->DeleteFile ($airplaneiorfile); + $a_srv->DeleteFile ($airplaneiorfile); + $a_cli->DeleteFile ($airplaneiorfile); + + ## Be sure to start the ImR on a consistent endpoint, so that any created IORs + ## remain valid even if the ImR restarts. + $IMR->Arguments ("-orbendpoint iiop://:8888 -x $imr_storefile -d 2 -o $imr_imriorfile $refstyle"); + $IMR_status = $IMR->Spawn (); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR Service returned $IMR_status\n"; + return 1; + } + if ($imr->WaitForFileTimed ($imriorfile,$imr->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($imr->GetFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($act->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$act_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($ti->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$ti_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($a_srv->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$a_srv_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $ACT->Arguments ("-d 2 -o $act_actiorfile -ORBInitRef ImplRepoService=file://$act_imriorfile"); + $ACT_status = $ACT->Spawn (); + if ($ACT_status != 0) { + print STDERR "ERROR: ImR Activator returned $ACT_status\n"; + return 1; + } + if ($act->WaitForFileTimed ($actiorfile,$act->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$act_actiorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($act->GetFile ($actiorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$act_actiorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $p_srv->DeleteFile ($P_SRV_cmd); + # Copy the server to a path with spaces to ensure that these + # work corrrectly. + copy ($A_SRV_cmd, $P_SRV_cmd); + chmod(0755, $P_SRV_cmd); + + # No need to specify imr_initref or -orbuseimr 1 for servers spawned by activator + $TI->Arguments ("-ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "add airplane_server -c \"\\\"$imr_P_SRV_cmd\\\" $refstyle\""); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $p_srv->DeleteFile ($P_SRV_cmd); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + ## This will write out the imr-ified IOR. Note : If you don't use -orbendpoint + ## when starting the ImR, then this IOR will no longer be valid when the ImR + ## restarts below. You can fix this by creating a new valid IOR, or starting + ## the ImR on a consistent endpoint. + $A_SRV->Arguments ("-o $a_srv_airplaneiorfile -ORBUseIMR 1 $refstyle ". + "-ORBInitRef ImplRepoService=file://$a_srv_imriorfile ". + "-ORBDebugLevel $debug_level"); + $A_SRV_status = $A_SRV->Spawn (); + if ($A_SRV_status != 0) { + print STDERR "ERROR: Airplane Server returned $A_SRV_status\n"; + return 1; + } + if ($a_srv->WaitForFileTimed ($airplaneiorfile,$a_srv->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$a_srv_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($a_srv->GetFile ($airplaneiorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$a_srv_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($a_cli->PutFile ($airplaneiorfile) == -1) { + print STDERR "ERROR: cannot set file <$a_cli_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $A_CLI_status = $A_CLI->SpawnWaitKill ($a_cli->ProcessStartWaitInterval()); + if ($A_CLI_status != 0) { + print STDERR "ERROR: Airplane Client returned $A_CLI_status\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $TI->Arguments ("-ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "shutdown airplane_server"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr shutdown returned $TI_status\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $A_SRV_status = $A_SRV->WaitKill ($a_srv->ProcessStartWaitInterval()); + if ($A_SRV_status != 0) { + print STDERR "ERROR: Airplane Server returned $A_SRV_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + # Should cause the activator to spawn another server. + $A_CLI_status = $A_CLI->SpawnWaitKill ($a_cli->ProcessStartWaitInterval()); + if ($A_CLI_status != 0) { + print STDERR "ERROR: Airplane Client 2 returned $A_CLI_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + # Shutdown airplane_server + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr shutdown 2 returned $TI_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $IMR_status = $IMR->TerminateWaitKill ($imr->ProcessStopWaitInterval()); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR returned $IMR_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + return 1; + } + + # Unlink so that we can wait on them again to know the server started. + $imr->DeleteFile ($imriorfile); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $a_srv->DeleteFile ($imriorfile); + print "Restarting Implementation Repository.\n"; + $IMR_status = $IMR->Spawn (); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR Service returned $IMR_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + return 1; + } + if ($imr->WaitForFileTimed ($imriorfile,$imr->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$imr_imriorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($imr->GetFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$imr_imriorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($act->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$act_imriorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($ti->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$ti_imriorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($a_srv->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$a_srv_imriorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + # Should cause the activator to spawn another server. + $A_CLI_status = $A_CLI->SpawnWaitKill ($a_cli->ProcessStartWaitInterval()+5); + if ($A_CLI_status != 0) { + print STDERR "ERROR: Airplane Client 3 returned $A_CLI_status\n"; + $status = 1; + } + + # Shutdown airplane_server + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr shutdown 3 returned $TI_status\n"; + $status = 1; + } + + $ACT_status = $ACT->TerminateWaitKill ($act->ProcessStopWaitInterval()); + if ($ACT_status != 0) { + print STDERR "ERROR: Activator returned $ACT_status\n"; + $status = 1; + } + + $IMR_status = $IMR->TerminateWaitKill ($imr->ProcessStopWaitInterval()); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR returned $IMR_status\n"; + $status = 1; + } + + $imr->DeleteFile ($imriorfile); + $imr->DeleteFile ($backing_store); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $a_srv->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $imr->DeleteFile ($airplaneiorfile); + $a_srv->DeleteFile ($airplaneiorfile); + $a_cli->DeleteFile ($airplaneiorfile); + $p_srv->DeleteFile ($P_SRV_cmd); + + return $status; +} + +############################################################################### + +sub both_ir_test +{ + my $status = 0; + + my $imr_imriorfile = $imr->LocalFile ($imriorfile); + my $act_imriorfile = $act->LocalFile ($imriorfile); + my $ti_imriorfile = $ti->LocalFile ($imriorfile); + my $a_srv_imriorfile = $a_srv->LocalFile ($imriorfile); + my $n_srv_imriorfile = $n_srv->LocalFile ($imriorfile); + my $act_actiorfile = $act->LocalFile ($actiorfile); + my $a_srv_airplaneiorfile = $a_srv->LocalFile ($airplaneiorfile); + my $n_srv_nesteaiorfile = $n_srv->LocalFile ($nesteaiorfile); + my $n_cli_nesteaiorfile = $n_cli->LocalFile ($nesteaiorfile); + $imr->DeleteFile ($imriorfile); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $a_srv->DeleteFile ($imriorfile); + $n_srv->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $a_srv->DeleteFile ($airplaneiorfile); + $a_cli->DeleteFile ($airplaneiorfile); + $n_srv->DeleteFile ($nesteaiorfile); + $n_cli->DeleteFile ($nesteaiorfile); + + $IMR->Arguments ("-d 2 -t 10 -o $imr_imriorfile $refstyle"); + $IMR_status = $IMR->Spawn (); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR Service returned $IMR_status\n"; + return 1; + } + if ($imr->WaitForFileTimed ($imriorfile,$imr->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($imr->GetFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$imr_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($act->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$act_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($ti->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$ti_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($a_srv->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$a_srv_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($n_srv->PutFile ($imriorfile) == -1) { + print STDERR "ERROR: cannot set file <$n_srv_imriorfile>\n"; + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $ACT->Arguments ("-e 16384 -o $act_actiorfile ". + "-ORBInitRef ImplRepoService=file://$act_imriorfile ". + "$refstyle -d 2"); + $ACT_status = $ACT->Spawn (); + if ($ACT_status != 0) { + print STDERR "ERROR: ImR Activator returned $ACT_status\n"; + return 1; + } + if ($act->WaitForFileTimed ($actiorfile,$act->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$act_actiorfile>\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + ## Note : It's crucial NOT to write out an IOR file when the activator + ## starts the server, or at least to write out a different file name + ## than the IOR files we're using for the clients. Otherwise a client + ## may attempt to use a partially written file. + # No need to specify imr_initref or -orbuseimr 1 for servers spawned by activator + $TI->Arguments ("-ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "add nestea_server -c \"$imr_N_SRV_cmd $refstyle\""); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + # No need to specify imr_initref or -orbuseimr 1 for servers spawned by activator + $TI->Arguments ("-ORBInitRef ImplRepoService=file://$ti_imriorfile ". + "add airplane_server -c \"$imr_A_SRV_cmd $refstyle\""); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $N_SRV->Arguments (" -o $n_srv_nesteaiorfile -ORBUseIMR 1 ". + "-ORBInitRef ImplRepoService=file://$n_srv_imriorfile ". + "$refstyle ". + "-ORBDebugLevel $debug_level"); + $N_SRV_status = $N_SRV->Spawn (); + if ($N_SRV_status != 0) { + print STDERR "ERROR: Nestea Server returned $N_SRV_status\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($n_srv->WaitForFileTimed ($nesteaiorfile,$n_srv->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$n_srv_nesteaiorfile>\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($n_srv->GetFile ($nesteaiorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$n_srv_nesteaiorfile>\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($n_cli->PutFile ($nesteaiorfile) == -1) { + print STDERR "ERROR: cannot set file <$n_cli_nesteaiorfile>\n"; + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + $A_SRV->Arguments (" -o $a_srv_airplaneiorfile -ORBUseIMR 1 ". + "-ORBInitRef ImplRepoService=file://$n_srv_imriorfile ". + "$refstyle ". + "-ORBDebugLevel $debug_level"); + $A_SRV_status = $A_SRV->Spawn (); + if ($A_SRV_status != 0) { + print STDERR "ERROR: Airplane Server returned $A_SRV_status\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($a_srv->WaitForFileTimed ($airplaneiorfile,$a_srv->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$a_srv_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($a_srv->GetFile ($airplaneiorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$a_srv_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + if ($a_cli->PutFile ($airplaneiorfile) == -1) { + print STDERR "ERROR: cannot set file <$a_cli_airplaneiorfile>\n"; + $A_SRV->Kill (); $A_SRV->TimedWait (1); + $N_SRV->Kill (); $N_SRV->TimedWait (1); + $ACT->Kill (); $ACT->TimedWait (1); + $IMR->Kill (); $IMR->TimedWait (1); + return 1; + } + + my @a_clients; + my @n_clients; + + for (1 .. 5) { + push @a_clients, &create_acli(); + push @n_clients, &create_ncli(); + } + + print "\n## Spawning multiple simultaneous clients with both servers running.\n"; + map $_->Spawn(), @a_clients; + map $_->Spawn(), @n_clients; + map $_->WaitKill($a_cli->ProcessStopWaitInterval()), @a_clients; + map $_->WaitKill($n_cli->ProcessStopWaitInterval()), @n_clients; + + $TI->Arguments ("-ORBInitRef ImplRepoService=file://$n_srv_imriorfile ". + "shutdown nestea_server"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $status = 1; + } + + $TI->Arguments ("-ORBInitRef ImplRepoService=file://$n_srv_imriorfile ". + "shutdown airplane_server"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $status = 1; + } + + $A_SRV_status = $A_SRV->WaitKill ($a_srv->ProcessStopWaitInterval()); + if ($A_SRV_status != 0) { + print STDERR "ERROR: Airplane Server returned $A_SRV_status\n"; + $status = 1; + } + $N_SRV_status = $N_SRV->WaitKill ($n_srv->ProcessStopWaitInterval()); + if ($N_SRV_status != 0) { + print STDERR "ERROR: Nestea Server returned $N_SRV_status\n"; + $status = 1; + } + + print "\n\n\n\n## Spawning multiple simultaneous clients with no servers running.\n"; + + map $_->Spawn(), @a_clients; + map $_->Spawn(), @n_clients; + map $_->WaitKill($a_cli->ProcessStopWaitInterval()), @a_clients; + map $_->WaitKill($n_cli->ProcessStopWaitInterval()), @n_clients; + + $TI->Arguments ("-ORBInitRef ImplRepoService=file://$n_srv_imriorfile ". + "shutdown nestea_server"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $status = 1; + } + + $TI->Arguments ("-ORBInitRef ImplRepoService=file://$n_srv_imriorfile ". + "shutdown airplane_server"); + $TI_status = $TI->SpawnWaitKill ($ti->ProcessStartWaitInterval()); + if ($TI_status != 0) { + print STDERR "ERROR: tao_imr returned $TI_status\n"; + $status = 1; + } + + $ACT_status = $ACT->TerminateWaitKill ($act->ProcessStopWaitInterval()); + if ($ACT_status != 0) { + print STDERR "ERROR: Activator returned $ACT_status\n"; + $status = 1; + } + + $IMR_status = $IMR->TerminateWaitKill ($imr->ProcessStopWaitInterval()); + if ($IMR_status != 0) { + print STDERR "ERROR: ImR returned $IMR_status\n"; + $status = 1; + } + + $imr->DeleteFile ($imriorfile); + $act->DeleteFile ($imriorfile); + $ti->DeleteFile ($imriorfile); + $a_srv->DeleteFile ($imriorfile); + $n_srv->DeleteFile ($imriorfile); + $act->DeleteFile ($actiorfile); + $a_srv->DeleteFile ($airplaneiorfile); + $a_cli->DeleteFile ($airplaneiorfile); + $n_srv->DeleteFile ($nesteaiorfile); + $n_cli->DeleteFile ($nesteaiorfile); + + return $status; +} + +############################################################################### +############################################################################### + +# Parse the arguments + +my $ret = 0; + +if ($#ARGV >= 0) { +for (my $i = 0; $i <= $#ARGV; $i++) { + if ($ARGV[$i] eq "-h" || $ARGV[$i] eq "-?") { + print "run_test test\n"; + print "\n"; + print "test -- Runs a specific test:\n"; + print " airplane, airplane_ir, nt_service_ir, ", + "nestea, nestea_ir,\n"; + print " both_ir, persistent_ir\n"; + exit 1; + } + elsif ($ARGV[$i] eq "airplane") { + $ret = airplane_test (); + } + elsif ($ARGV[$i] eq "airplane_ir") { + $ret = airplane_ir_test (); + } + elsif ($ARGV[$i] eq "nt_service_ir") { + $ret = nt_service_test (); + } + elsif ($ARGV[$i] eq "nestea") { + $ret = nestea_test (); + } + elsif ($ARGV[$i] eq "nestea_ir") { + $ret = nestea_ir_test (); + } + elsif ($ARGV[$i] eq "both_ir") { + $ret = both_ir_test (); + } + elsif ($ARGV[$i] eq "persistent_ir") { + $ret = persistent_ir_test (); + } + elsif ($ARGV[$i] eq "perclient") { + $ret = perclient(); + } + elsif ($ARGV[$i] eq "shutdown") { + $ret = shutdown_repo(); + } + else { + print "run_test: Unknown Option: ".$ARGV[$i]."\n"; + } +} +} else { + $ret = both_ir_test(); +} + +exit $ret; |