diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Log/RTEventLogNotification.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Log/RTEventLogNotification.cpp | 90 |
1 files changed, 0 insertions, 90 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Log/RTEventLogNotification.cpp b/TAO/orbsvcs/orbsvcs/Log/RTEventLogNotification.cpp deleted file mode 100644 index d3ceeb987e8..00000000000 --- a/TAO/orbsvcs/orbsvcs/Log/RTEventLogNotification.cpp +++ /dev/null @@ -1,90 +0,0 @@ -#include "orbsvcs/Log/LogNotification.h" -#include "orbsvcs/Log/RTEventLogNotification.h" -#include "orbsvcs/Time_Utilities.h" -#include "tao/debug.h" -#include "orbsvcs/Event_Utilities.h" -#include "orbsvcs/RtecEventChannelAdminC.h" -#include "orbsvcs/Event_Service_Constants.h" -#include "orbsvcs/ESF/ESF_Peer_Workers.h" -#include "orbsvcs/ESF/ESF_Peer_Admin.h" -#include "orbsvcs/ESF/ESF_Shutdown_Proxy.h" -#include "orbsvcs/Event/EC_ProxySupplier.h" -#include "orbsvcs/Event/EC_Dispatching.h" -#include "orbsvcs/Event/EC_Filter_Builder.h" -#include "orbsvcs/Event/EC_QOS_Info.h" -#include "orbsvcs/Event/EC_Event_Channel.h" -#include "orbsvcs/Event/EC_Scheduling_Strategy.h" -#include "orbsvcs/Event/EC_ConsumerControl.h" -#include "orbsvcs/ESF/ESF_RefCount_Guard.h" -#include "orbsvcs/ESF/ESF_Proxy_RefCount_Guard.h" - -ACE_RCSID (Log, - RTEventLogNotification, - "$Id$") - -TAO_BEGIN_VERSIONED_NAMESPACE_DECL - -TAO_RTEventLogNotification::TAO_RTEventLogNotification ( - RtecEventChannelAdmin::EventChannel_ptr ec) - : TAO_LogNotification (), - event_channel_ (RtecEventChannelAdmin::EventChannel::_duplicate (ec)) -{ - ACE_DECLARE_NEW_CORBA_ENV; - - obtainProxyConsumer (ACE_ENV_SINGLE_ARG_PARAMETER); -} - -TAO_RTEventLogNotification::~TAO_RTEventLogNotification (void) -{ - // No-Op. -} - -void -TAO_RTEventLogNotification::disconnect_push_supplier (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - // No-Op. -} - -void -TAO_RTEventLogNotification::obtainProxyConsumer (ACE_ENV_SINGLE_ARG_DECL) -{ - RtecEventChannelAdmin::SupplierAdmin_var supplier_admin = - event_channel_->for_suppliers(); - - consumer_ = supplier_admin->obtain_push_consumer(); - - RtecEventComm::PushSupplier_var supplier = - this->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - - // 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.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 - - consumer_->connect_push_supplier (supplier.in(), qos); -} - -void -TAO_RTEventLogNotification::send_notification (const CORBA::Any& any) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - RtecEventComm::EventSet event (1); - event.length (1); - event[0].header.type = ACE_ES_EVENT_UNDEFINED; - event[0].header.source = 1; - event[0].header.ttl = 1; -#ifndef TAO_LACKS_EVENT_CHANNEL_ANY - event[0].data.any_value <<= any; -#else - ACE_UNUSED_ARG (any); -#endif - - consumer_->push(event); -} - -TAO_END_VERSIONED_NAMESPACE_DECL |