summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Notify/Proxy.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Proxy.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/Proxy.cpp43
1 files changed, 17 insertions, 26 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Proxy.cpp b/TAO/orbsvcs/orbsvcs/Notify/Proxy.cpp
index a088943d05b..02632dce402 100644
--- a/TAO/orbsvcs/orbsvcs/Notify/Proxy.cpp
+++ b/TAO/orbsvcs/orbsvcs/Notify/Proxy.cpp
@@ -28,43 +28,41 @@ TAO_Notify_Proxy::~TAO_Notify_Proxy ()
}
CORBA::Object_ptr
-TAO_Notify_Proxy::activate (PortableServer::Servant servant ACE_ENV_ARG_DECL)
+TAO_Notify_Proxy::activate (PortableServer::Servant servant)
{
// Set the POA that we use to return our <ref>
this->set_primary_as_proxy_poa();
- return TAO_Notify_Object::activate (servant ACE_ENV_ARG_PARAMETER);
+ return TAO_Notify_Object::activate (servant);
}
CORBA::Object_ptr
TAO_Notify_Proxy::activate (PortableServer::Servant servant,
- CORBA::Long id
- ACE_ENV_ARG_DECL)
+ CORBA::Long id)
{
// Set the POA that we use to return our <ref>
this->set_primary_as_proxy_poa();
- return TAO_Notify_Object::activate (servant, id ACE_ENV_ARG_PARAMETER);
+ return TAO_Notify_Object::activate (servant, id);
}
void
-TAO_Notify_Proxy::deactivate (ACE_ENV_SINGLE_ARG_DECL)
+TAO_Notify_Proxy::deactivate (void)
{
ACE_ASSERT (this->proxy_poa() != 0 );
- this->proxy_poa()->deactivate (this->id() ACE_ENV_ARG_PARAMETER);
+ this->proxy_poa()->deactivate (this->id());
}
void
-TAO_Notify_Proxy::subscribed_types (TAO_Notify_EventTypeSeq& subscribed_types ACE_ENV_ARG_DECL)
+TAO_Notify_Proxy::subscribed_types (TAO_Notify_EventTypeSeq& subscribed_types)
{
ACE_GUARD_THROW_EX (TAO_SYNCH_MUTEX, ace_mon, this->lock_,
CORBA::INTERNAL ());
- ACE_CHECK;
// copy
subscribed_types = this->subscribed_types_;
}
void
-TAO_Notify_Proxy::types_changed (const TAO_Notify_EventTypeSeq& added, const TAO_Notify_EventTypeSeq& removed ACE_ENV_ARG_DECL)
+TAO_Notify_Proxy::types_changed (const TAO_Notify_EventTypeSeq& added, const TAO_Notify_EventTypeSeq& removed)
{
// return if the updates for this proxy are turned off or
// if all the updates in the channel are switched off.
@@ -75,18 +73,16 @@ TAO_Notify_Proxy::types_changed (const TAO_Notify_EventTypeSeq& added, const TAO
if (TAO_Notify_PROPERTIES::instance()->asynch_updates () == 1) // if we should send the updates synchronously.
{
- this->execute_task (request ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
+ this->execute_task (request);
}
else // execute in the current thread context.
{
- request.execute (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ request.execute ();
}
}
CosNotification::EventTypeSeq*
-TAO_Notify_Proxy::obtain_types (CosNotifyChannelAdmin::ObtainInfoMode mode, const TAO_Notify_EventTypeSeq& types ACE_ENV_ARG_DECL)
+TAO_Notify_Proxy::obtain_types (CosNotifyChannelAdmin::ObtainInfoMode mode, const TAO_Notify_EventTypeSeq& types)
ACE_THROW_SPEC ((
CORBA::SystemException
))
@@ -98,7 +94,6 @@ TAO_Notify_Proxy::obtain_types (CosNotifyChannelAdmin::ObtainInfoMode mode, cons
CORBA::NO_MEMORY ());
ACE_GUARD_THROW_EX (TAO_SYNCH_MUTEX, ace_mon, this->lock_, CORBA::INTERNAL ());
- ACE_CHECK_RETURN (event_type_seq._retn ());
if (mode == CosNotifyChannelAdmin::ALL_NOW_UPDATES_OFF ||
mode == CosNotifyChannelAdmin::ALL_NOW_UPDATES_ON)
@@ -130,7 +125,7 @@ TAO_Notify_Proxy::qos_changed (const TAO_Notify_QoSProperties& qos_properties)
}
void
-TAO_Notify_Proxy::save_persistent (TAO_Notify::Topology_Saver& saver ACE_ENV_ARG_DECL)
+TAO_Notify_Proxy::save_persistent (TAO_Notify::Topology_Saver& saver)
{
bool changed = this->children_changed_;
this->children_changed_ = false;
@@ -142,24 +137,21 @@ TAO_Notify_Proxy::save_persistent (TAO_Notify::Topology_Saver& saver ACE_ENV_ARG
this->save_attrs(attrs);
const char * type_name = this->get_proxy_type_name ();
- bool want_all_children = saver.begin_object(this->id(), type_name, attrs, changed ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
+ bool want_all_children = saver.begin_object(this->id(), type_name, attrs, changed);
if (want_all_children || this->filter_admin_.is_changed ())
{
- this->filter_admin_.save_persistent(saver ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
+ this->filter_admin_.save_persistent(saver);
}
if (want_all_children || this->subscribed_types_.is_changed ())
{
- this->subscribed_types_.save_persistent(saver ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
+ this->subscribed_types_.save_persistent(saver);
}
// todo: handle removed children
- saver.end_object(this->id(), type_name ACE_ENV_ARG_PARAMETER);
+ saver.end_object(this->id(), type_name);
}
}
@@ -176,7 +168,7 @@ TAO_Notify_Proxy::save_attrs (TAO_Notify::NVPList& attrs)
TAO_Notify::Topology_Object*
TAO_Notify_Proxy::load_child (const ACE_CString &type, CORBA::Long id,
- const TAO_Notify::NVPList& attrs ACE_ENV_ARG_DECL)
+ const TAO_Notify::NVPList& attrs)
{
ACE_UNUSED_ARG (id);
ACE_UNUSED_ARG (attrs);
@@ -187,7 +179,6 @@ TAO_Notify_Proxy::load_child (const ACE_CString &type, CORBA::Long id,
// in the constructor. we have to clear it out first.
this->subscribed_types_.reset();
result = &this->subscribed_types_;
- ACE_CHECK_RETURN(0);
}
else if (type == "filter_admin")
{