Home
last modified time | relevance | path

Searched refs:CStdRequest (Results 1 – 25 of 25) sorted by relevance

/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/
H A Dserver.cpp286 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 Dthreaded_server.cpp44 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 Dserver.cpp286 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 Dthreaded_server.cpp44 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 Dserver_connection.hpp69 virtual CStdRequest* CreateRequest(EServIO_Event event,
98 virtual CStdRequest* CreateRequest(EServIO_Event event,
124 virtual CStdRequest* CreateRequest(EServIO_Event event,
H A Dthread_pool_for_server.hpp72 typedef CRef<CStdRequest> TRequest;
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/connect/impl/
H A Dserver_connection.hpp69 virtual CStdRequest* CreateRequest(EServIO_Event event,
98 virtual CStdRequest* CreateRequest(EServIO_Event event,
124 virtual CStdRequest* CreateRequest(EServIO_Event event,
H A Dthread_pool_for_server.hpp72 typedef CRef<CStdRequest> TRequest;
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/test/
H A Dtest_threaded_client.cpp55 class CConnectionRequest : public CStdRequest
170 pool.AcceptRequest(CRef<ncbi::CStdRequest> in Run()
177 pool.AcceptRequest(CRef<ncbi::CStdRequest> in Run()
H A Dtest_server.cpp252 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 Dthread_pool_old.hpp541 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 Dthread_pool_old.hpp541 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 Dthread_pool_old.cpp44 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 Dthread_pool_old.cpp44 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 Dtest_thread_pool_old.cpp91 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 Dtest_nc_stress_pubmed.cpp232 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 Dtest_compound_id.cpp54 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 Dserver.hpp130 void SubmitRequest(const CRef<CStdRequest>& request);
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/connect/
H A Dserver.hpp130 void SubmitRequest(const CRef<CStdRequest>& request);
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/services/
H A Dwn_offline_mode.cpp247 m_ThreadPool->AcceptRequest(CRef<CStdRequest>( in OfflineRun()
H A Dgrid_worker_impl.hpp317 class CWorkerNodeRequest : public CStdRequest
H A Dwn_main_loop.cpp585 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 Dwn_offline_mode.cpp247 m_ThreadPool->AcceptRequest(CRef<CStdRequest>( in OfflineRun()
H A Dgrid_worker_impl.hpp317 class CWorkerNodeRequest : public CStdRequest
H A Dwn_main_loop.cpp584 m_WorkerNode->m_ThreadPool->AcceptRequest(CRef<CStdRequest>( in Main()