MCPcopy Create free account
hub / github.com/dask/dask / CounterLock

Class CounterLock

dask/array/tests/test_array_core.py:2331–2344  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

2329
2330
2331class CounterLock:
2332 def __init__(self, *args, **kwargs):
2333 self.lock = Lock(*args, **kwargs)
2334
2335 self.acquire_count = 0
2336 self.release_count = 0
2337
2338 def acquire(self, *args, **kwargs):
2339 self.acquire_count += 1
2340 return self.lock.acquire(*args, **kwargs)
2341
2342 def release(self, *args, **kwargs):
2343 self.release_count += 1
2344 return self.lock.release(*args, **kwargs)
2345
2346
2347def test_store_locks_failure_lock_released():

Callers 3

test_store_locksFunction · 0.85

Calls

no outgoing calls

Tested by 3

test_store_locksFunction · 0.68