aboutsummaryrefslogtreecommitdiff
path: root/format/pack/ingest/rev_write.go
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-03-08 17:53:45 +0800
committerGravatar Runxi Yu2026-03-08 17:53:45 +0800
commit3fe07dd316bde2ea625166176b2285bf0c631889 (patch)
tree181a5aa36765a98a2df43c9ab685cb241fd6a724 /format/pack/ingest/rev_write.go
parentinternal/progress: Use range here (diff)
signatureNo signature
*: Fix lints
Diffstat (limited to 'format/pack/ingest/rev_write.go')
-rw-r--r--format/pack/ingest/rev_write.go6
1 files changed, 6 insertions, 0 deletions
diff --git a/format/pack/ingest/rev_write.go b/format/pack/ingest/rev_write.go
index 9ed8dc6c..9b9432dc 100644
--- a/format/pack/ingest/rev_write.go
+++ b/format/pack/ingest/rev_write.go
@@ -34,6 +34,7 @@ func writeRev(state *ingestState) error {
}
var scratch [8]byte
+
writeProgress(state, "writing reverse index header...\r")
binary.BigEndian.PutUint32(scratch[:4], revMagic)
@@ -55,6 +56,7 @@ func writeRev(state *ingestState) error {
if err != nil {
return err
}
+
writeProgress(state, "writing reverse index header: done.\n")
entriesMeter := progress.New(progress.Options{
@@ -63,6 +65,7 @@ func writeRev(state *ingestState) error {
Title: "writing reverse index entries",
Total: uint64(len(packOrder)),
})
+
var entriesDone uint64
for _, recordIdx := range packOrder {
@@ -77,9 +80,11 @@ func writeRev(state *ingestState) error {
if err != nil {
return err
}
+
entriesDone++
entriesMeter.Set(entriesDone, 0)
}
+
if entriesDone > 0 {
entriesMeter.Stop("done")
}
@@ -102,6 +107,7 @@ func writeRev(state *ingestState) error {
if err != nil {
return err
}
+
writeProgress(state, "writing reverse index trailer: done.\n")
return nil