summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Notify/Method_Request_Lookup.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Method_Request_Lookup.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/Method_Request_Lookup.cpp47
1 files changed, 16 insertions, 31 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Method_Request_Lookup.cpp b/TAO/orbsvcs/orbsvcs/Notify/Method_Request_Lookup.cpp
index bee058ab534..3ae5412ccdd 100644
--- a/TAO/orbsvcs/orbsvcs/Notify/Method_Request_Lookup.cpp
+++ b/TAO/orbsvcs/orbsvcs/Notify/Method_Request_Lookup.cpp
@@ -1,27 +1,21 @@
// $Id$
-#include "orbsvcs/Notify/Method_Request_Lookup.h"
+#include "Method_Request_Lookup.h"
ACE_RCSID(Notify, TAO_Notify_Method_Request_Lookup, "$Id$")
-#include "orbsvcs/Notify/Consumer_Map.h"
-#include "orbsvcs/Notify/ProxySupplier.h"
-#include "orbsvcs/Notify/ProxyConsumer.h"
-#include "orbsvcs/Notify/Proxy.h"
-#include "orbsvcs/Notify/Admin.h"
-#include "orbsvcs/Notify/SupplierAdmin.h"
-#include "orbsvcs/Notify/Method_Request_Dispatch.h"
-#include "orbsvcs/Notify/Delivery_Request.h"
-#include "orbsvcs/Notify/EventChannelFactory.h"
-#include "orbsvcs/Notify/Event_Manager.h"
-#include "orbsvcs/Notify/Factory.h"
-
-#include "orbsvcs/ESF/ESF_Proxy_Collection.h"
+#include "Consumer_Map.h"
+#include "ProxySupplier.h"
+#include "ProxyConsumer.h"
+#include "Proxy.h"
+#include "Admin.h"
+#include "SupplierAdmin.h"
+#include "Method_Request_Dispatch.h"
+#include "Delivery_Request.h"
+#include "EventChannelFactory.h"
#include "tao/debug.h"
-#include "tao/CDR.h"
-
-TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+#include "tao/corba.h"
TAO_Notify_Method_Request_Lookup::TAO_Notify_Method_Request_Lookup (
const TAO_Notify_Event * event,
@@ -44,7 +38,6 @@ TAO_Notify_Method_Request_Lookup::work (
{
TAO_Notify_Method_Request_Dispatch_No_Copy request (*this, proxy_supplier, true);
proxy_supplier->deliver (request ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
}
else
{
@@ -64,7 +57,6 @@ int TAO_Notify_Method_Request_Lookup::execute_i (ACE_ENV_SINGLE_ARG_DECL)
parent.filter_admin (),
parent.filter_operator ()
ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
if (TAO_debug_level > 1)
ACE_DEBUG ((LM_DEBUG, "Proxyconsumer %x filter eval result = %d",&this->proxy_consumer_ , val));
@@ -86,10 +78,7 @@ int TAO_Notify_Method_Request_Lookup::execute_i (ACE_ENV_SINGLE_ARG_DECL)
consumers = entry->collection ();
if (consumers != 0)
- {
- consumers->for_each (this ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
- }
+ consumers->for_each (this ACE_ENV_ARG_PARAMETER);
map.release (entry);
}
@@ -98,10 +87,7 @@ int TAO_Notify_Method_Request_Lookup::execute_i (ACE_ENV_SINGLE_ARG_DECL)
consumers = map.broadcast_collection ();
if (consumers != 0)
- {
- consumers->for_each (this ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
- }
+ consumers->for_each (this ACE_ENV_ARG_PARAMETER);
this->complete ();
return 0;
}
@@ -220,14 +206,13 @@ TAO_Notify_Method_Request_Lookup_No_Copy::copy (ACE_ENV_SINGLE_ARG_DECL)
{
TAO_Notify_Method_Request_Queueable* request;
- TAO_Notify_Event::Ptr event(this->event_->queueable_copy(ACE_ENV_SINGLE_ARG_PARAMETER));
+ TAO_Notify_Event::Ptr event_var (
+ this->event_->queueable_copy (ACE_ENV_SINGLE_ARG_PARAMETER) );
ACE_CHECK_RETURN (0);
ACE_NEW_THROW_EX (request,
- TAO_Notify_Method_Request_Lookup_Queueable (event, this->proxy_consumer_),
+ TAO_Notify_Method_Request_Lookup_Queueable (event_var, this->proxy_consumer_),
CORBA::INTERNAL ());
return request;
}
-
-TAO_END_VERSIONED_NAMESPACE_DECL