| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| WaitingThread.java | 65 private Thread waiter; field in class:WaitingThread
119 return this.waiter;
147 if (this.waiter != null) {
151 "\nwaiter: " + this.waiter);
157 this.waiter = Thread.currentThread();
170 this.waiter = null;
186 if (this.waiter == null) {
|
| /frameworks/base/core/java/android/database/sqlite/ |
| SQLiteConnectionPool.java | 596 final ConnectionWaiter waiter; local
619 // No connections available. Enqueue a waiter in priority order.
622 waiter = obtainConnectionWaiterLocked(Thread.currentThread(), startTime,
628 waiter.mNext = successor;
635 predecessor.mNext = waiter;
637 mConnectionWaiterQueue = waiter;
640 nonce = waiter.mNonce;
649 if (waiter.mNonce == nonce) {
650 cancelConnectionWaiterLocked(waiter);
660 long nextBusyTimeoutTime = waiter.mStartTime + busyTimeoutMillis
785 ConnectionWaiter waiter = mConnectionWaiterQueue; local
922 ConnectionWaiter waiter = mConnectionWaiterQueue; local
969 ConnectionWaiter waiter = mConnectionWaiterPool; local
[all...] |
| /external/libmojo/mojo/edk/system/ |
| awakable_list_unittest.cc | 14 #include "mojo/edk/system/waiter.h"
30 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE, 1);
34 awakable_list.Remove(thread.waiter());
43 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_WRITABLE, 2);
54 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE, 3);
71 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE, 1);
76 awakable_list.Remove(thread.waiter());
85 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_WRITABLE, 2);
89 awakable_list.Remove(thread.waiter());
91 awakable_list.Remove(thread.waiter());
[all...] |
| waiter_unittest.cc | 10 #include "mojo/edk/system/waiter.h"
57 Waiter* waiter() { return &waiter_; } function in class:mojo::edk::__anon23510::WaitingThread
80 Waiter waiter_; // Thread-safe.
102 thread.waiter()->Awake(MOJO_RESULT_OK, 1);
112 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 2);
125 thread.waiter()->Awake(1, 3);
138 thread.waiter()->Awake(2, 4);
163 thread.waiter()->Awake(MOJO_RESULT_OK, 5);
173 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 6)
212 Waiter waiter; local
[all...] |
| waiter_test_utils.h | 15 #include "mojo/edk/system/waiter.h"
22 // This is a very simple thread that has a |Waiter|, on which it waits
24 // |Waiter| on creation, but the caller must start the thread with |Start()|. It
33 // awakable_list.Add(thread.waiter(), ...);
35 // ... some stuff to wake the waiter ...
36 // awakable_list.Remove(thread.waiter());
41 // |Waiter::Init()|, |AddAwakable()|, and |RemoveAwakable()| are done in the
42 // main (test) thread, not the waiter thread (as would actually happen in real
53 Waiter* waiter() { return &waiter_; function in class:mojo::edk::test::SimpleWaiterThread
[all...] |
| /libcore/luni/src/test/java/libcore/java/lang/ |
| OldAndroidMonitorTest.java | 110 static class Waiter extends Thread {
115 public Waiter(Object lock, CountDownLatch cdl) {
145 final Waiter waiter = new Waiter(lock, cdl); local
147 waiter.start();
149 // Wait for the "waiter" to start and acquire |lock| for the first time.
156 // Interrupt |waiter| after we acquire |lock|. This ensures that |waiter| is
159 waiter.interrupt()
[all...] |
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| RequestFutureTarget.java | 39 private static final Waiter DEFAULT_WAITER = new Waiter();
46 private final Waiter waiter; field in class:RequestFutureTarget
62 RequestFutureTarget(Handler mainHandler, int width, int height, boolean assertBackgroundThread, Waiter waiter) {
67 this.waiter = waiter;
83 waiter.notifyAll(this);
172 waiter.notifyAll(this)
[all...] |
| /tools/tradefederation/core/tests/src/com/android/tradefed/targetprep/ |
| DeviceFlashPreparerTest.java | 189 Thread waiter = new Thread() { local
201 waiter.start();
203 assertTrue("Invalid state: waiter thread is not alive", waiter.isAlive());
211 waiter.join(1000);
212 assertFalse("waiter thread has not returned", waiter.isAlive());
225 Thread waiter = new Thread() { local
238 waiter.start();
240 assertTrue("Invalid state: waiter thread is not alive", waiter.isAlive())
263 Thread waiter = new Thread() { local
[all...] |
| /external/libchrome/base/synchronization/ |
| waitable_event.h | 116 class Waiter {
118 // Signal the waiter to wake up.
120 // Consider the case of a Waiter which is in multiple WaitableEvent's
122 // signaled at the same time. Now, each will wake only the first waiter in
125 // to dequeue the waiter from the other wait-list in time), two auto-resets
126 // will have happened, but only one waiter has been signaled!
128 // Because of this, a Waiter may "reject" a wake by returning false. In
140 virtual ~Waiter() {}
162 bool Dequeue(Waiter* waiter, void* tag)
[all...] |
| waitable_event_posix.cc | 23 // waiter is either an async wait, in which case we have a Task and the
33 // firing a waiter and so we can store that pointer to find out which event
83 // This is a synchronous waiter. The thread is waiting on the given condition
86 class SyncWaiter : public WaitableEvent::Waiter {
266 // enqueued our waiter in them all.
311 // The locks of the WaitableEvents have been taken in order and the Waiter has
315 // None of the WaitableEvent locks are held. The Waiter has not been enqueued
322 size_t count, Waiter* waiter) {
334 const size_t r = EnqueueMany(waitables + 1, count - 1, waiter);
[all...] |
| /external/ltp/testcases/kernel/ipc/semaphore/ |
| sem02.c | 29 * Waiter, pid = <pid#>
33 * Waiter waiting, pid = <pid#>
34 * Waiter done waiting
61 void *waiter(void *);
102 rc = pthread_create(&pt[i], &attr, waiter, retval[i]);
122 place, the semop should complete and we'll print "Waiter done
124 void *waiter(void *foo) function
129 tst_resm(TINFO, "Waiter, pid = %d", pid);
132 tst_resm(TINFO, "Waiter waiting, pid = %d", pid);
134 tst_resm(TINFO, "Waiter done waiting")
[all...] |
| /external/linux-kselftest/tools/testing/selftests/futex/functional/ |
| futex_requeue_pi_signal_restart.c | 13 * kernel. The latter should return EWOULDBLOCK to the waiter.
102 info("Waiter running\n");
116 info("Waiter exiting with %d\n", waiter_ret);
125 pthread_t waiter; local
158 info("Creating waiter\n");
159 res = create_rt_thread(&waiter, waiterfn, NULL, SCHED_FIFO, 1);
173 * signal the waiter before requeue, waiter should automatically
175 * waiter to block on f1 again.
177 info("Issuing SIGUSR1 to waiter\n")
[all...] |
| futex_requeue_pi.c | 116 info("Waiter %ld: running\n", args->id);
129 info("waiter %ld woke with %d %s\n", args->id, args->ret,
143 info("Waiter %ld: exiting with %d\n", args->id, args->ret);
286 pthread_t waiter[THREAD_MAX], waker, blocker; local
323 if (create_rt_thread(&waiter[i], waiterfn, (void *)&args[i],
342 pthread_join(waiter[i],
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| NonBlockingThreadPool.h | 128 MaxSizeVector<EventCount::Waiter> waiters_;
141 EventCount::Waiter* waiter = &waiters_[thread_id]; local
160 if (!WaitForWork(waiter, &t)) {
195 bool WaitForWork(EventCount::Waiter* waiter, Task* t) {
199 ec_.Prewait(waiter);
203 ec_.CancelWait(waiter);
212 ec_.CancelWait(waiter);
232 ec_.CommitWait(waiter);
[all...] |
| /art/test/059-finalizer-throw/src/ |
| Main.java | 25 static Object waiter = new Object(); field in class:Main
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ticketpool/ |
| ReservableTicketPool.java | 52 private static class Waiter {
56 private Waiter(Condition doneCondition, int requestedTicketCount) {
128 private final ArrayDeque<Waiter> mTicketWaiters;
307 Waiter thisWaiter = new Waiter(mLock.newCondition(), tickets);
362 Waiter nextWaiter = mTicketWaiters.peek();
381 List<Waiter> toRemove = new ArrayList<>();
382 for (Waiter waiter : mTicketWaiters) {
383 if (waiter.getRequestedTicketCount() > mCapacity)
[all...] |
| FiniteTicketPool.java | 57 private class Waiter {
61 private Waiter(int ticketsRequested, Condition condition) {
78 private final LinkedList<Waiter> mWaiters;
103 Waiter nextWaiter = mWaiters.peekFirst();
125 Waiter thisWaiter = new Waiter(tickets, mLock.newCondition());
195 for (Waiter waiter : mWaiters) {
196 waiter.getCondition().signal();
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| SynchronousQueue.java | 237 volatile Thread waiter; // to control park/unpark field in class:SynchronousQueue.TransferStack.SNode
264 Thread w = waiter;
266 waiter = null;
392 if (m == null) // waiter is gone
415 * When a node/thread is about to block, it sets its waiter
418 * fulfiller noticing that waiter is non-null so should be
456 else if (s.waiter == null)
457 s.waiter = w; // establish waiter so can park next iter
479 s.waiter = null; // forget threa
539 volatile Thread waiter; \/\/ to control park\/unpark field in class:SynchronousQueue.TransferQueue.QNode
[all...] |
| /prebuilts/go/darwin-x86/src/sync/ |
| cond_test.go | 192 // Start a waiter.
207 // We know that the waiter is in the cond.Wait() call because we
214 // The new waiter may or may not get notified, but the first one
229 // Check that the first waiter does get signaled.
233 t.Fatalf("First waiter didn't get broadcast.")
236 // Release the second waiter in case it didn't get the
|
| /prebuilts/go/linux-x86/src/sync/ |
| cond_test.go | 192 // Start a waiter.
207 // We know that the waiter is in the cond.Wait() call because we
214 // The new waiter may or may not get notified, but the first one
229 // Check that the first waiter does get signaled.
233 t.Fatalf("First waiter didn't get broadcast.")
236 // Release the second waiter in case it didn't get the
|
| /external/dnsmasq/src/ |
| log.c | 385 struct timespec waiter; local
386 waiter.tv_sec = 0;
387 waiter.tv_nsec = 1000000 << (d - 1); /* 1 ms */
388 nanosleep(&waiter, NULL);
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/util/ |
| ConditionPriorityBlockingQueueTest.java | 154 Thread waiter = new Thread() { local
164 waiter.setName(getClass().getCanonicalName() + "#testTake_multiple_matchers");
165 waiter.start();
204 waiter.join();
|
| /external/dng_sdk/source/ |
| dng_pthread.cpp | 59 struct waiter { struct in namespace:__anon17554
60 struct waiter *prev;
61 struct waiter *next;
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;
578 int my_generation; // The broadcast generation this waiter is in
587 // Add this waiter to the end of the list.
593 // If the list was empty, set the head of the list to this waiter.
597 // Note which broadcast generation this waiter belongs to
[all...] |
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_signal/ |
| 4-2.c | 160 void *waiter(void *arg) function
173 UNRESOLVED(ret, "Unable to lock mutex in waiter thread");
189 UNRESOLVED(ret, "Unable to unlock mutex in waiter thread");
266 if ((ret = pthread_create(&th_waiter, NULL, waiter, NULL))) {
267 UNRESOLVED(ret, "Waiter thread creation failed");
304 UNRESOLVED(ret, "Waiter thread join failed");
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/uicc/ |
| AdnRecordCache.java | 318 Message waiter = waiters.get(i); local
320 AsyncResult.forMessage(waiter, ar.result, ar.exception);
321 waiter.sendToTarget();
|
