From e2e3cdd52c41a4f8f9367f3830c76cbfe3f0fea3 Mon Sep 17 00:00:00 2001 From: Trial97 Date: Sun, 6 Oct 2019 13:41:17 +0300 Subject: [PATCH] Updated ServiceManager --- servmanager/servmanager.go | 80 +------------------------------------- 1 file changed, 2 insertions(+), 78 deletions(-) diff --git a/servmanager/servmanager.go b/servmanager/servmanager.go index fa0b9b974..d4291e6ae 100644 --- a/servmanager/servmanager.go +++ b/servmanager/servmanager.go @@ -26,28 +26,16 @@ import ( "sync" "github.com/cgrates/cgrates/config" - "github.com/cgrates/cgrates/engine" "github.com/cgrates/cgrates/utils" "github.com/cgrates/rpcclient" ) // NewServiceManager returns a service manager -func NewServiceManager(cfg *config.CGRConfig, dm *engine.DataManager, - cdrStorage engine.CdrStorage, - loadStorage engine.LoadStorage, filterSChan chan *engine.FilterS, - server *utils.Server, dispatcherSChan chan rpcclient.RpcClientConnection, - engineShutdown chan bool) *ServiceManager { +func NewServiceManager(cfg *config.CGRConfig, engineShutdown chan bool) *ServiceManager { sm := &ServiceManager{ cfg: cfg, - dm: dm, engineShutdown: engineShutdown, - - cdrStorage: cdrStorage, - loadStorage: loadStorage, - filterS: filterSChan, - server: server, - subsystems: make(map[string]Service), - dispatcherSChan: dispatcherSChan, + subsystems: make(map[string]Service), } return sm } @@ -56,16 +44,8 @@ func NewServiceManager(cfg *config.CGRConfig, dm *engine.DataManager, type ServiceManager struct { sync.RWMutex // lock access to any shared data cfg *config.CGRConfig - dm *engine.DataManager engineShutdown chan bool - cacheS *engine.CacheS - cdrStorage engine.CdrStorage - loadStorage engine.LoadStorage - filterS chan *engine.FilterS - server *utils.Server subsystems map[string]Service - - dispatcherSChan chan rpcclient.RpcClientConnection } func (srvMngr *ServiceManager) Call(serviceMethod string, args interface{}, reply interface{}) error { @@ -156,27 +136,6 @@ func (srvMngr *ServiceManager) V1ServiceStatus(args ArgStartService, reply *stri return nil } -// GetDM returns the DataManager -func (srvMngr *ServiceManager) GetDM() *engine.DataManager { - srvMngr.RLock() - defer srvMngr.RUnlock() - return srvMngr.dm -} - -// GetCDRStorage returns the CdrStorage -func (srvMngr *ServiceManager) GetCDRStorage() engine.CdrStorage { - srvMngr.RLock() - defer srvMngr.RUnlock() - return srvMngr.cdrStorage -} - -// GetLoadStorage returns the LoadStorage -func (srvMngr *ServiceManager) GetLoadStorage() engine.LoadStorage { - srvMngr.RLock() - defer srvMngr.RUnlock() - return srvMngr.loadStorage -} - // GetConfig returns the Configuration func (srvMngr *ServiceManager) GetConfig() *config.CGRConfig { srvMngr.RLock() @@ -184,34 +143,6 @@ func (srvMngr *ServiceManager) GetConfig() *config.CGRConfig { return srvMngr.cfg } -// GetCacheS returns the CacheS -func (srvMngr *ServiceManager) GetCacheS() *engine.CacheS { - srvMngr.RLock() - defer srvMngr.RUnlock() - return srvMngr.cacheS -} - -// GetFilterS returns the FilterS -func (srvMngr *ServiceManager) GetFilterS() (fS *engine.FilterS) { - srvMngr.RLock() - defer srvMngr.RUnlock() - fS = <-srvMngr.filterS - srvMngr.filterS <- fS - return -} - -// GetServer returns the Server -func (srvMngr *ServiceManager) GetServer() *utils.Server { - srvMngr.RLock() - defer srvMngr.RUnlock() - return srvMngr.server -} - -// GetExitChan returns the exit chanel -func (srvMngr *ServiceManager) GetExitChan() chan bool { - return srvMngr.engineShutdown -} - // StartServices starts all enabled services func (srvMngr *ServiceManager) StartServices() (err error) { go srvMngr.handleReload() @@ -391,13 +322,6 @@ func (srvMngr ServiceManager) GetService(subsystem string) (srv Service) { return } -// SetCacheS sets the cacheS -func (srvMngr *ServiceManager) SetCacheS(chS *engine.CacheS) { - srvMngr.Lock() - srvMngr.cacheS = chS - srvMngr.Unlock() -} - // Service interface that describes what functions should a service implement type Service interface { // Start should handle the sercive start