Check to see why a lock acquisition failed

This commit is contained in:
Tiru Srikantha 2015-06-05 13:23:23 -07:00
parent 7e82b3c32c
commit 0184227828
1 changed files with 16 additions and 4 deletions

View File

@ -183,6 +183,17 @@ WAIT:
// Handle the case of not getting the lock
if !locked {
// Determine why the lock failed
qOpts.WaitIndex = 0
pair, meta, err = kv.Get(l.opts.Key, qOpts)
if pair != nil && pair.Session != "" {
//If the session is not null, this means that a wait can safely happen
//using a long poll
qOpts.WaitIndex = meta.LastIndex
goto WAIT
} else {
// If the session is empty and the lock failed to acquire, then it means
// a lock-delay is in effect and a timed wait must be used
select {
case <-time.After(DefaultLockRetryTime):
goto WAIT
@ -190,6 +201,7 @@ WAIT:
return nil, nil
}
}
}
HELD:
// Watch to ensure we maintain leadership