Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ForceUnlock (0.04 sec)

  1. cmd/local-locker.go

    func (l *localLocker) IsOnline() bool {
    	return true
    }
    
    // IsLocal - local locker returns true.
    func (l *localLocker) IsLocal() bool {
    	return true
    }
    
    func (l *localLocker) ForceUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	if ctx.Err() != nil {
    		return false, ctx.Err()
    	}
    
    	defer l.getMutex()()
    	if ctx.Err() != nil {
    		return false, ctx.Err()
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  2. cmd/local-locker_test.go

    								toUnLock = append(toUnLock, dsync.LockArgs{Resources: []string{k}, UID: lock.UID})
    							}
    						}
    					}
    					start := time.Now()
    					for _, lock := range toUnLock {
    						ok, err := l.ForceUnlock(t.Context(), lock)
    						if err != nil || !ok {
    							t.Fatal(err)
    						}
    					}
    					t.Logf("Expire 50%% took: %v. Left: %d/%d", time.Since(start).Round(time.Millisecond), len(l.lockUID), len(l.lockMap))
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
Back to top