/dports/misc/adios2/ADIOS2-2.7.1/source/adios2/toolkit/zmq/zmqreqrep/ |
H A D | ZmqReqRep.cpp | 46 m_Timeout = timeout; in OpenRequester() 53 m_Timeout = timeout; in OpenRequester() 63 zmq_setsockopt(m_Socket, ZMQ_SNDTIMEO, &m_Timeout, sizeof(m_Timeout)); in OpenRequester() 64 zmq_setsockopt(m_Socket, ZMQ_RCVTIMEO, &m_Timeout, sizeof(m_Timeout)); in OpenRequester() 65 zmq_setsockopt(m_Socket, ZMQ_LINGER, &m_Timeout, sizeof(m_Timeout)); in OpenRequester() 81 m_Timeout = timeout; in OpenReplier() 96 zmq_setsockopt(m_Socket, ZMQ_RCVTIMEO, &m_Timeout, sizeof(m_Timeout)); in OpenReplier() 97 zmq_setsockopt(m_Socket, ZMQ_LINGER, &m_Timeout, sizeof(m_Timeout)); in OpenReplier() 135 zmq_setsockopt(socket, ZMQ_SNDTIMEO, &m_Timeout, sizeof(m_Timeout)); in Request() 136 zmq_setsockopt(socket, ZMQ_RCVTIMEO, &m_Timeout, sizeof(m_Timeout)); in Request() [all …]
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/test/ |
H A D | test_ncbi_namedpipe_connector.cpp | 74 STimeout m_Timeout; member in CTest 80 m_Timeout.sec = 5; in CTest() 81 m_Timeout.usec = 123456; in CTest() 148 m_Timeout.sec = (unsigned int) tv; in Run() 149 m_Timeout.usec = (unsigned int)((tv - m_Timeout.sec) * kMicroSecondsPerSecond); in Run() 178 (m_Timeout.sec in Client() 179 + (double) m_Timeout.usec / kMicroSecondsPerSecond, 6) in Client() 189 CONN_TestConnector(connector, &m_Timeout, logfile, fTC_Everything); in Client() 209 + NStr::DoubleToString(m_Timeout.sec in Server() 216 assert(pipe.SetTimeout(eIO_Read, &m_Timeout) == eIO_Success); in Server() [all …]
|
H A D | test_ncbi_namedpipe.cpp | 131 STimeout m_Timeout; member in CTest 137 m_Timeout.sec = DEFAULT_TIMEOUT; in CTest() 138 m_Timeout.usec = 0; in CTest() 206 m_Timeout.sec = (unsigned int) tv; in Run() 207 m_Timeout.usec = (unsigned int)((tv - m_Timeout.sec) * kMicroSecondsPerSecond); in Run() 243 assert(pipe.SetTimeout(eIO_Open, &m_Timeout) == eIO_Success); in Client() 244 assert(pipe.SetTimeout(eIO_Read, &m_Timeout) == eIO_Success); in Client() 245 assert(pipe.SetTimeout(eIO_Write, &m_Timeout) == eIO_Success); in Client() 248 CDeadline timeout(g_STimeoutToCTimeout(&m_Timeout)); in Client() 363 assert(pipe.SetTimeout(eIO_Read, &m_Timeout) == eIO_Success); in Server() [all …]
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/serial/ |
H A D | rpcbase.hpp | 67 m_Timeout(kDefaultTimeout) in CRPCClient() 72 m_Timeout(kDefaultTimeout) in CRPCClient() 78 m_Timeout(kDefaultTimeout) in CRPCClient() 82 if ( !sx_IsSpecial(m_Timeout) ) { in ~CRPCClient() 241 m_Timeout)); in x_ConnectURL() 256 const STimeout* old_timeout = m_Timeout; in SetTimeout() 258 m_Timeout = timeout; in SetTimeout() 260 m_Timeout = new STimeout(*timeout); in SetTimeout() 290 return m_Timeout; in GetTimeout() 309 if (m_Timeout == kDefaultTimeout) { in AsyncConnect() [all …]
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/serial/ |
H A D | rpcbase.hpp | 67 m_Timeout(kDefaultTimeout) in CRPCClient() 72 m_Timeout(kDefaultTimeout) in CRPCClient() 78 m_Timeout(kDefaultTimeout) in CRPCClient() 82 if ( !sx_IsSpecial(m_Timeout) ) { in ~CRPCClient() 241 m_Timeout)); in x_ConnectURL() 256 const STimeout* old_timeout = m_Timeout; in SetTimeout() 258 m_Timeout = timeout; in SetTimeout() 260 m_Timeout = new STimeout(*timeout); in SetTimeout() 290 return m_Timeout; in GetTimeout() 309 if (m_Timeout == kDefaultTimeout) { in AsyncConnect() [all …]
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/objtools/pubseq_gateway/cassandra/test/unit/ |
H A D | get_public_comment.cpp | 65 , m_Timeout(10000) in CGetPublicCommentTest() 90 unsigned int m_Timeout; member in __anon7ea432ea0111::CGetPublicCommentTest 122 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 135 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 154 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 167 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 186 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 199 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 224 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 237 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() [all …]
|
H A D | bioseq_info_task.cpp | 63 , m_Timeout(10000) in CBioseqInfoTaskFetchTest() 88 unsigned int m_Timeout; member in __anon73b4e5da0111::CBioseqInfoTaskFetchTest 115 m_Timeout, 0, m_Connection, m_KeyspaceName, request, in TEST_F() 133 m_Timeout, 0, m_Connection, m_KeyspaceName, request, in TEST_F() 161 m_Timeout, 0, m_Connection, m_KeyspaceName, request, in TEST_F() 189 m_Timeout, 0, m_Connection, m_KeyspaceName, request, in TEST_F() 212 m_Timeout, 0, m_Connection, m_KeyspaceName, request, in TEST_F() 235 m_Timeout, 0, m_Connection, m_KeyspaceName, request, in TEST_F() 258 m_Timeout, 0, m_Connection, m_KeyspaceName, request, in TEST_F() 292 m_Timeout, 0, m_Connection, m_KeyspaceName, request, in TEST_F()
|
H A D | load_blob_task.cpp | 63 , m_Timeout(10000) in CBlobTaskLoadBlobTest() 88 unsigned int m_Timeout; member in __anon32a6a06a0111::CBlobTaskLoadBlobTest 126 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 146 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 156 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F()
|
H A D | fetch_split_history.cpp | 61 , m_Timeout(10000) in CFetchSplitHistoryTest() 86 unsigned int m_Timeout; member in __anone70cd1000111::CFetchSplitHistoryTest 97 m_Timeout, 0, m_Connection, m_KeyspaceName, 1, in TEST_F() 121 m_Timeout, 0, m_Connection, m_KeyspaceName, sat_key, in TEST_F() 150 m_Timeout, 0, m_Connection, m_KeyspaceName, sat_key, 1589226071, in TEST_F()
|
H A D | nannot_fetch.cpp | 68 , m_Timeout(10000) in CNAnnotTaskFetchTest() 93 unsigned int m_Timeout; member in __anon0f2aff110111::CNAnnotTaskFetchTest 214 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 244 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 271 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 326 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 387 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 441 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 497 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() 545 m_Timeout, 0, m_Connection, m_KeyspaceName, in TEST_F() [all …]
|
H A D | psg_api.cpp | 64 , m_Timeout(10000) in CPsgApiTest() 89 unsigned int m_Timeout; member in __anona8304a9d0111::CPsgApiTest 125 m_Timeout, 0, m_Connection, m_KeyspaceName, si2csi_request, in TEST_F() 147 m_Timeout, 0, m_Connection, m_KeyspaceName, bioseq_request, in TEST_F()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/util/ |
H A D | lock_vector.hpp | 156 unsigned GetTimeout() const { return m_Timeout; } in GetTimeout() 164 unsigned m_Timeout; member in CLockVectorGuard 174 m_Timeout(timeout_ms), in CLockVectorGuard() 187 m_Timeout(timeout_ms), in CLockVectorGuard() 234 if (m_Timeout) { in DoLock() 236 if (time_spent > m_Timeout) { in DoLock()
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/util/ |
H A D | lock_vector.hpp | 156 unsigned GetTimeout() const { return m_Timeout; } in GetTimeout() 164 unsigned m_Timeout; member in CLockVectorGuard 174 m_Timeout(timeout_ms), in CLockVectorGuard() 187 m_Timeout(timeout_ms), in CLockVectorGuard() 234 if (m_Timeout) { in DoLock() 236 if (time_spent > m_Timeout) { in DoLock()
|
/dports/astro/kstars/kstars-3.5.6/kstars/auxiliary/ |
H A D | ksmessagebox.cpp | 127 m_Timeout = timeout; in setupTimeout() 128 if (m_Timeout == 0) in setupTimeout() 154 m_ProgressIndicator->setRange(0, m_Timeout); in setupTimeout() 155 m_ProgressIndicator->setValue(static_cast<int>(m_Timeout)); in setupTimeout() 262 m_Timeout--; in timerTick() 263 m_ProgressIndicator->setValue(static_cast<int>(m_Timeout)); in timerTick() 265 if (m_Timeout == 0) in timerTick() 283 message.insert("timeout", static_cast<int32_t>(m_Timeout)); in createMessageObject()
|
H A D | ksmessagebox.h | 30 Q_PROPERTY(quint32 timeout MEMBER m_Timeout) 64 quint32 m_Timeout {60}; 73 m_Timeout = 0; in resetTimeout()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/objects/trackmgr/ |
H A D | gridrpcclient.hpp | 285 m_Timeout(DefaultTimeout) in CGridRPCBaseClient() 294 m_Timeout(DefaultTimeout) in CGridRPCBaseClient() 312 m_Timeout = timeout; in SetTimeout() 353 const CNetScheduleAPI::EJobStatus evt = grid_cli.SubmitAndWait(m_Timeout); in AskStream() 418 const CNetScheduleAPI::EJobStatus evt = grid_cli.SubmitAndWait(m_Timeout); in Ask() 453 m_Timeout(c.m_Timeout) in CGridRPCBaseClient() 469 const CNetScheduleAPI::EJobStatus evt = job_submitter.WaitForJob(job.job_id, m_Timeout); in x_GetJobById() 500 Uint4 m_Timeout; member in CGridRPCBaseClient
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/objects/trackmgr/ |
H A D | gridrpcclient.hpp | 285 m_Timeout(DefaultTimeout) in CGridRPCBaseClient() 294 m_Timeout(DefaultTimeout) in CGridRPCBaseClient() 312 m_Timeout = timeout; in SetTimeout() 353 const CNetScheduleAPI::EJobStatus evt = grid_cli.SubmitAndWait(m_Timeout); in AskStream() 418 const CNetScheduleAPI::EJobStatus evt = grid_cli.SubmitAndWait(m_Timeout); in Ask() 453 m_Timeout(c.m_Timeout) in CGridRPCBaseClient() 469 const CNetScheduleAPI::EJobStatus evt = job_submitter.WaitForJob(job.job_id, m_Timeout); in x_GetJobById() 500 Uint4 m_Timeout; member in CGridRPCBaseClient
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/app/netstorage/utils/ |
H A D | netstorage_gc_database.cpp | 48 : m_Verbose(verbose), m_Db(NULL), m_Timeout(timeout, 0) in CNetStorageGCDatabase() 101 query.ExecuteSP("sp_getapplock", m_Timeout); in GetAppLock() 134 query.ExecuteSP("sp_releaseapplock", m_Timeout); in ReleaseAppLock() 215 query.Execute(m_Timeout); in GetGCCandidates() 246 query.Execute(m_Timeout); in GetDBStructureVersion() 305 query.Execute(m_Timeout); in RemoveObject() 363 query.Execute(m_Timeout); in RemoveObject()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/corelib/ |
H A D | interprocess_lock.hpp | 213 : m_Timeout(timeout), in PInterProcessLock() 220 resource.Lock(m_Timeout, m_Granularity); in operator ()() 224 CTimeout m_Timeout; member in PInterProcessLock
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/corelib/ |
H A D | interprocess_lock.hpp | 213 : m_Timeout(timeout), in PInterProcessLock() 220 resource.Lock(m_Timeout, m_Granularity); in operator ()() 224 CTimeout m_Timeout; member in PInterProcessLock
|
/dports/misc/adios2/ADIOS2-2.7.1/source/adios2/engine/dataman/ |
H A D | DataManReader.cpp | 32 helper::GetParameter(m_IO.m_Parameters, "Timeout", m_Timeout); in DataManReader() 39 m_Requesters[0].OpenRequester(m_Timeout, m_ReceiverBufferSize); in DataManReader() 60 if (duration.count() > m_Timeout) in DataManReader() 89 m_Requesters.back().OpenRequester(address, m_Timeout, in DataManReader() 141 timeout = m_Timeout; in BeginStep()
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/objtools/eutils/api/ |
H A D | eutils.hpp | 71 const CTimeout& GetTimeout(void) const { return m_Timeout; } in GetTimeout() 73 void SetTimeout(const CTimeout& tmo) { m_Timeout = tmo; } in SetTimeout() 94 CTimeout m_Timeout; member in CEUtils_ConnContext
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/objtools/eutils/api/ |
H A D | eutils.hpp | 71 const CTimeout& GetTimeout(void) const { return m_Timeout; } in GetTimeout() 73 void SetTimeout(const CTimeout& tmo) { m_Timeout = tmo; } in SetTimeout() 94 CTimeout m_Timeout; member in CEUtils_ConnContext
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/ |
H A D | ncbi_conn_test.cpp | 96 m_Timeout = &x_Timeout; in SetTimeout() 98 m_Timeout = kInfiniteTimeout/*0*/; in SetTimeout() 140 if (!m_Timeout) in x_TimeoutMsg() 143 int n = ::sprintf(tmo, "%u", m_Timeout->sec); in x_TimeoutMsg() 144 if (m_Timeout->usec) in x_TimeoutMsg() 145 ::sprintf(tmo + n, ".%06u", m_Timeout->usec); in x_TimeoutMsg() 307 m_Timeout = 0; in ExtraCheckOnFailure() 549 0/*extra*/, m_Timeout); in ServiceOkay() 816 if (x_Large(m_Timeout)) in GetFWConnections() 893 net_info->timeout = m_Timeout; in CheckFWConnections() [all …]
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/connect/ |
H A D | ncbi_conn_test.cpp | 96 m_Timeout = &x_Timeout; in SetTimeout() 98 m_Timeout = kInfiniteTimeout/*0*/; in SetTimeout() 140 if (!m_Timeout) in x_TimeoutMsg() 143 int n = ::sprintf(tmo, "%u", m_Timeout->sec); in x_TimeoutMsg() 144 if (m_Timeout->usec) in x_TimeoutMsg() 145 ::sprintf(tmo + n, ".%06u", m_Timeout->usec); in x_TimeoutMsg() 307 m_Timeout = 0; in ExtraCheckOnFailure() 549 0/*extra*/, m_Timeout); in ServiceOkay() 816 if (x_Large(m_Timeout)) in GetFWConnections() 893 net_info->timeout = m_Timeout; in CheckFWConnections() [all …]
|