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 flapper

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2023-05-03 21:00:17 -07:00
parent ae73e6a573
commit da8aeac91b
1 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
server/jetstream_cluster_3_test.go
View File

@@ -3900,7 +3900,7 @@ func TestJetStreamClusterStreamAccountingOnStoreError(t *testing.T) {
require_NoError(t, err)
msg := strings.Repeat("Z", 32*1024)
for i := 0; i < 100; i++ {
for i := 0; i < 10; i++ {
sendStreamMsg(t, nc, "foo", msg)
}
s := c.randomServer()
@@ -3918,14 +3918,15 @@ func TestJetStreamClusterStreamAccountingOnStoreError(t *testing.T) {
// Wait for this to propgate.
// The bug will have us not release reserved resources properly.
time.Sleep(time.Second)
info, err := js.AccountInfo()
require_NoError(t, err)
// Default tier
if info.Store != 0 {
t.Fatalf("Expected store to be 0 but got %v", friendlyBytes(info.Store))
}
checkFor(t, 10*time.Second, 200*time.Millisecond, func() error {
info, err := js.AccountInfo()
require_NoError(t, err)
// Default tier
if info.Store != 0 {
return fmt.Errorf("Expected store to be 0 but got %v", friendlyBytes(info.Store))
}
return nil
})
// Now check js from server directly regarding reserved.
sjs.mu.RLock()