diff options
Diffstat (limited to 'TAO/orbsvcs/tests/FT_Naming/Load_Balancing/run_test.pl')
| -rwxr-xr-x | TAO/orbsvcs/tests/FT_Naming/Load_Balancing/run_test.pl | 229 |
1 files changed, 229 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/FT_Naming/Load_Balancing/run_test.pl b/TAO/orbsvcs/tests/FT_Naming/Load_Balancing/run_test.pl new file mode 100755 index 00000000000..729d20d38aa --- /dev/null +++ b/TAO/orbsvcs/tests/FT_Naming/Load_Balancing/run_test.pl @@ -0,0 +1,229 @@ +eval '(exit $?0)' && eval 'exec perl -S $0 ${1+"$@"}' + & eval 'exec perl -S $0 $argv:q' + if 0; + +# $Id$ +# -*- perl -*- + +# This is a Perl script that runs a Naming Service test. It starts +# all the servers and clients as necessary. + +use lib "$ENV{ACE_ROOT}/bin"; +use PerlACE::TestTarget; +use Cwd; + +$status = 0; +$debug_level = '0'; +$startdir = getcwd(); + +my $test = PerlACE::TestTarget::create_target (1) || die "Create target 1 failed\n"; +my $server2 = PerlACE::TestTarget::create_target (2) || die "Create target 2 failed\n"; +my $client = PerlACE::TestTarget::create_target (3) || die "Create target 3 failed\n"; + + +# Variables for command-line arguments to naming service executables. +$hostname = $test->HostName (); + +$ns_orb_port1 = 10001 + $test->RandomPort (); +$ns_orb_port2 = 10002 + $test->RandomPort (); +$ns_endpoint1 = "iiop://$hostname:$ns_orb_port1"; +$ns_endpoint2 = "iiop://$hostname:$ns_orb_port2"; + +$naming_persistence_dir = "NameService"; +$groups_persistence_dir = "Groups"; + +$primary_iorfile = "$naming_persistence_dir/ns_replica_primary.ior"; +$combined_ns_iorfile = "combined_ns.ior"; +$combined_nm_iorfile = "combined_nm.ior"; + +my $test_combined_ns_iorfile = $test->LocalFile ($combined_ns_iorfile); +my $test_combined_nm_iorfile = $test->LocalFile ($combined_nm_iorfile); +my $test_primary_iorfile = $test->LocalFile ($primary_iorfile); + +my $server_obj_group_iorfile = "obj.ior"; + +#Files used by the server2 +my $server2_nm_iorfile = $server2->LocalFile ($combined_nm_iorfile); +$server2->DeleteFile($server2_nm_iorfile); +my $server2_ns_iorfile = $server2->LocalFile ($combined_ns_iorfile); +$server2->DeleteFile($server2_ns_iorfile); +my $server2_obj_group_iorfile = $server2->LocalFile ($server_obj_group_iorfile); +$server2->DeleteFile($server_obj_group_iorfile); + +#Files which used by client +my $client_ns_iorfile = $client->LocalFile ($combined_ns_iorfile); +$client->DeleteFile($client_ns_iorfile); + +$status = 0; + +print "INFO: Running the test in ", getcwd(), "\n"; + +sub clean_persistence_dir($$) +{ + my $target = shift; + my $directory_name = shift; + + chdir $directory_name; + opendir(THISDIR, "."); + @allfiles = grep(!/^\.\.?$/, readdir(THISDIR)); + closedir(THISDIR); + foreach $tmp (@allfiles){ + $target->DeleteFile ($tmp); + } + chdir ".."; +} + +# Make sure that the directory to use to hold the persistence data +# exists and is cleaned out. +sub init_persistence_directory($$) +{ + my $target = shift; + my $directory_name = shift; + + if ( ! -d $directory_name ) { + mkdir ($directory_name, 0777); + } else { + clean_persistence_dir ($target, $directory_name); + } +} + + +my $args = "-ORBEndPoint $ns_endpoint1 " . + "-m 0 " . + "-r $naming_persistence_dir " . + "-v $groups_persistence_dir " . + "--primary"; +my $prog = "$startdir/../../../Naming_Service/tao_ft_naming"; + +print STDERR "Starting Primary: $prog $args\n"; + +$NS1 = $test->CreateProcess ("$prog", "$args"); + +# Clean out the primary ior file to allow us to wait for it +$test->DeleteFile ($primary_iorfile); + +init_persistence_directory ($test, $naming_persistence_dir); +init_persistence_directory ($test, $groups_persistence_dir); + +$NS1->Spawn (); + +if ($test->WaitForFileTimed ($primary_iorfile, + $test->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$test_primary_iorfile>\n"; + $NS1->Kill (); $NS1->TimedWait (1); + exit 1; +} + +$args = "-ORBEndPoint $ns_endpoint2 " . + "-g $combined_nm_iorfile " . + "-c $combined_ns_iorfile " . + "-m 0 " . + "-r $naming_persistence_dir " . + "-v $groups_persistence_dir " . + "--backup"; + +$prog = "$startdir/../../../Naming_Service/tao_ft_naming"; + +print STDERR "Starting Backup: $prog $args\n"; + +$NS2 = $test->CreateProcess ("$prog", "$args"); + +# clean up the old generated ior files +$test->DeleteFile ($combined_ns_iorfile); +$test->DeleteFile ($combined_nm_iorfile); + +$NS2->Spawn (); + +if ($test->WaitForFileTimed ($combined_ns_iorfile, + $test->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$test_combined_ns_iorfile>\n"; + $NS2->Kill (); $NS2->TimedWait (1); + exit 1; +} + +$SV2 = $server2->CreateProcess ("server", + "-ORBdebuglevel $debug_level " . + "-ORBInitRef NameService=file://$server2_ns_iorfile " . + "-ORBInitRef NamingManager=file://$server2_nm_iorfile " . + "-o $server2_obj_group_iorfile"); + +$CL = $client->CreateProcess ("client", + "-ORBInitRef NameService=file://$client_ns_iorfile"); + +print STDERR "\n\n======== Running Application Controlled Membership Test================\n"; +print STDERR "\n"; + +print STDERR "This test uses the RoundRobin Load Balancing strategy \n"; + +print STDERR "6 servers are created and added into a Object Group\n"; + +print STDERR "When the client accesses an object group through the naming service, the"; +print STDERR "FT_Naming_Service will apply the RoundRobin load balancing strategy\n"; +print STDERR "selects one of the servers and then the client makes an invocations on\n"; +print STDERR "the server. This is done 15 times to ensure we support the wraparround\n"; +print STDERR "condition. When done, the application has to delete the object from the\n"; +print STDERR "object group. This is called the application controlled membership of\n"; +print STDERR "object group.\n"; +print STDERR "\n"; + +$server_status = $SV2->Spawn (); + +if ($server_status != 0) { + print STDERR "ERROR: server returned $server_status\n"; + exit 1; +} + +sub KillServers{ + $SV1->Kill (); $SV1->TimedWait (1); + $SV2->Kill (); $SV2->TimedWait (1); +} + +if ($server2->WaitForFileTimed ($server_obj_group_iorfile, + $server2->ProcessStartWaitInterval()) == -1) { + print STDERR "ERROR: cannot find file <$server2_obj_group_iorfile>\n"; + KillServers (); + exit 1; +} + +if ($server2->GetFile ($server_obj_group_iorfile) == -1) { + print STDERR "ERROR: cannot retrieve file <$server2_obj_group_iorfile>\n"; + KillServers (); + exit 1; +} + +if ($client->PutFile ($server_obj_group_iorfile) == -1) { + print STDERR "ERROR: cannot set file <$client_ns_iorfile>\n"; + KillServers (); + exit 1; +} + +$client_status = $CL->SpawnWaitKill ($client->ProcessStartWaitInterval() + 85); + +if ($client_status != 0) { + print STDERR "ERROR: client returned $client_status\n"; + $status = 1; +} + +$server_status = $SV2->WaitKill ($server2->ProcessStopWaitInterval()); + +if ($server_status != 0) { + print STDERR "ERROR: server returned $server_status\n"; + $status = 1; +} + +$server2->DeleteFile($nm_iorfile); +$server2->DeleteFile($server_obj_group_iorfile); +$client->DeleteFile($server_obj_group_iorfile); + +$NS1->Kill (); +$NS2->Kill (); + +$test->DeleteFile ($primary_iorfile); +$test->DeleteFile ($combined_ns_iorfile); + +clean_persistence_dir ($test, $naming_persistence_dir); +clean_persistence_dir ($test, $groups_persistence_dir); +rmdir ($naming_persistence_dir); +rmdir ($groups_persistence_dir); + +exit $status; |