diff options
author | Phil Mesnier <mesnier_p@ociweb.com> | 2009-03-02 22:49:17 +0000 |
---|---|---|
committer | Phil Mesnier <mesnier_p@ociweb.com> | 2009-03-02 22:49:17 +0000 |
commit | c13918de8f7bf1c779cdae1fbafe9010cdd78592 (patch) | |
tree | f12cdbfbfdab0c0ecc9b4123ecb65e6ba4eb1173 /TAO/orbsvcs/orbsvcs/Notify/ProxyConsumer.cpp | |
parent | 452ce7093d45b09e79db8cb59fd7c7e6e9b2090c (diff) | |
download | ATCD-c13918de8f7bf1c779cdae1fbafe9010cdd78592.tar.gz |
Mon Mar 2 22:48:25 UTC 2009 Phil Mesnier <mesnier_p@ociweb.com> Reapplication of notify service updates
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/ProxyConsumer.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/ProxyConsumer.cpp | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/ProxyConsumer.cpp b/TAO/orbsvcs/orbsvcs/Notify/ProxyConsumer.cpp index 742ac748116..a3a1101cbaa 100644 --- a/TAO/orbsvcs/orbsvcs/Notify/ProxyConsumer.cpp +++ b/TAO/orbsvcs/orbsvcs/Notify/ProxyConsumer.cpp @@ -54,6 +54,8 @@ TAO_Notify_ProxyConsumer::init (TAO_Notify::Topology_Parent* topology_parent) this->supplier_admin_.reset (dynamic_cast<TAO_Notify_SupplierAdmin *>(topology_parent)); ACE_ASSERT (this->supplier_admin_.get() != 0); + this->filter_admin_.event_channel_factory (this->supplier_admin_->event_channel()->event_channel_factory ()); + const CosNotification::QoSProperties &default_ps_qos = TAO_Notify_PROPERTIES::instance ()->default_proxy_consumer_qos_properties (); @@ -111,6 +113,8 @@ TAO_Notify_ProxyConsumer::connect (TAO_Notify_Supplier *supplier) void TAO_Notify_ProxyConsumer::push_i (TAO_Notify_Event * event) { + last_ping_ = ACE_OS::gettimeofday (); + if (this->supports_reliable_events ()) { TAO_Notify_Event::Ptr pevent(event->queueable_copy()); @@ -183,4 +187,19 @@ TAO_Notify_ProxyConsumer::destroy (void) // It is not safe to delete the non-refcounted supplier here. } + +ACE_Time_Value +TAO_Notify_ProxyConsumer::last_ping() const +{ + return this->last_ping_.value (); +} + + +void +TAO_Notify_ProxyConsumer::last_ping(const ACE_Time_Value& tv) +{ + this->last_ping_ = tv; +} + + TAO_END_VERSIONED_NAMESPACE_DECL |