From b5279062ede47ec6c52671cf8c7be0519cd6dba4 Mon Sep 17 00:00:00 2001 From: DanB Date: Wed, 9 Nov 2016 17:30:09 +0100 Subject: [PATCH] Diameter using POOL_FIRST for SMG connection instead of POOL_BROADCAST --- cmd/cgr-engine/cgr-engine.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/cgr-engine/cgr-engine.go b/cmd/cgr-engine/cgr-engine.go index e48f92c9d..7f8df125b 100644 --- a/cmd/cgr-engine/cgr-engine.go +++ b/cmd/cgr-engine/cgr-engine.go @@ -221,7 +221,7 @@ func startDiameterAgent(internalSMGChan chan *sessionmanager.SMGeneric, internal var smgConn, pubsubConn *rpcclient.RpcClientPool if len(cfg.DiameterAgentCfg().SMGenericConns) != 0 { - smgConn, err = engine.NewRPCPool(rpcclient.POOL_BROADCAST, cfg.ConnectAttempts, cfg.Reconnects, cfg.ConnectTimeout, cfg.ReplyTimeout, + smgConn, err = engine.NewRPCPool(rpcclient.POOL_FIRST, cfg.ConnectAttempts, cfg.Reconnects, cfg.ConnectTimeout, cfg.ReplyTimeout, cfg.DiameterAgentCfg().SMGenericConns, smgChan, cfg.InternalTtl) if err != nil { utils.Logger.Crit(fmt.Sprintf(" Could not connect to SMG: %s", err.Error()))