diff options
| author | 2026-03-08 03:31:12 +0800 | |
|---|---|---|
| committer | 2026-03-08 03:31:12 +0800 | |
| commit | 74584d2dee4f349b5b3535669fa304b95f0f6e52 (patch) | |
| tree | 8ce22050c4726eeaffa29f34074bf8f874c51c7c /format/pack/ingest/ingest.go | |
| parent | receivepack: Add basic progress logging (diff) | |
| signature | No signature | |
format/pack/ingest: Add more progress
Diffstat (limited to 'format/pack/ingest/ingest.go')
| -rw-r--r-- | format/pack/ingest/ingest.go | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/format/pack/ingest/ingest.go b/format/pack/ingest/ingest.go index 22007d27..5f204c2b 100644 --- a/format/pack/ingest/ingest.go +++ b/format/pack/ingest/ingest.go @@ -1,6 +1,10 @@ package ingest -import "fmt" +import ( + "fmt" + + "codeberg.org/lindenii/furgit/internal/utils" +) // ingest initializes transaction state and executes the ingest pipeline. func ingest(state *ingestState) (out Result, err error) { @@ -47,6 +51,7 @@ func ingest(state *ingestState) (out Result, err error) { return Result{}, err } + utils.WriteProgressf(state.opts.Progress, "writing index: start\n") err = state.packFile.Sync() if err != nil { return Result{}, &DestinationWriteError{Op: fmt.Sprintf("sync pack: %v", err)} @@ -56,11 +61,18 @@ func ingest(state *ingestState) (out Result, err error) { if err != nil { return Result{}, err } + utils.WriteProgressf(state.opts.Progress, "writing index: done\n") + if state.opts.WriteRev { + utils.WriteProgressf(state.opts.Progress, "writing reverse index: start\n") + } err = writeRev(state) if err != nil { return Result{}, err } + if state.opts.WriteRev { + utils.WriteProgressf(state.opts.Progress, "writing reverse index: done\n") + } return finalizeArtifacts(state) } |
