diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_Gateway_IIOP.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/EC_Gateway_IIOP.cpp | 64 |
1 files changed, 32 insertions, 32 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_IIOP.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_IIOP.cpp index d8287744bc6..18e8643be65 100644 --- a/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_IIOP.cpp +++ b/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_IIOP.cpp @@ -11,7 +11,7 @@ TAO_BEGIN_VERSIONED_NAMESPACE_DECL -TAO_EC_Gateway_IIOP::TAO_EC_Gateway_IIOP (void) +TAO_EC_Gateway_IIOP::TAO_EC_Gateway_IIOP () : busy_count_ (0), update_posted_ (0), cleanup_posted_ (0), @@ -22,36 +22,36 @@ TAO_EC_Gateway_IIOP::TAO_EC_Gateway_IIOP (void) consumer_is_active_ (false), supplier_ (this), supplier_is_active_ (false), - ec_control_ (0), - factory_ (0), + ec_control_ (nullptr), + factory_ (nullptr), use_ttl_ (1), use_consumer_proxy_map_ (1) { - if (this->factory_ == 0) + if (this->factory_ == nullptr) { this->factory_ = ACE_Dynamic_Service<TAO_EC_Gateway_IIOP_Factory>::instance ("EC_Gateway_IIOP_Factory"); - if (this->factory_ == 0) + if (this->factory_ == nullptr) { - TAO_EC_Gateway_IIOP_Factory *f = 0; + TAO_EC_Gateway_IIOP_Factory *f = nullptr; ACE_NEW (f, TAO_EC_Gateway_IIOP_Factory); this->factory_ = f; } } - if (this->factory_ != 0) + if (this->factory_ != nullptr) { this->use_ttl_ = this->factory_->use_ttl(); this->use_consumer_proxy_map_ = this->factory_->use_consumer_proxy_map(); } } -TAO_EC_Gateway_IIOP::~TAO_EC_Gateway_IIOP (void) +TAO_EC_Gateway_IIOP::~TAO_EC_Gateway_IIOP () { delete ec_control_; - ec_control_ = 0; + ec_control_ = nullptr; } int @@ -74,7 +74,7 @@ TAO_EC_Gateway_IIOP::init_i (RtecEventChannelAdmin::EventChannel_ptr supplier_ec this->consumer_ec_ = RtecEventChannelAdmin::EventChannel::_duplicate (consumer_ec); - if (ec_control_ == 0) + if (ec_control_ == nullptr) { ec_control_ = factory_->create_consumerec_control(this); ec_control_->activate(); @@ -90,7 +90,7 @@ TAO_EC_Gateway_IIOP::init_i (RtecEventChannelAdmin::EventChannel_ptr supplier_ec } void -TAO_EC_Gateway_IIOP::close (void) +TAO_EC_Gateway_IIOP::close () { ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->lock_); @@ -98,7 +98,7 @@ TAO_EC_Gateway_IIOP::close (void) } void -TAO_EC_Gateway_IIOP::cleanup_consumer_proxies (void) +TAO_EC_Gateway_IIOP::cleanup_consumer_proxies () { ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->lock_); @@ -113,7 +113,7 @@ TAO_EC_Gateway_IIOP::cleanup_consumer_proxies (void) } void -TAO_EC_Gateway_IIOP::close_i (void) +TAO_EC_Gateway_IIOP::close_i () { // ORBSVCS_DEBUG ((LM_DEBUG, "ECG (%t) Closing gateway\n")); this->disconnect_consumer_proxies_i (); @@ -122,7 +122,7 @@ TAO_EC_Gateway_IIOP::close_i (void) } void -TAO_EC_Gateway_IIOP::disconnect_consumer_proxies_i (void) +TAO_EC_Gateway_IIOP::disconnect_consumer_proxies_i () { if (this->consumer_proxy_map_.current_size () > 0) { @@ -157,7 +157,7 @@ TAO_EC_Gateway_IIOP::disconnect_consumer_proxies_i (void) } void -TAO_EC_Gateway_IIOP::disconnect_supplier_proxy_i (void) +TAO_EC_Gateway_IIOP::disconnect_supplier_proxy_i () { if (!CORBA::is_nil (this->supplier_proxy_.in ())) { @@ -169,7 +169,7 @@ TAO_EC_Gateway_IIOP::disconnect_supplier_proxy_i (void) } void -TAO_EC_Gateway_IIOP::reconnect_consumer_ec(void) +TAO_EC_Gateway_IIOP::reconnect_consumer_ec() { ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->lock_); @@ -203,7 +203,7 @@ TAO_EC_Gateway_IIOP::update_consumer ( } void -TAO_EC_Gateway_IIOP::cleanup_consumer_proxies_i (void) +TAO_EC_Gateway_IIOP::cleanup_consumer_proxies_i () { if (this->consumer_proxy_map_.current_size () > 0) { @@ -262,7 +262,7 @@ TAO_EC_Gateway_IIOP::open_i ( { sub.dependencies[i].rt_info = this->supplier_info_; - RtecEventChannelAdmin::ProxyPushConsumer_ptr proxy = 0; + RtecEventChannelAdmin::ProxyPushConsumer_ptr proxy = nullptr; const RtecEventComm::EventHeader &h = sub.dependencies[i].event.header; @@ -420,7 +420,7 @@ TAO_EC_Gateway_IIOP::update_supplier ( } void -TAO_EC_Gateway_IIOP::disconnect_push_consumer (void) +TAO_EC_Gateway_IIOP::disconnect_push_consumer () { // ORBSVCS_DEBUG ((LM_DEBUG, // "ECG (%t): Supplier-consumer received " @@ -428,7 +428,7 @@ TAO_EC_Gateway_IIOP::disconnect_push_consumer (void) } void -TAO_EC_Gateway_IIOP::disconnect_push_supplier (void) +TAO_EC_Gateway_IIOP::disconnect_push_supplier () { // ORBSVCS_DEBUG ((LM_DEBUG, // "ECG (%t): Supplier received " @@ -466,7 +466,7 @@ TAO_EC_Gateway_IIOP::push (const RtecEventComm::EventSet &events) continue; } - RtecEventChannelAdmin::ProxyPushConsumer_ptr proxy = 0; + RtecEventChannelAdmin::ProxyPushConsumer_ptr proxy = nullptr; RtecEventComm::EventSourceID sid = events[i].header.source; if (sid == ACE_ES_EVENT_SOURCE_ANY || this->use_consumer_proxy_map_ == 0 || this->consumer_proxy_map_.find (sid, proxy) == -1) @@ -531,7 +531,7 @@ TAO_EC_Gateway_IIOP::push_to_consumer ( } int -TAO_EC_Gateway_IIOP::shutdown (void) +TAO_EC_Gateway_IIOP::shutdown () { ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->lock_, -1); @@ -566,7 +566,7 @@ TAO_EC_Gateway_IIOP::shutdown (void) } int -TAO_EC_Gateway_IIOP::cleanup_consumer_ec (void) +TAO_EC_Gateway_IIOP::cleanup_consumer_ec () { ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->lock_, -1); @@ -576,7 +576,7 @@ TAO_EC_Gateway_IIOP::cleanup_consumer_ec (void) } int -TAO_EC_Gateway_IIOP::cleanup_supplier_ec (void) +TAO_EC_Gateway_IIOP::cleanup_supplier_ec () { ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->lock_, -1); @@ -586,21 +586,21 @@ TAO_EC_Gateway_IIOP::cleanup_supplier_ec (void) } void -TAO_EC_Gateway_IIOP::cleanup_consumer_ec_i (void) +TAO_EC_Gateway_IIOP::cleanup_consumer_ec_i () { this->consumer_ec_ = RtecEventChannelAdmin::EventChannel::_nil (); } void -TAO_EC_Gateway_IIOP::cleanup_supplier_ec_i (void) +TAO_EC_Gateway_IIOP::cleanup_supplier_ec_i () { this->supplier_ec_ = RtecEventChannelAdmin::EventChannel::_nil (); } CORBA::Boolean -TAO_EC_Gateway_IIOP::is_consumer_ec_connected_i (void) const +TAO_EC_Gateway_IIOP::is_consumer_ec_connected_i () const { return !CORBA::is_nil (this->consumer_ec_.in ()); } @@ -615,11 +615,11 @@ TAO_EC_Gateway_IIOP::consumer_ec_non_existent ( TAO_SYNCH_MUTEX, ace_mon, this->lock_, CORBA::INTERNAL ()); - disconnected = 0; + disconnected = false; if (this->is_consumer_ec_connected_i () == 0) { - disconnected = 1; - return 0; + disconnected = true; + return false; } consumer_ec = CORBA::Object::_duplicate (this->consumer_ec_.in ()); @@ -633,7 +633,7 @@ TAO_EC_Gateway_IIOP::consumer_ec_non_existent ( } void -TAO_EC_Gateway_IIOP::suspend_supplier_ec (void) +TAO_EC_Gateway_IIOP::suspend_supplier_ec () { if (!CORBA::is_nil (this->supplier_proxy_.in ()) && supplier_ec_suspended_ == 0) { @@ -644,7 +644,7 @@ TAO_EC_Gateway_IIOP::suspend_supplier_ec (void) } void -TAO_EC_Gateway_IIOP::resume_supplier_ec (void) +TAO_EC_Gateway_IIOP::resume_supplier_ec () { if (!CORBA::is_nil (this->supplier_proxy_.in ()) && supplier_ec_suspended_ == 1) { |