Home
last modified time | relevance | path

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

123456

/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/services/
H A Dnetschedule_api_admin.cpp49 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 Dnetcache_api.cpp102 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 Dnetcache_api_impl.hpp85 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 Dnetcache_api_admin.cpp45 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 Dnetservice_api.cpp68 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 Dnetschedule_api.cpp360 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 Dnetschedule_api_admin.cpp49 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 Dnetcache_api.cpp102 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 Dnetcache_api_impl.hpp85 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 Dnetcache_api_admin.cpp45 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 Dnetservice_api.cpp68 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 Dnetschedule_api.cpp360 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 DTransports.cpp151 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 DTimestamp.cpp139 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 Drpcbase.hpp210 _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 Drpcbase_impl.hpp74 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 Drpcbase.hpp210 _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 Drpcbase_impl.hpp74 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 DI2PService.h98 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 DPltEvent.h115 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 DPltEvent.h115 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 DPltEvent.h115 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 DPltEvent.h115 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 Dncbi_url.hpp390 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 Dncbi_url.hpp390 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()

123456