Skip to content

Commit 199e124

Browse files
authored
remove defer statement for boost retrieve (#1254)
1 parent 468fa93 commit 199e124

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

retrievalmarket/client/client.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -549,14 +549,16 @@ func (c *Client) retrieveContentFromPeerWithProgressCallback(
549549
chanid = newchid
550550
chanidLk.Unlock()
551551

552-
defer func() { _ = c.dataTransfer.CloseDataTransferChannel(ctx, chanid) }()
553-
554552
// Wait for the retrieval to finish before exiting the function
555553
awaitfinished:
556554
for {
557555
select {
558556
case err := <-dtRes:
559557
if err != nil {
558+
go func() {
559+
_ = c.dataTransfer.CloseDataTransferChannel(ctx, chanid)
560+
}()
561+
560562
return nil, fmt.Errorf("data transfer failed: %w", err)
561563
}
562564

0 commit comments

Comments
 (0)