From 4aec388a15fc35c61d53908cd4a7ce1183284d1b Mon Sep 17 00:00:00 2001 From: jdl Date: Sat, 30 Jul 2022 09:34:30 +0200 Subject: [PATCH] Cleanup --- kvstore/shipping_test.go | 4 ++-- kvstore/sync-send.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/kvstore/shipping_test.go b/kvstore/shipping_test.go index ba5097c..d488b79 100644 --- a/kvstore/shipping_test.go +++ b/kvstore/shipping_test.go @@ -125,8 +125,8 @@ func TestShipping(t *testing.T) { }) run("simple concurrent", func(t *testing.T, pDir, sDir string, prim, sec *KV, cbs *callbacks, nw *testconn.Network) { - M := 1000 - N := 100 + M := 64 + N := 128 wg := sync.WaitGroup{} diff --git a/kvstore/sync-send.go b/kvstore/sync-send.go index 0737c42..10f11b6 100644 --- a/kvstore/sync-send.go +++ b/kvstore/sync-send.go @@ -28,7 +28,7 @@ func (kv *KV) SyncSend(conn net.Conn) { POLL: - for i := 0; i < 8; i++ { + for i := 0; i < 4; i++ { if kv.MaxSeqNum() > afterSeqNum { goto REPLAY }