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

Reduce client connection attempts to test engine status

Browse Source 
200 -> 16

Previously, considering the fibonacci back off strategy, if engine failed to
start it would have tried to attempt connections for 2.862799e+33 years.

Now, the amount of attempts is 16, equivalent to around 2 and a half seconds.
Should be more than enough, considering that usually 6-7 attempts are enough.
This commit is contained in:
ionutboangiu
2024-09-25 12:33:07 +03:00
committed by Dan Christian Bogos
parent fe1a2a13bd
commit f26a0c2d0b
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
apis/cores_it_test.go
View File

@@ -128,7 +128,7 @@ func testCoreItStartEngineByExecWithCPUProfiling(t *testing.T) {
}
fib := utils.FibDuration(time.Millisecond, 0)
var connected bool
for i := 0; i < 200; i++ {
for i := 0; i < 16; i++ {
time.Sleep(fib())
if _, err := jsonrpc.Dial(utils.TCP, coreSCfg.ListenCfg().RPCJSONListen); err != nil {
t.Log(err)
@@ -184,7 +184,7 @@ func testCoreItStartEngineByExecWIthMemProfiling(t *testing.T) {
}
fib := utils.FibDuration(time.Millisecond, 0)
var connected bool
for i := 0; i < 200; i++ {
for i := 0; i < 16; i++ {
time.Sleep(fib())
if _, err := jsonrpc.Dial(utils.TCP, coreSCfg.ListenCfg().RPCJSONListen); err != nil {
t.Log(err)

4
engine/libtest.go
View File

@@ -119,7 +119,7 @@ func StartEngine(cfgPath string, waitEngine int) (*exec.Cmd, error) {
}
fib := utils.FibDuration(time.Millisecond, 0)
var connected bool
for i := 0; i < 200; i++ {
for i := 0; i < 16; i++ {
time.Sleep(fib())
if _, err := jsonrpc.Dial(utils.TCP, cfg.ListenCfg().RPCJSONListen); err != nil {
utils.Logger.Warning(fmt.Sprintf("Error <%s> when opening test connection to: <%s>",
@@ -147,7 +147,7 @@ func StartEngineWithContext(ctx context.Context, cfgPath string, waitEngine int)
return
}
fib := utils.FibDuration(time.Millisecond, 0)
for i := 0; i < 200; i++ {
for i := 0; i < 16; i++ {
time.Sleep(fib())
if _, err = jsonrpc.Dial(utils.TCP, cfg.ListenCfg().RPCJSONListen); err != nil {
continue