Method CommitBlobs

ethstorage/storage_manager.go:214–254

CommitBlobs This function will be called when p2p sync received blobs. It will commit the blobs that match local L1 view and return the unmatched ones. Note that the caller must make sure the blobs data and the corresponding commit are matched.

(kvIndices []uint64, blobs [][]byte, commits []common.Hash)

// that match local L1 view and return the unmatched ones.
// Note that the caller must make sure the blobs data and the corresponding commit are matched.
func (s *StorageManager) CommitBlobs(kvIndices []uint64, blobs [][]byte, commits []common.Hash) ([]uint64, error) {
	if len(kvIndices) != len(blobs) || len(blobs) != len(commits) {
		return nil, errors.New("invalid params lens")
	}
	var (
		l            = len(kvIndices)
		encodedBlobs = make([][]byte, l)
		encoded      = make([]bool, l)
	)
	for i := 0; i < len(kvIndices); i++ {
		encodedBlob, success, err := s.shardManager.TryEncodeKV(kvIndices[i], blobs[i], commits[i])
		if !success || err != nil {
			s.lg.Warn("Blob encode failed", "index", kvIndices[i], "err", err)
			continue
		}
		encodedBlobs[i] = encodedBlob
		encoded[i] = true
	}

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

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

	inserted := []uint64{}
	for i, contractMeta := range metas {
		if !encoded[i] {
			continue
		}
		err := s.commitEncodedBlob(kvIndices[i], encodedBlobs[i], commits[i], contractMeta)
		if err != nil {
			s.lg.Warn("Commit blobs fail", "kvIndex", kvIndices[i], "err", err.Error())
			continue
		}
		inserted = append(inserted, kvIndices[i])
	}
	return inserted, nil
}

// 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.