*** empty log message ***

1 files changed, 28 insertions, 5 deletions

diff --git a/TAO/orbsvcs/tests/AVStreams/Simple_Two_Stage/sender.cpp b/TAO/orbsvcs/tests/AVStreams/Simple_Two_Stage/sender.cpp
index 234d7ac3c20..90f32320755 100644
--- a/TAO/orbsvcs/tests/AVStreams/Simple_Two_Stage/sender.cpp
+++ b/TAO/orbsvcs/tests/AVStreams/Simple_Two_Stage/sender.cpp
@@ -1,3 +1,4 @@
+
 // $Id$
 
 #include "sender.h"
@@ -34,9 +35,11 @@ Sender::Sender (void)
     frame_count_ (0),
     filename_ ("input"),
     input_file_ (0),
-    protocol_ ("UDP"),
+    protocol_ ("QoS_UDP"),
     frame_rate_ (30.0),
-    mb_ (BUFSIZ)
+    mb_ (BUFSIZ),
+    src_addr_ (0),
+    dest_addr_ (0)
 {
 }
 
@@ -53,7 +56,7 @@ Sender::parse_args (int argc,
                     char **argv)
 {
   // Parse command line arguments
-  ACE_Get_Opt opts (argc, argv, "f:p:r:d");
+  ACE_Get_Opt opts (argc, argv, "f:p:r:s:d:v");
 
   int c;
   while ((c= opts ()) != -1)
@@ -69,7 +72,17 @@ Sender::parse_args (int argc,
         case 'r':
           this->frame_rate_ = (double)ACE_OS::atoi (opts.opt_arg ());
           break;
-        case 'd':
+	case 's':
+	  ACE_NEW_RETURN (this->src_addr_,
+			  ACE_INET_Addr (opts.opt_arg ()),
+			  0);
+	  break;
+	case 'd':
+	  ACE_NEW_RETURN (this->dest_addr_,
+			  ACE_INET_Addr (opts.opt_arg ()),
+			  0);
+	  break;
+        case 'v':
           TAO_debug_level++;
           break;
         default:
@@ -160,13 +173,17 @@ Sender::init (int argc,
   // Initialize the  QoS
   AVStreams::streamQoS_var the_qos (new AVStreams::streamQoS);
 
+
   // Create the forward flow specification to describe the flow.
   TAO_Forward_FlowSpec_Entry entry ("Data_Receiver",
                                     "IN",
                                     "USER_DEFINED",
                                     "",
                                     this->protocol_.c_str (),
-                                    0);
+                                    this->src_addr_);
+  
+  if (this->dest_addr_ != 0)
+    entry.set_peer_addr (this->dest_addr_);
 
   AVStreams::flowSpec flow_spec (1);
   flow_spec.length (1);
@@ -401,6 +418,12 @@ main (int argc,
   return 0;
 }
 
+Sender::~Sender (void)
+{
+  delete this->src_addr_;
+  delete this->dest_addr_;
+}
+
 #if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
 template class ACE_Singleton <Sender,ACE_Null_Mutex>;
 template class TAO_AV_Endpoint_Reactive_Strategy_A<Sender_StreamEndPoint,TAO_VDev,AV_Null_MediaCtrl>;