mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
@@ -837,11 +837,12 @@ func TestFileStoreCompactLastPlusOne(t *testing.T) {
|
||||
if state.Msgs != 0 {
|
||||
t.Fatalf("Expected no message but got %d", state.Msgs)
|
||||
}
|
||||
fmt.Printf("state is %+v\n", state)
|
||||
|
||||
fs.StoreMsg(subj, nil, msg)
|
||||
state = fs.State()
|
||||
fmt.Printf("state is %+v\n", state)
|
||||
if state.Msgs != 1 {
|
||||
t.Fatalf("Expected one message but got %d", state.Msgs)
|
||||
}
|
||||
}
|
||||
|
||||
func TestFileStoreCompactPerf(t *testing.T) {
|
||||
|
||||
@@ -3720,8 +3720,6 @@ func TestJetStreamClusterRemoveServer(t *testing.T) {
|
||||
sl := c.streamLeader("$G", "TEST")
|
||||
c.removeJetStream(sl)
|
||||
|
||||
fmt.Printf("Will remove %q\n", sl)
|
||||
|
||||
c.waitOnLeader()
|
||||
c.waitOnStreamLeader("$G", "TEST")
|
||||
|
||||
|
||||
@@ -331,7 +331,7 @@ func TestNoRaceLargeClusterMem(t *testing.T) {
|
||||
checkClusterFormed(t, servers...)
|
||||
|
||||
// Calculate in MB what we are using now.
|
||||
const max = 60 * 1024 * 1024 // 60MB
|
||||
const max = 64 * 1024 * 1024 // 64MB
|
||||
runtime.ReadMemStats(&m)
|
||||
used := m.TotalAlloc - pta
|
||||
if used > max {
|
||||
|
||||
Reference in New Issue
Block a user