/external/libese/apps/boot/card/src/com/android/verifiedboot/storage/ |
D | Storage.java | 68 private LockInterface[] locks; field in Storage 140 locks = new LockInterface[4]; in Storage() 143 locks[LOCK_CARRIER] = new CarrierLock(); in Storage() 145 locks[LOCK_CARRIER]); in Storage() 149 locks[LOCK_DEVICE] = new BasicLock(NO_METADATA, NO_REQ_LOCKS); in Storage() 150 BasicLock lockRef = (BasicLock)locks[LOCK_DEVICE]; in Storage() 157 locks[LOCK_BOOT] = new BasicLock(NO_METADATA, (short) 2); in Storage() 158 lockRef = (BasicLock)locks[LOCK_BOOT]; in Storage() 159 lockRef.addRequiredLock(locks[LOCK_CARRIER]); in Storage() 160 lockRef.addRequiredLock(locks[LOCK_DEVICE]); in Storage() [all …]
|
/external/guava/android/guava-tests/benchmark/com/google/common/util/concurrent/ |
D | CycleDetectingLockFactoryBenchmark.java | 22 import java.util.concurrent.locks.Lock; 23 import java.util.concurrent.locks.ReentrantLock; 79 private static void lockAndUnlockNested(Lock[] locks, int reps) { in lockAndUnlockNested() argument 81 for (int j = 0; j < locks.length; j++) { in lockAndUnlockNested() 82 locks[j].lock(); in lockAndUnlockNested() 84 for (int j = locks.length - 1; j >= 0; j--) { in lockAndUnlockNested() 85 locks[j].unlock(); in lockAndUnlockNested()
|
D | StripedBenchmark.java | 34 import java.util.concurrent.locks.Lock; 35 import java.util.concurrent.locks.ReentrantLock; 100 final List<Lock> locks = new ArrayList<>(numStripes); field in StripedBenchmark 104 locks.clear(); in sizeOfPopulatedStriped() 107 locks.add(striped.getAt(i)); in sizeOfPopulatedStriped()
|
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
D | CycleDetectingLockFactoryBenchmark.java | 22 import java.util.concurrent.locks.Lock; 23 import java.util.concurrent.locks.ReentrantLock; 79 private static void lockAndUnlockNested(Lock[] locks, int reps) { in lockAndUnlockNested() argument 81 for (int j = 0; j < locks.length; j++) { in lockAndUnlockNested() 82 locks[j].lock(); in lockAndUnlockNested() 84 for (int j = locks.length - 1; j >= 0; j--) { in lockAndUnlockNested() 85 locks[j].unlock(); in lockAndUnlockNested()
|
D | StripedBenchmark.java | 34 import java.util.concurrent.locks.Lock; 35 import java.util.concurrent.locks.ReentrantLock; 100 final List<Lock> locks = new ArrayList<>(numStripes); field in StripedBenchmark 104 locks.clear(); in sizeOfPopulatedStriped() 107 locks.add(striped.getAt(i)); in sizeOfPopulatedStriped()
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
D | Striped.java | 38 import java.util.concurrent.locks.Condition; 39 import java.util.concurrent.locks.Lock; 40 import java.util.concurrent.locks.ReadWriteLock; 41 import java.util.concurrent.locks.ReentrantLock; 42 import java.util.concurrent.locks.ReentrantReadWriteLock; 438 final AtomicReferenceArray<ArrayReference<? extends L>> locks; 446 this.locks = new AtomicReferenceArray<>(size); 455 ArrayReference<? extends L> existingRef = locks.get(index); 462 while (!locks.compareAndSet(index, existingRef, newRef)) { 464 existingRef = locks.get(index); [all …]
|
D | ForwardingLock.java | 18 import java.util.concurrent.locks.Condition; 19 import java.util.concurrent.locks.Lock;
|
/external/guava/android/guava/src/com/google/common/util/concurrent/ |
D | Striped.java | 38 import java.util.concurrent.locks.Condition; 39 import java.util.concurrent.locks.Lock; 40 import java.util.concurrent.locks.ReadWriteLock; 41 import java.util.concurrent.locks.ReentrantLock; 42 import java.util.concurrent.locks.ReentrantReadWriteLock; 438 final AtomicReferenceArray<ArrayReference<? extends L>> locks; 446 this.locks = new AtomicReferenceArray<>(size); 455 ArrayReference<? extends L> existingRef = locks.get(index); 462 while (!locks.compareAndSet(index, existingRef, newRef)) { 464 existingRef = locks.get(index); [all …]
|
D | ForwardingLock.java | 18 import java.util.concurrent.locks.Condition; 19 import java.util.concurrent.locks.Lock;
|
/external/jacoco/org.jacoco.core.test.validation.java5/src/org/jacoco/core/test/validation/java5/ |
D | StructuredLockingTest.java | 140 Set<Integer> locks; field in StructuredLockingTest.LockFrame 144 locks = new HashSet<Integer>(); in LockFrame() 153 locks = new HashSet<Integer>(((LockFrame) src).locks); in init() 175 locks.add(Integer.valueOf(lock))); in enter() 180 locks.remove(Integer.valueOf(lock))); in exit() 186 this.locks.addAll(((LockFrame) frame).locks); in merge() 191 assertEquals(message, Collections.emptySet(), locks); in assertNoLock()
|
/external/llvm-project/compiler-rt/lib/sanitizer_common/tests/ |
D | sanitizer_deadlock_detector_test.cpp | 164 set<uptr> locks; in RunRemoveNodeTest() local 165 locks.insert(l0); in RunRemoveNodeTest() 166 locks.insert(l1); in RunRemoveNodeTest() 167 locks.insert(l2); in RunRemoveNodeTest() 168 locks.insert(l3); in RunRemoveNodeTest() 169 locks.insert(l4); in RunRemoveNodeTest() 170 locks.insert(l5); in RunRemoveNodeTest() 173 locks.insert(lt); in RunRemoveNodeTest() 178 EXPECT_EQ(locks.size(), d.size()); in RunRemoveNodeTest() 194 locks.clear(); in RunRemoveNodeTest() [all …]
|
/external/compiler-rt/lib/sanitizer_common/tests/ |
D | sanitizer_deadlock_detector_test.cc | 165 set<uptr> locks; in RunRemoveNodeTest() local 166 locks.insert(l0); in RunRemoveNodeTest() 167 locks.insert(l1); in RunRemoveNodeTest() 168 locks.insert(l2); in RunRemoveNodeTest() 169 locks.insert(l3); in RunRemoveNodeTest() 170 locks.insert(l4); in RunRemoveNodeTest() 171 locks.insert(l5); in RunRemoveNodeTest() 174 locks.insert(lt); in RunRemoveNodeTest() 179 EXPECT_EQ(locks.size(), d.size()); in RunRemoveNodeTest() 195 locks.clear(); in RunRemoveNodeTest() [all …]
|
/external/kotlinx.atomicfu/atomicfu/src/nativeTest/kotlin/kotlinx/atomicfu/locks/ |
D | SynchronizedTest.kt | 1 package kotlinx.atomicfu.locks in <lambda>() 45 val locks = Array(nLocks) { SynchronizedObject() }.freeze() in <lambda>() constant 48 counters to locks in <lambda>() 49 }) { (counters, locks) -> in <lambda>() method 50 locks.forEachIndexed { i, lock -> in <lambda>()
|
/external/cldr/tools/java/org/unicode/cldr/util/ |
D | LockSupportMap.java | 17 private final ConcurrentMap<E, Object> locks = new ConcurrentHashMap<>(); field in LockSupportMap 34 Object newLock = locks.putIfAbsent(item, oldLock); in getItemLock() 50 return locks.remove(itemToRemove); in removeItemLock()
|
/external/vulkan-validation-layers/layers/ |
D | vk_layer_utils.h | 197 write_lock_guard_t lock(locks[h].lock); 203 write_lock_guard_t lock(locks[h].lock); 211 write_lock_guard_t lock(locks[h].lock); 217 read_lock_guard_t lock(locks[h].lock); 250 read_lock_guard_t lock(locks[h].lock); 264 write_lock_guard_t lock(locks[h].lock); 281 read_lock_guard_t lock(locks[h].lock); 310 } locks[BUCKETS];
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
D | StripedTest.java | 35 import java.util.concurrent.locks.Lock; 36 import java.util.concurrent.locks.ReadWriteLock; 37 import java.util.concurrent.locks.ReentrantLock; 38 import java.util.concurrent.locks.ReentrantReadWriteLock; 182 Iterable<?> locks = striped.bulkGet(objects); 183 assertTrue(Ordering.natural().onResultOf(Functions.forMap(indexByLock)).isOrdered(locks)); 187 assertEquals(Lists.newArrayList(locks), Lists.newArrayList(locks2));
|
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
D | StripedTest.java | 35 import java.util.concurrent.locks.Lock; 36 import java.util.concurrent.locks.ReadWriteLock; 37 import java.util.concurrent.locks.ReentrantLock; 38 import java.util.concurrent.locks.ReentrantReadWriteLock; 182 Iterable<?> locks = striped.bulkGet(objects); 183 assertTrue(Ordering.natural().onResultOf(Functions.forMap(indexByLock)).isOrdered(locks)); 187 assertEquals(Lists.newArrayList(locks), Lists.newArrayList(locks2));
|
/external/mockito/src/main/java/org/mockito/internal/matchers/ |
D | CapturingMatcher.java | 14 import java.util.concurrent.locks.Lock; 15 import java.util.concurrent.locks.ReadWriteLock; 16 import java.util.concurrent.locks.ReentrantReadWriteLock;
|
/external/arm-trusted-firmware/lib/psci/ |
D | psci_lib.mk | 12 lib/locks/exclusive/${ARCH}/spinlock.S \ 28 PSCI_LIB_SOURCES += lib/locks/bakery/bakery_lock_coherent.c 30 PSCI_LIB_SOURCES += lib/locks/bakery/bakery_lock_normal.c
|
/external/python/cpython3/Lib/asyncio/ |
D | staggered.py | 10 from . import locks 83 previous_failed: typing.Optional[locks.Event]) -> None: 98 this_failed = locks.Event()
|
D | __init__.py | 13 from .locks import * 32 locks.__all__ +
|
/external/tensorflow/tensorflow/core/kernels/ |
D | training_op_helpers.h | 77 std::vector<Var*> vars, std::unique_ptr<std::vector<mutex_lock>> locks, in VariableInputLockHolder() 80 locks_(std::move(locks)), in VariableInputLockHolder() 171 auto locks = absl::make_unique<std::vector<mutex_lock>>(); in MaybeLockVariableInputMutexesInOrder() local 173 locks->reserve(acquire_order.size()); in MaybeLockVariableInputMutexesInOrder() 181 locks->emplace_back(*mu); in MaybeLockVariableInputMutexesInOrder() 187 return VariableInputLockHolder(std::move(vars), std::move(locks), in MaybeLockVariableInputMutexesInOrder()
|
/external/kotlinx.atomicfu/atomicfu/src/jvmMain/kotlin/kotlinx/atomicfu/locks/ |
D | Synchronized.kt | 3 package kotlinx.atomicfu.locks 12 public actual typealias ReentrantLock = java.util.concurrent.locks.ReentrantLock in reentrantLock()
|
/external/junit/src/main/java/org/junit/internal/requests/ |
D | MemoizingRequest.java | 3 import java.util.concurrent.locks.Lock; 4 import java.util.concurrent.locks.ReentrantLock;
|
/external/curl/tests/libtest/ |
D | lib506.c | 40 static int locks[3]; variable 72 if(locks[locknum]) { in my_lock() 76 locks[locknum]++; in my_lock() 108 if(!locks[locknum]) { in my_unlock() 112 locks[locknum]--; in my_unlock()
|