From 089bcceb33704628a98e51be65d0835f63107300 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ra=C3=BAl=20Kripalani?= Date: Fri, 16 Jul 2021 19:09:56 +0100 Subject: [PATCH] remove test concurrency guardrails. --- itests/deals_concurrent_test.go | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/itests/deals_concurrent_test.go b/itests/deals_concurrent_test.go index 716be04e1..b9920ba5a 100644 --- a/itests/deals_concurrent_test.go +++ b/itests/deals_concurrent_test.go @@ -7,7 +7,6 @@ import ( "testing" "time" - "github.com/filecoin-project/lotus/chain/actors/policy" "github.com/stretchr/testify/require" datatransfer "github.com/filecoin-project/go-data-transfer" @@ -57,8 +56,7 @@ func TestDealWithMarketAndMinerNode(t *testing.T) { }) } - // TODO: add 2, 4, 8, more when this graphsync issue is fixed: https://github.com/ipfs/go-graphsync/issues/175# - cycles := []int{1} + cycles := []int{4, 8} for _, n := range cycles { n := n ns := fmt.Sprintf("%d", n) @@ -102,8 +100,7 @@ func TestDealCyclesConcurrent(t *testing.T) { }) } - // TODO: add 2, 4, 8, more when this graphsync issue is fixed: https://github.com/ipfs/go-graphsync/issues/175# - cycles := []int{2} + cycles := []int{1, 2, 4, 8} for _, n := range cycles { n := n ns := fmt.Sprintf("%d", n) @@ -178,7 +175,7 @@ func TestSimultanenousTransferLimit(t *testing.T) { t.Logf("running concurrent deals: %d", concurrency) dh.RunConcurrentDeals(kit.RunConcurrentDealsOpts{ - N: concurrency, // TODO: set to 20 after https://github.com/ipfs/go-graphsync/issues/175 is fixed + N: concurrency, FastRetrieval: true, StartEpoch: startEpoch, })