aboutsummaryrefslogtreecommitdiff
path: root/format/pack/ingest/stream_scan.go
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-03-05 20:59:49 +0800
committerGravatar Runxi Yu2026-03-05 21:03:08 +0800
commit8bd9c519f3da004d3686b1d61bf8d261f021df0c (patch)
treee2d0e4bbee215532789f24e629e9031858f36c5b /format/pack/ingest/stream_scan.go
parent*: Fix lint wsl_v5 (diff)
signatureNo signature
*: Fix lints
Diffstat (limited to 'format/pack/ingest/stream_scan.go')
-rw-r--r--format/pack/ingest/stream_scan.go14
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)}
}