- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for ForceUnlock (0.04 sec)
-
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) -
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)