uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 10:06:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Guardian reporting force timeouts for locks also for wrapper

Browse Source
This commit is contained in:
DanB
2019-03-18 10:37:35 +01:00
parent fa75764203
commit d555a52ad1
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
guardian/guardian.go
View File

@@ -146,6 +146,7 @@ func (gl *GuardianLocker) Guard(handler func() (interface{}, error), timeout tim
case err = <-errChan:
case reply = <-rplyChan:
case <-time.After(timeout):
utils.Logger.Warning(fmt.Sprintf("<Guardian> force timing-out locks: %+v", lockIDs))
}
} else { // a bit dangerous but wait till handler finishes
select {
@@ -168,7 +169,7 @@ func (gl *GuardianLocker) GuardIDs(refID string, timeout time.Duration, lkIDs ..
time.Sleep(timeout)
lkIDs := gl.unlockWithReference(retRefID)
if len(lkIDs) != 0 {
utils.Logger.Warning(fmt.Sprintf("<Guardian> WARNING: force timing-out locks: %+v", lkIDs))
utils.Logger.Warning(fmt.Sprintf("<Guardian> force timing-out locks: %+v", lkIDs))
}
}()
}