gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Fix TestNoRaceJetStreamSparseConsumers

Browse Source 
This is the same fix as in https://github.com/nats-io/nats-server/pull/4500

This means it adds `StallWait` to `PublishAsync`, as that's seems to be the only
reason why this test fails.

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
This commit is contained in:
Tomasz Pietrek
2023-09-08 11:34:16 +02:00
parent 11f0ea99a4
commit 7b54a1e6a1
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/norace_test.go
View File

@@ -4321,14 +4321,14 @@ func TestNoRaceJetStreamSparseConsumers(t *testing.T) {
// We will purposely place foo msgs near the beginning, then in middle, then at the end.
for n := 0; n < 2; n++ {
_, err = js.PublishAsync("foo", msg)
_, err = js.PublishAsync("foo", msg, nats.StallWait(800*time.Millisecond))
require_NoError(t, err)
for i := 0; i < 1_000_000; i++ {
_, err = js.PublishAsync("bar", msg)
_, err = js.PublishAsync("bar", msg, nats.StallWait(800*time.Millisecond))
require_NoError(t, err)
}
_, err = js.PublishAsync("foo", msg)
_, err = js.PublishAsync("foo", msg, nats.StallWait(800*time.Millisecond))
require_NoError(t, err)
}
select {