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

Changed cache verification replication/remote

Browse Source
This commit is contained in:
adi
2022-10-20 17:34:15 +03:00
committed by Dan Christian Bogos
parent 8b02b44a34
commit d7ee81c86e
6 changed files with 31 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
dispatchers/libdispatcher.go
View File

@@ -455,13 +455,16 @@ func callDH(dh *engine.DispatcherHost, routeID string, dR *DispatcherRoute,
Value: dR,
GroupIDs: []string{utils.ConcatenatedKey(utils.CacheDispatcherProfiles, dR.Tenant, dR.ProfileID)},
}
if err = engine.Cache.SetWithReplicate(argsCache); err != nil {
if !rpcclient.IsNetworkError(err) {
return
if len(config.CgrConfig().CacheCfg().ReplicationConns) != 0 &&
config.CgrConfig().CacheCfg().Partitions[utils.CacheDispatcherRoutes].Replicate {
if err = engine.Cache.SetWithReplicate(argsCache); err != nil {
if !rpcclient.IsNetworkError(err) {
return
}
// did not dispatch properly, fail-back to standard dispatching
utils.Logger.Warning(fmt.Sprintf("<%s> ignoring cache network error <%s> setting route dR %+v",
utils.DispatcherS, err.Error(), dR))
}
// did not dispatch properly, fail-back to standard dispatching
utils.Logger.Warning(fmt.Sprintf("<%s> ignoring cache network error <%s> setting route dR %+v",
utils.DispatcherS, err.Error(), dR))
}
}
if err = dh.Call(method, args, reply); err != nil {