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

Fix local tests

Browse Source
This commit is contained in:
DanB
2014-01-23 13:18:00 +01:00
parent 4f3e91d8ca
commit 5d857f1255
3 changed files with 4 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
apier/v1/apier_local_test.go
View File

@@ -25,7 +25,6 @@ import (
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
"net/rpc"
"net/rpc/jsonrpc"
"os/exec"
"path"
"reflect"
@@ -135,11 +134,7 @@ func TestRpcConn(t *testing.T) {
return
}
var err error
if cfg.RPCEncoding == utils.JSON {
rater, err = jsonrpc.Dial("tcp", cfg.MediatorRater)
} else {
rater, err = rpc.Dial("tcp", cfg.MediatorRater)
}
rater, err = rpc.Dial("tcp", "127.0.0.1:2013") //ToDo: Fix with automatic config
if err != nil {
t.Fatal("Could not connect to rater: ", err.Error())
}

7
apier/v1/tutfscsv_local_test.go
View File

@@ -23,7 +23,6 @@ import (
"fmt"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
"net/rpc"
"net/rpc/jsonrpc"
"os/exec"
"path"
@@ -102,11 +101,7 @@ func TestFsCsvRpcConn(t *testing.T) {
return
}
var err error
if cfg.RPCEncoding == utils.JSON {
rater, err = jsonrpc.Dial("tcp", cfg.MediatorRater)
} else {
rater, err = rpc.Dial("tcp", cfg.MediatorRater)
}
rater, err = jsonrpc.Dial("tcp", "127.0.0.1:2012") // ToDo: Fix here with config loaded from file
if err != nil {
t.Fatal("Could not connect to rater: ", err.Error())
}

4
cmd/cgr-engine/cgr-engine.go
View File

@@ -88,7 +88,7 @@ func startMediator(responder *engine.Responder, loggerDb engine.LogStorage, cdrD
time.Sleep(time.Duration(i/2) * time.Second)
}
if err != nil {
engine.Logger.Crit(fmt.Sprintf("Could not connect to engine: %v", err))
engine.Logger.Crit(fmt.Sprintf("<Mediator> Could not connect to engine: %v", err))
exitChan <- true
}
connector = &engine.RPCClientConnector{Client: client}
@@ -130,7 +130,7 @@ func startSessionManager(responder *engine.Responder, loggerDb engine.LogStorage
time.Sleep(time.Duration(i/2) * time.Second)
}
if err != nil {
engine.Logger.Crit(fmt.Sprintf("Could not connect to engine: %v", err))
engine.Logger.Crit(fmt.Sprintf("<SessionManager> Could not connect to engine: %v", err))
exitChan <- true
}
connector = &engine.RPCClientConnector{Client: client}