diff options
Diffstat (limited to 'TAO/orbsvcs/examples/RtEC/UDP/Supplier.cpp')
-rw-r--r-- | TAO/orbsvcs/examples/RtEC/UDP/Supplier.cpp | 108 |
1 files changed, 0 insertions, 108 deletions
diff --git a/TAO/orbsvcs/examples/RtEC/UDP/Supplier.cpp b/TAO/orbsvcs/examples/RtEC/UDP/Supplier.cpp deleted file mode 100644 index b12ce21200e..00000000000 --- a/TAO/orbsvcs/examples/RtEC/UDP/Supplier.cpp +++ /dev/null @@ -1,108 +0,0 @@ -// $Id$ - -#include "Supplier.h" -#include "orbsvcs/RtecEventChannelAdminS.h" -#include "orbsvcs/Event_Service_Constants.h" - -#include "TestC.h" - -ACE_RCSID (EC_Examples, - Supplier, - "$Id$") - -Supplier::Supplier (bool valuetype) : valuetype_ (valuetype) -{ -} - -void -Supplier::connect (RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin - ACE_ENV_ARG_DECL) -{ - this->proxy_ = - supplier_admin->obtain_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - RtecEventComm::PushSupplier_var me = - this->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - // Simple publication, but usually the helper classes in - // $TAO_ROOT/orbsvcs/Event_Utils.h are a better way to do this. - RtecEventChannelAdmin::SupplierQOS qos; - qos.is_gateway = 0; - - qos.publications.length (1); - RtecEventComm::EventHeader& h0 = - qos.publications[0].event.header; - h0.type = ACE_ES_EVENT_UNDEFINED; // first free event type - h0.source = 1; // first free event source - - this->proxy_->connect_push_supplier (me.in (), qos - ACE_ENV_ARG_PARAMETER); - ACE_CHECK; -} - -void -Supplier::disconnect (ACE_ENV_SINGLE_ARG_DECL) -{ - // Disconnect from the EC - ACE_TRY - { - this->proxy_->disconnect_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - } - ACE_CATCHANY - { - } - ACE_ENDTRY; - - PortableServer::POA_var poa = - this->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - PortableServer::ObjectId_var id = - poa->servant_to_id (this ACE_ENV_ARG_PARAMETER); - ACE_CHECK; - poa->deactivate_object (id.in () ACE_ENV_ARG_PARAMETER); - ACE_CHECK; -} - -void -Supplier::perform_push (ACE_ENV_SINGLE_ARG_DECL) -{ - ACE_TRY - { - // The event type and source must match our publications - RtecEventComm::EventSet event (1); - event.length (1); - event[0].header.type = ACE_ES_EVENT_UNDEFINED; - event[0].header.source = 1; - // Avoid loops throught the event channel federations - event[0].header.ttl = 1; - - if (this->valuetype_) - { - OBV_ValueTypeData * test_data = 0; - ACE_NEW (test_data, OBV_ValueTypeData ()); - test_data->data ("ACE/TAO/CIAO"); - event[0].data.any_value <<= test_data; - } - else - { - event[0].data.any_value <<= CORBA::string_dup( "ACE/TAO/CIAO"); - } - - this->proxy_->push (event ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - } - ACE_CATCHANY - { - } - ACE_ENDTRY; -} - -void -Supplier::disconnect_push_supplier (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ -} - |