diff options
| author |  Runxi Yu | 2026-06-24 05:30:43 +0000 |
|---|---|---|
| committer | Runxi Yu | 2026-06-24 05:30:43 +0000 |
| commit | fc5f3a7d9cdf5407894a97c4637a3c3a6ec110d9 (patch) | |
| tree | 86f6bdf6433d5d94720d40499757bd485193ce1e /object | |
| parent | object/store/packed/internal/ingest: Concurrent resolver (diff) | |
Basic lint fix
Diffstat (limited to 'object')
| -rw-r--r-- | object/store/packed/internal/ingest/resolve.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/object/store/packed/internal/ingest/resolve.go b/object/store/packed/internal/ingest/resolve.go index 0d0207b6..dbb1856c 100644 --- a/object/store/packed/internal/ingest/resolve.go +++ b/object/store/packed/internal/ingest/resolve.go @@ -153,6 +153,7 @@ func (res *resolver) run(workers int) error { go func() { defer wg.Done() + res.worker() }() } @@ -263,6 +264,7 @@ func (ingestion *ingestion) resolveOneChild(index int, baseType typ.Type, baseCo rec.oid = oid rec.resolved = true + ingestion.byOID.Store(oid, index) ingestion.baseCache.Add(baseCacheKey{offset: rec.offset}, cachedContent{objectType: baseType, content: content}) |