Clear locks only if not in emergency mode
This commit is contained in:
parent
a4d59a04b5
commit
db00144cab
@ -293,7 +293,10 @@ func (c *cluster) establishLeadership(ctx context.Context, emergency bool) error
|
||||
c.cancelLeaderShip = cancel
|
||||
|
||||
go c.synchronizeAndRebalance(ctx, c.syncInterval, emergency)
|
||||
go c.clearLocks(ctx, time.Minute)
|
||||
|
||||
if !emergency {
|
||||
go c.clearLocks(ctx, time.Minute)
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user