diff options
| author | 2026-03-05 20:59:49 +0800 | |
|---|---|---|
| committer | 2026-03-05 21:03:08 +0800 | |
| commit | 8bd9c519f3da004d3686b1d61bf8d261f021df0c (patch) | |
| tree | e2d0e4bbee215532789f24e629e9031858f36c5b /format/pack/ingest/stream_scan.go | |
| parent | *: Fix lint wsl_v5 (diff) | |
| signature | No signature | |
*: Fix lints
Diffstat (limited to 'format/pack/ingest/stream_scan.go')
| -rw-r--r-- | format/pack/ingest/stream_scan.go | 14 |
1 files changed, 10 insertions, 4 deletions
diff --git a/format/pack/ingest/stream_scan.go b/format/pack/ingest/stream_scan.go index 8f429e43..b3cf4c00 100644 --- a/format/pack/ingest/stream_scan.go +++ b/format/pack/ingest/stream_scan.go @@ -27,7 +27,8 @@ func streamPackAndScan(state *ingestState) error { state.algo.Size(), ) - if err := readAndValidatePackHeader(state); err != nil { + err = readAndValidatePackHeader(state) + if err != nil { return err } @@ -46,7 +47,8 @@ func streamPackAndScan(state *ingestState) error { } } - if err := state.stream.finishAndFlushTrailer(); err != nil { + err = state.stream.finishAndFlushTrailer() + if err != nil { return err } @@ -67,7 +69,9 @@ func streamPackAndScan(state *ingestState) error { // readAndValidatePackHeader reads and validates PACK header from the stream. func readAndValidatePackHeader(state *ingestState) error { var hdr [12]byte - if err := state.stream.readFull(hdr[:]); err != nil { + + err := state.stream.readFull(hdr[:]) + if err != nil { return &ErrInvalidPackHeader{Reason: fmt.Sprintf("read header: %v", err)} } @@ -199,7 +203,9 @@ func parseEntryPrefix(state *ingestState, startOffset uint64) (objectRecord, err case objecttype.TypeCommit, objecttype.TypeTree, objecttype.TypeBlob, objecttype.TypeTag: case objecttype.TypeRefDelta: baseRaw := make([]byte, state.algo.Size()) - if err := state.stream.readFull(baseRaw); err != nil { + + err := state.stream.readFull(baseRaw) + if err != nil { return record, &ErrMalformedPackEntry{Offset: startOffset, Reason: fmt.Sprintf("read ref base: %v", err)} } |
