Method CommitEmptyBlobs

ethstorage/storage_manager.go:258–301

CommitEmptyBlobs use to commit batch empty blobs, return inserted blobs count, next index to fill and error GetKvMetas got. Any error (like encode or commit) happen to a blob, cancel to rest.

(start, limit uint64)

// CommitEmptyBlobs use to commit batch empty blobs, return inserted blobs count, next index to fill
// and error GetKvMetas got. Any error (like encode or commit) happen to a blob, cancel to rest.
func (s *StorageManager) CommitEmptyBlobs(start, limit uint64) (uint64, uint64, error) {
	var (
		encodedBlobs = make([][]byte, 0)
		kvIndices    = make([]uint64, 0)
		inserted     = uint64(0)
		emptyBs      = make([]byte, 0)
		hash         = common.Hash{}
		next         = start
	)
	for i := start; i <= limit; i++ {
		encodedBlob, success, err := s.shardManager.TryEncodeKV(i, emptyBs, hash)
		if !success || err != nil {
			s.lg.Warn("Blob encode failed", "index", i, "err", err)
			break
		}
		encodedBlobs = append(encodedBlobs, encodedBlob)
		kvIndices = append(kvIndices, i)
	}

	s.mu.Lock()
	defer s.mu.Unlock()

	metas, err := s.getKvMetas(kvIndices)
	if err != nil {
		return inserted, next, err
	}

	for i, index := range kvIndices {
		err := s.commitEncodedBlob(index, encodedBlobs[i], hash, metas[i])
		if err == nil {
			inserted++
		} else {
			var commitErr *CommitMismatchError
			if !errors.As(err, &commitErr) {
				s.lg.Info("Commit blobs fail", "kvIndex", kvIndices[i], "err", err.Error())
				break
			}
		}
		// if meta is not equal to empty hash, that mean the blob is not empty,
		// so cancel the fill empty for that index and continue the rest.
		next++
	}
	return inserted, next, nil
}

// CommitBlob This function will be called when p2p sync received a blob.
// Return err if the passed commit and the one queried from contract are not matched.