diff options
author | chappell_j <chappell_j@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2009-01-26 19:56:00 +0000 |
---|---|---|
committer | chappell_j <chappell_j@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2009-01-26 19:56:00 +0000 |
commit | 484347da8a1d2dd966f3300c41ba32f6cebf3655 (patch) | |
tree | 33df3d7371556365b0ddce8a91f491c2e570134c /TAO/orbsvcs/orbsvcs/Notify/ProxyConsumer.cpp | |
parent | 22f09a0031a3222ccd001e7db8d8320c52f3dae5 (diff) | |
download | ATCD-484347da8a1d2dd966f3300c41ba32f6cebf3655.tar.gz |
merge Yan Dai's changes
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 |