gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-15 18:50:41 -07:00
Code Issues Packages Projects Releases Wiki Activity

Test fails under race flag, so scale back

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2020-05-03 14:51:16 -07:00
parent 03aacecb81
commit 585fa8cc89
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
test/jetstream_test.go
View File

@@ -4760,7 +4760,6 @@ func TestJetStreamAPIStreamListPaging(t *testing.T) {
checkResp(reqList(streamsNum-22), 22, streamsNum-22)
}
// FIXME(dlc) - server shutdown takes a long time with large consumers.
func TestJetStreamAPIConsumerListPaging(t *testing.T) {
s := RunBasicJetStreamServer()
defer s.Shutdown()
@@ -4786,7 +4785,7 @@ func TestJetStreamAPIConsumerListPaging(t *testing.T) {
defer sub.Unsubscribe()
nc.Flush()
consumersNum := 4 * server.JSApiNamesLimit
consumersNum := server.JSApiNamesLimit
for i := 1; i <= consumersNum; i++ {
_, err := mset.AddConsumer(&server.ConsumerConfig{DeliverSubject: fmt.Sprintf("d.%d", i)})
if err != nil {
@@ -4826,9 +4825,6 @@ func TestJetStreamAPIConsumerListPaging(t *testing.T) {
}
checkResp(reqList(0), server.JSApiNamesLimit, 0)
checkResp(reqList(server.JSApiNamesLimit), server.JSApiNamesLimit, server.JSApiNamesLimit)
checkResp(reqList(2*server.JSApiNamesLimit), server.JSApiNamesLimit, 2*server.JSApiNamesLimit)
checkResp(reqList(consumersNum), 0, consumersNum)
checkResp(reqList(consumersNum-22), 22, consumersNum-22)
}