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" {