Added reload for RPCConnections section from config

cgrates · Mar 25, 2020 · 7a746a2 · 7a746a2
1 parent f2c8f2b
commit 7a746a2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git 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
@@ -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
 	}