Skip to content

M
mybee
Commit 08442482 authored by aloknerurkar's avatar aloknerurkar Committed by GitHub
Browse files
Options

fix: pushsync test limits (#2097)

parent 4a94d1fe
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
pkg/pushsync/pushsync_test.go
View file @ 08442482
...@@ -951,7 +951,7 @@ func TestPushChunkToClosestSkipFailed(t *testing.T) { ...@@ -951,7 +951,7 @@ func TestPushChunkToClosestSkipFailed(t *testing.T) {
lock.Lock() lock.Lock()
defer lock.Unlock() defer lock.Unlock()
if triggerCount < 9 { if triggerCount < 6 {
triggerCount++ triggerCount++
stream.Close() stream.Close()
return errors.New("new error") return errors.New("new error")
...@@ -1016,7 +1016,7 @@ func TestPushChunkToClosestSkipFailed(t *testing.T) { ...@@ -1016,7 +1016,7 @@ func TestPushChunkToClosestSkipFailed(t *testing.T) {
} }
// out of 4, 3 peers should return accouting error. So we should have effectively // out of 4, 3 peers should return accouting error. So we should have effectively
// sent only 1 msg // sent only 1 msg
if ta2.Get(tags.StateSent) != 10 { if ta2.Get(tags.StateSent) != 7 {
t.Fatalf("tags error") t.Fatalf("tags error")
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment