|
| 1 | +// Copyright (c) Aptos Foundation |
| 2 | +// Licensed pursuant to the Innovation-Enabling Source Code License, available at https://github.com/aptos-labs/aptos-core/blob/main/LICENSE |
| 3 | + |
| 4 | +//! Sequential block execution: runs each user transaction in order against an |
| 5 | +//! overlay of the outputs before it. |
| 6 | +// |
| 7 | +// TODO(completeness): Block-STM integration (parallel execution) is a separate |
| 8 | +// workstream; this wrapper is the single-threaded stand-in. |
| 9 | + |
| 10 | +use crate::AptosVMv2; |
| 11 | +use aptos_block_executor::txn_provider::TxnProvider; |
| 12 | +use aptos_types::{ |
| 13 | + block_executor::{ |
| 14 | + config::BlockExecutorConfigFromOnchain, |
| 15 | + transaction_slice_metadata::TransactionSliceMetadata, |
| 16 | + }, |
| 17 | + state_store::{ |
| 18 | + state_key::StateKey, state_storage_usage::StateStorageUsage, state_value::StateValue, |
| 19 | + StateView, StateViewResult, TStateView, |
| 20 | + }, |
| 21 | + transaction::{ |
| 22 | + signature_verified_transaction::SignatureVerifiedTransaction, AuxiliaryInfo, BlockOutput, |
| 23 | + Transaction, TransactionOutput, TransactionStatus, |
| 24 | + }, |
| 25 | + write_set::TransactionWrite, |
| 26 | +}; |
| 27 | +use aptos_vm::VMBlockExecutor; |
| 28 | +use aptos_vm_types::output::VMOutput; |
| 29 | +use move_core_types::vm_status::{StatusCode, VMStatus}; |
| 30 | +use std::collections::HashMap; |
| 31 | + |
| 32 | +/// `VMBlockExecutor` implementation backed by MonoMove, executing sequentially. |
| 33 | +pub struct AptosVMv2BlockExecutor { |
| 34 | + vm: AptosVMv2, |
| 35 | +} |
| 36 | + |
| 37 | +impl VMBlockExecutor for AptosVMv2BlockExecutor { |
| 38 | + fn new() -> Self { |
| 39 | + Self { |
| 40 | + vm: AptosVMv2::new(), |
| 41 | + } |
| 42 | + } |
| 43 | + |
| 44 | + fn execute_block( |
| 45 | + &self, |
| 46 | + txn_provider: &aptos_block_executor::txn_provider::default::DefaultTxnProvider< |
| 47 | + SignatureVerifiedTransaction, |
| 48 | + AuxiliaryInfo, |
| 49 | + >, |
| 50 | + state_view: &(impl StateView + Sync), |
| 51 | + _onchain_config: BlockExecutorConfigFromOnchain, |
| 52 | + _transaction_slice_metadata: TransactionSliceMetadata, |
| 53 | + ) -> Result<BlockOutput<SignatureVerifiedTransaction, TransactionOutput>, VMStatus> { |
| 54 | + let mut overlay = OverlayView { |
| 55 | + base: state_view, |
| 56 | + overlay: HashMap::new(), |
| 57 | + }; |
| 58 | + let mut outputs = Vec::with_capacity(txn_provider.num_txns()); |
| 59 | + for txn in txn_provider.get_txns() { |
| 60 | + let output = match txn.expect_valid() { |
| 61 | + Transaction::UserTransaction(signed_txn) => { |
| 62 | + let (_status, output) = self.vm.execute_user_transaction(&overlay, signed_txn); |
| 63 | + output |
| 64 | + }, |
| 65 | + // TODO(completeness): block metadata, epilogue, state |
| 66 | + // checkpoint, and validator transactions. |
| 67 | + _ => VMOutput::empty_with_status(TransactionStatus::Discard( |
| 68 | + StatusCode::FEATURE_UNDER_GATING, |
| 69 | + )), |
| 70 | + }; |
| 71 | + let output = output |
| 72 | + .try_materialize_into_transaction_output(&overlay) |
| 73 | + .map_err(|e| { |
| 74 | + VMStatus::error( |
| 75 | + StatusCode::UNKNOWN_INVARIANT_VIOLATION_ERROR, |
| 76 | + Some(format!("materialization failed: {e:?}")), |
| 77 | + ) |
| 78 | + })?; |
| 79 | + for (key, op) in output.write_set().write_op_iter() { |
| 80 | + overlay.overlay.insert(key.clone(), op.as_state_value()); |
| 81 | + } |
| 82 | + outputs.push(output); |
| 83 | + } |
| 84 | + Ok(BlockOutput::new(outputs, None)) |
| 85 | + } |
| 86 | +} |
| 87 | + |
| 88 | +/// A state view layering the block's prior outputs over the base view. |
| 89 | +struct OverlayView<'a, S> { |
| 90 | + base: &'a S, |
| 91 | + overlay: HashMap<StateKey, Option<StateValue>>, |
| 92 | +} |
| 93 | + |
| 94 | +impl<S: StateView> TStateView for OverlayView<'_, S> { |
| 95 | + type Key = StateKey; |
| 96 | + |
| 97 | + fn get_state_value(&self, state_key: &StateKey) -> StateViewResult<Option<StateValue>> { |
| 98 | + match self.overlay.get(state_key) { |
| 99 | + Some(value) => Ok(value.clone()), |
| 100 | + None => self.base.get_state_value(state_key), |
| 101 | + } |
| 102 | + } |
| 103 | + |
| 104 | + fn get_usage(&self) -> StateViewResult<StateStorageUsage> { |
| 105 | + // TODO(correctness): account for the overlay's items and bytes. |
| 106 | + self.base.get_usage() |
| 107 | + } |
| 108 | +} |
0 commit comments