diff options
Diffstat (limited to 'TAO/orbsvcs/tests/Event/Basic/BCast.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/Event/Basic/BCast.cpp | 157 |
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_; -} |