| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/util/ |
| H A D | thread_pool_old.cpp | 57 old_max = m_MaxThreads; in KillAllThreads()
59 m_MaxThreads = 0; // Forbid spawning new threads in KillAllThreads()
97 m_MaxThreads = old_max; in KillAllThreads()
105 if (m_MaxThreads > 0) { in Register()
116 if (m_MaxThreads > 0) { in UnRegister()
|
| H A D | thread_pool.cpp | 1996 m_MaxThreads(max_threads), in CThreadPool_Controller()
2038 if (count > m_MaxThreads) { in EnsureLimits()
2039 pool->FinishThreads(count - m_MaxThreads); in EnsureLimits()
2065 m_MaxThreads = max_threads; in SetMaxThreads()
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/util/ |
| H A D | thread_pool_old.cpp | 57 old_max = m_MaxThreads; in KillAllThreads()
59 m_MaxThreads = 0; // Forbid spawning new threads in KillAllThreads()
97 m_MaxThreads = old_max; in KillAllThreads()
105 if (m_MaxThreads > 0) { in Register()
116 if (m_MaxThreads > 0) { in UnRegister()
|
| H A D | thread_pool.cpp | 1996 m_MaxThreads(max_threads), in CThreadPool_Controller()
2038 if (count > m_MaxThreads) { in EnsureLimits()
2039 pool->FinishThreads(count - m_MaxThreads); in EnsureLimits()
2065 m_MaxThreads = max_threads; in SetMaxThreads()
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/ |
| H A D | threaded_server.cpp | 84 m_MaxThreads < m_InitThreads || m_MaxThreads > 1000) { in Run()
91 CStdPoolOfThreads pool(m_MaxThreads, m_QueueSize, m_SpawnThreshold); in Run()
|
| H A D | server.cpp | 241 : m_MaxThreads(max_threads), in CPoolOfThreads_ForServer()
300 for (TACValue i = 0; i < m_MaxThreads; ++i) { in KillAllThreads()
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/connect/ |
| H A D | threaded_server.cpp | 84 m_MaxThreads < m_InitThreads || m_MaxThreads > 1000) { in Run()
91 CStdPoolOfThreads pool(m_MaxThreads, m_QueueSize, m_SpawnThreshold); in Run()
|
| H A D | server.cpp | 241 : m_MaxThreads(max_threads), in CPoolOfThreads_ForServer()
300 for (TACValue i = 0; i < m_MaxThreads; ++i) { in KillAllThreads()
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/connect/ |
| H A D | threaded_server.hpp | 82 m_InitThreads(5), m_MaxThreads(10), m_QueueSize(20),
126 unsigned int m_MaxThreads; ///< Maximum simultaneous threads
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/connect/ |
| H A D | threaded_server.hpp | 82 m_InitThreads(5), m_MaxThreads(10), m_QueueSize(20),
126 unsigned int m_MaxThreads; ///< Maximum simultaneous threads
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/services/ |
| H A D | grid_worker.cpp | 357 m_MaxThreads(1), in SGridWorkerNodeImpl()
439 m_MaxThreads = CSystemInfo::GetCpuCount(); in x_WNCoreInit()
442 m_MaxThreads = NStr::StringToUInt(max_threads); in x_WNCoreInit()
445 m_MaxThreads = CSystemInfo::GetCpuCount(); in x_WNCoreInit()
448 "Using \'auto\' option (" << m_MaxThreads << ")."); in x_WNCoreInit()
475 _ASSERT(m_MaxThreads > 0); in x_StartWorkerThreads()
478 m_ThreadPool = new CStdPoolOfThreads(m_MaxThreads, 0, 1, kMax_UInt, in x_StartWorkerThreads()
484 m_ThreadPool->Spawn(init_threads <= m_MaxThreads ? in x_StartWorkerThreads()
485 init_threads : m_MaxThreads); in x_StartWorkerThreads()
813 "Maximum job threads: " << m_MaxThreads << "\n"); in Run()
[all …]
|
| H A D | grid_worker_impl.hpp | 219 unsigned int m_MaxThreads; member
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/connect/services/ |
| H A D | grid_worker.cpp | 357 m_MaxThreads(1), in SGridWorkerNodeImpl()
439 m_MaxThreads = CSystemInfo::GetCpuCount(); in x_WNCoreInit()
442 m_MaxThreads = NStr::StringToUInt(max_threads); in x_WNCoreInit()
445 m_MaxThreads = CSystemInfo::GetCpuCount(); in x_WNCoreInit()
448 "Using \'auto\' option (" << m_MaxThreads << ")."); in x_WNCoreInit()
475 _ASSERT(m_MaxThreads > 0); in x_StartWorkerThreads()
478 m_ThreadPool = new CStdPoolOfThreads(m_MaxThreads, 0, 1, kMax_UInt, in x_StartWorkerThreads()
484 m_ThreadPool->Spawn(init_threads <= m_MaxThreads ? in x_StartWorkerThreads()
485 init_threads : m_MaxThreads); in x_StartWorkerThreads()
813 "Maximum job threads: " << m_MaxThreads << "\n"); in Run()
[all …]
|
| H A D | grid_worker_impl.hpp | 219 unsigned int m_MaxThreads; member
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/util/ |
| H A D | thread_pool.hpp | 593 unsigned int m_MaxThreads; member in CThreadPool_Controller
666 return m_MaxThreads; in GetMaxThreads()
|
| H A D | thread_pool_old.hpp | 502 volatile TACValue m_MaxThreads; member in CPoolOfThreads
1060 : m_MaxThreads(max_threads), m_MaxUrgentThreads(max_urgent_threads), in CPoolOfThreads()
1123 } else if (m_ThreadCount.Get() < m_MaxThreads) { in HasImmediateRoom()
1180 && m_ThreadCount.Get() < m_MaxThreads) { in x_AcceptRequest()
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/util/ |
| H A D | thread_pool.hpp | 593 unsigned int m_MaxThreads; member in CThreadPool_Controller
666 return m_MaxThreads; in GetMaxThreads()
|
| H A D | thread_pool_old.hpp | 502 volatile TACValue m_MaxThreads; member in CPoolOfThreads
1060 : m_MaxThreads(max_threads), m_MaxUrgentThreads(max_urgent_threads), in CPoolOfThreads()
1123 } else if (m_ThreadCount.Get() < m_MaxThreads) { in HasImmediateRoom()
1180 && m_ThreadCount.Get() < m_MaxThreads) { in x_AcceptRequest()
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/test/ |
| H A D | test_threaded_server.cpp | 51 m_MaxThreads = max; in CTestThreadedServer()
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/connect/impl/ |
| H A D | thread_pool_for_server.hpp | 275 volatile TACValue m_MaxThreads; member in CPoolOfThreads_ForServer
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/connect/impl/ |
| H A D | thread_pool_for_server.hpp | 275 volatile TACValue m_MaxThreads; member in CPoolOfThreads_ForServer
|