| /thrift-3.4.0/lib/d/src/thrift/util/ |
| D | awaitable.d | 42 void wait();
51 bool wait(Duration timeout);
88 override void wait() { in wait() function
90 while (!triggered_) condition_.wait(); in wait()
94 override bool wait(Duration timeout) { in wait() function
97 condition_.wait(timeout); in wait()
|
| D | future.d | 74 completion.wait(); in TFuture()
89 enforce(completion.wait(timeout), new TFutureException( in TFuture()
448 queueNonEmptyCondition_.wait(remaining); in TFutureAggregatorRange()
|
| /thrift-3.4.0/lib/cpp/src/thrift/concurrency/ |
| D | Monitor.h | 99 void wait(const std::chrono::milliseconds &timeout) const;
101 void wait(uint64_t timeout_ms = 0ULL) const { this->wait(std::chrono::milliseconds(timeout_ms)); }
|
| D | Monitor.cpp | 63 void wait(const std::chrono::milliseconds &timeout) { in wait() function in apache::thrift::concurrency::Monitor::Impl
120 conditionVariable_.wait(lock); in waitForever()
160 void Monitor::wait(const std::chrono::milliseconds &timeout) const { in wait() function in apache::thrift::concurrency::Monitor
161 const_cast<Monitor::Impl*>(impl_)->wait(timeout); in wait()
|
| D | ThreadManager.cpp | 271 manager_->monitor_.wait(); in run()
366 workerMonitor_.wait(); in addWorker()
385 monitor_.wait(); in start()
431 workerMonitor_.wait(); in removeWorkersUnderLock()
475 maxMonitor_.wait(timeout); in add()
|
| D | TimerManager.cpp | 196 monitor_.wait(); in start()
214 monitor_.wait(); in stop()
|
| D | Thread.h | 138 monitor_.wait(); in start()
|
| /thrift-3.4.0/lib/cpp/test/concurrency/ |
| D | ThreadFactoryTests.h | 107 monitor->wait(1000);
137 _monitor.wait(); in run()
175 monitor.wait(); in synchStartTest()
185 monitor.wait(100); in synchStartTest()
197 monitor.wait(); in synchStartTest()
229 monitor.wait(timeout);
|
| D | TimerManagerTests.h | 103 _monitor.wait();
146 _monitor.wait(timeout * 2);
180 _monitor.wait(timeout * 2);
212 _monitor.wait(timeout * 2);
245 _monitor.wait(timeout);
|
| D | ThreadManagerTests.h | 49 _sleep.wait(millisec); in sleep_()
141 monitor.wait();
214 _blockMonitor.wait(); in run()
321 doneMonitor.wait();
352 doneMonitor.wait();
367 doneMonitor.wait();
605 entryMonitor.wait(); in apiTestWithThreadFactory()
|
| /thrift-3.4.0/lib/d/test/ |
| D | async_test.d | 149 servingCondition.wait(); in main()
342 enforce(!a.completion.wait(dur!"usecs"(1)), in run()
344 enforce(!a.completion.wait(dur!"usecs"(1)), in run()
346 enforce(a.completion.wait(dur!"msecs"(200)), in run()
355 enforce(!a.completion.wait(dur!"usecs"(1)), in run()
357 enforce(!a.completion.wait(dur!"usecs"(1)), in run()
359 enforce(a.completion.wait(dur!"msecs"(200)), in run()
|
| /thrift-3.4.0/test/ |
| D | test.py | 79 r.wait()
81 return dispatcher.wait()
115 r.wait()
117 return dispatcher.wait()
|
| /thrift-3.4.0/lib/cpp/test/processor/ |
| D | EventLog.cpp | 99 monitor_.wait(timeout); in waitForEvent()
120 monitor_.wait(timeout); in waitForConnEvent()
|
| /thrift-3.4.0/lib/d/src/thrift/internal/test/ |
| D | server.d | 102 servingCondition.wait(); in synchronized()
105 enforce(doneCondition.wait(dur!"msecs"(3*1000))); in synchronized()
|
| /thrift-3.4.0/lib/c_glib/test/ |
| D | testframedtransport.c | 102 g_assert ( wait (&status) == pid ); in test_open_and_close()
158 g_assert ( wait (&status) == pid ); in test_read_and_write()
244 g_assert (wait (&status) == pid); in test_read_after_peer_close()
|
| D | testbufferedtransport.c | 102 g_assert ( wait (&status) == pid ); in test_open_and_close()
169 g_assert ( wait (&status) == pid ); in test_read_and_write()
304 g_assert ( wait (&status) == pid ); in test_write_fail()
|
| D | testtransportsocket.c | 143 g_assert ( wait (&status) == pid ); in test_open_and_close()
187 g_assert ( wait (&status) == pid ); in test_read_and_write()
286 g_assert (wait (&status) == pid); in test_peek()
|
| D | testthriftbufferedreadcheck.c | 88 g_assert ( wait (&status) == pid ); in test_open_and_close()
137 g_assert ( wait (&status) == pid ); in test_read_and_write()
|
| D | testthriftframedreadcheck.c | 86 g_assert ( wait (&status) == pid ); in test_open_and_close()
136 g_assert ( wait (&status) == pid ); in test_read_and_write()
|
| D | testzlibtransport.c | 113 g_assert ( wait (&status) == pid ); in test_open_and_close()
155 g_assert ( wait (&status) == pid ); in test_read_and_write()
|
| D | testsimpleserver.c | 105 g_assert (wait (&status) == pid); in test_server()
|
| /thrift-3.4.0/test/threads/ |
| D | ThreadsServer.cpp | 95 m.wait(1000); in go2sleep()
|
| /thrift-3.4.0/lib/d/src/thrift/server/ |
| D | taskpool.d | 120 queueState.connClosed.wait();
173 queueState.connClosed.wait();
|
| /thrift-3.4.0/test/crossrunner/ |
| D | run.py | 141 def wait(self, timeout): member in ExecutionContext
223 cl.wait(test.timeout)
349 def wait(self, timeout=None): member in NonAsyncResult
417 def wait(self): member in TestDispatcher
|
| /thrift-3.4.0/lib/py/src/server/ |
| D | TProcessPoolServer.py | 115 self.stopCondition.wait()
|
