| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/connect/services/ |
| H A D | netschedule_api_executor.cpp | 185 m_API->m_Service.ExcludeServer(orig_server); it; ++it) in ClaimNewPreferredAffinity()
315 m_Impl->m_API->m_Service.ExcludeServer(server); it; ++it) in GetJob()
418 CNetServiceIterator it(executor->m_API->m_Service.FindServer( in RequestJob()
629 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in ChangePreferredAffinities()
640 return m_Impl->m_API->m_Service->GetClientName(); in GetClientName()
645 return m_Impl->m_API->m_Service.GetServiceName(); in GetServiceName()
|
| H A D | netstorage_rpc.cpp | 520 m_Listener(netstorage_rpc->m_Service->m_Listener) in SContext()
782 m_Service = SNetServiceImpl::Create("NetStorageAPI", m_Config.service, m_Config.client_name, in SNetStorageRPC()
790 m_Service(SNetServiceImpl::Clone(server, parent->m_Service)), in SNetStorageRPC()
820 const auto reply = Exchange(m_Service, request, &conn); in Create()
1008 return m_Service; in GetServiceIfLocator()
1014 CNetService service(m_Service.Clone(service_name)); in GetServiceIfLocator()
1357 …return SNetStorageObjectImpl::Create<SNetStorageObjectRPC>(rpc, rpc->m_Service, builder, kEmptyStr… in Open()
1377 return m_Impl->m_NetStorageRPC->m_Service; in GetService()
1388 return m_Impl->m_NetStorageRPC->Exchange(m_Impl->m_NetStorageRPC->m_Service, in ExchangeJson()
|
| H A D | netschedule_api_impl.hpp | 317 m_Service->m_Listener.GetPointer()); in GetListener()
324 …const CNetScheduleAPI::SServerParams& GetServerParams() { return m_ServerParamsSync(m_Service, m_Q… in GetServerParams()
333 return m_Service.GetServer(nskey.host, nskey.port); in GetServer()
374 CNetService m_Service; member
|
| H A D | srv_connections_impl.hpp | 256 m_Service(service), in SNetServerImpl()
284 CNetService m_Service; member
|
| H A D | netschedule_api_submitter.cpp | 119 m_API->m_Service.FindServerAndExec(cmd, false)); in SubmitJobImpl()
148 m_Impl->m_API->m_Service.FindServerAndExec(cmd, false)); in SubmitJobBatch()
318 return m_Impl->m_API->m_Service.FindServer(&read_executor, in Read()
607 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in CancelJobGroup()
|
| H A D | netstorage_rpc.hpp | 74 CNetService m_Service; member
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/app/netstorage/ |
| H A D | nst_handler.cpp | 1211 m_Service = ""; in x_ProcessHello()
1216 ticket, m_Service, protocol_version, in x_ProcessHello()
2305 m_Server->GetServiceTTL(m_Service, ttl); in x_ProcessSetAttr()
3487 m_Service, in x_GetObject()
3629 return net_storage.Create(m_Service, flags); in x_CreateObjectStream()
3696 switch (m_Server->InMetadataServices(m_Service)) in x_ConvertMetadataArgument()
3742 service = m_Service; in x_ValidateWriteMetaDBAccess()
3779 switch (m_Server->InMetadataServices(m_Service)) in x_ValidateWriteMetaDBAccess()
3785 "Service provided in HELLO (" + m_Service + in x_ValidateWriteMetaDBAccess()
3825 service = m_Service; in x_DetectMetaDBNeedUpdate()
[all …]
|
| H A D | nst_clients.hpp | 86 { m_Service = service; } in SetService()
121 string m_Service; // Optional service member in CNSTClient
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/services/ |
| H A D | netstorage_rpc.cpp | 520 m_Listener(netstorage_rpc->m_Service->m_Listener) in SContext()
782 m_Service = SNetServiceImpl::Create("NetStorageAPI", m_Config.service, m_Config.client_name, in SNetStorageRPC()
790 m_Service(SNetServiceImpl::Clone(server, parent->m_Service)), in SNetStorageRPC()
820 const auto reply = Exchange(m_Service, request, &conn); in Create()
1008 return m_Service; in GetServiceIfLocator()
1014 CNetService service(m_Service.Clone(service_name)); in GetServiceIfLocator()
1357 …return SNetStorageObjectImpl::Create<SNetStorageObjectRPC>(rpc, rpc->m_Service, builder, kEmptyStr… in Open()
1377 return m_Impl->m_NetStorageRPC->m_Service; in GetService()
1388 return m_Impl->m_NetStorageRPC->Exchange(m_Impl->m_NetStorageRPC->m_Service, in ExchangeJson()
|
| H A D | netschedule_api_impl.hpp | 317 m_Service->m_Listener.GetPointer()); in GetListener()
324 …const CNetScheduleAPI::SServerParams& GetServerParams() { return m_ServerParamsSync(m_Service, m_Q… in GetServerParams()
333 return m_Service.GetServer(nskey.host, nskey.port); in GetServer()
374 CNetService m_Service; member
|
| H A D | srv_connections_impl.hpp | 256 m_Service(service), in SNetServerImpl()
284 CNetService m_Service; member
|
| H A D | netschedule_api_submitter.cpp | 119 m_API->m_Service.FindServerAndExec(cmd, false)); in SubmitJobImpl()
148 m_Impl->m_API->m_Service.FindServerAndExec(cmd, false)); in SubmitJobBatch()
318 return m_Impl->m_API->m_Service.FindServer(&read_executor, in Read()
607 m_Impl->m_API->m_Service.ExecOnAllServers(cmd); in CancelJobGroup()
|
| H A D | netstorage_rpc.hpp | 74 CNetService m_Service; member
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/sample/app/dbapi/ |
| H A D | dbapi_simple.cpp | 108 string m_Service; member in CDbapiSimpleApp
253 m_Service = args["service"].AsString(); in ParseArgs()
362 m_Conn->ConnectValidated(val, m_User, m_Password, m_Service, m_DbName); in SetupDb()
|
| /dports/security/i2pd/i2pd-2.40.0/libi2pd/ |
| H A D | Streaming.cpp | 75 std::shared_ptr<const i2p::data::LeaseSet> remote, int port): m_Service (service), in Stream()
78 m_RemoteLeaseSet (remote), m_ReceiveTimer (m_Service), m_ResendTimer (m_Service), in Stream()
79 m_AckSendTimer (m_Service), m_NumSentBytes (0), m_NumReceivedBytes (0), m_Port (port), in Stream()
89 m_Service (service), m_SendStreamID (0), m_SequenceNumber (0), m_LastReceivedSequenceNumber (-1), in Stream()
91 m_ReceiveTimer (m_Service), m_ResendTimer (m_Service), m_AckSendTimer (m_Service), in Stream()
491 m_Service.post (std::bind (&Stream::SendBuffer, shared_from_this ())); in AsyncSend()
763 m_Service.post (std::bind (&Stream::SendPacket, shared_from_this (), p)); in SendClose()
|
| H A D | Transports.h | 98 boost::asio::io_service& GetService () { return *m_Service; }; in GetService()
157 boost::asio::io_service * m_Service; variable
|
| H A D | Timestamp.h | 49 boost::asio::io_service m_Service; variable
|
| H A D | util.h | 172 boost::asio::io_service& GetIOService () { return m_Service; } in GetIOService()
187 boost::asio::io_service m_Service; variable
|
| H A D | SSU.h | 66 boost::asio::io_service& GetService () { return m_Service; }; in GetService()
133 boost::asio::io_service m_Service, m_ReceiversService, m_ReceiversServiceV6; variable
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/app/netstorage/utils/ |
| H A D | netstorage_gc_database.hpp | 43 string m_Service; member
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/algo/blast/api/ |
| H A D | remote_blast.cpp | 494 m_Service); in GetMasks()
859 m_QSR->SetService(m_Service = service); in x_Init()
1143 m_Service); in x_QueryMaskingLocationsToNetwork()
1535 (m_Program == "tblastn" && m_Service == "rpsblast")) { in x_SetDatabase()
1716 m_Service = strategy.GetService(); in x_GetRequestInfoFromFile()
1727 if(m_Service == "psi") in x_GetRequestInfoFromFile()
1812 m_Service = grir->GetService(); in x_GetRequestInfoFromRID()
1893 if (! m_Service.empty()) { in GetService()
1894 return m_Service; in GetService()
1899 return m_Service; in GetService()
[all …]
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/algo/blast/api/ |
| H A D | remote_blast.cpp | 494 m_Service); in GetMasks()
859 m_QSR->SetService(m_Service = service); in x_Init()
1143 m_Service); in x_QueryMaskingLocationsToNetwork()
1535 (m_Program == "tblastn" && m_Service == "rpsblast")) { in x_SetDatabase()
1716 m_Service = strategy.GetService(); in x_GetRequestInfoFromFile()
1727 if(m_Service == "psi") in x_GetRequestInfoFromFile()
1812 m_Service = grir->GetService(); in x_GetRequestInfoFromRID()
1893 if (! m_Service.empty()) { in GetService()
1894 return m_Service; in GetService()
1899 return m_Service; in GetService()
[all …]
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/serial/ |
| H A D | rpcbase.cpp | 100 m_Service(service), in CRPCClient_Base()
113 m_Service(service), in CRPCClient_Base()
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/serial/ |
| H A D | rpcbase.cpp | 100 m_Service(service), in CRPCClient_Base()
113 m_Service(service), in CRPCClient_Base()
|
| /dports/security/i2pd/i2pd-2.40.0/daemon/ |
| H A D | UPnP.h | 69 boost::asio::io_service m_Service; variable
|