Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for readLocks (0.06 sec)

  1. internal/dsync/drwmutex.go

    		lockFound := false
    		for _, uid := range dm.readLocks {
    			if isLocked(uid) {
    				lockFound = true
    				break
    			}
    		}
    		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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  3. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  4. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 35.9K bytes
    - Viewed (0)
  5. cmd/namespace-lock.go

    	lockSource := getSource(2)
    	start := UTCNow()
    	const readLock = false
    	success := make([]int, len(li.paths))
    	for i, path := range li.paths {
    		if !li.ns.lock(ctx, li.volume, path, lockSource, li.opsID, readLock, timeout.Timeout()) {
    			timeout.LogFailure()
    			for si, sint := range success {
    				if sint == 1 {
    					li.ns.unlock(li.volume, li.paths[si], readLock)
    				}
    			}
    			if errors.Is(ctx.Err(), context.Canceled) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cache.go

    		ReadSectors:  currentStats.ReadSectors - initialStats.ReadSectors,
    		WriteSectors: currentStats.WriteSectors - initialStats.WriteSectors,
    		ReadTicks:    currentStats.ReadTicks - initialStats.ReadTicks,
    		WriteTicks:   currentStats.WriteTicks - initialStats.WriteTicks,
    		TotalTicks:   currentStats.TotalTicks - initialStats.TotalTicks,
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  7. internal/disk/stat_test.go

    			expectedIOStats: IOStats{
    				ReadIOs:        1432553,
    				ReadMerges:     420084,
    				ReadSectors:    66247626,
    				ReadTicks:      2398227,
    				WriteIOs:       7077314,
    				WriteMerges:    8720147,
    				WriteSectors:   157049224,
    				WriteTicks:     7469810,
    				CurrentIOs:     0,
    				TotalTicks:     7580552,
    				ReqTicks:       9869354,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        Object key = new Object();
        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();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        Object key = new Object();
        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();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. internal/disk/disk.go

    	Name       string
    	Rotational *bool
    	NRRequests uint64
    }
    
    // IOStats contains stats of a single drive
    type IOStats struct {
    	ReadIOs        uint64
    	ReadMerges     uint64
    	ReadSectors    uint64
    	ReadTicks      uint64
    	WriteIOs       uint64
    	WriteMerges    uint64
    	WriteSectors   uint64
    	WriteTicks     uint64
    	CurrentIOs     uint64
    	TotalTicks     uint64
    	ReqTicks       uint64
    	DiscardIOs     uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.7K bytes
    - Viewed (0)
Back to top