Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for expireOldLocks (0.08 sec)

  1. cmd/local-locker_test.go

    	}
    	if len(l.lockUID) != len(rResources)+len(wResources) {
    		t.Fatalf("lockUID len, got %d, want %d + %d", len(l.lockUID), len(rResources), len(wResources))
    	}
    	// Expire an hour from now, should keep all
    	l.expireOldLocks(time.Hour)
    	if len(l.lockMap) != len(rResources)+len(wResources) {
    		t.Fatalf("lockmap len, got %d, want %d + %d", len(l.lockMap), len(rResources), len(wResources))
    	}
    	if len(l.lockUID) != len(rResources)+len(wResources) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. cmd/local-locker.go

    				return true, nil
    			}
    		}
    	}
    }
    
    // Similar to removeEntry but only removes an entry only if the lock entry exists in map.
    // Caller must hold 'l.mutex' lock.
    func (l *localLocker) expireOldLocks(interval time.Duration) {
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    
    	for k, lris := range l.lockMap {
    		modified := false
    		for i := 0; i < len(lris); {
    			lri := &lris[i]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
Back to top