Home
last modified time | relevance | path

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

12345

/dports/misc/adios2/ADIOS2-2.7.1/source/adios2/toolkit/zmq/zmqreqrep/
H A DZmqReqRep.cpp46 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 Dtest_ncbi_namedpipe_connector.cpp74 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 Dtest_ncbi_namedpipe.cpp131 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 Drpcbase.hpp67 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 Drpcbase.hpp67 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 Dget_public_comment.cpp65 , 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 Dbioseq_info_task.cpp63 , 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 Dload_blob_task.cpp63 , 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 Dfetch_split_history.cpp61 , 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 Dnannot_fetch.cpp68 , 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 Dpsg_api.cpp64 , 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 Dlock_vector.hpp156 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 Dlock_vector.hpp156 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 Dksmessagebox.cpp127 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 Dksmessagebox.h30 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 Dgridrpcclient.hpp285 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 Dgridrpcclient.hpp285 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 Dnetstorage_gc_database.cpp48 : 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 Dinterprocess_lock.hpp213 : 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 Dinterprocess_lock.hpp213 : 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 DDataManReader.cpp32 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 Deutils.hpp71 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 Deutils.hpp71 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 Dncbi_conn_test.cpp96 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 Dncbi_conn_test.cpp96 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 …]

12345