summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Event/Basic/BCast.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Event/Basic/BCast.cpp')
-rw-r--r--TAO/orbsvcs/tests/Event/Basic/BCast.cpp157
1 files changed, 0 insertions, 157 deletions
diff --git a/TAO/orbsvcs/tests/Event/Basic/BCast.cpp b/TAO/orbsvcs/tests/Event/Basic/BCast.cpp
deleted file mode 100644
index 93e068b6d84..00000000000
--- a/TAO/orbsvcs/tests/Event/Basic/BCast.cpp
+++ /dev/null
@@ -1,157 +0,0 @@
-// $Id$
-
-#include "BCast.h"
-#include "Consumer.h"
-#include "Supplier.h"
-#include "orbsvcs/Event/ECG_Mcast_Gateway.h"
-#include "tao/ORB_Core.h"
-#include "ace/Arg_Shifter.h"
-#include "ace/INET_Addr.h"
-
-ACE_RCSID (EC_Tests_Basic,
- BCast,
- "$Id$")
-
-int
-main (int argc, char *argv [])
-{
- EC_BCast driver;
- return driver.run (argc, argv);
-}
-
-// ****************************************************************
-
-EC_BCast::EC_BCast (void)
- : bcast_address_ ("255.255.255.255"),
- bcast_port_ (12345)
-{
-}
-
-int
-EC_BCast::parse_args (int& argc, char* argv[])
-{
- if (this->EC_Driver::parse_args (argc, argv) != 0)
- return -1;
-
- ACE_Arg_Shifter arg_shifter (argc, argv);
-
- while (arg_shifter.is_anything_left ())
- {
- const char *arg = arg_shifter.get_current ();
-
- if (ACE_OS::strcmp (arg, "-port") == 0)
- {
- arg_shifter.consume_arg ();
- this->bcast_port_ = ACE_OS::atoi (arg_shifter.get_current ());
- }
-
- else if (ACE_OS::strcmp (arg, "-address") == 0)
- {
- arg_shifter.consume_arg ();
- this->bcast_address_ = arg_shifter.get_current ();
- }
-
- arg_shifter.ignore_arg ();
- }
-
- return 0;
-}
-
-void
-EC_BCast::print_args (void) const
-{
- this->EC_Driver::print_args ();
-}
-
-void
-EC_BCast::print_usage (void)
-{
- this->EC_Driver::print_usage ();
-}
-
-void
-EC_BCast::modify_attributes (TAO_EC_Event_Channel_Attributes&)
-{
-}
-
-void
-EC_BCast::execute_test (ACE_ENV_SINGLE_ARG_DECL)
-{
- // Subscription determining which EC events will get sent out on the
- // UDP socket.
- RtecEventChannelAdmin::ConsumerQOS sub;
- int shutdown_event_type;
- this->build_consumer_qos (0, sub, shutdown_event_type ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- // Obtain UDP address in the string format for Gateway initialization.
- char address_server_arg [256];
- ACE_INET_Addr udp_addr;
- if (udp_addr.set (this->bcast_port_, this->bcast_address_) == -1
- || udp_addr.addr_to_string (address_server_arg, 256) == -1)
- {
- ACE_ERROR ((LM_ERROR,
- "%N (%l): Problems with specified UDP address\n"));
- return;
- }
-
- // Set up UDP federation.
- TAO_ECG_Mcast_Gateway::Attributes lAttributes;
- lAttributes.address_server_type = TAO_ECG_Mcast_Gateway::ECG_ADDRESS_SERVER_BASIC;
- lAttributes.handler_type = TAO_ECG_Mcast_Gateway::ECG_HANDLER_UDP;
- lAttributes.service_type = TAO_ECG_Mcast_Gateway::ECG_MCAST_TWO_WAY;
-
- TAO_ECG_Mcast_Gateway gateway;
- if (gateway.init (sub,
- address_server_arg,
- lAttributes)
- == -1)
- return;
-
- gateway.run (this->orb_.in (),
- this->event_channel_.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- if (this->allocate_tasks () == -1)
- return;
-
- this->activate_tasks (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- if (this->verbose ())
- ACE_DEBUG ((LM_DEBUG, "BCast (%P|%t) suppliers are active\n"));
-
- ACE_Time_Value tv (30, 0);
- this->orb_->run (tv);
-
- // Wait for the supplier threads...
- if (ACE_Thread_Manager::instance ()->wait () == -1)
- {
- ACE_ERROR ((LM_ERROR, "BCast (%P|%t) Thread_Manager wait failed\n"));
- }
-}
-
-void
-EC_BCast::dump_results (void)
-{
- this->EC_Driver::dump_results ();
-}
-
-// ****************************************************************
-
-Simple_Address_Server::
-Simple_Address_Server (const ACE_INET_Addr& address)
-{
- this->address_.ipaddr = address.get_ip_address ();
- this->address_.port = address.get_port_number ();
-}
-
-void
-Simple_Address_Server::get_addr (const RtecEventComm::EventHeader&,
- RtecUDPAdmin::UDP_Addr& address
- ACE_ENV_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
- address = this->address_;
-}