Fix: lock updater - return correct bool value
The function which extend lock duration in DB returns incorrect bool value (return default false value). This cause that context is canceled when extending lock duration and whole update process fails. This commit fixes the bug and return correct bool value.
This commit is contained in:
parent
3316e7e1ef
commit
4e49aaf346
@ -360,7 +360,7 @@ func AcquireLock(datastore Datastore, name, owner string, duration time.Duration
|
|||||||
|
|
||||||
// ExtendLock extends the duration of an existing global lock for the given
|
// ExtendLock extends the duration of an existing global lock for the given
|
||||||
// duration.
|
// duration.
|
||||||
func ExtendLock(ds Datastore, name, whoami string, desiredLockDuration time.Duration) (extended bool, expiration time.Time) {
|
func ExtendLock(ds Datastore, name, whoami string, desiredLockDuration time.Duration) (bool, time.Time) {
|
||||||
tx, err := ds.Begin()
|
tx, err := ds.Begin()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return false, time.Time{}
|
return false, time.Time{}
|
||||||
@ -374,7 +374,7 @@ func ExtendLock(ds Datastore, name, whoami string, desiredLockDuration time.Dura
|
|||||||
|
|
||||||
if locked {
|
if locked {
|
||||||
if err := tx.Commit(); err == nil {
|
if err := tx.Commit(); err == nil {
|
||||||
return
|
return locked, expiration
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user