From b9fcf8b24e3cdc5972fc928d26e98dcf6d67b960 Mon Sep 17 00:00:00 2001 From: gezimbll Date: Wed, 29 May 2024 05:51:50 -0400 Subject: [PATCH] adding time.Sleep in dispatcher tests --- dispatchers/lib_test.go | 1 + dispatchers/responder_it_test.go | 2 ++ 2 files changed, 3 insertions(+) diff --git a/dispatchers/lib_test.go b/dispatchers/lib_test.go index c69e99fa7..a473a6b30 100644 --- a/dispatchers/lib_test.go +++ b/dispatchers/lib_test.go @@ -96,6 +96,7 @@ func (d *testDispatcher) stopEngine(t *testing.T) { if err := exec.Command("kill", "-9", pid).Run(); err != nil { t.Fatalf("Error at stop engine:%v\n", err) } + time.Sleep(200 * time.Millisecond) // // if err := d.cmd.Process.Kill(); err != nil { // // t.Fatalf("Error at stop engine:%v\n", err) // } diff --git a/dispatchers/responder_it_test.go b/dispatchers/responder_it_test.go index 598f66e6f..382cc644a 100644 --- a/dispatchers/responder_it_test.go +++ b/dispatchers/responder_it_test.go @@ -24,6 +24,7 @@ package dispatchers import ( "fmt" "testing" + "time" "github.com/cgrates/cgrates/utils" ) @@ -159,6 +160,7 @@ func testDspResponderShutdown(t *testing.T) { } else if reply != "Done!" { t.Errorf("Received: %s", utils.ToJSON(reply)) } + time.Sleep(200 * time.Millisecond) if err := dispEngine.RPC.Call(utils.CoreSv1Status, &ev, &statusReply); err != nil { t.Error(err) } else if statusReply[utils.NodeID] != "ALL2" {