- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for writeLock (0.08 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
// Establish an ordering from writeLockA -> writeLockB. writeLockA.lock(); writeLockB.lock(); writeLockB.unlock(); writeLockA.unlock(); // Establish an ordering from writeLockB -> writeLockC. writeLockB.lock(); writeLockC.lock(); writeLockB.unlock(); // writeLockC -> writeLockA should fail. PotentialDeadlockException expected =Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 16.2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lease/LeaseManager.java
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 18.8K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java
} } finally { lock.writeLock().unlock(); } } /** * Remove a child entry * * @param childName child file name */ public void removeChild(String childName) { lock.writeLock().lock(); try { if (children.remove(childName) != null) {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 02:21:31 UTC 2025 - 11.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/persistent/PersistentHandleManager.java
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 24 00:49:49 UTC 2025 - 13K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
subrouter.Methods(http.MethodPost).Path("/v1/force-unlock").HandlerFunc(lockServer.ForceUnlockHandler) nodes[i] = httptest.NewServer(router) } } const WriteLock = -1 type lockServer struct { mutex sync.Mutex // Map of locks, with negative value indicating (exclusive) write lock // and positive values indicating number of read locks lockMap map[string]int64
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.3K bytes - Viewed (0) -
docs/smb3-features/04-directory-leasing-design.md
public void markComplete() { lock.writeLock().lock(); try { this.isComplete = true; this.hasChanges = false; this.lastUpdateTime = System.currentTimeMillis(); } finally { lock.writeLock().unlock(); } } public void invalidate() { lock.writeLock().lock(); try { children.clear();Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 36.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
Lock readLock = striped.get(key).readLock(); WeakReference<Object> garbage = new WeakReference<>(new Object()); GcFinalization.awaitClear(garbage); Lock writeLock = striped.get(key).writeLock(); readLock.lock(); assertFalse(writeLock.tryLock()); readLock.unlock(); } @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts. public void testStrongImplementations() {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 8.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
Lock readLock = striped.get(key).readLock(); WeakReference<Object> garbage = new WeakReference<>(new Object()); GcFinalization.awaitClear(garbage); Lock writeLock = striped.get(key).writeLock(); readLock.lock(); assertFalse(writeLock.tryLock()); readLock.unlock(); } @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts. public void testStrongImplementations() {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 8.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
this.writeLock = new CycleDetectingReentrantWriteLock(this); this.lockGraphNode = Preconditions.checkNotNull(lockGraphNode); } ///// Overridden ReentrantReadWriteLock methods. ///// @Override public ReadLock readLock() { return readLock; } @Override public WriteLock writeLock() { return writeLock; }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 17:06:34 UTC 2025 - 35.9K bytes - Viewed (0) -
docs/smb3-features/01-smb3-lease-design.md
} } public void releaseLease(Smb2LeaseKey key) { lock.writeLock().lock(); try { LeaseEntry entry = leases.remove(key); if (entry != null) { pathToLease.remove(entry.path); } } finally { lock.writeLock().unlock(); } } private void flushCachedWrites(String path) {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 22K bytes - Viewed (0)