/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/ |
H A D | server.cpp | 286 class CFatalRequest_ForServer : public CStdRequest 298 CRef<CStdRequest> poison(new CFatalRequest_ForServer); in KillAllThreads() 344 class CServer_Request : public CStdRequest 509 CStdRequest* 520 CStdRequest* 681 CRef<CStdRequest> req(conn_base->CreateRequest( in x_DoRun() 688 CRef<CStdRequest> req(conn_base->CreateRequest( in x_DoRun() 695 CRef<CStdRequest> req(conn_base->CreateRequest( in x_DoRun() 741 CRef<CStdRequest> req(conn_base->CreateRequest( in x_DoRun() 762 CRef<CStdRequest> req(conn_base->CreateRequest( in x_DoRun() [all …]
|
H A D | threaded_server.cpp | 44 class CSocketRequest : public CStdRequest 114 (CRef<ncbi::CStdRequest> in Run()
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/connect/ |
H A D | server.cpp | 286 class CFatalRequest_ForServer : public CStdRequest 298 CRef<CStdRequest> poison(new CFatalRequest_ForServer); in KillAllThreads() 344 class CServer_Request : public CStdRequest 509 CStdRequest* 520 CStdRequest* 681 CRef<CStdRequest> req(conn_base->CreateRequest( in x_DoRun() 688 CRef<CStdRequest> req(conn_base->CreateRequest( in x_DoRun() 695 CRef<CStdRequest> req(conn_base->CreateRequest( in x_DoRun() 741 CRef<CStdRequest> req(conn_base->CreateRequest( in x_DoRun() 762 CRef<CStdRequest> req(conn_base->CreateRequest( in x_DoRun() [all …]
|
H A D | threaded_server.cpp | 44 class CSocketRequest : public CStdRequest 114 (CRef<ncbi::CStdRequest> in Run()
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/connect/impl/ |
H A D | server_connection.hpp | 69 virtual CStdRequest* CreateRequest(EServIO_Event event, 98 virtual CStdRequest* CreateRequest(EServIO_Event event, 124 virtual CStdRequest* CreateRequest(EServIO_Event event,
|
H A D | thread_pool_for_server.hpp | 72 typedef CRef<CStdRequest> TRequest;
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/connect/impl/ |
H A D | server_connection.hpp | 69 virtual CStdRequest* CreateRequest(EServIO_Event event, 98 virtual CStdRequest* CreateRequest(EServIO_Event event, 124 virtual CStdRequest* CreateRequest(EServIO_Event event,
|
H A D | thread_pool_for_server.hpp | 72 typedef CRef<CStdRequest> TRequest;
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/test/ |
H A D | test_threaded_client.cpp | 55 class CConnectionRequest : public CStdRequest 170 pool.AcceptRequest(CRef<ncbi::CStdRequest> in Run() 177 pool.AcceptRequest(CRef<ncbi::CStdRequest> in Run()
|
H A D | test_server.cpp | 252 class CConnectionRequest : public CStdRequest 414 pool.AcceptRequest(CRef<ncbi::CStdRequest> in Run()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/util/ |
H A D | thread_pool_old.hpp | 541 class CStdRequest : public CObject class 545 virtual ~CStdRequest(void) {} in ~CStdRequest() 560 void CBlockingQueue<CRef<CStdRequest> >::CQueueItem::x_SetStatus in x_SetStatus() 575 : public CThreadInPool< CRef< CStdRequest > > 578 typedef CThreadInPool< CRef< CStdRequest > > TParent; 594 virtual void ProcessRequest(const CRef<CStdRequest>& req) in ProcessRequest() 595 { const_cast<CStdRequest&>(*req).Process(); } in ProcessRequest() 607 : public CPoolOfThreads< CRef< CStdRequest > > 610 typedef CPoolOfThreads< CRef< CStdRequest > > TParent;
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/util/ |
H A D | thread_pool_old.hpp | 541 class CStdRequest : public CObject class 545 virtual ~CStdRequest(void) {} in ~CStdRequest() 560 void CBlockingQueue<CRef<CStdRequest> >::CQueueItem::x_SetStatus in x_SetStatus() 575 : public CThreadInPool< CRef< CStdRequest > > 578 typedef CThreadInPool< CRef< CStdRequest > > TParent; 594 virtual void ProcessRequest(const CRef<CStdRequest>& req) in ProcessRequest() 595 { const_cast<CStdRequest&>(*req).Process(); } in ProcessRequest() 607 : public CPoolOfThreads< CRef< CStdRequest > > 610 typedef CPoolOfThreads< CRef< CStdRequest > > TParent;
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/util/ |
H A D | thread_pool_old.cpp | 44 class CFatalRequest : public CStdRequest 75 CRef<CStdRequest> poison(new CFatalRequest); in KillAllThreads()
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/util/ |
H A D | thread_pool_old.cpp | 44 class CFatalRequest : public CStdRequest 75 CRef<CStdRequest> poison(new CFatalRequest); in KillAllThreads()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/util/test/ |
H A D | test_thread_pool_old.cpp | 91 class CTestRequest : public CStdRequest 146 pool.AcceptRequest(CRef<CStdRequest>(new CTestRequest(i + 1, in Run()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/app/netcache/test/ |
H A D | test_nc_stress_pubmed.cpp | 232 class CReadTask : public CStdRequest 249 class CDelayedReadTask : public CStdRequest 346 … readThreadPool.AcceptRequest(CRef<CStdRequest>(new CReadTask(this, cln, NcKey))); in DoWrite() 437 … drThreadPool.AcceptRequest(CRef<CStdRequest>(new CDelayedReadTask(this, cln, (*Pos).NcKey()))); in CheckReadDelayed() 521 class CWriteTask : public CStdRequest 660 … writeThreadPool.AcceptRequest(CRef<CStdRequest>(new CWriteTask(pPotam, cln))); in Stress()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/services/test/ |
H A D | test_compound_id.cpp | 54 class CCompoundIDTestRequest : public CStdRequest 257 pool.AcceptRequest(CRef<ncbi::CStdRequest>(new CCompoundIDTestRequest( in Run()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/connect/ |
H A D | server.hpp | 130 void SubmitRequest(const CRef<CStdRequest>& request);
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/connect/ |
H A D | server.hpp | 130 void SubmitRequest(const CRef<CStdRequest>& request);
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/services/ |
H A D | wn_offline_mode.cpp | 247 m_ThreadPool->AcceptRequest(CRef<CStdRequest>( in OfflineRun()
|
H A D | grid_worker_impl.hpp | 317 class CWorkerNodeRequest : public CStdRequest
|
H A D | wn_main_loop.cpp | 585 m_WorkerNode->m_ThreadPool->AcceptRequest(CRef<CStdRequest>( in Main()
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/connect/services/ |
H A D | wn_offline_mode.cpp | 247 m_ThreadPool->AcceptRequest(CRef<CStdRequest>( in OfflineRun()
|
H A D | grid_worker_impl.hpp | 317 class CWorkerNodeRequest : public CStdRequest
|
H A D | wn_main_loop.cpp | 584 m_WorkerNode->m_ThreadPool->AcceptRequest(CRef<CStdRequest>( in Main()
|