summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Notify
diff options
context:
space:
mode:
authorpradeep <pradeep@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2000-09-25 21:18:51 +0000
committerpradeep <pradeep@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2000-09-25 21:18:51 +0000
commit989b3471268d65ca297e20abf50a6764f17e76aa (patch)
tree7d92f5f3c00705972d5a123b5197fa530148abeb /TAO/orbsvcs/orbsvcs/Notify
parent47622ff8be27be8ddd0044cbfb3762447b165688 (diff)
downloadATCD-989b3471268d65ca297e20abf50a6764f17e76aa.tar.gz
Mon Sep 25 16:17:01 2000 Pradeep Gore <pradeep@cs.wustl.edu>
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify')
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/Notify_AdminProperties.cpp4
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/Notify_Default_Collection_Factory.cpp8
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/Notify_Default_EMO_Factory.cpp10
3 files changed, 14 insertions, 8 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Notify_AdminProperties.cpp b/TAO/orbsvcs/orbsvcs/Notify/Notify_AdminProperties.cpp
index ac06bb90187..866a1074e62 100644
--- a/TAO/orbsvcs/orbsvcs/Notify/Notify_AdminProperties.cpp
+++ b/TAO/orbsvcs/orbsvcs/Notify/Notify_AdminProperties.cpp
@@ -90,10 +90,10 @@ TAO_Notify_AdminProperties::set_admin (const CosNotification::AdminProperties &
#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
-template class ACE_Atomic_Op<ACE_Thread_Mutex,int>;
+template class ACE_Atomic_Op<ACE_SYNCH_MUTEX,int>;
#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
-#pragma instantiate ACE_Atomic_Op<ACE_Thread_Mutex,int>
+#pragma instantiate ACE_Atomic_Op<ACE_SYNCH_MUTEX,int>
#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_Collection_Factory.cpp b/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_Collection_Factory.cpp
index 6ec821f9dbe..aa80e6b62e2 100644
--- a/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_Collection_Factory.cpp
+++ b/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_Collection_Factory.cpp
@@ -132,6 +132,10 @@ template class TAO_ESF_Proxy_Collection<TAO_Notify_EventListener>;
template class TAO_ESF_Proxy_List<TAO_Notify_UpdateListener>;
template class TAO_ESF_Proxy_Collection<TAO_Notify_UpdateListener>;
+template class TAO_ESF_Copy_On_Write_Read_Guard<TAO_ESF_Proxy_List<TAO_Notify_EventListener>, ACE_Unbounded_Set_Iterator<TAO_Notify_EventListener*>, ACE_SYNCH_MUTEX>;
+
+template class TAO_ESF_Copy_On_Write_Read_Guard<TAO_ESF_Proxy_List<TAO_Notify_UpdateListener>, ACE_Unbounded_Set_Iterator<TAO_Notify_UpdateListener*>, ACE_SYNCH_MUTEX>;
+
#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
#pragma instantiate TAO_ESF_Worker<TAO_Notify_EventListener>
@@ -163,4 +167,8 @@ TAO_ESF_Proxy_List<TAO_Notify_UpdateListener>,
#pragma instantiate TAO_ESF_Proxy_List<TAO_Notify_UpdateListener>
#pragma instantiate TAO_ESF_Proxy_Collection<TAO_Notify_UpdateListener>
+#pragma instantiate TAO_ESF_Copy_On_Write_Read_Guard<TAO_ESF_Proxy_List<TAO_Notify_EventListener>, ACE_Unbounded_Set_Iterator<TAO_Notify_EventListener*>, ACE_SYNCH_MUTEX>
+
+#pragma instantiate TAO_ESF_Copy_On_Write_Read_Guard<TAO_ESF_Proxy_List<TAO_Notify_UpdateListener>, ACE_Unbounded_Set_Iterator<TAO_Notify_UpdateListener*>, ACE_SYNCH_MUTEX>
+
#endif /*ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_EMO_Factory.cpp b/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_EMO_Factory.cpp
index 595a4e891d3..2231bb97ff3 100644
--- a/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_EMO_Factory.cpp
+++ b/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_EMO_Factory.cpp
@@ -190,16 +190,14 @@ TAO_Notify_Default_EMO_Factory::create_dispatching_task (CORBA::Environment &ACE
int dispatching_threads_flags =
THR_SCHED_DEFAULT|THR_BOUND|THR_NEW_LWP;
- int dispatching_threads_priority =
- ACE_THR_PRI_OTHER_MIN;
- // ACE_THR_PRI_OTHER_DEF;
- // ACE_THR_PRI_OTHER_DEF;
+ // int dispatching_threads_priority
+
+ // Later: give the user options to specify threads flags and thread priority for each task.
if (this->mt_dispatching_ == 1)
ACE_NEW_THROW_EX (task, TAO_Notify_MT_Worker_Task (this->dispatching_threads_,
dispatching_threads_flags,
- 0,
- dispatching_threads_priority),
+ 0),
CORBA::NO_MEMORY ());
else
ACE_NEW_THROW_EX (task,