aboutsummaryrefslogtreecommitdiff
path: root/format/pack/ingest/idx_write.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/idx_write.go
parent*: Fix lint wsl_v5 (diff)
signatureNo signature
*: Fix lints
Diffstat (limited to 'format/pack/ingest/idx_write.go')
-rw-r--r--format/pack/ingest/idx_write.go38
1 files changed, 26 insertions, 12 deletions
diff --git a/format/pack/ingest/idx_write.go b/format/pack/ingest/idx_write.go
index f3d63b76..8db11ba0 100644
--- a/format/pack/ingest/idx_write.go
+++ b/format/pack/ingest/idx_write.go
@@ -24,11 +24,13 @@ func writeIdx(state *ingestState) error {
}
write := func(src []byte) error {
- if _, err := state.idxFile.Write(src); err != nil {
+ _, err := state.idxFile.Write(src)
+ if err != nil {
return err
}
- if _, err := hashImpl.Write(src); err != nil {
+ _, err = hashImpl.Write(src)
+ if err != nil {
return err
}
@@ -39,7 +41,8 @@ func writeIdx(state *ingestState) error {
binary.BigEndian.PutUint32(scratch[:4], idxMagicV2)
binary.BigEndian.PutUint32(scratch[4:8], idxVersionV2)
- if err := write(scratch[:8]); err != nil {
+ err = write(scratch[:8])
+ if err != nil {
return err
}
@@ -55,14 +58,17 @@ func writeIdx(state *ingestState) error {
cumulative += fanout[i]
binary.BigEndian.PutUint32(scratch[:4], cumulative)
- if err := write(scratch[:4]); err != nil {
+ err := write(scratch[:4])
+ if err != nil {
return err
}
}
for _, recordIdx := range order {
idRaw := state.records[recordIdx].objectID.Bytes()
- if err := write(idRaw); err != nil {
+
+ err := write(idRaw)
+ if err != nil {
return err
}
}
@@ -70,7 +76,8 @@ func writeIdx(state *ingestState) error {
for _, recordIdx := range order {
binary.BigEndian.PutUint32(scratch[:4], state.records[recordIdx].crc32)
- if err := write(scratch[:4]); err != nil {
+ err := write(scratch[:4])
+ if err != nil {
return err
}
}
@@ -88,7 +95,8 @@ func writeIdx(state *ingestState) error {
binary.BigEndian.PutUint32(scratch[:4], uint32(offset))
}
- if err := write(scratch[:4]); err != nil {
+ err := write(scratch[:4])
+ if err != nil {
return err
}
}
@@ -96,17 +104,21 @@ func writeIdx(state *ingestState) error {
for _, off := range largeOffsets {
binary.BigEndian.PutUint64(scratch[:8], off)
- if err := write(scratch[:8]); err != nil {
+ err := write(scratch[:8])
+ if err != nil {
return err
}
}
- if err := write(state.packHash.Bytes()); err != nil {
+ err = write(state.packHash.Bytes())
+ if err != nil {
return err
}
idxHash := hashImpl.Sum(nil)
- if _, err := state.idxFile.Write(idxHash); err != nil {
+
+ _, err = state.idxFile.Write(idxHash)
+ if err != nil {
return err
}
@@ -140,11 +152,13 @@ func verifyResolvedRecords(state *ingestState) error {
// writeAndHash writes src to dst and updates hash.
func writeAndHash(dst io.Writer, hashImpl hash.Hash, src []byte) error {
- if _, err := dst.Write(src); err != nil {
+ _, err := dst.Write(src)
+ if err != nil {
return err
}
- if _, err := hashImpl.Write(src); err != nil {
+ _, err = hashImpl.Write(src)
+ if err != nil {
return err
}