aboutsummaryrefslogtreecommitdiff
path: root/format/pack/ingest/thin_fix.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/thin_fix.go
parent*: Fix lint wsl_v5 (diff)
signatureNo signature
*: Fix lints
Diffstat (limited to 'format/pack/ingest/thin_fix.go')
-rw-r--r--format/pack/ingest/thin_fix.go28
1 files changed, 20 insertions, 8 deletions
diff --git a/format/pack/ingest/thin_fix.go b/format/pack/ingest/thin_fix.go
index 15fe7674..05ad9494 100644
--- a/format/pack/ingest/thin_fix.go
+++ b/format/pack/ingest/thin_fix.go
@@ -39,7 +39,9 @@ func maybeFixThin(state *ingestState) error {
}
newEnd := size - hashSize
- if err := state.packFile.Truncate(newEnd); err != nil {
+
+ err = state.packFile.Truncate(newEnd)
+ if err != nil {
return err
}
@@ -52,14 +54,16 @@ func maybeFixThin(state *ingestState) error {
continue
}
- if _, err := appendBaseObject(state, id, ty, content); err != nil {
+ _, err = appendBaseObject(state, id, ty, content)
+ if err != nil {
return err
}
state.thinFixed = true
}
- if err := rewritePackHeaderAndTrailer(state); err != nil {
+ err = rewritePackHeaderAndTrailer(state)
+ if err != nil {
return err
}
@@ -71,7 +75,9 @@ func appendBaseObject(state *ingestState, id objectid.ObjectID, realType objectt
start := state.stream.consumed
header := encodePackEntryHeader(realType, int64(len(content)))
- if _, err := state.packFile.WriteAt(header, int64(start)); err != nil {
+
+ _, err := state.packFile.WriteAt(header, int64(start))
+ if err != nil {
return 0, err
}
@@ -81,11 +87,14 @@ func appendBaseObject(state *ingestState, id objectid.ObjectID, realType objectt
counting := &countingWriter{dst: section}
zw := zlib.NewWriter(io.MultiWriter(counting, crc))
- if _, err := zw.Write(content); err != nil {
+
+ _, err = zw.Write(content)
+ if err != nil {
return 0, err
}
- if err := zw.Close(); err != nil {
+ err = zw.Close()
+ if err != nil {
return 0, err
}
@@ -153,7 +162,8 @@ func rewritePackHeaderAndTrailer(state *ingestState) error {
var countRaw [4]byte
binary.BigEndian.PutUint32(countRaw[:], uint32(len(state.records)))
- if _, err := state.packFile.WriteAt(countRaw[:], 8); err != nil {
+ _, err := state.packFile.WriteAt(countRaw[:], 8)
+ if err != nil {
return err
}
@@ -195,7 +205,9 @@ func rewritePackHeaderAndTrailer(state *ingestState) error {
}
sum := hashImpl.Sum(nil)
- if _, err := state.packFile.WriteAt(sum, endWithoutTrailer); err != nil {
+
+ _, err = state.packFile.WriteAt(sum, endWithoutTrailer)
+ if err != nil {
return err
}