From 7a746a2fd38aa625ab2890cb83391eb7aa50d5ec Mon Sep 17 00:00:00 2001 From: Trial97 Date: Wed, 25 Mar 2020 12:08:45 +0200 Subject: [PATCH] Added reload for RPCConnections section from config --- config/config.go | 1 + servmanager/servmanager.go | 3 +++ 2 files changed, 4 insertions(+) diff --git a/config/config.go b/config/config.go index 002f74eb3..4fb4c604c 100755 --- a/config/config.go +++ b/config/config.go @@ -1411,6 +1411,7 @@ func (cfg *CGRConfig) reloadSections(sections ...string) (err error) { return fmt.Errorf("Invalid section: <%s>", section) case GENERAL_JSN: // nothing to reload case RPCConnsJsonName: // nothing to reload + cfg.rldChans[RPCConnsJsonName] <- struct{}{} case DATADB_JSN: // reloaded before case STORDB_JSN: // reloaded before case LISTEN_JSN: diff --git a/servmanager/servmanager.go b/servmanager/servmanager.go index 13c6302f7..ec1a56483 100644 --- a/servmanager/servmanager.go +++ b/servmanager/servmanager.go @@ -26,6 +26,7 @@ import ( "sync" "github.com/cgrates/cgrates/config" + "github.com/cgrates/cgrates/engine" "github.com/cgrates/cgrates/utils" "github.com/cgrates/rpcclient" ) @@ -307,6 +308,8 @@ func (srvMngr *ServiceManager) handleReload() { if err = srvMngr.reloadService(utils.StorDB); err != nil { return } + case <-srvMngr.GetConfig().GetReloadChan(config.RPCConnsJsonName): + engine.Cache.Clear([]string{utils.CacheRPCConnections}) } // handle RPC server }