diff options
Diffstat (limited to 'ace')
-rw-r--r-- | ace/Malloc_T.cpp | 4 | ||||
-rw-r--r-- | ace/Thread_Manager.cpp | 14 | ||||
-rwxr-xr-x | ace/ace.icc | 3 |
3 files changed, 14 insertions, 7 deletions
diff --git a/ace/Malloc_T.cpp b/ace/Malloc_T.cpp index 084331b08b9..08de9b70109 100644 --- a/ace/Malloc_T.cpp +++ b/ace/Malloc_T.cpp @@ -258,7 +258,7 @@ ACE_Malloc_T<ACE_MEM_POOL_2, ACE_LOCK, ACE_CB>::ACE_Malloc_T (const ACE_TCHAR *p ACE_TRACE ("ACE_Malloc_T<ACE_MEM_POOL_2, ACE_LOCK, ACE_CB>::ACE_Malloc_T"); if (this->open () == -1) ACE_ERROR ((LM_ERROR, - ACE_LIB_TEXT ("%p"), + ACE_LIB_TEXT ("%p\n"), ACE_LIB_TEXT ("ACE_Malloc_T<ACE_MEM_POOL_2, ACE_LOCK, ACE_CB>::ACE_Malloc_T"))); } @@ -274,7 +274,7 @@ ACE_Malloc_T<ACE_MEM_POOL_2, ACE_LOCK, ACE_CB>::ACE_Malloc_T (const ACE_TCHAR *p ACE_TRACE ("ACE_Malloc_T<ACE_MEM_POOL_2, ACE_LOCK, ACE_CB>::ACE_Malloc_T"); if (this->open () == -1) ACE_ERROR ((LM_ERROR, - ACE_LIB_TEXT ("%p"), + ACE_LIB_TEXT ("%p\n"), ACE_LIB_TEXT ("ACE_Malloc_T<ACE_MEM_POOL_2, ACE_LOCK, ACE_CB>::ACE_Malloc_T"))); } #endif /* ACE_HAS_TEMPLATE_TYPEDEFS */ diff --git a/ace/Thread_Manager.cpp b/ace/Thread_Manager.cpp index a9578efc99b..e1035372ebe 100644 --- a/ace/Thread_Manager.cpp +++ b/ace/Thread_Manager.cpp @@ -1975,7 +1975,6 @@ ACE_Thread_Manager::task_all_list (ACE_Task_Base *task_list[], ACE_TRACE ("ACE_Thread_Manager::task_all_list"); ACE_MT (ACE_GUARD_RETURN (ACE_Thread_Mutex, ace_mon, this->lock_, -1)); - ACE_Task_Base **task_list_iterator = task_list; size_t task_list_count = 0; for (ACE_Double_Linked_List_Iterator<ACE_Thread_Descriptor> iter (this->thr_list_); @@ -1985,10 +1984,17 @@ ACE_Thread_Manager::task_all_list (ACE_Task_Base *task_list[], if (task_list_count >= n) break; - if ( iter.next ()->task_ ) + ACE_Task_Base *task_p = iter.next ()->task_; + if (0 != task_p) { - task_list_iterator[task_list_count] = iter.next ()->task_; - task_list_count++; + // This thread has a task pointer; see if it's already in the + // list. Don't add duplicates. + size_t i = 0; + for (; i < task_list_count; ++i) + if (task_list[i] == task_p) + break; + if (i == task_list_count) // No match - add this one + task_list[task_list_count++] = task_p; } } diff --git a/ace/ace.icc b/ace/ace.icc index 09c3bb81239..b0f228139ac 100755 --- a/ace/ace.icc +++ b/ace/ace.icc @@ -403,7 +403,7 @@ group MEMORY_FILES = "Malloc_Allocator.cpp", "Mem_Map.cpp", "Memory_Pool.cpp", - "Obstack.cpp", + "Obchunk.cpp", "Read_Buffer.cpp", "Shared_Memory.cpp", "Shared_Memory_MM.cpp", @@ -416,6 +416,7 @@ group MEMORY_INCLUDES = "Malloc_Allocator.h", "Mem_Map.h", "Memory_Pool.h", + "Obchunk.h", "Obstack.h", "Read_Buffer.h", "Shared_Memory.h", |