| /libcore/luni/src/test/java/libcore/java/net/ |
| OldDatagramPacketTest.java | 40 final Object lock = new Object(); local
47 synchronized (lock) {
49 lock.notifyAll();
72 synchronized (lock) {
75 lock.wait();
|
| /prebuilt/ndk/android-ndk-r4/platforms/android-3/arch-arm/usr/include/linux/raid/ |
| md_k.h | 180 #define __wait_event_lock_irq(wq, condition, lock, cmd) do { wait_queue_t __wait; init_waitqueue_entry(&__wait, current); add_wait_queue(&wq, &__wait); for (;;) { set_current_state(TASK_UNINTERRUPTIBLE); if (condition) break; spin_unlock_irq(&lock); cmd; schedule(); spin_lock_irq(&lock); } current->state = TASK_RUNNING; remove_wait_queue(&wq, &__wait); } while (0)
182 #define wait_event_lock_irq(wq, condition, lock, cmd) do { if (condition) break; __wait_event_lock_irq(wq, condition, lock, cmd); } while (0)
|
| /prebuilt/ndk/android-ndk-r4/platforms/android-4/arch-arm/usr/include/linux/raid/ |
| md_k.h | 180 #define __wait_event_lock_irq(wq, condition, lock, cmd) do { wait_queue_t __wait; init_waitqueue_entry(&__wait, current); add_wait_queue(&wq, &__wait); for (;;) { set_current_state(TASK_UNINTERRUPTIBLE); if (condition) break; spin_unlock_irq(&lock); cmd; schedule(); spin_lock_irq(&lock); } current->state = TASK_RUNNING; remove_wait_queue(&wq, &__wait); } while (0)
182 #define wait_event_lock_irq(wq, condition, lock, cmd) do { if (condition) break; __wait_event_lock_irq(wq, condition, lock, cmd); } while (0)
|
| /prebuilt/ndk/android-ndk-r4/platforms/android-5/arch-arm/usr/include/linux/raid/ |
| md_k.h | 180 #define __wait_event_lock_irq(wq, condition, lock, cmd) do { wait_queue_t __wait; init_waitqueue_entry(&__wait, current); add_wait_queue(&wq, &__wait); for (;;) { set_current_state(TASK_UNINTERRUPTIBLE); if (condition) break; spin_unlock_irq(&lock); cmd; schedule(); spin_lock_irq(&lock); } current->state = TASK_RUNNING; remove_wait_queue(&wq, &__wait); } while (0)
182 #define wait_event_lock_irq(wq, condition, lock, cmd) do { if (condition) break; __wait_event_lock_irq(wq, condition, lock, cmd); } while (0)
|
| /prebuilt/ndk/android-ndk-r4/platforms/android-5/arch-x86/usr/include/linux/raid/ |
| md_k.h | 180 #define __wait_event_lock_irq(wq, condition, lock, cmd) do { wait_queue_t __wait; init_waitqueue_entry(&__wait, current); add_wait_queue(&wq, &__wait); for (;;) { set_current_state(TASK_UNINTERRUPTIBLE); if (condition) break; spin_unlock_irq(&lock); cmd; schedule(); spin_lock_irq(&lock); } current->state = TASK_RUNNING; remove_wait_queue(&wq, &__wait); } while (0)
182 #define wait_event_lock_irq(wq, condition, lock, cmd) do { if (condition) break; __wait_event_lock_irq(wq, condition, lock, cmd); } while (0)
|
| /prebuilt/ndk/android-ndk-r4/platforms/android-8/arch-arm/usr/include/linux/raid/ |
| md_k.h | 180 #define __wait_event_lock_irq(wq, condition, lock, cmd) do { wait_queue_t __wait; init_waitqueue_entry(&__wait, current); add_wait_queue(&wq, &__wait); for (;;) { set_current_state(TASK_UNINTERRUPTIBLE); if (condition) break; spin_unlock_irq(&lock); cmd; schedule(); spin_lock_irq(&lock); } current->state = TASK_RUNNING; remove_wait_queue(&wq, &__wait); } while (0)
182 #define wait_event_lock_irq(wq, condition, lock, cmd) do { if (condition) break; __wait_event_lock_irq(wq, condition, lock, cmd); } while (0)
|
| /prebuilt/ndk/android-ndk-r4/platforms/android-8/arch-x86/usr/include/linux/raid/ |
| md_k.h | 180 #define __wait_event_lock_irq(wq, condition, lock, cmd) do { wait_queue_t __wait; init_waitqueue_entry(&__wait, current); add_wait_queue(&wq, &__wait); for (;;) { set_current_state(TASK_UNINTERRUPTIBLE); if (condition) break; spin_unlock_irq(&lock); cmd; schedule(); spin_lock_irq(&lock); } current->state = TASK_RUNNING; remove_wait_queue(&wq, &__wait); } while (0)
182 #define wait_event_lock_irq(wq, condition, lock, cmd) do { if (condition) break; __wait_event_lock_irq(wq, condition, lock, cmd); } while (0)
|
| /prebuilt/ndk/android-ndk-r5/platforms/android-3/arch-arm/usr/include/linux/raid/ |
| md_k.h | 180 #define __wait_event_lock_irq(wq, condition, lock, cmd) do { wait_queue_t __wait; init_waitqueue_entry(&__wait, current); add_wait_queue(&wq, &__wait); for (;;) { set_current_state(TASK_UNINTERRUPTIBLE); if (condition) break; spin_unlock_irq(&lock); cmd; schedule(); spin_lock_irq(&lock); } current->state = TASK_RUNNING; remove_wait_queue(&wq, &__wait); } while (0)
182 #define wait_event_lock_irq(wq, condition, lock, cmd) do { if (condition) break; __wait_event_lock_irq(wq, condition, lock, cmd); } while (0)
|
| /prebuilt/ndk/android-ndk-r6/platforms/android-3/arch-arm/usr/include/linux/raid/ |
| md_k.h | 180 #define __wait_event_lock_irq(wq, condition, lock, cmd) do { wait_queue_t __wait; init_waitqueue_entry(&__wait, current); add_wait_queue(&wq, &__wait); for (;;) { set_current_state(TASK_UNINTERRUPTIBLE); if (condition) break; spin_unlock_irq(&lock); cmd; schedule(); spin_lock_irq(&lock); } current->state = TASK_RUNNING; remove_wait_queue(&wq, &__wait); } while (0)
182 #define wait_event_lock_irq(wq, condition, lock, cmd) do { if (condition) break; __wait_event_lock_irq(wq, condition, lock, cmd); } while (0)
|
| /prebuilt/ndk/android-ndk-r6/platforms/android-3/arch-x86/usr/include/linux/raid/ |
| md_k.h | 180 #define __wait_event_lock_irq(wq, condition, lock, cmd) do { wait_queue_t __wait; init_waitqueue_entry(&__wait, current); add_wait_queue(&wq, &__wait); for (;;) { set_current_state(TASK_UNINTERRUPTIBLE); if (condition) break; spin_unlock_irq(&lock); cmd; schedule(); spin_lock_irq(&lock); } current->state = TASK_RUNNING; remove_wait_queue(&wq, &__wait); } while (0)
182 #define wait_event_lock_irq(wq, condition, lock, cmd) do { if (condition) break; __wait_event_lock_irq(wq, condition, lock, cmd); } while (0)
|
| /external/chromium/base/synchronization/ |
| condition_variable_win.cc | 10 #include "base/synchronization/lock.h"
15 ConditionVariable::ConditionVariable(Lock* user_lock)
64 AutoUnlock unlock(user_lock_); // Release caller's lock
70 } // Reacquire callers lock to depth at entry.
356 6) How is it that the callers lock is released atomically with the
359 allocation takes place before the caller's lock is released (and
363 Hence we actually "commit to wait" before releasing the lock, making
366 8) Why do you need to lock your data structures during waiting, as the
367 caller is already in possession of a lock? We need to Acquire() and
368 Release() our internal lock during Signal() and Broadcast(). If we trie
[all...] |
| condition_variable.h | 79 #include "base/synchronization/lock.h"
87 // Construct a cv for use with ONLY one user lock.
88 explicit ConditionVariable(Lock* user_lock);
109 // All calls to methods MUST be done under protection of a lock so that links
110 // can be validated. Without the lock, some links might asynchronously
160 base::Lock internal_lock_;
162 // Lock that is acquired before calling Wait().
163 base::Lock& user_lock_;
180 base::Lock* user_lock_; // Needed to adjust shadow lock state on wait
[all...] |
| /external/libxml2/ |
| threads.c | 108 pthread_mutex_t lock; member in struct:_xmlMutex
124 pthread_mutex_t lock; member in struct:_xmlRMutex
133 xmlMutexPtr lock;
143 * - xmlLibraryLock a global lock
198 pthread_mutex_init(&tok->lock, NULL);
226 pthread_mutex_destroy(&tok->lock);
239 * xmlMutexLock() is used to lock a libxml2 token.
248 pthread_mutex_lock(&tok->lock);
277 pthread_mutex_unlock(&tok->lock);
292 * synchronizing access to data. token_r is a re-entrant lock and thus usefu
[all...] |
| /packages/apps/Settings/src/com/android/settings/applications/ |
| ApplicationsState.java | 376 * background thread only holds the lock for a short amount of time, if
378 * acquiring its lock for a long time... sometimes even > 5 seconds
381 * Dalvik will promote a monitor to a "real" lock if it detects enough
384 * lock immediately.
395 if (DEBUG_LOCKING) Log.v(TAG, "resume about to acquire lock...");
440 if (DEBUG_LOCKING) Log.v(TAG, "...resume releasing lock");
445 if (DEBUG_LOCKING) Log.v(TAG, "pause about to acquire lock...");
449 if (DEBUG_LOCKING) Log.v(TAG, "...pause releasing lock");
517 if (DEBUG_LOCKING) Log.v(TAG, "rebuild acquired lock");
522 if (DEBUG_LOCKING) Log.v(TAG, "rebuild releasing lock");
[all...] |
| /dalvik/vm/ |
| Atomic.cpp | 25 * spin lock implementation. We don't want to rely on mutex innards,
177 pthread_mutex_t* lock = SWAP_LOCK(addr); local
179 pthread_mutex_lock(lock);
184 pthread_mutex_unlock(lock);
198 pthread_mutex_t* lock = SWAP_LOCK(addr); local
200 pthread_mutex_lock(lock);
208 pthread_mutex_unlock(lock);
215 pthread_mutex_t* lock = SWAP_LOCK(addr); local
217 pthread_mutex_lock(lock);
219 pthread_mutex_unlock(lock);
[all...] |
| /external/elfutils/libelf/ |
| elf_end.c | 41 rwlock_wrlock (elf->lock);
47 rwlock_unlock (elf->lock);
70 /* This is tricky. Lock must be acquire from the father to
71 the child but here we already have the child lock. We
72 solve this problem by giving free the child lock. The
75 rwlock_unlock (elf->lock);
76 rwlock_rdlock (parent->lock);
77 rwlock_wrlock (elf->lock);
91 rwlock_unlock (parent->lock);
195 rwlock_fini (elf->lock);
[all...] |
| /external/webkit/Source/WebCore/webaudio/ |
| AudioContext.h | 151 // mustReleaseLock is set to true if we acquired the lock in this method call and caller must unlock(), false if it was previously acquired.
152 void lock(bool& mustReleaseLock);
154 // Returns true if we own the lock.
155 // mustReleaseLock is set to true if we acquired the lock in this method call and caller must unlock(), false if it was previously acquired.
160 // Returns true if this thread owns the context's lock.
169 context->lock(m_mustReleaseLock);
188 // Only accessed when the graph lock is held.
243 // Either accessed when the graph lock is held, or on the main thread when the audio thread has finished.
249 // Only accessed when the graph lock is held.
263 volatile ThreadIdentifier m_graphOwnerThread; // if the lock is held then this is the thread which owns it, otherwise == UndefinedThreadIdentifie
[all...] |
| /external/webkit/Source/WebKit/android/WebCoreSupport/ |
| WebCookieJar.cpp | 55 MutexLocker lock(databaseDirectoryMutex);
110 MutexLocker lock(instanceMutex);
123 MutexLocker lock(instanceMutex);
150 MutexLocker lock(m_allowCookiesMutex);
156 MutexLocker lock(m_allowCookiesMutex);
170 MutexLocker lock(m_allowCookiesMutex);
177 MutexLocker lock(m_allowCookiesMutex);
231 base::Lock m_lock;
247 MutexLocker lock(instanceMutex);
258 MutexLocker lock(instanceMutex)
[all...] |
| /external/webkit/Source/WebKit/mac/Misc/ |
| WebCoreStatistics.mm | 61 JSLock lock(SilenceAssertionsOnly);
67 JSLock lock(SilenceAssertionsOnly);
73 JSLock lock(SilenceAssertionsOnly);
79 JSLock lock(SilenceAssertionsOnly);
85 JSLock lock(SilenceAssertionsOnly);
100 JSLock lock(SilenceAssertionsOnly);
165 JSLock lock(SilenceAssertionsOnly);
171 JSLock lock(SilenceAssertionsOnly);
199 JSLock lock(SilenceAssertionsOnly);
243 JSLock lock(SilenceAssertionsOnly)
[all...] |
| /external/chromium/chrome/browser/sync/syncable/ |
| syncable.cc | 419 ScopedKernelLock lock(this);
420 return GetEntryById(id, &lock);
424 ScopedKernelLock* const lock) {
436 ScopedKernelLock lock(this);
449 ScopedKernelLock lock(this);
466 ScopedKernelLock lock(this);
467 return GetEntryByHandle(metahandle, &lock);
471 ScopedKernelLock* lock) {
488 ScopedKernelLock lock(this);
491 for (iterator i = GetParentChildIndexLowerBound(lock, parent_id)
[all...] |
| /external/bluetooth/glib/gthread/ |
| gthread-win32.c | 94 CRITICAL_SECTION lock; member in struct:_GCond
188 InitializeCriticalSection (&retval->lock);
196 EnterCriticalSection (&cond->lock);
204 LeaveCriticalSection (&cond->lock);
211 EnterCriticalSection (&cond->lock);
217 LeaveCriticalSection (&cond->lock);
234 EnterCriticalSection (&cond->lock);
240 LeaveCriticalSection (&cond->lock);
251 EnterCriticalSection (&cond->lock);
261 LeaveCriticalSection (&cond->lock);
[all...] |
| /external/chromium/chrome/browser/sync/engine/net/ |
| server_connection_manager.h | 15 #include "base/synchronization/lock.h"
169 typedef EventChannel<ServerConnectionEvent, base::Lock> Channel;
212 base::AutoLock lock(scm_->server_parameters_mutex_);
290 base::AutoLock lock(terminate_all_io_mutex_);
305 base::AutoLock lock(auth_token_mutex_);
310 base::AutoLock lock(auth_token_mutex_);
316 base::AutoLock lock(path_mutex_);
321 base::AutoLock lock(path_mutex_);
338 mutable base::Lock server_parameters_mutex_;
356 mutable base::Lock path_mutex_
[all...] |
| /external/clang/lib/CodeGen/ |
| CGObjCRuntime.cpp | 292 // Evaluate the lock operand. This is guaranteed to dominate the
293 // ARC release and lock-release cleanups.
295 llvm::Value *lock; local
297 lock = CGF.EmitARCRetainScalarExpr(lockExpr);
298 lock = CGF.EmitObjCConsumeObject(lockExpr->getType(), lock);
300 lock = CGF.EmitScalarExpr(lockExpr);
302 lock = CGF.Builder.CreateBitCast(lock, CGF.VoidPtrTy);
304 // Acquire the lock
[all...] |
| /external/v8/src/ |
| execution.h | 168 void InitThread(const ExecutionAccess& lock);
171 void ClearThread(const ExecutionAccess& lock);
192 // have the global V8 lock if you are using multiple V8 threads.
215 // You should hold the ExecutionAccess lock when calling this method.
216 bool has_pending_interrupts(const ExecutionAccess& lock) {
219 ASSERT(!should_postpone_interrupts(lock));
223 // You should hold the ExecutionAccess lock when calling this method.
224 bool should_postpone_interrupts(const ExecutionAccess& lock) {
228 // You should hold the ExecutionAccess lock when calling this method.
229 inline void set_interrupt_limits(const ExecutionAccess& lock);
[all...] |
| /external/valgrind/unittest/ |
| thread_wrappers_pthread.h | 139 /// pthread_mutex_t is *not* a reader-writer lock,
160 void Lock() { CHECK(0 == pthread_mutex_lock(&mu_));}
169 void ReaderLock() { Lock(); }
173 void LockWhen(Condition cond) { Lock(); WaitLoop(cond); }
174 void ReaderLockWhen(Condition cond) { Lock(); WaitLoop(cond); }
178 { Lock(); return WaitLoopWithTimeout(cond, millis); }
180 { Lock(); return WaitLoopWithTimeout(cond, millis); }
237 // ReaderLock method of Mutex to be the real rw-lock.
238 // So, we need a special lock class to test reader locks.
244 void Lock() { CHECK(0 == pthread_rwlock_wrlock(&mu_));
[all...] |
