| /external/jetty/src/java/org/eclipse/jetty/util/ |
| D | ArrayQueue.java | 39 protected final Object _lock; field in ArrayQueue
67 _lock = lock == null ? this : lock; in ArrayQueue()
75 synchronized (_lock) in getCapacity()
93 synchronized (_lock) in offer()
129 synchronized (_lock) in element()
146 synchronized (_lock) in peek()
157 synchronized (_lock) in poll()
179 synchronized (_lock) in remove()
191 synchronized (_lock) in clear()
203 synchronized (_lock) in isEmpty()
[all …]
|
| /external/jetty/src/java/org/eclipse/jetty/websocket/ |
| D | WebSocketGeneratorD08.java | 35 private final Lock _lock = new ReentrantLock(); field in WebSocketGeneratorD08
59 _lock.lock(); in getBuffer()
66 _lock.unlock(); in getBuffer()
72 _lock.lock(); in addFrame()
197 _lock.unlock(); in addFrame()
203 if (!_lock.tryLock()) in flushBuffer()
223 _lock.unlock(); in flushBuffer()
229 if (!_lock.tryLock()) in flush()
261 _lock.unlock(); in flush()
267 _lock.lock(); in isBufferEmpty()
[all …]
|
| D | WebSocketGeneratorRFC6455.java | 39 private final Lock _lock = new ReentrantLock(); field in WebSocketGeneratorRFC6455
63 _lock.lock(); in getBuffer()
70 _lock.unlock(); in getBuffer()
76 _lock.lock(); in addFrame()
201 _lock.unlock(); in addFrame()
207 if (!_lock.tryLock()) in flushBuffer()
227 _lock.unlock(); in flushBuffer()
233 if (!_lock.tryLock()) in flush()
265 _lock.unlock(); in flush()
271 _lock.lock(); in isBufferEmpty()
[all …]
|
| /external/jetty/src/java/org/eclipse/jetty/util/thread/ |
| D | Timeout.java | 37 private Object _lock; field in Timeout
45 _lock=new Object(); in Timeout()
52 _lock=lock; in Timeout()
102 synchronized (_lock) in expired()
130 synchronized (_lock) in tick()
169 synchronized (_lock) in schedule()
196 synchronized (_lock) in cancelAll()
205 synchronized (_lock) in isEmpty()
214 synchronized (_lock) in getTimeToNext()
347 synchronized (timeout._lock) in cancel()
|
| /external/libevent/ |
| D | evthread_pthread.c | 59 evthread_posix_lock_free(void *_lock, unsigned locktype) in evthread_posix_lock_free() argument
61 pthread_mutex_t *lock = _lock; in evthread_posix_lock_free()
67 evthread_posix_lock(unsigned mode, void *_lock) in evthread_posix_lock() argument
69 pthread_mutex_t *lock = _lock; in evthread_posix_lock()
77 evthread_posix_unlock(unsigned mode, void *_lock) in evthread_posix_unlock() argument
79 pthread_mutex_t *lock = _lock; in evthread_posix_unlock()
135 evthread_posix_cond_wait(void *_cond, void *_lock, const struct timeval *tv) in evthread_posix_cond_wait() argument
139 pthread_mutex_t *lock = _lock; in evthread_posix_cond_wait()
|
| D | evthread_win32.c | 62 evthread_win32_lock_free(void *_lock, unsigned locktype) in evthread_win32_lock_free() argument
64 CRITICAL_SECTION *lock = _lock; in evthread_win32_lock_free()
70 evthread_win32_lock(unsigned mode, void *_lock) in evthread_win32_lock() argument
72 CRITICAL_SECTION *lock = _lock; in evthread_win32_lock()
82 evthread_win32_unlock(unsigned mode, void *_lock) in evthread_win32_unlock() argument
84 CRITICAL_SECTION *lock = _lock; in evthread_win32_unlock()
155 evthread_win32_condvar_wait(void *_cond, void *_lock, const struct timeval *tv) in evthread_win32_condvar_wait() argument
158 CRITICAL_SECTION *lock = _lock; in evthread_win32_condvar_wait()
231 evthread_win32_cond_wait(void *_cond, void *_lock, const struct timeval *tv) in evthread_win32_cond_wait() argument
234 CRITICAL_SECTION *lock = _lock; in evthread_win32_cond_wait()
|
| D | evthread.c | 254 debug_cond_wait(void *_cond, void *_lock, const struct timeval *tv) in debug_cond_wait() argument
257 struct debug_lock *lock = _lock; in debug_cond_wait()
259 EVLOCK_ASSERT_LOCKED(_lock); in debug_cond_wait()
|
| /external/v8/build/android/pylib/base/ |
| D | test_collection.py | 17 self._lock = threading.Lock()
36 with self._lock:
52 with self._lock:
59 with self._lock:
79 with self._lock:
|
| D | test_dispatcher.py | 39 self._lock = threading.Lock()
48 with self._lock:
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/oauth2client/oauth2client/ |
| D | keyring_storage.py | 61 self._lock = threading.Lock()
67 self._lock.acquire()
75 self._lock.release()
|
| D | file.py | 39 self._lock = threading.Lock()
50 self._lock.acquire()
58 self._lock.release()
|
| D | multistore_file.py | 159 multistore._lock()
224 self._multistore._lock()
280 def _lock(self): member in _MultiStore
|
| /external/webrtc/webrtc/modules/video_capture/mac/qtkit/ |
| D | video_capture_qtkit_objc.mm | 49 [_lock release];
57 [_lock lock];
59 [_lock unlock];
174 _lock = [[NSLock alloc] init];
231 [_lock lock];
233 [_lock unlock];
255 [_lock unlock];
|
| D | video_capture_qtkit_objc.h | 38 NSLock* _lock; variable
|
| /external/autotest/site_utils/rpm_control_system/ |
| D | frontend_server.py | 89 self._lock = threading.Lock()
200 with self._lock:
251 with self._lock:
284 with self._lock:
306 with self._lock:
|
| D | rpm_dispatcher.py | 65 self._lock = threading.Lock()
90 with self._lock:
101 with self._lock:
|
| /external/autotest/client/virt/ |
| D | kvm_monitor.py | 73 self._lock = threading.RLock()
115 if self._lock.acquire(False):
233 self._lock.release()
282 self._lock.release()
597 self._lock.release()
627 self._lock.release()
702 self._lock.release()
727 self._lock.release()
|
| D | aexpect.py | 13 def _lock(filename): function
42 fd = _lock(filename)
86 lock_server_running = _lock(lock_server_running_filename)
423 lock_client_starting = _lock(self.lock_client_starting_filename)
|
| /external/chromium-trace/catapult/devil/devil/utils/lazy/ |
| D | weak_constant.py | 18 self._lock = threading.Lock()
25 with self._lock:
|
| /external/jetty/src/java/org/eclipse/jetty/util/component/ |
| D | AbstractLifeCycle.java | 41 private final Object _lock = new Object(); field in AbstractLifeCycle
57 synchronized (_lock) in start()
82 synchronized (_lock) in stop()
|
| /external/autotest/client/deps/lansim/src/py/ |
| D | simulator.py | 57 self._lock = NullContext()
110 with self._lock:
205 with self._lock:
307 self._lock = threading.RLock()
|
| /external/chromium-trace/catapult/common/py_trace_event/py_trace_event/trace_event_impl/ |
| D | log.py | 16 _lock = threading.Lock() variable
39 _lock.acquire()
43 _lock.release()
|
| /external/libunwind_llvm/src/ |
| D | UnwindCursor.hpp | 63 static pthread_rwlock_t _lock; member in libunwind::DwarfFDECache
91 pthread_rwlock_t DwarfFDECache<A>::_lock = PTHREAD_RWLOCK_INITIALIZER; member in libunwind::DwarfFDECache<A>
101 _LIBUNWIND_LOG_NON_ZERO(::pthread_rwlock_rdlock(&_lock)); in findFDE()
110 _LIBUNWIND_LOG_NON_ZERO(::pthread_rwlock_unlock(&_lock)); in findFDE()
117 _LIBUNWIND_LOG_NON_ZERO(::pthread_rwlock_wrlock(&_lock)); in add()
141 _LIBUNWIND_LOG_NON_ZERO(::pthread_rwlock_unlock(&_lock)); in add()
146 _LIBUNWIND_LOG_NON_ZERO(::pthread_rwlock_wrlock(&_lock)); in removeAllIn()
156 _LIBUNWIND_LOG_NON_ZERO(::pthread_rwlock_unlock(&_lock)); in removeAllIn()
169 _LIBUNWIND_LOG_NON_ZERO(::pthread_rwlock_wrlock(&_lock)); in iterateCacheEntries()
173 _LIBUNWIND_LOG_NON_ZERO(::pthread_rwlock_unlock(&_lock)); in iterateCacheEntries()
|
| /external/llvm/test/tools/llvm-objdump/ |
| D | coff-private-headers.test | 15 IMPORT-NEXT: 892 _lock
|
| /external/chromium-trace/catapult/third_party/Paste/paste/ |
| D | httpserver.py | 384 self._lock.acquire()
388 self._lock.release()
390 self._lock.acquire()
394 self._lock.release()
|