uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-15 13:19:53 +05:00
Code Issues Packages Projects Releases Wiki Activity

Fixed *rpc ee and services

Browse Source
This commit is contained in:
porosnicuadrian
2021-10-27 16:30:16 +03:00
committed by Dan Christian Bogos
parent bb2ad8f57f
commit 029c04df50
2 changed files with 3 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
ees/rpc.go
View File

@@ -62,13 +62,9 @@ func (e *RPCee) Cfg() (eCfg *config.EventExporterCfg) {
func (e *RPCee) Connect() (err error) {
e.Lock()
if e.conn != nil {
var conn *rpcclient.RPCClient
conn, err = rpcclient.NewRPCClient(context.TODO(), utils.TCP, e.cfg.ExportPath, e.tls,
e.keyPath, e.certPath, e.caPath, 1, 1, e.connTimeout, e.replyTimeout, e.codec, nil, false, nil)
if err == nil {
e.conn = conn
}
if e.conn, err = rpcclient.NewRPCClient(context.TODO(), utils.TCP, e.cfg.ExportPath, e.tls,
e.keyPath, e.certPath, e.caPath, 1, 1, e.connTimeout, e.replyTimeout, e.codec, nil, false, nil); err != nil {
return
}
e.Unlock()
return

4
services/cgr-engine.go
View File

@@ -119,10 +119,6 @@ func (cgr *CGREngine) GetServDeps() map[string]*sync.WaitGroup {
return cgr.srvDep
}
func (cgr *CGREngine) GetDbService() *DataDBService {
return cgr.dmS
}
func (cgr *CGREngine) AddService(service servmanager.Service, connName, apiPrefix string,
iConnCh chan birpc.ClientConnector) {
cgr.srvManager.AddServices(service)