- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for readLocks (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)