uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Remove debug logs

Browse Source
This commit is contained in:
TeoV
2019-12-03 09:37:09 -05:00
parent 522cf0ac78
commit 2b1fc15e96
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
engine/connmanager.go
View File

@@ -29,11 +29,14 @@ func NewConnManager(cfg *config.CGRConfig, rpcInternal map[string]chan rpcclient
return &ConnManager{cfg: cfg, rpcInternal: rpcInternal}
}
//ConnManager handle the RPC connections
type ConnManager struct {
cfg *config.CGRConfig
rpcInternal map[string]chan rpcclient.RpcClientConnection
}
//getConn is used to retrieves a connection from cache
//in case this doesn't exist create it and cache it
func (cM *ConnManager) getConn(connID string) (connPool *rpcclient.RpcClientPool, err error) {
//try to get the connection from cache
if x, ok := Cache.Get(utils.CacheRPCConnections, connID); ok {
@@ -42,7 +45,7 @@ func (cM *ConnManager) getConn(connID string) (connPool *rpcclient.RpcClientPool
}
return x.(*rpcclient.RpcClientPool), nil
}
// in case we don't found in cache create the connection and add this in cache
// in case we don't find in cache create the connection and add this in cache
var intChan chan rpcclient.RpcClientConnection
var connCfg *config.RPCConn
if internalChan, has := cM.rpcInternal[connID]; has {

3
services/connmanager.go
View File

@@ -19,7 +19,6 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package services
import (
"fmt"
"sync"
"github.com/cgrates/cgrates/config"
@@ -29,8 +28,6 @@ import (
)
func NewConnManagerService(cfg *config.CGRConfig, intConns map[string]chan rpcclient.RpcClientConnection) *ConnManagerService {
fmt.Println("Enter in NewConnManagerService")
fmt.Println(intConns)
return &ConnManagerService{
cfg: cfg,
connMgr: engine.NewConnManager(cfg, intConns),