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