fix buffer test

This commit is contained in:
c9s 2024-11-20 18:12:22 +08:00
parent 7da83e9e6c
commit f74ea33e53
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54

View File

@ -64,7 +64,7 @@ func TestDepthBuffer_CorruptedUpdateAtTheBeginning(t *testing.T) {
{Price: itov(99), Volume: itov(1)}, {Price: itov(99), Volume: itov(1)},
}, },
}, snapshotFinalID, nil }, snapshotFinalID, nil
}) }, time.Millisecond*5)
resetC := make(chan struct{}, 1) resetC := make(chan struct{}, 1)
@ -104,7 +104,7 @@ func TestDepthBuffer_ConcurrentRun(t *testing.T) {
{Price: itov(99), Volume: itov(1)}, {Price: itov(99), Volume: itov(1)},
}, },
}, snapshotFinalID, nil }, snapshotFinalID, nil
}) }, time.Millisecond*5)
readyCnt := 0 readyCnt := 0
resetCnt := 0 resetCnt := 0