Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for writeLocks (0.04 sec)

  1. internal/dsync/drwmutex.go

    	{
    		dm.m.Lock()
    		defer dm.m.Unlock()
    
    		// Check if minimally a single bool is set in the writeLocks array
    		lockFound := slices.ContainsFunc(dm.writeLocks, isLocked)
    		if !lockFound {
    			panic("Trying to Unlock() while no Lock() is active")
    		}
    
    		// Copy write locks to stack array
    		copy(locks, dm.writeLocks)
    	}
    
    	// Tolerance is not set, defaults to half of the locker clients.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

        public void releaseLease(Smb2LeaseKey key) {
            lock.writeLock().lock();
            try {
                LeaseEntry entry = leases.remove(key);
                if (entry != null) {
                    pathToLease.remove(entry.getPath());
                    log.debug("Released lease for path: {} with key: {}", entry.getPath(), key);
                }
            } finally {
                lock.writeLock().unlock();
            }
        }
    
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/persistent/PersistentHandleManager.java

            lock.writeLock().lock();
            try {
                handles.put(path, info);
                guidToHandle.put(guid, info);
    
                if (type == HandleType.PERSISTENT) {
                    persistHandle(info);
                }
            } finally {
                lock.writeLock().unlock();
            }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 24 00:49:49 UTC 2025
    - 13K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. guava/src/com/google/common/util/concurrent/Striped.java

        }
    
        @Override
        public Lock readLock() {
          return new WeakSafeLock(delegate.readLock(), this);
        }
    
        @Override
        public Lock writeLock() {
          return new WeakSafeLock(delegate.writeLock(), this);
        }
      }
    
      /** Lock object that ensures a strong reference is retained to a specified object. */
      private static final class WeakSafeLock extends ForwardingLock {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 16 22:01:32 UTC 2025
    - 20.6K bytes
    - Viewed (0)
Back to top