- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 14 for readLocks (0.08 seconds)
-
internal/dsync/drwmutex.go
defer dm.m.Unlock() // Check if minimally a single bool is set in the writeLocks array lockFound := slices.ContainsFunc(dm.readLocks, isLocked) if !lockFound { panic("Trying to RUnlock() while no RLock() is active") } // Copy write locks to stack array copy(locks, dm.readLocks) } // Tolerance is not set, defaults to half of the locker clients. tolerance := len(restClnts) / 2 isReadLock := true
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
ReentrantReadWriteLock readWriteLockC = factory.newReentrantReadWriteLock("ReadWriteC"); readLockA = readWriteLockA.readLock(); readLockB = readWriteLockB.readLock(); readLockC = readWriteLockC.readLock(); writeLockA = readWriteLockA.writeLock(); writeLockB = readWriteLockB.writeLock(); writeLockC = readWriteLockC.writeLock();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 16.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
ReentrantReadWriteLock readWriteLockC = factory.newReentrantReadWriteLock("ReadWriteC"); readLockA = readWriteLockA.readLock(); readLockB = readWriteLockB.readLock(); readLockC = readWriteLockC.readLock(); writeLockA = readWriteLockA.writeLock(); writeLockB = readWriteLockB.writeLock(); writeLockC = readWriteLockC.writeLock();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 16.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
super(fair); this.readLock = new CycleDetectingReentrantReadLock(this); this.writeLock = new CycleDetectingReentrantWriteLock(this); this.lockGraphNode = Preconditions.checkNotNull(lockGraphNode); } ///// Overridden ReentrantReadWriteLock methods. ///// @Override public ReadLock readLock() { return readLock; } @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 36K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java
* * @return list of child file info */ public List<FileInfo> getChildren() { lock.readLock().lock(); try { lastAccessTime = System.currentTimeMillis(); return new ArrayList<>(children.values()); } finally { lock.readLock().unlock(); } } /** * Get a specific child * * @param name child nameCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 11.4K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/persistent/PersistentHandleManager.java
* @return the handle info or null if not found */ public HandleInfo getHandleByGuid(HandleGuid guid) { lock.readLock().lock(); try { return guidToHandle.get(guid); } finally { lock.readLock().unlock(); } } /** * Get handle information by path * @param path the file pathCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:49:49 GMT 2025 - 13K bytes - Click Count (0) -
docs/smb3-features/04-directory-leasing-design.md
public List<FileInfo> getChildren() { lock.readLock().lock(); try { lastAccessTime = System.currentTimeMillis(); return new ArrayList<>(children.values()); } finally { lock.readLock().unlock(); } } public FileInfo getChild(String name) { lock.readLock().lock(); try {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 36.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
* setFuture(cancelledFuture)}. * * <p>Beware of completing a future while holding a lock. Its listeners may do slow work or * acquire other locks, risking deadlocks. */ @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { @RetainedLocalRef Object localValue = value(); boolean rValue = false;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 43.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
} /** * Using this as the blocker object allows introspection and debugging tools to see that the * currentRunner thread is blocked on the progress of the interruptor thread, which can help * identify deadlocks. */ @VisibleForTesting static final class Blocker extends AbstractOwnableSynchronizer implements Runnable { private final InterruptibleTask<?> task; private Blocker(InterruptibleTask<?> task) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 10K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Striped.java
private final ReadWriteLock delegate; WeakSafeReadWriteLock() { this.delegate = new ReentrantReadWriteLock(); } @Override public Lock readLock() { return new WeakSafeLock(delegate.readLock(), this); } @Override public Lock writeLock() { return new WeakSafeLock(delegate.writeLock(), this); } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 16 22:01:32 GMT 2025 - 20.6K bytes - Click Count (0)