eval '(exit $?0)' && eval 'exec perl -S $0 ${1+"$@"}'
    & eval 'exec perl -S $0 $argv:q'
    if 0;

# $Id: Messenger_run_test.pl 1435 2008-10-06 22:42:53Z martinezm $
# -*- perl -*-

use Sys::Hostname;

use Env (DDS_ROOT);
use lib "$DDS_ROOT/bin";
use Env (ACE_ROOT);
use lib "$ACE_ROOT/bin";
use DDS_Run_Test;
use CrossSyncDDS;

$| = 1;
my $status = 0;
my $use_svc_config = !new PerlACE::ConfigList->check_config ('STATIC');

my $file_prefix = "$ENV{DDS_ROOT}/DevGuideExamples/DCPS/Messenger";
my $pub_config_file = "$file_prefix/pub.ini";
my $sub_config_file = "$file_prefix/sub.ini";
my $opts = $use_svc_config ? "-ORBSvcConf $file_prefix/tcp.conf" : '';
my $pub_opts = "";
my $sub_opts = "";
my $repo_bit_opt = $opts;

if ($ARGV[0] eq 'udp') {
    $opts .= ($use_svc_config ?
		  " -ORBSvcConf $file_prefix/udp.conf " : '')
	. "-t udp";
    $pub_config_file = "$file_prefix/pub_udp.ini";
    $sub_config_file = "$file_prefix/sub_udp.ini";
}
elsif ($ARGV[0] eq 'mcast') {
    $opts .= ($use_svc_config ?
		  " -ORBSvcConf $file_prefix/mcast.conf " : '')
	. "-t mcast";
    $pub_config_file = "$file_prefix/pub_mcast.ini";
    $sub_config_file = "$file_prefix/sub_mcast.ini";
}
elsif ($ARGV[0] eq 'reliable_mcast') {
    $opts .= ($use_svc_config ?
	      " -ORBSvcConf $file_prefix/reliable_mcast.conf " : '')
        . "-t reliable_mcast";
    $pub_config_file = "$file_prefix/pub_reliable_mcast.ini";
    $sub_config_file = "$file_prefix/sub_reliable_mcast.ini";
}
elsif ($ARGV[0] eq 'default_mcast') {
    $opts .= ($use_svc_config ?
		  " -ORBSvcConf $file_prefix/mcast.conf " : '');
    $pub_opts = "-t default_mcast_pub";
    $sub_opts = "-t default_mcast_sub";
}

$CS = new CrossSyncDDS (1, PerlACE::random_port(), PerlACE::random_port()
			, $pub_config_file, $sub_config_file);
if (!$CS) {
    print "Crossplatform test pre-reqs not met. Skipping...\n";
    exit 0;
}

@test_configs = $CS->get_config_info();
$pub_config_file = @test_configs[0];
$sub_config_file = @test_configs[1];

my $role = $CS->wait();
if ($role == -1) {
    print "ERROR: Test pre-reqs not met.\n";
    exit -1;
}

@ports = $CS->boot_ports ();
my($port1) = 10001 + @ports[0];
my $dcpsrepo_ior = "repo.ior";
my $repo_host;
if ($role == CrossSync::SERVER) {
    $repo_host = $CS->self();
} else {
    $repo_host = $CS->peer();
}
my $common_args = "-DCPSInfoRepo corbaloc:iiop:$repo_host:$port1/DCPSInfoRepo"
    . " $opts";

unlink $dcpsrepo_ior;

$Subscriber = PerlDDS::create_process
      ("$ENV{DDS_ROOT}/DevGuideExamples/DCPS/Messenger/subscriber",
       "-DCPSConfigFile $sub_config_file $common_args $sub_opts");
$Publisher = PerlDDS::create_process
      ("$ENV{DDS_ROOT}/DevGuideExamples/DCPS/Messenger/publisher",
       "-DCPSConfigFile $pub_config_file $common_args $pub_opts");

if ($role == CrossSync::SERVER) {
    unlink $dcpsrepo_ior;
    $DCPSREPO = PerlDDS::create_process
          ("$ENV{DDS_ROOT}/bin/DCPSInfoRepo",
           "$repo_bit_opt -o $dcpsrepo_ior "
           . "-ORBEndpoint iiop://:$port1");

    print $DCPSREPO->CommandLine(). "\n";
    $DCPSREPO->Spawn ();
    if (PerlACE::waitforfile_timed ($dcpsrepo_ior, 30) == -1) {
	print STDERR "ERROR: waiting for DCPSInfo IOR file\n";
	$DCPSREPO->Kill ();
	exit 1;
    }
    unlink $dcpsrepo_ior;

    print $Publisher->CommandLine(). "\n";
    $Publisher->Spawn ();

    if ($CS->ready () == -1) {
	print STDERR "ERROR: subscriber failed to initialize.\n";
	$status = 1;
	$DCPSREPO->Kill ();
	$Publisher->Kill ();
	exit 1;
    }

    $PublisherResult = $Publisher->WaitKill (300);
    if ($PublisherResult != 0) {
	print STDERR "ERROR: publisher returned $PublisherResult \n";
	$status = 1;
    }

    $ir = $DCPSREPO->TerminateWaitKill(5);
    if ($ir != 0) {
	print STDERR "ERROR: DCPSInfoRepo returned $ir\n";
	$status = 1;
    }
} else {
    print $Subscriber->CommandLine(). "\n";
    $Subscriber->Spawn ();

    $SubscriberResult = $Subscriber->WaitKill (15);
    if ($SubscriberResult != 0) {
	print STDERR "ERROR: subscriber returned $SubscriberResult \n";
	$status = 1;
    }
}

if ($status == 0) {
  print "test PASSED.\n";
} else {
  print STDERR "test FAILED.\n";
}

exit $status;

#  LocalWords:  eval