Method checkMeta

ethstorage/storage_manager.go:557–575

(kvIdx uint64)

}

func (s *StorageManager) checkMeta(kvIdx uint64) (common.Hash, error) {
	metaInContract, err := s.l1Source.GetKvMetas([]uint64{kvIdx}, rpc.FinalizedBlockNumber.Int64())
	if err != nil {
		return common.Hash{}, fmt.Errorf("failed to query KV meta: kvIndex=%d, %w", kvIdx, err)
	}
	if len(metaInContract) == 0 {
		return common.Hash{}, fmt.Errorf("failed to query KV meta: kvIndex=%d, no meta found", kvIdx)
	}
	var commit common.Hash
	copy(commit[:], metaInContract[0][32-HashSizeInContract:32])
	metaLocal, success, err := s.shardManager.TryReadMeta(kvIdx)
	if err != nil {
		return common.Hash{}, fmt.Errorf("failed to read local meta: kvIndex=%d, %w", kvIdx, err)
	}
	if !success {
		return common.Hash{}, fmt.Errorf("local meta not found: kvIndex=%d", kvIdx)
	}
	return commit, CompareCommits(commit.Bytes(), metaLocal)
}

// TryWriteWithMetaCheck will try to fetch blob and write into the local storage file.
// Before fetching blob, it will compare the provided commit to the one in the contract and make sure the correct commit is used.