summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Event/EC_Basic_Factory.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_Basic_Factory.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Event/EC_Basic_Factory.cpp262
1 files changed, 0 insertions, 262 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Basic_Factory.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_Basic_Factory.cpp
deleted file mode 100644
index e9bc5dcb730..00000000000
--- a/TAO/orbsvcs/orbsvcs/Event/EC_Basic_Factory.cpp
+++ /dev/null
@@ -1,262 +0,0 @@
-// $Id$
-
-#include "orbsvcs/Event/EC_Basic_Factory.h"
-#include "orbsvcs/Event/EC_Reactive_Dispatching.h"
-#include "orbsvcs/Event/EC_Basic_Filter_Builder.h"
-#include "orbsvcs/Event/EC_Trivial_Supplier_Filter.h"
-#include "orbsvcs/Event/EC_ConsumerAdmin.h"
-#include "orbsvcs/Event/EC_SupplierAdmin.h"
-#include "orbsvcs/Event/EC_Default_ProxyConsumer.h"
-#include "orbsvcs/Event/EC_Default_ProxySupplier.h"
-#include "orbsvcs/Event/EC_ObserverStrategy.h"
-#include "orbsvcs/Event/EC_Null_Scheduling.h"
-#include "orbsvcs/Event/EC_Reactive_Timeout_Generator.h"
-#include "orbsvcs/Event/EC_Reactive_ConsumerControl.h"
-#include "orbsvcs/Event/EC_Reactive_SupplierControl.h"
-#include "orbsvcs/Event/EC_Event_Channel_Base.h" // @@ MSVC 6 bug
-
-#include "orbsvcs/ESF/ESF_Proxy_List.h"
-#include "orbsvcs/ESF/ESF_Delayed_Changes.h"
-
-#include "tao/ORB_Core.h"
-
-ACE_RCSID (Event,
- EC_Basic_Factory,
- "$Id$")
-
-TAO_BEGIN_VERSIONED_NAMESPACE_DECL
-
-TAO_EC_Basic_Factory::TAO_EC_Basic_Factory (void)
-{
-}
-
-TAO_EC_Basic_Factory::~TAO_EC_Basic_Factory (void)
-{
-}
-
-TAO_EC_Dispatching*
-TAO_EC_Basic_Factory::create_dispatching (TAO_EC_Event_Channel_Base *)
-{
- return new TAO_EC_Reactive_Dispatching ();
-}
-
-void
-TAO_EC_Basic_Factory::destroy_dispatching (TAO_EC_Dispatching *x)
-{
- delete x;
-}
-
-TAO_EC_Filter_Builder*
-TAO_EC_Basic_Factory::create_filter_builder (TAO_EC_Event_Channel_Base *ec)
-{
- return new TAO_EC_Basic_Filter_Builder (ec);
-}
-
-void
-TAO_EC_Basic_Factory::destroy_filter_builder (TAO_EC_Filter_Builder *x)
-{
- delete x;
-}
-
-TAO_EC_Supplier_Filter_Builder*
-TAO_EC_Basic_Factory::create_supplier_filter_builder (TAO_EC_Event_Channel_Base *ec)
-{
- return new TAO_EC_Trivial_Supplier_Filter_Builder (ec);
-}
-
-void
-TAO_EC_Basic_Factory::destroy_supplier_filter_builder (TAO_EC_Supplier_Filter_Builder *x)
-{
- delete x;
-}
-
-TAO_EC_ConsumerAdmin*
-TAO_EC_Basic_Factory::create_consumer_admin (TAO_EC_Event_Channel_Base *ec)
-{
- return new TAO_EC_ConsumerAdmin (ec);
-}
-
-void
-TAO_EC_Basic_Factory::destroy_consumer_admin (TAO_EC_ConsumerAdmin *x)
-{
- delete x;
-}
-
-TAO_EC_SupplierAdmin*
-TAO_EC_Basic_Factory::create_supplier_admin (TAO_EC_Event_Channel_Base *ec)
-{
- return new TAO_EC_SupplierAdmin (ec);
-}
-
-void
-TAO_EC_Basic_Factory::destroy_supplier_admin (TAO_EC_SupplierAdmin *x)
-{
- delete x;
-}
-
-TAO_EC_ProxyPushSupplier*
-TAO_EC_Basic_Factory::create_proxy_push_supplier (TAO_EC_Event_Channel_Base *ec)
-{
- return new TAO_EC_Default_ProxyPushSupplier (ec, TAO_EC_DEFAULT_CONSUMER_VALIDATE_CONNECTION);
-}
-
-void
-TAO_EC_Basic_Factory::destroy_proxy_push_supplier (TAO_EC_ProxyPushSupplier *x)
-{
- delete x;
-}
-
-TAO_EC_ProxyPushConsumer*
-TAO_EC_Basic_Factory::create_proxy_push_consumer (TAO_EC_Event_Channel_Base *ec)
-{
- return new TAO_EC_Default_ProxyPushConsumer (ec);
-}
-
-void
-TAO_EC_Basic_Factory::destroy_proxy_push_consumer (TAO_EC_ProxyPushConsumer *x)
-{
- delete x;
-}
-
-TAO_EC_Timeout_Generator*
-TAO_EC_Basic_Factory::create_timeout_generator (TAO_EC_Event_Channel_Base *)
-{
- int argc = 0;
- char **argv = 0;
- CORBA::ORB_var orb =
- CORBA::ORB_init (argc, argv, "");
- ACE_Reactor *reactor = orb->orb_core ()->reactor ();
- return new TAO_EC_Reactive_Timeout_Generator (reactor);
-}
-
-void
-TAO_EC_Basic_Factory::destroy_timeout_generator (TAO_EC_Timeout_Generator *x)
-{
- delete x;
-}
-
-TAO_EC_ObserverStrategy*
-TAO_EC_Basic_Factory::create_observer_strategy (TAO_EC_Event_Channel_Base *ec)
-{
- ACE_Lock* lock;
- ACE_NEW_RETURN (lock, ACE_Lock_Adapter<TAO_SYNCH_MUTEX>, 0);
- return new TAO_EC_Basic_ObserverStrategy (ec, lock);
-}
-
-void
-TAO_EC_Basic_Factory::destroy_observer_strategy (TAO_EC_ObserverStrategy *x)
-{
- delete x;
-}
-
-TAO_EC_Scheduling_Strategy*
-TAO_EC_Basic_Factory::create_scheduling_strategy (TAO_EC_Event_Channel_Base*)
-{
- return new TAO_EC_Null_Scheduling;
-}
-
-void
-TAO_EC_Basic_Factory::destroy_scheduling_strategy (TAO_EC_Scheduling_Strategy* x)
-{
- delete x;
-}
-
-TAO_EC_ProxyPushConsumer_Collection*
-TAO_EC_Basic_Factory::create_proxy_push_consumer_collection (TAO_EC_Event_Channel_Base *)
-{
- // This typedef is a workaround for a SunCC 4.2 bug
- typedef TAO_ESF_Proxy_List<TAO_EC_ProxyPushConsumer>::Iterator TAO_EC_Consumer_List_Iterator;
- return new TAO_ESF_Delayed_Changes<TAO_EC_ProxyPushConsumer,
- TAO_ESF_Proxy_List<TAO_EC_ProxyPushConsumer>,
- TAO_ESF_Proxy_List<TAO_EC_ProxyPushConsumer>::Iterator,
- ACE_SYNCH> ();
-}
-
-void
-TAO_EC_Basic_Factory::destroy_proxy_push_consumer_collection (TAO_EC_ProxyPushConsumer_Collection *x)
-{
- delete x;
-}
-
-TAO_EC_ProxyPushSupplier_Collection*
-TAO_EC_Basic_Factory::create_proxy_push_supplier_collection (TAO_EC_Event_Channel_Base *)
-{
- // This typedef is a workaround for a SunCC 4.2 bug
- typedef TAO_ESF_Proxy_List<TAO_EC_ProxyPushSupplier>::Iterator TAO_EC_Supplier_List_Iterator;
- return new TAO_ESF_Delayed_Changes<TAO_EC_ProxyPushSupplier,
- TAO_ESF_Proxy_List<TAO_EC_ProxyPushSupplier>,
- TAO_ESF_Proxy_List<TAO_EC_ProxyPushSupplier>::Iterator,
- ACE_SYNCH> ();
-}
-
-void
-TAO_EC_Basic_Factory::destroy_proxy_push_supplier_collection (TAO_EC_ProxyPushSupplier_Collection *x)
-{
- delete x;
-}
-
-ACE_Lock*
-TAO_EC_Basic_Factory::create_consumer_lock (void)
-{
- return new ACE_Lock_Adapter<TAO_SYNCH_MUTEX> ();
-}
-
-void
-TAO_EC_Basic_Factory::destroy_consumer_lock (ACE_Lock* x)
-{
- delete x;
-}
-
-ACE_Lock*
-TAO_EC_Basic_Factory::create_supplier_lock (void)
-{
- return new ACE_Lock_Adapter<TAO_SYNCH_RECURSIVE_MUTEX> ();
-}
-
-void
-TAO_EC_Basic_Factory::destroy_supplier_lock (ACE_Lock* x)
-{
- delete x;
-}
-
-TAO_EC_ConsumerControl*
-TAO_EC_Basic_Factory::create_consumer_control (TAO_EC_Event_Channel_Base* ec)
-{
- int argc = 0;
- char **argv = 0;
- CORBA::ORB_var orb =
- CORBA::ORB_init (argc, argv, "");
- // Hard-coded rate to 10 times a second
- ACE_Time_Value rate (0, 100000);
- // Hard-coded polling-timeout to 10 msec
- ACE_Time_Value timeout (0, TAO_EC_DEFAULT_CONSUMER_CONTROL_TIMEOUT);
- return new TAO_EC_Reactive_ConsumerControl (rate, timeout, ec, orb.in ());
-}
-
-void
-TAO_EC_Basic_Factory::destroy_consumer_control (TAO_EC_ConsumerControl* x)
-{
- delete x;
-}
-
-TAO_EC_SupplierControl*
-TAO_EC_Basic_Factory::create_supplier_control (TAO_EC_Event_Channel_Base* ec)
-{
- int argc = 0;
- char **argv = 0;
- CORBA::ORB_var orb =
- CORBA::ORB_init (argc, argv, "");
- // Hard-coded rate to 10 times a second
- ACE_Time_Value rate (0, 100000);
- // Hard-coded polling-timeout to 10 msec
- ACE_Time_Value timeout (0, TAO_EC_DEFAULT_SUPPLIER_CONTROL_TIMEOUT);
- return new TAO_EC_Reactive_SupplierControl (rate, timeout, ec, orb.in ());
-}
-
-void
-TAO_EC_Basic_Factory::destroy_supplier_control (TAO_EC_SupplierControl* x)
-{
- delete x;
-}
-
-TAO_END_VERSIONED_NAMESPACE_DECL