Skip to content

Commit 5802981

Browse files
authored
refactor: remove flaky TestMultipleDealsConcurrentResumptionDisconnect (#1138)
1 parent b9327dd commit 5802981

File tree

1 file changed

+0
-25
lines changed

1 file changed

+0
-25
lines changed

storagemarket/provider_transfer_test.go

Lines changed: 0 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -75,31 +75,6 @@ func TestRetryShutdownRecoverable(t *testing.T) {
7575
require.EqualValues(t, dealcheckpoints.Accepted, pds.Checkpoint)
7676
}
7777

78-
func TestMultipleDealsConcurrentResumptionDisconnect(t *testing.T) {
79-
logging.SetLogLevel("http-transport", "WARN") //nolint:errcheck
80-
81-
nDeals := 5
82-
ctx := context.Background()
83-
fileSize := testFileSize
84-
85-
// setup the provider test harness with a disconnecting server that disconnects after sending the given number of bytes
86-
harness := NewHarness(t, withHttpDisconnectServerAfter(int64(fileSize/101)), withHttpTransportOpts([]httptransport.Option{httptransport.BackOffRetryOpt(50*time.Millisecond, 100*time.Millisecond, 2, 1000)}))
87-
// start the provider test harness
88-
harness.Start(t, ctx)
89-
defer harness.Stop()
90-
91-
tds := harness.executeNDealsConcurrentAndWaitFor(t, nDeals, func(i int) *testDeal {
92-
return harness.newDealBuilder(t, i, withNormalFileSize(fileSize)).withAllMinerCallsNonBlocking().withDisconnectingHttpServer().build()
93-
}, func(_ int, td *testDeal) error {
94-
return td.waitForCheckpoint(dealcheckpoints.AddedPiece)
95-
})
96-
97-
for i := 0; i < nDeals; i++ {
98-
td := tds[i]
99-
td.assertPieceAdded(t, ctx)
100-
}
101-
}
102-
10378
func TestTransferCancelledByUser(t *testing.T) {
10479
ctx := context.Background()
10580

0 commit comments

Comments
 (0)