diff options
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Latency/control.cpp')
| -rw-r--r-- | TAO/orbsvcs/tests/AVStreams/Latency/control.cpp | 190 |
1 files changed, 0 insertions, 190 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Latency/control.cpp b/TAO/orbsvcs/tests/AVStreams/Latency/control.cpp deleted file mode 100644 index 0cec49350d2..00000000000 --- a/TAO/orbsvcs/tests/AVStreams/Latency/control.cpp +++ /dev/null @@ -1,190 +0,0 @@ -// $Id$ - -#include "orbsvcs/AV/AVStreams_i.h" -#include "orbsvcs/AV/FlowSpec_Entry.h" -#include "tao/TAO.h" -#include "ace/Get_Opt.h" -#include "ace/INET_Addr.h" - -ACE_RCSID(Latency, ping, "$Id$") - -const char *ping_ior = "file://ping.ior"; -const char *pong_ior = "file://pong.ior"; -const char *ping_address = "224.9.9.2:12345"; -const char *pong_address = "224.9.9.2:23456"; -const char *protocol = "UDP"; - -int milliseconds = 30000; - -int -parse_args (int argc, char *argv[]) -{ - ACE_Get_Opt get_opts (argc, argv, "f:g:s:r:t:p:"); - int c; - - while ((c = get_opts ()) != -1) - switch (c) - { - case 'f': - ping_ior = get_opts.optarg; - break; - - case 'g': - pong_ior = get_opts.optarg; - break; - - case 'r': - ping_address = get_opts.optarg; - break; - - case 's': - pong_address = get_opts.optarg; - break; - - case 't': - milliseconds = ACE_OS::atoi (get_opts.optarg); - break; - - case 'p': - protocol = get_opts.optarg; - break; - - case '?': - default: - ACE_ERROR_RETURN ((LM_ERROR, - "usage: %s " - "-f <ping_ior> " - "-g <ping_ior> " - "-s <ping_address> " - "-r <pong_address> " - "-t <milliseconds> " - "-p protocols " - "\n", - argv [0]), - -1); - } - - - // Indicates sucessful parsing of the command line - return 0; -} - -int main (int argc, char *argv[]) -{ - ACE_TRY_NEW_ENV - { - TAO_AV_Core *av_core = TAO_AV_CORE::instance (); - av_core->init (argc, argv, ACE_TRY_ENV); - ACE_TRY_CHECK; - - parse_args (argc, argv); - - TAO_ORB_Manager* orb_manager = - av_core->orb_manager (); - - CORBA::ORB_var orb = orb_manager->orb (); - - CORBA::Object_var poa_object = - orb->resolve_initial_references("RootPOA", ACE_TRY_ENV); - ACE_TRY_CHECK; - - PortableServer::POA_var root_poa = - PortableServer::POA::_narrow (poa_object.in (), ACE_TRY_ENV); - ACE_TRY_CHECK; - - PortableServer::POAManager_var poa_manager = - root_poa->the_POAManager (ACE_TRY_ENV); - ACE_TRY_CHECK; - - poa_manager->activate (ACE_TRY_ENV); - ACE_TRY_CHECK; - - // Connect the two streams and run them... - AVStreams::flowSpec flow_spec (2); - flow_spec.length (2); - - ACE_INET_Addr ping_addr; - ping_addr.set (ping_address); - TAO_Forward_FlowSpec_Entry ping ("Ping", - "IN", - "UNS:ping", - "", - protocol, - &ping_addr); - flow_spec[0] = CORBA::string_dup (ping.entry_to_string ()); - - ACE_INET_Addr pong_addr; - pong_addr.set (pong_address); - TAO_Forward_FlowSpec_Entry pong ("Pong", - "OUT", - "UNS:pong", - "", - protocol, - &pong_addr); - flow_spec[1] = CORBA::string_dup (pong.entry_to_string ()); - - TAO_StreamCtrl stream_control_impl; - - AVStreams::StreamCtrl_var stream_control = - stream_control_impl._this (ACE_TRY_ENV); - ACE_TRY_CHECK; - - CORBA::Object_var obj = - orb->string_to_object (ping_ior, ACE_TRY_ENV); - ACE_TRY_CHECK; - AVStreams::MMDevice_var ping_sender = - AVStreams::MMDevice::_narrow (obj.in (), ACE_TRY_ENV); - ACE_TRY_CHECK; - - obj = - orb->string_to_object (pong_ior, ACE_TRY_ENV); - ACE_TRY_CHECK; - AVStreams::MMDevice_var pong_sender = - AVStreams::MMDevice::_narrow (obj.in (), ACE_TRY_ENV); - ACE_TRY_CHECK; - - AVStreams::streamQoS_var the_qos = - new AVStreams::streamQoS; - - stream_control->bind_devs (pong_sender.in (), - ping_sender.in (), - the_qos.inout (), - flow_spec, - ACE_TRY_ENV); - ACE_TRY_CHECK; - - flow_spec.length (0); - stream_control->start (flow_spec, ACE_TRY_ENV); - ACE_TRY_CHECK; - - ACE_Time_Value tv (0, milliseconds * 1000); - if (orb->run (tv) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "orb->run"), -1); - ACE_DEBUG ((LM_DEBUG, "event loop finished\n")); - - flow_spec.length (0); - stream_control->stop (flow_spec, ACE_TRY_ENV); - ACE_TRY_CHECK; - - // root_poa->destroy (1, 1, ACE_TRY_ENV); - // ACE_TRY_CHECK; - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, - "Catched exception:"); - return 1; - } - ACE_ENDTRY; - - return 0; -} - -// **************************************************************** - -// @@ TODO -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) - -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) - -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |