Home
last modified time | relevance | path

Searched refs:waiter (Results 1 – 25 of 62) sorted by relevance

123

/external/python/cpython3/Lib/concurrent/futures/
D_base.py154 waiter = _AsCompletedWaiter()
156 waiter = _FirstCompletedWaiter()
162 waiter = _AllCompletedWaiter(pending_count, stop_on_exception=True)
164 waiter = _AllCompletedWaiter(pending_count, stop_on_exception=False)
169 f._waiters.append(waiter)
171 return waiter
174 def _yield_finished_futures(fs, waiter, ref_collect): argument
190 f._waiters.remove(waiter)
224 waiter = _create_and_install_waiters(fs, _AS_COMPLETED)
227 yield from _yield_finished_futures(finished, waiter,
[all …]
/external/python/futures/concurrent/futures/
D_base.py156 waiter = _AsCompletedWaiter()
158 waiter = _FirstCompletedWaiter()
164 waiter = _AllCompletedWaiter(pending_count, stop_on_exception=True)
166 waiter = _AllCompletedWaiter(pending_count, stop_on_exception=False)
171 f._waiters.append(waiter)
173 return waiter
176 def _yield_finished_futures(fs, waiter, ref_collect): argument
192 f._waiters.remove(waiter)
226 waiter = _create_and_install_waiters(fs, _AS_COMPLETED)
229 for f in _yield_finished_futures(finished, waiter,
[all …]
/external/grpc-grpc/src/ruby/qps/
Dclient.rb87 waiter = nil
89 waiter = Poisson.new(config.load_params.poisson.offered_load /
95 unary_ping_ponger(req,stub,config,waiter)
97 streaming_ping_ponger(req,stub,config,waiter)
103 def wait_to_issue(waiter) argument
104 if waiter
105 delay = waiter.advance-Time.now
109 def unary_ping_ponger(req, stub, config,waiter) argument
111 wait_to_issue(waiter)
117 def streaming_ping_ponger(req, stub, config, waiter) argument
[all …]
/external/python/cpython3/Lib/asyncio/
Dstreams.py178 waiter = self._drain_waiter
179 if waiter is not None:
181 if not waiter.done():
182 waiter.set_result(None)
189 waiter = self._drain_waiter
190 if waiter is None:
193 if waiter.done():
196 waiter.set_result(None)
198 waiter.set_exception(exc)
205 waiter = self._drain_waiter
[all …]
Dbase_subprocess.py14 waiter=None, extra=None, **kwargs): argument
53 self._loop.create_task(self._connect_pipes(waiter))
157 async def _connect_pipes(self, waiter): argument
187 if waiter is not None and not waiter.cancelled():
188 waiter.set_exception(exc)
190 if waiter is not None and not waiter.cancelled():
191 waiter.set_result(None)
220 for waiter in self._exit_waiters:
221 if not waiter.cancelled():
222 waiter.set_result(returncode)
[all …]
Dtasks.py366 def _release_waiter(waiter, *args): argument
367 if not waiter.done():
368 waiter.set_result(None)
399 waiter = loop.create_future()
400 timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
401 cb = functools.partial(_release_waiter, waiter)
409 await waiter
434 waiter = loop.create_future()
437 timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
449 if not waiter.done():
[all …]
Dproactor_events.py28 def __init__(self, loop, sock, protocol, waiter=None, argument
45 if waiter is not None:
48 waiter, None)
160 def __init__(self, loop, sock, protocol, waiter=None, argument
164 super().__init__(loop, sock, protocol, waiter, extra, server)
447 def __init__(self, loop, sock, protocol, waiter=None, argument
449 super().__init__(loop, sock, protocol, waiter, extra, server)
493 def _make_socket_transport(self, sock, protocol, waiter=None, argument
495 return _ProactorSocketTransport(self, sock, protocol, waiter,
499 self, rawsock, protocol, sslcontext, waiter=None, argument
[all …]
Dbase_events.py278 for waiter in waiters:
279 if not waiter.done():
280 waiter.set_result(waiter)
353 waiter = self._loop.create_future()
354 self._waiters.append(waiter)
355 await waiter
430 def _make_socket_transport(self, sock, protocol, waiter=None, *, argument
436 self, rawsock, protocol, sslcontext, waiter=None, argument
445 address=None, waiter=None, extra=None): argument
449 def _make_read_pipe_transport(self, pipe, protocol, waiter=None, argument
[all …]
Dselector_events.py58 def _make_socket_transport(self, sock, protocol, waiter=None, *, argument
60 return _SelectorSocketTransport(self, sock, protocol, waiter,
64 self, rawsock, protocol, sslcontext, waiter=None, argument
69 self, protocol, sslcontext, waiter,
77 address=None, waiter=None, extra=None): argument
79 address, waiter, extra)
198 waiter = self.create_future()
201 conn, protocol, sslcontext, waiter=waiter,
206 conn, protocol, waiter=waiter, extra=extra,
210 await waiter
[all …]
Dunix_events.py174 def _make_read_pipe_transport(self, pipe, protocol, waiter=None, argument
176 return _UnixReadPipeTransport(self, pipe, protocol, waiter, extra)
178 def _make_write_pipe_transport(self, pipe, protocol, waiter=None, argument
180 return _UnixWritePipeTransport(self, pipe, protocol, waiter, extra)
186 waiter = self.create_future()
189 waiter=waiter, extra=extra,
195 await waiter
426 def __init__(self, loop, pipe, protocol, waiter=None, extra=None): argument
450 if waiter is not None:
453 waiter, None)
[all …]
Dqueues.py64 waiter = waiters.popleft()
65 if not waiter.done():
66 waiter.set_result(None)
/external/apache-http/src/org/apache/http/impl/conn/tsccm/
DWaitingThread.java65 private Thread waiter; field in WaitingThread
119 return this.waiter; in getThread()
147 if (this.waiter != null) { in await()
151 "\nwaiter: " + this.waiter); in await()
157 this.waiter = Thread.currentThread(); in await()
170 this.waiter = null; in await()
186 if (this.waiter == null) { in wakeup()
/external/glide/library/src/main/java/com/bumptech/glide/request/
DRequestFutureTarget.java46 private final Waiter waiter; field in RequestFutureTarget
62 …Target(Handler mainHandler, int width, int height, boolean assertBackgroundThread, Waiter waiter) { in RequestFutureTarget() argument
67 this.waiter = waiter; in RequestFutureTarget()
83 waiter.notifyAll(this); in cancel()
172 waiter.notifyAll(this); in onLoadFailed()
183 waiter.notifyAll(this); in onResourceReady()
200 waiter.waitForTimeout(this, 0); in doGet()
202 waiter.waitForTimeout(this, timeoutMillis); in doGet()
/external/python/cpython3/Lib/test/test_asyncio/
Dtest_sslproto.py30 def ssl_protocol(self, *, waiter=None, proto=None): argument
34 ssl_proto = sslproto.SSLProtocol(self.loop, proto, sslcontext, waiter,
57 waiter = mock.Mock()
59 sslproto.SSLProtocol(self.loop, app_proto, sslcontext, waiter,
65 waiter = mock.Mock()
67 sslproto.SSLProtocol(self.loop, app_proto, sslcontext, waiter,
71 waiter = asyncio.Future(loop=self.loop)
72 ssl_proto = self.ssl_protocol(waiter=waiter)
76 self.assertIsInstance(waiter.exception(), ConnectionResetError)
82 waiter = asyncio.Future(loop=self.loop)
[all …]
Dtest_subprocess.py42 def create_transport(self, waiter=None): argument
48 None, None, None, 0, waiter=waiter)
52 waiter = asyncio.Future(loop=self.loop)
53 transport, protocol = self.create_transport(waiter)
55 self.loop.run_until_complete(waiter)
78 waiter = asyncio.Future(loop=self.loop)
79 transport, protocol = self.create_transport(waiter)
81 self.loop.run_until_complete(waiter)
/external/syzkaller/pkg/report/testdata/gvisor/report/
D61 TITLE: DATA RACE in waiter.(*Entry).Next
9 gvisor.googlesource.com/gvisor/pkg/waiter.(*Entry).Next()
13 gvisor.googlesource.com/gvisor/pkg/waiter.(*Queue).EventUnregister()
14 pkg/waiter/waiter.go:167 +0x67
37 gvisor.googlesource.com/gvisor/pkg/waiter.(*Entry).SetNext()
41 gvisor.googlesource.com/gvisor/pkg/waiter.(*Queue).EventRegister()
42 pkg/waiter/waiter.go:160 +0x86
112 gvisor.googlesource.com/gvisor/pkg/waiter.(*Entry).Next()
116 gvisor.googlesource.com/gvisor/pkg/waiter.(*Queue).EventUnregister()
117 pkg/waiter/waiter.go:167 +0x67
[all …]
/external/libchrome/base/synchronization/
Dwaitable_event_perftest.cc67 SignalerThread(TraceWaitableEvent* waiter, TraceWaitableEvent* signaler) in SignalerThread() argument
69 waiter_(waiter), in SignalerThread()
130 TraceWaitableEvent waiter(kSamples); in TEST() local
134 SignalerThread thread(&signaler, &waiter); in TEST()
139 waiter.Wait(); in TEST()
149 PrintPerfWaitableEvent(&waiter, "_waiter", "multithread-1000-samples"); in TEST()
Dwaitable_event_posix.cc331 Waiter* waiter) { in EnqueueMany() argument
347 waitables[i].first->Enqueue(waiter); in EnqueueMany()
414 void WaitableEvent::Enqueue(Waiter* waiter) { in Enqueue() argument
415 kernel_->waiters_.push_back(waiter); in Enqueue()
422 bool WaitableEvent::WaitableEventKernel::Dequeue(Waiter* waiter, void* tag) { in Dequeue() argument
425 if (*i == waiter && (*i)->Compare(tag)) { in Dequeue()
Dwaitable_event.h250 bool Dequeue(Waiter* waiter, void* tag);
270 size_t count, Waiter* waiter);
274 void Enqueue(Waiter* waiter);
/external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/
DNonBlockingThreadPool.h141 EventCount::Waiter* waiter = &waiters_[thread_id]; in WorkerLoop() local
160 if (!WaitForWork(waiter, &t)) { in WorkerLoop()
195 bool WaitForWork(EventCount::Waiter* waiter, Task* t) { in WaitForWork() argument
199 ec_.Prewait(waiter); in WaitForWork()
203 ec_.CancelWait(waiter); in WaitForWork()
212 ec_.CancelWait(waiter); in WaitForWork()
232 ec_.CommitWait(waiter); in WaitForWork()
/external/linux-kselftest/tools/testing/selftests/futex/functional/
Dfutex_requeue_pi_signal_restart.c126 pthread_t waiter; in main() local
161 res = create_rt_thread(&waiter, waiterfn, NULL, SCHED_FIFO, 1); in main()
180 pthread_kill(waiter, SIGUSR1); in main()
211 pthread_kill(waiter, SIGUSR1); in main()
213 pthread_join(waiter, NULL); in main()
/external/ltp/testcases/kernel/ipc/semaphore/
Dsem02.c61 void *waiter(void *);
102 rc = pthread_create(&pt[i], &attr, waiter, retval[i]); in main()
124 void *waiter(void *foo) in waiter() function
/external/python/cpython3/Lib/
Dthreading.py289 waiter = _allocate_lock()
290 waiter.acquire()
291 self._waiters.append(waiter)
296 waiter.acquire()
300 gotit = waiter.acquire(True, timeout)
302 gotit = waiter.acquire(False)
308 self._waiters.remove(waiter)
351 for waiter in waiters_to_notify:
352 waiter.release()
354 all_waiters.remove(waiter)
/external/dng_sdk/source/
Ddng_pthread.cpp59 struct waiter { struct
60 struct waiter *prev; argument
61 struct waiter *next; argument
87 waiter *head_waiter; // List of threads waiting on this condition
88 waiter *tail_waiter; // Used to get FIFO, rather than LIFO, behavior for pthread_cond_signal
576 waiter this_wait; in cond_wait_internal()
687 waiter *first; in dng_pthread_cond_signal()
719 waiter *first; in dng_pthread_cond_broadcast()
734 waiter *next = first->next; in dng_pthread_cond_broadcast()
/external/tensorflow/tensorflow/core/framework/
Drendezvous.cc191 item->waiter(Status::OK(), send_args, item->recv_args, val, is_dead); in Send()
215 item->waiter = std::move(done); in RecvAsync()
249 item->waiter(status, Args(), Args(), Tensor(), false); in StartAbort()
260 DoneCallback waiter = nullptr; member
276 bool IsSendValue() const { return this->waiter == nullptr; } in IsSendValue()

123