Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for readLocks (0.68 sec)

  1. 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
    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

        ReentrantReadWriteLock readWriteLockC = factory.newReentrantReadWriteLock("ReadWriteC");
        readLockA = readWriteLockA.readLock();
        readLockB = readWriteLockB.readLock();
        readLockC = readWriteLockC.readLock();
        writeLockA = readWriteLockA.writeLock();
        writeLockB = readWriteLockB.writeLock();
        writeLockC = readWriteLockC.writeLock();
    
    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. 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
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 17:06:34 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  4. 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
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 17:06:34 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  5. 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 name
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  6. 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 path
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 24 00:49:49 UTC 2025
    - 13K bytes
    - Viewed (0)
  7. 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 {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 36.2K bytes
    - Viewed (0)
  8. 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);
        }
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 16 22:01:32 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  9. 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) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  10. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java

                mojos.put(Thread.currentThread(), mojoDescriptor);
                boolean aggregator = mojoDescriptor.isAggregator();
                acquiredAggregatorLock = aggregator ? aggregatorLock.writeLock() : aggregatorLock.readLock();
                acquiredProjectLock = getProjectLock(session);
                if (!acquiredAggregatorLock.tryLock()) {
                    Thread owner = aggregatorLock.getOwner();
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Jun 12 14:55:55 UTC 2025
    - 21K bytes
    - Viewed (0)
Back to top