1 files changed, 26 insertions, 2 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Bidirectional_Flows/run_test.pl b/TAO/orbsvcs/tests/AVStreams/Bidirectional_Flows/run_test.pl
index e5b712073f8..482b8444379 100755
--- a/TAO/orbsvcs/tests/AVStreams/Bidirectional_Flows/run_test.pl
+++ b/TAO/orbsvcs/tests/AVStreams/Bidirectional_Flows/run_test.pl
@@ -7,6 +7,7 @@ eval '(exit $?0)' && eval 'exec perl -S $0 ${1+"$@"}'
 
 use lib $ENV{"ACE_ROOT"}.'/bin';
 use PerlACE::Run_Test;
+use File::stat;
 
 # amount of delay between running the servers
 
@@ -16,11 +17,34 @@ $status = 0;
 $nsior = PerlACE::LocalFile ("ns.ior");
 $outfile = PerlACE::LocalFile ("output");
 
+# generate test stream data
+$input = "test_input";
+while ( -e $input ) {
+    $input = $input."X";
+}
+open( INPUT, "> $input" ) || die( "can't create input file: $input" );
+for($i =0; $i < 1000 ; $i++ ) {
+    print INPUT <<EOFINPUT;
+0123456789
+0123456789
+0123456789
+0123456789
+0123456789
+0123456789
+0123456789
+0123456789
+0123456789
+0123456789
+EOFINPUT
+}
+close(INPUT);
+
+
 unlink $nsior;
 
 $NS = new PerlACE::Process ($ENV{"TAO_ROOT"}."/orbsvcs/Naming_Service/Naming_Service", "-o $nsior");
 $SV = new PerlACE::Process ("receiver", "-ORBInitRef NameService=file://$nsior -f output");
-$CL = new PerlACE::Process ("sender", "-ORBInitRef NameService=file://$nsior -f input -r 2");
+$CL = new PerlACE::Process ("sender", "-ORBInitRef NameService=file://$nsior -f $input -r 2");
 
 print STDERR "Starting Naming Service\n";
 
@@ -62,6 +86,6 @@ if ($nserver != 0) {
 }
 
 unlink $nsior;
-unlink $output;
+unlink $output, $input;
 
 exit $status;