diff options
| author |  Runxi Yu | 2026-03-08 03:42:28 +0800 |
|---|---|---|
| committer | Runxi Yu | 2026-03-08 03:42:28 +0800 |
| commit | b99e33900bc9ba8c7b608725c9aa30fdf8b62f0e (patch) | |
| tree | 91cf585ca25e5058b3c1c462ebe7f4ab453d093e /receivepack/service | |
| parent | receivepack: Update tests (diff) | |
| signature | No signature | |
receivepack: No receiving objects label
Diffstat (limited to 'receivepack/service')
| -rw-r--r-- | receivepack/service/ingest_quarantine.go | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/receivepack/service/ingest_quarantine.go b/receivepack/service/ingest_quarantine.go index 2956c51e..8bc7c1c3 100644 --- a/receivepack/service/ingest_quarantine.go +++ b/receivepack/service/ingest_quarantine.go @@ -17,7 +17,7 @@ func (service *Service) ingestQuarantine( } if req.Pack == nil { - utils.WriteProgressf(service.opts.Progress, "receiving objects: unpack failed: missing pack stream\n") + utils.WriteProgressf(service.opts.Progress, "unpack failed: missing pack stream\n") result.UnpackError = "missing pack stream" fillCommandErrors(result, commands, "missing pack stream") @@ -26,7 +26,7 @@ func (service *Service) ingestQuarantine( } if service.opts.ObjectsRoot == nil { - utils.WriteProgressf(service.opts.Progress, "receiving objects: unpack failed: objects root not configured\n") + utils.WriteProgressf(service.opts.Progress, "unpack failed: objects root not configured\n") result.UnpackError = "objects root not configured" fillCommandErrors(result, commands, "objects root not configured") @@ -37,7 +37,7 @@ func (service *Service) ingestQuarantine( utils.WriteProgressf(service.opts.Progress, "creating quarantine...\r") quarantineName, quarantineRoot, err := service.createQuarantineRoot() if err != nil { - utils.WriteProgressf(service.opts.Progress, "receiving objects: unpack failed: %v\n", err) + utils.WriteProgressf(service.opts.Progress, "unpack failed: %v\n", err) result.UnpackError = err.Error() fillCommandErrors(result, commands, err.Error()) @@ -47,7 +47,7 @@ func (service *Service) ingestQuarantine( quarantinePackRoot, err := service.openQuarantinePackRoot(quarantineRoot) if err != nil { - utils.WriteProgressf(service.opts.Progress, "receiving objects: unpack failed: %v\n", err) + utils.WriteProgressf(service.opts.Progress, "unpack failed: %v\n", err) result.UnpackError = err.Error() fillCommandErrors(result, commands, err.Error()) @@ -58,7 +58,7 @@ func (service *Service) ingestQuarantine( return "", nil, false } utils.WriteProgressf(service.opts.Progress, "creating quarantine: done.\n") - utils.WriteProgressf(service.opts.Progress, "receiving objects: unpacking...\r") + utils.WriteProgressf(service.opts.Progress, "unpacking...\r") ingested, err := ingest.Ingest( req.Pack, @@ -75,7 +75,7 @@ func (service *Service) ingestQuarantine( _ = quarantinePackRoot.Close() if err != nil { - utils.WriteProgressf(service.opts.Progress, "receiving objects: unpack failed: %v\n", err) + utils.WriteProgressf(service.opts.Progress, "unpack failed: %v\n", err) result.UnpackError = err.Error() fillCommandErrors(result, commands, err.Error()) @@ -86,7 +86,7 @@ func (service *Service) ingestQuarantine( return "", nil, false } - utils.WriteProgressf(service.opts.Progress, "receiving objects: unpacking: done (%d objects, %s).\n", ingested.ObjectCount, ingested.PackHash) + utils.WriteProgressf(service.opts.Progress, "unpacking: done (%d objects, %s).\n", ingested.ObjectCount, ingested.PackHash) result.Ingest = &ingested |