sector import: Fix lint

itests/sector_import_full_test.go

@@ -259,7 +259,7 @@ func TestSectorImport(t *testing.T) {
 					return
 				}
 
-				remoteCommit1(s)(w, r)
+				testRemoteCommit1(s, m)(w, r)
 			}
 		}
 	})))

storage/pipeline/fsm.go

@@ -855,7 +855,7 @@ func maybeNotifyRemoteDone(success bool, state string) func(*SectorInfo) {
 			return
 		}
 
-		defer resp.Body.Close()
+		defer resp.Body.Close() //nolint:errcheck
 
 		if resp.StatusCode != http.StatusOK {
 			log.Errorf("remote done notification received non-200 http response %s", resp.Status)

storage/pipeline/states_sealing.go

@@ -602,7 +602,7 @@ func (m *Sealing) handleCommitting(ctx statemachine.Context, sector SectorInfo)
 			return ctx.Send(SectorRemoteCommit1Failed{xerrors.Errorf("requesting remote commit1: %w", err)})
 		}
 
-		defer resp.Body.Close()
+		defer resp.Body.Close() //nolint:errcheck
 
 		if resp.StatusCode != http.StatusOK {
 			return ctx.Send(SectorRemoteCommit1Failed{xerrors.Errorf("remote commit1 received non-200 http response %s", resp.Status)})
@@ -648,7 +648,7 @@ func (m *Sealing) handleCommitting(ctx statemachine.Context, sector SectorInfo)
 			return ctx.Send(SectorRemoteCommit2Failed{xerrors.Errorf("requesting remote commit2: %w", err)})
 		}
 
-		defer resp.Body.Close()
+		defer resp.Body.Close() //nolint:errcheck
 
 		if resp.StatusCode != http.StatusOK {
 			return ctx.Send(SectorRemoteCommit2Failed{xerrors.Errorf("remote commit2 received non-200 http response %s", resp.Status)})

storage/sealer/tarutil/systar.go

@@ -103,7 +103,9 @@ func ExtractTar(body io.Reader, dir string, buf []byte) (int64, error) {
 			return read, xerrors.Errorf("tar file %#v is bigger than expected: %d > %d", header.Name, header.Size, sz)
 		}
 
-		r, err := io.CopyBuffer(f, tr, buf)
+		ltr := io.LimitReader(tr, header.Size)
+
+		r, err := io.CopyBuffer(f, ltr, buf)
 		read += r
 		if err != nil {
 			return read, err