- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 22 for writeLocks (0.08 seconds)
-
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.Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.3K bytes - Click Count (0) -
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 =Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 16.3K bytes - Click Count (0) -
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 =Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 16.3K bytes - Click Count (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) {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 11.4K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lease/LeaseManager.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 18.8K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/persistent/PersistentHandleManager.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:49:49 GMT 2025 - 13K bytes - Click Count (0) -
cmd/metrics-v3-cache.go
WriteSectors: currentStats.WriteSectors - initialStats.WriteSectors, ReadTicks: currentStats.ReadTicks - initialStats.ReadTicks, WriteTicks: currentStats.WriteTicks - initialStats.WriteTicks, TotalTicks: currentStats.TotalTicks - initialStats.TotalTicks, } } func getDriveIOStatMetrics(ioStats madmin.DiskIOStats, duration time.Duration) (m driveIOStatMetrics) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 8.1K bytes - Click Count (0) -
internal/disk/stat_test.go
ReadIOs: 1432553, ReadMerges: 420084, ReadSectors: 66247626, ReadTicks: 2398227, WriteIOs: 7077314, WriteMerges: 8720147, WriteSectors: 157049224, WriteTicks: 7469810, CurrentIOs: 0, TotalTicks: 7580552, ReqTicks: 9869354, DiscardIOs: 46037, DiscardMerges: 0, DiscardSectors: 41695120, DiscardTicks: 1315,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 3.5K bytes - Click Count (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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.3K bytes - Click Count (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();Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 36.2K bytes - Click Count (0)