1 files changed, 358 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Event_Manager.cpp b/TAO/orbsvcs/orbsvcs/Notify/Event_Manager.cpp
new file mode 100644
index 00000000000..52d2540d0cc
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Notify/Event_Manager.cpp
@@ -0,0 +1,358 @@
+// $Id$
+
+#include "Event_Manager.h"
+#include "tao/debug.h"
+
+#if ! defined (__ACE_INLINE__)
+#include "Event_Manager.inl"
+#endif /* __ACE_INLINE__ */
+
+ACE_RCSID(RT_Notify, TAO_NS_Event_Manager, "$Id$")
+
+#include "ace/Refcounted_Auto_Ptr.h"
+#include "orbsvcs/ESF/ESF_Proxy_Collection.h"
+
+#include "EventTypeSeq.h"
+#include "Event.h"
+#include "Peer.h"
+#include "Consumer.h"
+#include "ProxyConsumer.h"
+#include "ProxySupplier.h"
+#include "Proxy.h"
+#include "Admin.h"
+#include "EventChannel.h"
+#include "EventChannelFactory.h"
+#include "Notify_Service.h"
+#include "Pending_Worker_T.h"
+#include "Event_Map_Observer_T.h"
+#include "Dispatch_Observer_T.h"
+#include "Event_Map_T.h"
+
+TAO_NS_Event_Manager::TAO_NS_Event_Manager (void)
+  :consumer_map_ (0), supplier_map_ (0),
+   consumer_map_observer_ (0), supplier_map_observer_ (0),
+   event_dispatch_observer_(0), updates_dispatch_observer_ (0),
+   event_pending_worker_ (0), updates_pending_worker_ (0)
+{
+}
+
+TAO_NS_Event_Manager::~TAO_NS_Event_Manager ()
+{
+  if (TAO_debug_level > 0)
+    {
+      ACE_DEBUG ((LM_DEBUG, "destroying consumer/supplier map count = %d/%d, \n",
+                  this->consumer_map_->event_type_count (), this->supplier_map_->event_type_count ()));
+    }
+
+  delete this->consumer_map_;
+  delete this->supplier_map_;
+  delete this->consumer_map_observer_;
+  delete this->supplier_map_observer_;
+  delete this->event_dispatch_observer_;
+  delete this->updates_dispatch_observer_;
+  delete this->event_pending_worker_;
+  delete this->updates_pending_worker_;
+}
+
+void
+TAO_NS_Event_Manager::init (ACE_ENV_SINGLE_ARG_DECL)
+{
+  ACE_NEW_THROW_EX (this->consumer_map_,
+                    TAO_NS_Consumer_Map (),
+                    CORBA::NO_MEMORY ());
+  ACE_CHECK;
+
+  ACE_NEW_THROW_EX (this->supplier_map_,
+                    TAO_NS_Supplier_Map (),
+                    CORBA::NO_MEMORY ());
+  ACE_CHECK;
+
+  ACE_NEW_THROW_EX (this->consumer_map_observer_,
+                    TAO_NS_Consumer_Map_Observer (),
+                    CORBA::NO_MEMORY ());
+  ACE_CHECK;
+
+
+  ACE_NEW_THROW_EX (this->supplier_map_observer_,
+                    TAO_NS_Supplier_Map_Observer (),
+                    CORBA::NO_MEMORY ());
+  ACE_CHECK;
+
+  ACE_NEW_THROW_EX (this->event_dispatch_observer_,
+                    TAO_NS_Event_Dispatch_Observer (),
+                    CORBA::NO_MEMORY ());
+  ACE_CHECK;
+
+  ACE_NEW_THROW_EX (this->updates_dispatch_observer_,
+                    TAO_NS_Updates_Dispatch_Observer (),
+                    CORBA::NO_MEMORY ());
+  ACE_CHECK;
+
+  ACE_NEW_THROW_EX (this->event_pending_worker_,
+                    TAO_NS_Event_Pending_Worker (),
+                    CORBA::NO_MEMORY ());
+  ACE_CHECK;
+
+  ACE_NEW_THROW_EX (this->updates_pending_worker_,
+                    TAO_NS_Updates_Pending_Worker (),
+                    CORBA::NO_MEMORY ());
+  ACE_CHECK;
+
+  this->consumer_map_->init (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  this->supplier_map_->init (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  this->event_dispatch_observer_->init (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  this->updates_dispatch_observer_->init (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  this->consumer_map_observer_->init (this->supplier_map_, this->updates_dispatch_observer_);
+  ACE_CHECK;
+
+  this->supplier_map_observer_->init (this->consumer_map_, this->updates_dispatch_observer_);
+  ACE_CHECK;
+
+  this->consumer_map_->attach_observer (this->consumer_map_observer_);
+  this->supplier_map_->attach_observer (this->supplier_map_observer_);
+
+  this->event_pending_worker_->init (this->event_dispatch_observer_, TAO_NS_PROPERTIES::instance()->update_period () ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  if (TAO_NS_PROPERTIES::instance()->updates () == 0)
+    this->updates_pending_worker_->worker_suspend ();
+
+  this->updates_pending_worker_->init (this->updates_dispatch_observer_, TAO_NS_PROPERTIES::instance()->update_period () ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+}
+
+void
+TAO_NS_Event_Manager::shutdown (void)
+{
+  this->event_pending_worker_->shutdown ();
+  this->updates_pending_worker_->shutdown ();
+}
+
+void
+TAO_NS_Event_Manager::subscribe (TAO_NS_ProxySupplier* proxy_supplier, const TAO_NS_EventTypeSeq& seq ACE_ENV_ARG_DECL)
+{
+  TAO_NS_EventTypeSeq::CONST_ITERATOR iter (seq);
+
+  TAO_NS_EventType* event_type;
+
+  for (iter.first (); iter.next (event_type) != 0; iter.advance ())
+    {
+      consumer_map_->insert (proxy_supplier, *event_type ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+    }
+}
+
+void
+TAO_NS_Event_Manager::un_subscribe (TAO_NS_ProxySupplier* proxy_supplier, const TAO_NS_EventTypeSeq& seq ACE_ENV_ARG_DECL)
+{
+  TAO_NS_EventTypeSeq::CONST_ITERATOR iter (seq);
+
+  TAO_NS_EventType* event_type = 0;
+
+  for (iter.first (); iter.next (event_type) != 0; iter.advance ())
+    {
+      consumer_map_->remove (proxy_supplier, *event_type ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+    }
+}
+
+void
+TAO_NS_Event_Manager::publish (TAO_NS_ProxyConsumer* proxy_consumer, const TAO_NS_EventTypeSeq& seq ACE_ENV_ARG_DECL)
+{
+  TAO_NS_EventTypeSeq::CONST_ITERATOR iter (seq);
+
+  TAO_NS_EventType* event_type = 0;
+
+  for (iter.first (); iter.next (event_type) != 0; iter.advance ())
+    {
+      supplier_map_->insert (proxy_consumer, *event_type ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+    }
+
+}
+
+void
+TAO_NS_Event_Manager::un_publish (TAO_NS_ProxyConsumer* proxy_consumer, const TAO_NS_EventTypeSeq& seq ACE_ENV_ARG_DECL)
+{
+  TAO_NS_EventTypeSeq::CONST_ITERATOR iter (seq);
+
+  TAO_NS_EventType* event_type = 0;
+
+  for (iter.first (); iter.next (event_type) != 0; iter.advance ())
+    {
+      supplier_map_->remove (proxy_consumer, *event_type ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+    }
+}
+
+#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
+
+template class TAO_NS_Event_Map_T<TAO_NS_ProxySupplier, TAO_SYNCH_RW_MUTEX>;
+template class TAO_NS_Event_Map_T<TAO_NS_ProxyConsumer, TAO_SYNCH_RW_MUTEX>;
+
+template class TAO_NS_Event_Map_Observer_T<TAO_NS_ProxyConsumer>;
+template class TAO_NS_Event_Map_Observer_T<TAO_NS_ProxySupplier>;
+
+template class TAO_NS_Dispatch_Observer_T<TAO_NS_Peer>;
+template class TAO_NS_Dispatch_Observer_T<TAO_NS_Consumer>;
+
+template class TAO_NS_Pending_Worker_T<TAO_NS_Peer>;
+template class TAO_NS_Pending_Worker_T<TAO_NS_Consumer>;
+
+template class TAO_NS_Dispatch_Pending_Worker_T<TAO_NS_Consumer>;
+template class TAO_NS_Dispatch_Pending_Worker_T<TAO_NS_Peer>;
+
+template class TAO_NS_Update_Removed_Worker<TAO_NS_ProxyConsumer>;
+template class TAO_NS_Update_Removed_Worker<TAO_NS_ProxySupplier>;
+template class TAO_NS_Update_Added_Worker<TAO_NS_ProxyConsumer>;
+
+template class ACE_Hash<TAO_NS_EventType>;
+template class ACE_Equal_To<TAO_NS_EventType>;
+
+template class TAO_NS_Event_Map_Entry_T<TAO_NS_ProxyConsumer>;
+template class TAO_NS_Event_Map_Entry_T<TAO_NS_ProxySupplier>;
+
+template class ACE_Hash_Map_Manager_Ex<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxyConsumer> *, ACE_Hash<TAO_NS_EventType>, ACE_Equal_To<TAO_NS_EventType>, ACE_Null_Mutex>;
+template class ACE_Hash_Map_Manager_Ex<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxySupplier> *, ACE_Hash<TAO_NS_EventType>, ACE_Equal_To<TAO_NS_EventType>, ACE_Null_Mutex>;
+template class ACE_Hash_Map_Manager<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxySupplier> *, ACE_Null_Mutex>;
+template class ACE_Hash_Map_Manager<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxyConsumer> *, ACE_Null_Mutex>;
+template class ACE_Hash_Map_Manager<ACE_CString, CORBA_Any, ACE_Null_Mutex>;
+
+template class TAO_NS_Object_Find_Worker_T<TAO_NS_Proxy>;
+template class TAO_NS_Object_Find_Worker_T<TAO_NS_Admin>;
+template class TAO_NS_Object_Find_Worker_T<TAO_NS_EventChannel>;
+
+template class TAO_NS_Update_Added_Worker<TAO_NS_ProxySupplier>;
+
+template class ACE_Unbounded_Set<TAO_NS_EventType>;
+template class ACE_Unbounded_Set_Const_Iterator<TAO_NS_EventType>;
+template class ACE_Unbounded_Queue<ACE_Refcounted_Auto_Ptr<TAO_NS_Event, TAO_SYNCH_MUTEX> >;
+template class ACE_Unbounded_Set_Iterator<TAO_NS_EventType>;
+
+template class TAO_ESF_Worker<TAO_NS_ProxySupplier>;
+template class TAO_ESF_Worker<TAO_NS_ProxyConsumer>;
+template class TAO_ESF_Worker<TAO_NS_Proxy>;
+template class TAO_ESF_Worker<TAO_NS_Consumer>;
+template class TAO_ESF_Worker<TAO_NS_Peer>;
+template class TAO_ESF_Worker<TAO_NS_Admin>;
+template class TAO_ESF_Worker<TAO_NS_EventChannel>;
+
+template class ACE_Refcounted_Auto_Ptr<TAO_NS_Event, TAO_SYNCH_MUTEX>;
+template class ACE_Unbounded_Queue_Iterator<ACE_Refcounted_Auto_Ptr<TAO_NS_Event, TAO_SYNCH_MUTEX> >;
+
+template class ACE_Node<ACE_Refcounted_Auto_Ptr<TAO_NS_Event, TAO_SYNCH_MUTEX > >;
+template class ACE_Node<TAO_NS_Supplier *>;
+template class ACE_Node<TAO_NS_Admin *>;
+template class ACE_Node<TAO_NS_EventChannel *>;
+template class ACE_Node<TAO_NS_ProxyConsumer *>;
+template class ACE_Node<TAO_NS_EventType>;
+template class ACE_Node<TAO_NS_Peer *>;
+template class ACE_Node<TAO_NS_ProxySupplier *>;
+template class ACE_Node<TAO_NS_Proxy *>;
+template class ACE_Node<TAO_NS_Consumer *>;
+
+template class ACE_Hash_Map_Entry<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxyConsumer> *>;
+template class ACE_Hash_Map_Entry<ACE_CString, CORBA_Any>;
+template class ACE_Hash_Map_Entry<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxySupplier> *>;
+
+template class ACE_Hash_Map_Iterator_Base_Ex<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxySupplier> *, ACE_Hash<TAO_NS_EventType>, ACE_Equal_To<TAO_NS_EventType>, ACE_Null_Mutex>;
+template class ACE_Hash_Map_Iterator_Base_Ex<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxyConsumer> *, ACE_Hash<TAO_NS_EventType>, ACE_Equal_To<TAO_NS_EventType>, ACE_Null_Mutex>;
+
+template class ACE_Hash_Map_Manager_Ex<ACE_CString, CORBA_Any, ACE_Hash<ACE_CString >, ACE_Equal_To<ACE_CString >, ACE_Null_Mutex>;
+
+template class ACE_Hash_Map_Iterator_Base_Ex<ACE_CString, CORBA_Any, ACE_Hash<ACE_CString >, ACE_Equal_To<ACE_CString >, ACE_Null_Mutex>;
+
+template class TAO_ESF_Shutdown_Proxy<TAO_NS_EventChannel>;
+template class TAO_ESF_Shutdown_Proxy<TAO_NS_Admin>;
+template class TAO_ESF_Shutdown_Proxy<TAO_NS_Proxy>;
+
+#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
+
+#pragma instantiate TAO_NS_Event_Map_T<TAO_NS_ProxySupplier, TAO_SYNCH_RW_MUTEX>
+#pragma instantiate TAO_NS_Event_Map_T<TAO_NS_ProxyConsumer, TAO_SYNCH_RW_MUTEX>
+
+#pragma instantiate TAO_NS_Event_Map_Observer_T<TAO_NS_ProxyConsumer>
+#pragma instantiate TAO_NS_Event_Map_Observer_T<TAO_NS_ProxySupplier>
+
+#pragma instantiate TAO_NS_Dispatch_Observer_T<TAO_NS_Peer>
+#pragma instantiate TAO_NS_Dispatch_Observer_T<TAO_NS_Consumer>
+
+#pragma instantiate TAO_NS_Pending_Worker_T<TAO_NS_Peer>
+#pragma instantiate TAO_NS_Pending_Worker_T<TAO_NS_Consumer>
+
+#pragma instantiate TAO_NS_Dispatch_Pending_Worker_T<TAO_NS_Consumer>
+#pragma instantiate TAO_NS_Dispatch_Pending_Worker_T<TAO_NS_Peer>
+
+#pragma instantiate TAO_NS_Update_Removed_Worker<TAO_NS_ProxyConsumer>
+#pragma instantiate TAO_NS_Update_Removed_Worker<TAO_NS_ProxySupplier>
+#pragma instantiate TAO_NS_Update_Added_Worker<TAO_NS_ProxyConsumer>
+
+#pragma instantiate ACE_Hash<TAO_NS_EventType>
+#pragma instantiate ACE_Equal_To<TAO_NS_EventType>
+
+#pragma instantiate TAO_NS_Event_Map_Entry_T<TAO_NS_ProxyConsumer>
+#pragma instantiate TAO_NS_Event_Map_Entry_T<TAO_NS_ProxySupplier>
+
+#pragma instantiate ACE_Hash_Map_Manager_Ex<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxyConsumer> *, ACE_Hash<TAO_NS_EventType>, ACE_Equal_To<TAO_NS_EventType>, ACE_Null_Mutex>
+#pragma instantiate ACE_Hash_Map_Manager_Ex<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxySupplier> *, ACE_Hash<TAO_NS_EventType>, ACE_Equal_To<TAO_NS_EventType>, ACE_Null_Mutex>
+#pragma instantiate ACE_Hash_Map_Manager<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxySupplier> *, ACE_Null_Mutex>
+#pragma instantiate ACE_Hash_Map_Manager<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxyConsumer> *, ACE_Null_Mutex>
+#pragma instantiate ACE_Hash_Map_Manager<ACE_CString, CORBA_Any, ACE_Null_Mutex>
+
+#pragma instantiate TAO_NS_Object_Find_Worker_T<TAO_NS_Proxy>
+#pragma instantiate TAO_NS_Object_Find_Worker_T<TAO_NS_Admin>
+#pragma instantiate TAO_NS_Object_Find_Worker_T<TAO_NS_EventChannel>
+
+#pragma instantiate TAO_NS_Update_Added_Worker<TAO_NS_ProxySupplier>
+
+#pragma instantiate ACE_Unbounded_Set<TAO_NS_EventType>
+#pragma instantiate ACE_Unbounded_Set_Const_Iterator<TAO_NS_EventType>
+#pragma instantiate ACE_Unbounded_Queue<ACE_Refcounted_Auto_Ptr<TAO_NS_Event, TAO_SYNCH_MUTEX> >
+#pragma instantiate ACE_Unbounded_Set_Iterator<TAO_NS_EventType>
+
+#pragma instantiate TAO_ESF_Worker<TAO_NS_ProxySupplier>
+#pragma instantiate TAO_ESF_Worker<TAO_NS_ProxyConsumer>
+#pragma instantiate TAO_ESF_Worker<TAO_NS_Proxy>
+#pragma instantiate TAO_ESF_Worker<TAO_NS_Consumer>
+#pragma instantiate TAO_ESF_Worker<TAO_NS_Peer>
+#pragma instantiate TAO_ESF_Worker<TAO_NS_Admin>
+#pragma instantiate TAO_ESF_Worker<TAO_NS_EventChannel>
+
+#pragma instantiate ACE_Refcounted_Auto_Ptr<TAO_NS_Event, TAO_SYNCH_MUTEX>
+#pragma instantiate ACE_Unbounded_Queue_Iterator<ACE_Refcounted_Auto_Ptr<TAO_NS_Event, TAO_SYNCH_MUTEX> >
+
+#pragma instantiate ACE_Node<ACE_Refcounted_Auto_Ptr<TAO_NS_Event, TAO_SYNCH_MUTEX > >
+#pragma instantiate ACE_Node<TAO_NS_Supplier *>
+#pragma instantiate ACE_Node<TAO_NS_Admin *>
+#pragma instantiate ACE_Node<TAO_NS_EventChannel *>
+#pragma instantiate ACE_Node<TAO_NS_ProxyConsumer *>
+#pragma instantiate ACE_Node<TAO_NS_EventType>
+#pragma instantiate ACE_Node<TAO_NS_Peer *>
+#pragma instantiate ACE_Node<TAO_NS_ProxySupplier *>
+#pragma instantiate ACE_Node<TAO_NS_Proxy *>
+#pragma instantiate ACE_Node<TAO_NS_Consumer *>
+
+#pragma instantiate ACE_Hash_Map_Entry<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxyConsumer> *>
+#pragma instantiate ACE_Hash_Map_Entry<ACE_CString, CORBA_Any>
+#pragma instantiate ACE_Hash_Map_Entry<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxySupplier> *>
+
+#pragma instantiate ACE_Hash_Map_Iterator_Base_Ex<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxySupplier> *, ACE_Hash<TAO_NS_EventType>, ACE_Equal_To<TAO_NS_EventType>, ACE_Null_Mutex>
+#pragma instantiate ACE_Hash_Map_Iterator_Base_Ex<TAO_NS_EventType, TAO_NS_Event_Map_Entry_T<TAO_NS_ProxyConsumer> *, ACE_Hash<TAO_NS_EventType>, ACE_Equal_To<TAO_NS_EventType>, ACE_Null_Mutex>
+
+#pragma instantiate ACE_Hash_Map_Manager_Ex<ACE_CString, CORBA_Any, ACE_Hash<ACE_CString >, ACE_Equal_To<ACE_CString >, ACE_Null_Mutex>
+
+#pragma instantiate ACE_Hash_Map_Iterator_Base_Ex<ACE_CString, CORBA_Any, ACE_Hash<ACE_CString >, ACE_Equal_To<ACE_CString >, ACE_Null_Mutex>
+
+#pragma instantiate TAO_ESF_Shutdown_Proxy<TAO_NS_EventChannel>
+#pragma instantiate TAO_ESF_Shutdown_Proxy<TAO_NS_Admin>
+#pragma instantiate TAO_ESF_Shutdown_Proxy<TAO_NS_Proxy>
+
+#endif /*ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */