summaryrefslogtreecommitdiff
path: root/TAO
diff options
context:
space:
mode:
authorJohnny Willemsen <jwillemsen@remedy.nl>2018-04-13 12:29:03 +0200
committerJohnny Willemsen <jwillemsen@remedy.nl>2018-04-13 12:29:03 +0200
commit657865f97f242c1377304d0970b592df4f45f2ee (patch)
treee8bf39b3863b445d81ad5cf3991c3100dd02fd35 /TAO
parentfe1fa2d58972d22ccc6b228060279ac6bcbeb929 (diff)
downloadATCD-657865f97f242c1377304d0970b592df4f45f2ee.tar.gz
Use true/false instead of 1/0 for connected checks
* TAO/orbsvcs/orbsvcs/CosEvent/CEC_EventChannel.cpp: * TAO/orbsvcs/orbsvcs/CosEvent/CEC_Factory.cpp: * TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.cpp: * TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.inl: * TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp: * TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.inl: * TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushConsumer.inl: * TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.cpp: * TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.inl: * TAO/orbsvcs/orbsvcs/CosEvent/CEC_TypedProxyPushConsumer.cpp:
Diffstat (limited to 'TAO')
-rw-r--r--TAO/orbsvcs/orbsvcs/CosEvent/CEC_EventChannel.cpp2
-rw-r--r--TAO/orbsvcs/orbsvcs/CosEvent/CEC_Factory.cpp2
-rw-r--r--TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.cpp18
-rw-r--r--TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.inl2
-rw-r--r--TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp14
-rw-r--r--TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.inl2
-rw-r--r--TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushConsumer.inl2
-rw-r--r--TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.cpp30
-rw-r--r--TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.inl2
-rw-r--r--TAO/orbsvcs/orbsvcs/CosEvent/CEC_TypedProxyPushConsumer.cpp16
10 files changed, 43 insertions, 47 deletions
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_EventChannel.cpp b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_EventChannel.cpp
index 63b3407fecf..522f8e5506b 100644
--- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_EventChannel.cpp
+++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_EventChannel.cpp
@@ -11,8 +11,6 @@
#include "orbsvcs/CosEvent/CEC_EventChannel.inl"
#endif /* __ACE_INLINE__ */
-
-
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
TAO_CEC_EventChannel::
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Factory.cpp b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Factory.cpp
index 50fe4fd1094..6eef61ef41a 100644
--- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Factory.cpp
+++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Factory.cpp
@@ -1,8 +1,6 @@
#include "orbsvcs/CosEvent/CEC_Factory.h"
#include "ace/Dynamic_Service.h"
-
-
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
TAO_CEC_Factory::~TAO_CEC_Factory (void)
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.cpp b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.cpp
index 625fade23c1..a12bdf9b683 100644
--- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.cpp
+++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.cpp
@@ -89,7 +89,7 @@ TAO_CEC_ProxyPullConsumer::try_pull_from_supplier (
CORBA::INTERNAL ());
// @@ CosEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
return 0; // ACE_THROW (CosEventComm::Disconnected ());????
supplier =
@@ -135,7 +135,7 @@ TAO_CEC_ProxyPullConsumer::pull_from_supplier ()
CORBA::INTERNAL ());
// @@ CosEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
return 0; // ACE_THROW (CosEventComm::Disconnected ());????
supplier =
@@ -168,15 +168,15 @@ TAO_CEC_ProxyPullConsumer::supplier_non_existent (
ACE_Lock, ace_mon, *this->lock_,
CORBA::INTERNAL ());
- disconnected = 0;
- if (this->is_connected_i () == 0)
+ disconnected = false;
+ if (!this->is_connected_i ())
{
- disconnected = 1;
- return 0;
+ disconnected = true;
+ return false;
}
if (CORBA::is_nil (this->nopolicy_supplier_.in ()))
{
- return 0;
+ return false;
}
supplier = CORBA::Object::_duplicate (this->nopolicy_supplier_.in ());
}
@@ -184,7 +184,7 @@ TAO_CEC_ProxyPullConsumer::supplier_non_existent (
#if (TAO_HAS_MINIMUM_CORBA == 0)
return supplier->_non_existent ();
#else
- return 0;
+ return false;
#endif /* TAO_HAS_MINIMUM_CORBA */
}
@@ -332,7 +332,7 @@ TAO_CEC_ProxyPullConsumer::disconnect_pull_consumer ()
CORBA::INTERNAL ());
// @@ CosEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
throw CORBA::BAD_INV_ORDER (); // @@ add user exception?
supplier = this->supplier_._retn ();
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.inl b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.inl
index 67bb6e354ef..d0a626e9b03 100644
--- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.inl
+++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullConsumer.inl
@@ -10,7 +10,7 @@ TAO_CEC_ProxyPullConsumer::is_connected_i (void) const
ACE_INLINE CORBA::Boolean
TAO_CEC_ProxyPullConsumer::is_connected (void) const
{
- ACE_GUARD_RETURN (ACE_Lock, ace_mon, *this->lock_, 0);
+ ACE_GUARD_RETURN (ACE_Lock, ace_mon, *this->lock_, false);
return this->is_connected_i ();
}
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp
index 305920b65ee..db840f03ee5 100644
--- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp
+++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp
@@ -113,15 +113,15 @@ TAO_CEC_ProxyPullSupplier::consumer_non_existent (
ACE_Lock, ace_mon, *this->lock_,
CORBA::INTERNAL ());
- disconnected = 0;
- if (this->is_connected_i () == 0)
+ disconnected = false;
+ if (!this->is_connected_i ())
{
- disconnected = 1;
- return 0;
+ disconnected = true;
+ return false;
}
if (CORBA::is_nil (this->nopolicy_consumer_.in ()))
{
- return 0;
+ return false;
}
consumer = CORBA::Object::_duplicate (this->nopolicy_consumer_.in ());
}
@@ -129,7 +129,7 @@ TAO_CEC_ProxyPullSupplier::consumer_non_existent (
#if (TAO_HAS_MINIMUM_CORBA == 0)
return consumer->_non_existent ();
#else
- return 0;
+ return false;
#endif /* TAO_HAS_MINIMUM_CORBA */
}
@@ -300,7 +300,7 @@ TAO_CEC_ProxyPullSupplier::disconnect_pull_supplier ()
CORBA::INTERNAL ());
// @@ CosEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
throw CORBA::BAD_INV_ORDER ();
consumer = this->consumer_._retn ();
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.inl b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.inl
index 96c4591583e..9101a57bc0b 100644
--- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.inl
+++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.inl
@@ -10,7 +10,7 @@ TAO_CEC_ProxyPullSupplier::is_connected_i (void) const
ACE_INLINE CORBA::Boolean
TAO_CEC_ProxyPullSupplier::is_connected (void) const
{
- ACE_GUARD_RETURN (ACE_Lock, ace_mon, *this->lock_, 0);
+ ACE_GUARD_RETURN (ACE_Lock, ace_mon, *this->lock_, false);
return this->is_connected_i ();
}
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushConsumer.inl b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushConsumer.inl
index 0f865f9b440..d93fc640172 100644
--- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushConsumer.inl
+++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushConsumer.inl
@@ -10,7 +10,7 @@ TAO_CEC_ProxyPushConsumer::is_connected_i (void) const
ACE_INLINE CORBA::Boolean
TAO_CEC_ProxyPushConsumer::is_connected (void) const
{
- ACE_GUARD_RETURN (ACE_Lock, ace_mon, *this->lock_, 0);
+ ACE_GUARD_RETURN (ACE_Lock, ace_mon, *this->lock_, false);
return this->is_connected_i ();
}
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.cpp b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.cpp
index f8891b2e576..b1a1569031a 100644
--- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.cpp
+++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.cpp
@@ -207,7 +207,7 @@ TAO_CEC_ProxyPushSupplier::push (const CORBA::Any &event)
{
ACE_GUARD (ACE_Lock, ace_mon, *this->lock_);
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
return;
TAO_ESF_RefCount_Guard<CORBA::ULong> cnt_mon (this->refcount_);
@@ -235,7 +235,7 @@ TAO_CEC_ProxyPushSupplier::invoke (const TAO_CEC_TypedEvent& typed_event)
ACE_GUARD (ACE_Lock, ace_mon, *this->lock_);
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
return;
TAO_ESF_RefCount_Guard<CORBA::ULong> cnt_mon (this->refcount_);
@@ -261,7 +261,7 @@ TAO_CEC_ProxyPushSupplier::push_nocopy (CORBA::Any &event)
{
ACE_GUARD (ACE_Lock, ace_mon, *this->lock_);
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
return;
TAO_ESF_RefCount_Guard<CORBA::ULong> cnt_mon (this->refcount_);
@@ -518,7 +518,7 @@ TAO_CEC_ProxyPushSupplier::disconnect_push_supplier ()
CORBA::INTERNAL ());
// @@ CosEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
throw CORBA::BAD_INV_ORDER ();
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
@@ -603,7 +603,7 @@ TAO_CEC_ProxyPushSupplier::push_to_consumer (const CORBA::Any& event)
CORBA::INTERNAL ());
// @@ CosEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
return; // ACE_THROW (CosEventComm::Disconnected ());????
consumer =
@@ -640,7 +640,7 @@ TAO_CEC_ProxyPushSupplier::reactive_push_to_consumer (
CosEventComm::PushConsumer_var consumer;
{
ACE_GUARD (ACE_Lock, ace_mon, *this->lock_);
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
return; // TAO_THROW (CosEventComm::Disconnected ());????
consumer =
@@ -697,7 +697,7 @@ TAO_CEC_ProxyPushSupplier::invoke_to_consumer (const TAO_CEC_TypedEvent &typed_e
CORBA::INTERNAL ());
// @@ CosEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
return; // ACE_THROW (CosEventComm::Disconnected ());????
typed_consumer_obj =
@@ -765,7 +765,7 @@ TAO_CEC_ProxyPushSupplier::reactive_invoke_to_consumer (
{
ACE_GUARD (ACE_Lock, ace_mon, *this->lock_);
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
{
return; // TAO_THROW (CosEventComm::Disconnected ());????
}
@@ -838,11 +838,11 @@ TAO_CEC_ProxyPushSupplier::consumer_non_existent (
ACE_Lock, ace_mon, *this->lock_,
CORBA::INTERNAL ());
- disconnected = 0;
- if (this->is_connected_i () == 0)
+ disconnected = false;
+ if (!this->is_connected_i ())
{
- disconnected = 1;
- return 0;
+ disconnected = true;
+ return false;
}
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
@@ -850,7 +850,7 @@ TAO_CEC_ProxyPushSupplier::consumer_non_existent (
{
if (CORBA::is_nil (this->nopolicy_typed_consumer_.in ()))
{
- return 0;
+ return false;
}
consumer = CORBA::Object::_duplicate
(this->nopolicy_typed_consumer_.in ());
@@ -860,7 +860,7 @@ TAO_CEC_ProxyPushSupplier::consumer_non_existent (
#endif /* TAO_HAS_TYPED_EVENT_CHANNEL */
if (CORBA::is_nil (this->nopolicy_consumer_.in ()))
{
- return 0;
+ return false;
}
consumer = CORBA::Object::_duplicate (this->nopolicy_consumer_.in ());
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
@@ -871,7 +871,7 @@ TAO_CEC_ProxyPushSupplier::consumer_non_existent (
#if (TAO_HAS_MINIMUM_CORBA == 0)
return consumer->_non_existent ();
#else
- return 0;
+ return false;
#endif /* TAO_HAS_MINIMUM_CORBA */
}
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.inl b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.inl
index 79be8659d44..995109cfb53 100644
--- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.inl
+++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPushSupplier.inl
@@ -21,7 +21,7 @@ TAO_CEC_ProxyPushSupplier::is_connected_i (void) const
ACE_INLINE CORBA::Boolean
TAO_CEC_ProxyPushSupplier::is_connected (void) const
{
- ACE_GUARD_RETURN (ACE_Lock, ace_mon, *this->lock_, 0);
+ ACE_GUARD_RETURN (ACE_Lock, ace_mon, *this->lock_, false);
return this->is_connected_i ();
}
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_TypedProxyPushConsumer.cpp b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_TypedProxyPushConsumer.cpp
index 74b83b68e39..93b02abfe2f 100644
--- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_TypedProxyPushConsumer.cpp
+++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_TypedProxyPushConsumer.cpp
@@ -115,15 +115,15 @@ TAO_CEC_TypedProxyPushConsumer::supplier_non_existent (
ACE_Lock, ace_mon, *this->lock_,
CORBA::INTERNAL ());
- disconnected = 0;
- if (this->is_connected_i () == 0)
+ disconnected = false;
+ if (!this->is_connected_i ())
{
- disconnected = 1;
- return 0;
+ disconnected = true;
+ return false;
}
if (CORBA::is_nil (this->nopolicy_typed_supplier_.in ()))
{
- return 0;
+ return false;
}
supplier = CORBA::Object::_duplicate
(this->nopolicy_typed_supplier_.in ());
@@ -132,7 +132,7 @@ TAO_CEC_TypedProxyPushConsumer::supplier_non_existent (
#if (TAO_HAS_MINIMUM_CORBA == 0)
return supplier->_non_existent ();
#else
- return 0;
+ return false;
#endif /* TAO_HAS_MINIMUM_CORBA */
}
@@ -284,7 +284,7 @@ TAO_CEC_TypedProxyPushConsumer::disconnect_push_consumer ()
CORBA::INTERNAL ());
// @@ CosEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
- if (this->is_connected_i () == 0)
+ if (!this->is_connected_i ())
throw CORBA::BAD_INV_ORDER (); // @@ add user exception?
supplier = this->typed_supplier_._retn ();
@@ -374,7 +374,7 @@ TAO_CEC_TypedProxyPushConsumer_Guard::
// @@ Returning something won't work either, the error should be
// logged though!
- if (proxy->is_connected_i () == 0)
+ if (!proxy->is_connected_i ())
return;
this->locked_ = 1;