Method DownloadAllMetas

ethstorage/storage_manager.go:383–412

DownloadAllMetas This function download the blob hashes of all the local storage shards from the smart contract

(ctx context.Context, batchSize uint64)

// DownloadAllMetas This function download the blob hashes of all the local storage shards from the smart contract
func (s *StorageManager) DownloadAllMetas(ctx context.Context, batchSize uint64) error {
	s.mu.Lock()
	kvEntryCount := s.kvEntryCount
	s.mu.Unlock()

	for _, sid := range s.Shards() {
		first, limit := s.KvEntries()*sid, s.KvEntries()*(sid+1)

		// batch request metas until the kvEntryCount
		end := min(limit, kvEntryCount)

		// Additional check to ensure end is not less than first
		// E.g. There are more than one shard, and kvEntryCount is even less than the first of the current shard
		if end < first {
			continue
		}

		s.lg.Info("Begin to download metas", "shard", sid, "first", first, "end", end, "limit", limit, "kvEntryCount", kvEntryCount)
		ts := time.Now()

		err := s.downloadMetaInParallel(ctx, first, end, batchSize)
		if err != nil {
			return err
		}

		s.lg.Info("All the metas has been downloaded", "first", first, "end", end, "time", time.Since(ts).Seconds())
	}

	return nil
}

func (s *StorageManager) downloadMetaInParallel(ctx context.Context, from, to, batchSize uint64) error {
	var wg sync.WaitGroup