Skip to content

Commit 3ce2865

Browse files
committed
remove handler test race
1 parent fc476f6 commit 3ce2865

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

server/handler_test.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -800,7 +800,8 @@ func TestHandlerKillQuery(t *testing.T) {
800800
})
801801
}()
802802

803-
time.Sleep(100 * time.Millisecond)
803+
wg.Wait()
804+
wg.Add(1)
804805
var sleepQueryID string
805806
err = handler.ComQuery(context.Background(), conn2, "SHOW PROCESSLIST", func(res *sqltypes.Result, more bool) error {
806807
// 1, , , test, Query, 0, ... , SELECT SLEEP(1000)
@@ -825,15 +826,13 @@ func TestHandlerKillQuery(t *testing.T) {
825826
})
826827
require.NoError(err)
827828

828-
time.Sleep(100 * time.Millisecond)
829829
err = handler.ComQuery(context.Background(), conn2, "KILL QUERY "+sleepQueryID, func(res *sqltypes.Result, more bool) error {
830830
return nil
831831
})
832832
require.NoError(err)
833833
wg.Wait()
834834
require.Error(sleepErr)
835835

836-
time.Sleep(100 * time.Millisecond)
837836
err = handler.ComQuery(context.Background(), conn2, "SHOW PROCESSLIST", func(res *sqltypes.Result, more bool) error {
838837
// 1, , , test, Sleep, 0, ,
839838
// 2, , , test, Query, 0, running, SHOW PROCESSLIST

0 commit comments

Comments
 (0)