Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for writeLocks (0.05 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. 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
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  6. 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) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  7. 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)
  8. 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,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  9. cmd/metrics-realtime.go

    				ReadSectors:    st.ReadSectors,
    				ReadTicks:      st.ReadTicks,
    				WriteIOs:       st.WriteIOs,
    				WriteMerges:    st.WriteMerges,
    				WriteSectors:   st.WriteSectors,
    				WriteTicks:     st.WriteTicks,
    				CurrentIOs:     st.CurrentIOs,
    				TotalTicks:     st.TotalTicks,
    				ReqTicks:       st.ReqTicks,
    				DiscardIOs:     st.DiscardIOs,
    				DiscardMerges:  st.DiscardMerges,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  10. 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)
Back to top