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 }