Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 22 for writeLocks (0.06 seconds)

  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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.3K bytes
    - Click Count (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 =
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 16.2K bytes
    - Click Count (0)
  3. 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();
            }
        }
    
        /**
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 18.8K bytes
    - Click Count (0)
  4. 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: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 23 02:21:31 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  5. 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();
            }
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 24 00:49:49 GMT 2025
    - 13K bytes
    - Click Count (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) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  7. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.3K bytes
    - Click Count (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,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  9. 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: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 36.2K bytes
    - Click Count (0)
  10. internal/disk/disk.go

    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
    	DiscardMerges  uint64
    	DiscardSectors uint64
    	DiscardTicks   uint64
    	FlushIOs       uint64
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 1.7K bytes
    - Click Count (0)
Back to Top