summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Log/RTEventLogNotification.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Log/RTEventLogNotification.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Log/RTEventLogNotification.cpp90
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