Method run

cli/command_cache_sync.go:24–54

(ctx context.Context, rep repo.DirectRepositoryWriter)

}

func (c *commandCacheSync) run(ctx context.Context, rep repo.DirectRepositoryWriter) error {
	eg, ctx := errgroup.WithContext(ctx)

	ch := make(chan blob.ID, c.parallel)

	// workers that will prefetch blobs.
	for range c.parallel {
		eg.Go(func() error {
			for blobID := range ch {
				if err := rep.ContentManager().MetadataCache().PrefetchBlob(ctx, blobID); err != nil {
					return errors.Wrap(err, "error prefetching blob")
				}
			}

			return nil
		})
	}

	// populate channel with blob IDs.
	eg.Go(func() error {
		defer close(ch)

		return rep.BlobReader().ListBlobs(ctx, content.PackBlobIDPrefixSpecial, func(bm blob.Metadata) error {
			ch <- bm.BlobID

			return nil
		})
	})

	return errors.Wrap(eg.Wait(), "error synchronizing metadata cache")
}