/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/services/ |
H A D | netschedule_api_admin.cpp | 49 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in SwitchToDrainMode() 65 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in ShutdownServer() 78 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in ReloadServerConfig() 98 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in CreateQueue() 107 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in DeleteQueue() 137 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in CancelAllJobs() 145 m_Impl->m_API->m_Service.PrintCmdOutput(cmd, in PrintServerVersion() 176 m_Impl->m_API->m_Service.PrintCmdOutput(cmd, in DumpQueue() 278 m_Impl->m_API->m_Service.PrintCmdOutput(cmd, in PrintConf() 288 m_Impl->m_API->m_Service.PrintCmdOutput(cmd, in PrintServerStatistics() [all …]
|
H A D | netcache_api.cpp | 102 GetListener()->SetAuthString(m_Service->MakeAuthString()); in Init() 104 if (m_Service->GetClientName().length() < 3) { in Init() 135 m_Service.GetServiceName())) { in Init() 216 ns_client_name = ns_api->m_Service->GetClientName(); in SNetCacheAPIImpl() 235 m_Service(SNetServiceImpl::Clone(server, parent->m_Service)), in SNetCacheAPIImpl() 330 m_Iterator = m_Service.Iterate(m_PrimaryServer); in NextServer() 348 CNetService service(m_Service); in ExecMirrorAware() 547 m_Service.GetServiceName() << ":" << e.what() << in InitiateWriteCmd() 580 if (m_Service.IsLoadBalanced()) { in InitiateWriteCmd() 600 m_Service.GetServiceName(), key_flags); in InitiateWriteCmd() [all …]
|
H A D | netcache_api_impl.hpp | 85 return static_cast<CNetCacheServerListener*>(m_Service->m_Listener.GetPointer()); in GetListener() 125 CNetService m_Service; member 157 m_Service(service), in SNetCacheMirrorTraversal() 166 CNetService m_Service; member in SNetCacheMirrorTraversal
|
H A D | netcache_api_admin.cpp | 45 m_API->m_Service.ExecOnAllServers(cmd); in ExecOnAllServers() 52 m_API->m_Service.PrintCmdOutput(cmd, output_stream, style); in PrintCmdOutput() 66 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in ShutdownServer()
|
H A D | netservice_api.cpp | 68 m_Service(service) in SNoRetry() 70 _ASSERT(m_Service); in SNoRetry() 72 Swap(*m_Service, m_MaxRetries); in SNoRetry() 77 Swap(*m_Service, m_MaxRetries); in ~SNoRetry() 81 CNetRef<SNetServiceImpl> m_Service; member 109 CNetService service(m_Service); in DeleteThis() 122 if (!Referenced() && m_Service) { in DeleteThis() 127 m_Service = NULL; in DeleteThis() 852 m_Service(service) in SRandomServiceTraversal() 860 CNetService m_Service; member in SRandomServiceTraversal [all …]
|
H A D | netschedule_api.cpp | 360 if (m_Service.IsLoadBalanced()) { in x_ClearNode() 472 string auth(m_Service->MakeAuthString()); in MakeAuthString() 581 m_Service->GetClientName() + "::" + in Init() 731 m_Service(SNetServiceImpl::Clone(server, parent->m_Service)), in SNetScheduleAPIImpl() 910 return m_Impl->m_Service; in GetService() 1021 *server = new SNetServerImpl(m_Service, in GetServerByNode() 1022 m_Service->m_ServerPool->ReturnServer(known_server)); in GetServerByNode() 1088 cmd += "service=" + m_Service->m_ServiceName; in GetQueueParams() 1111 CUrlArgs url_parser(m_Service.FindServerAndExec(cmd, in GetQueueParams() 1164 m_Service->m_ServerPool->ResetServerConnections(); in UpdateAuthString() [all …]
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/connect/services/ |
H A D | netschedule_api_admin.cpp | 49 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in SwitchToDrainMode() 65 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in ShutdownServer() 78 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in ReloadServerConfig() 98 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in CreateQueue() 107 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in DeleteQueue() 137 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in CancelAllJobs() 145 m_Impl->m_API->m_Service.PrintCmdOutput(cmd, in PrintServerVersion() 176 m_Impl->m_API->m_Service.PrintCmdOutput(cmd, in DumpQueue() 278 m_Impl->m_API->m_Service.PrintCmdOutput(cmd, in PrintConf() 288 m_Impl->m_API->m_Service.PrintCmdOutput(cmd, in PrintServerStatistics() [all …]
|
H A D | netcache_api.cpp | 102 GetListener()->SetAuthString(m_Service->MakeAuthString()); in Init() 104 if (m_Service->GetClientName().length() < 3) { in Init() 135 m_Service.GetServiceName())) { in Init() 216 ns_client_name = ns_api->m_Service->GetClientName(); in SNetCacheAPIImpl() 235 m_Service(SNetServiceImpl::Clone(server, parent->m_Service)), in SNetCacheAPIImpl() 330 m_Iterator = m_Service.Iterate(m_PrimaryServer); in NextServer() 348 CNetService service(m_Service); in ExecMirrorAware() 547 m_Service.GetServiceName() << ":" << e.what() << in InitiateWriteCmd() 580 if (m_Service.IsLoadBalanced()) { in InitiateWriteCmd() 600 m_Service.GetServiceName(), key_flags); in InitiateWriteCmd() [all …]
|
H A D | netcache_api_impl.hpp | 85 return static_cast<CNetCacheServerListener*>(m_Service->m_Listener.GetPointer()); in GetListener() 125 CNetService m_Service; member 157 m_Service(service), in SNetCacheMirrorTraversal() 166 CNetService m_Service; member in SNetCacheMirrorTraversal
|
H A D | netcache_api_admin.cpp | 45 m_API->m_Service.ExecOnAllServers(cmd); in ExecOnAllServers() 52 m_API->m_Service.PrintCmdOutput(cmd, output_stream, style); in PrintCmdOutput() 66 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in ShutdownServer()
|
H A D | netservice_api.cpp | 68 m_Service(service) in SNoRetry() 70 _ASSERT(m_Service); in SNoRetry() 72 Swap(*m_Service, m_MaxRetries); in SNoRetry() 77 Swap(*m_Service, m_MaxRetries); in ~SNoRetry() 81 CNetRef<SNetServiceImpl> m_Service; member 109 CNetService service(m_Service); in DeleteThis() 122 if (!Referenced() && m_Service) { in DeleteThis() 127 m_Service = NULL; in DeleteThis() 852 m_Service(service) in SRandomServiceTraversal() 860 CNetService m_Service; member in SRandomServiceTraversal [all …]
|
H A D | netschedule_api.cpp | 360 if (m_Service.IsLoadBalanced()) { in x_ClearNode() 472 string auth(m_Service->MakeAuthString()); in MakeAuthString() 581 m_Service->GetClientName() + "::" + in Init() 731 m_Service(SNetServiceImpl::Clone(server, parent->m_Service)), in SNetScheduleAPIImpl() 910 return m_Impl->m_Service; in GetService() 1021 *server = new SNetServerImpl(m_Service, in GetServerByNode() 1022 m_Service->m_ServerPool->ReturnServer(known_server)); in GetServerByNode() 1088 cmd += "service=" + m_Service->m_ServiceName; in GetQueueParams() 1111 CUrlArgs url_parser(m_Service.FindServerAndExec(cmd, in GetQueueParams() 1164 m_Service->m_ServerPool->ResetServerConnections(); in UpdateAuthString() [all …]
|
/dports/security/i2pd/i2pd-2.40.0/libi2pd/ |
H A D | Transports.cpp | 151 if (m_Service) in ~Transports() 156 delete m_Service; m_Service = nullptr; in ~Transports() 162 if (!m_Service) in Start() 164 m_Service = new boost::asio::io_service (); in Start() 165 m_Work = new boost::asio::io_service::work (*m_Service); in Start() 167 m_PeerTestTimer = new boost::asio::deadline_timer (*m_Service); in Start() 317 if (m_Service) m_Service->stop (); in Stop() 330 while (m_IsRunning && m_Service) in Run() 334 m_Service->run (); in Run() 653 m_Service->post([session, this]() in PeerConnected() [all …]
|
H A D | Timestamp.cpp | 139 NTPTimeSync::NTPTimeSync (): m_IsRunning (false), m_Timer (m_Service) in NTPTimeSync() 157 m_Service.post (std::bind (&NTPTimeSync::Sync, this)); in Start() 171 m_Service.stop (); in Stop() 188 m_Service.run (); in Run()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/serial/ |
H A D | rpcbase.hpp | 210 _ASSERT( !m_Service.empty() ); in x_Connect() 212 AutoPtr<SConnNetInfo> net_info(ConnNetInfo_Create(m_Service.c_str())); in x_Connect() 217 (m_Service, fSERV_Any | fSERV_DelayOpen, net_info.get(), &x_extra, m_Timeout)); in x_Connect() 301 _ASSERT( !m_Service.empty() ); in AsyncConnect() 303 AutoPtr<SConnNetInfo> net_info(ConnNetInfo_Create(m_Service.c_str())); in AsyncConnect() 307 new CConn_ServiceStream(m_Service, fSERV_Any, net_info.get(), &x_extra, in AsyncConnect()
|
H A D | rpcbase_impl.hpp | 74 const string& GetService(void) const { return m_Service; } in GetService() 75 void SetService(const string& service) { m_Service = service; } in SetService() 135 string m_Service; ///< Used by default Connect(). member in CRPCClient_Base
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/serial/ |
H A D | rpcbase.hpp | 210 _ASSERT( !m_Service.empty() ); in x_Connect() 212 AutoPtr<SConnNetInfo> net_info(ConnNetInfo_Create(m_Service.c_str())); in x_Connect() 217 (m_Service, fSERV_Any | fSERV_DelayOpen, net_info.get(), &x_extra, m_Timeout)); in x_Connect() 301 _ASSERT( !m_Service.empty() ); in AsyncConnect() 303 AutoPtr<SConnNetInfo> net_info(ConnNetInfo_Create(m_Service.c_str())); in AsyncConnect() 307 new CConn_ServiceStream(m_Service, fSERV_Any, net_info.get(), &x_extra, in AsyncConnect()
|
H A D | rpcbase_impl.hpp | 74 const string& GetService(void) const { return m_Service; } in GetService() 75 void SetService(const string& service) { m_Service = service; } in SetService() 135 string m_Service; ///< Used by default Connect(). member in CRPCClient_Base
|
/dports/security/i2pd/i2pd-2.40.0/libi2pd_client/ |
H A D | I2PService.h | 98 I2PServiceHandler(I2PService * parent) : m_Service(parent), m_Dead(false) { } in I2PServiceHandler() 112 …inline void Done (std::shared_ptr<I2PServiceHandler> me) { if(m_Service) m_Service->RemoveHandler(… in Done() 114 inline I2PService * GetOwner() { return m_Service; } in GetOwner() 118 I2PService *m_Service;
|
/dports/multimedia/gpac-mp4box/gpac-1.0.0/extra_lib/include/platinum/ |
H A D | PltEvent.h | 115 PLT_Service* m_Service; variable 182 PLT_EventSubscriberFinderByService(PLT_Service* service) : m_Service(service) {} in PLT_EventSubscriberFinderByService() 188 PLT_Service* m_Service;
|
/dports/multimedia/gpac-libgpac/gpac-1.0.0/extra_lib/include/platinum/ |
H A D | PltEvent.h | 115 PLT_Service* m_Service; variable 182 PLT_EventSubscriberFinderByService(PLT_Service* service) : m_Service(service) {} in PLT_EventSubscriberFinderByService() 188 PLT_Service* m_Service;
|
/dports/graphics/digikam/digikam-7.4.0/core/dplugins/generic/tools/mediaserver/upnpsdk/Platinum/Source/Core/ |
H A D | PltEvent.h | 115 PLT_Service* m_Service; variable 182 PLT_EventSubscriberFinderByService(PLT_Service* service) : m_Service(service) {} in PLT_EventSubscriberFinderByService() 188 PLT_Service* m_Service;
|
/dports/multimedia/kodi/xbmc-19.3-Matrix/lib/libUPnP/Platinum/Source/Core/ |
H A D | PltEvent.h | 115 PLT_Service* m_Service; variable 182 PLT_EventSubscriberFinderByService(PLT_Service* service) : m_Service(service) {} in PLT_EventSubscriberFinderByService() 188 PLT_Service* m_Service;
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/corelib/ |
H A D | ncbi_url.hpp | 390 bool IsService(void) const { return !m_Service.empty(); } in IsService() 391 string GetService(void) const { return m_Service; } in GetService() 471 string m_Service; member in CUrl 548 m_Service.clear(); in SetHost() 556 m_Service = service; in SetService() 586 m_Service.clear(); in x_SetHost() 592 m_Service = NStr::URLDecode(service); in x_SetService()
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/corelib/ |
H A D | ncbi_url.hpp | 390 bool IsService(void) const { return !m_Service.empty(); } in IsService() 391 string GetService(void) const { return m_Service; } in GetService() 471 string m_Service; member in CUrl 548 m_Service.clear(); in SetHost() 556 m_Service = service; in SetService() 586 m_Service.clear(); in x_SetHost() 592 m_Service = NStr::URLDecode(service); in x_SetService()
|