Searched refs:_active_lock (Results 1 – 11 of 11) sorted by relevance
42 RateLimiter() : _queue_lock(TSMutexCreate()), _active_lock(TSMutexCreate()) {} in RateLimiter()47 TSMutexDestroy(_active_lock); in ~RateLimiter()56 TSMutexLock(_active_lock); in reserve()59 TSMutexUnlock(_active_lock); // Reduce the critical section, release early in reserve()63 TSMutexUnlock(_active_lock); in reserve()71 TSMutexLock(_active_lock); in release()73 TSMutexUnlock(_active_lock); in release()155 TSMutex _queue_lock, _active_lock; // Resource locks variable
152 self._active_lock = threading.Lock()182 self._active_lock.acquire()184 self._active_lock.release()
2960 self._active_lock = threading.Lock()2991 self._active_lock.acquire()2993 self._active_lock.release()
2702 self._active_lock = threading.Lock()2733 self._active_lock.acquire()2735 self._active_lock.release()
3246 self._active_lock = threading.Lock()3277 self._active_lock.acquire()3279 self._active_lock.release()
3101 self._active_lock = threading.Lock()3132 self._active_lock.acquire()3134 self._active_lock.release()
3248 self._active_lock = threading.Lock()3279 self._active_lock.acquire()3281 self._active_lock.release()