Skip to content

Commit 3d3e3d5

Browse files
committed
Retry lock acquire even when all nodes are taken
1 parent 1cf2a3e commit 3d3e3d5

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

mutex.go

-3
Original file line numberDiff line numberDiff line change
@@ -84,9 +84,6 @@ func (m *Mutex) LockContext(ctx context.Context) error {
8484
return m.acquire(ctx, pool, value)
8585
})
8686
}()
87-
if n == 0 && err != nil {
88-
return err
89-
}
9087

9188
now := time.Now()
9289
until := now.Add(m.expiry - now.Sub(start) - time.Duration(int64(float64(m.expiry)*m.driftFactor)))

0 commit comments

Comments
 (0)