use crate::{cfg::GasParams, transaction::AccessListItemTr as _, Transaction, TransactionType};
use primitives::hardfork::SpecId;
#[derive(Clone, Copy, Debug, Default, PartialEq, Eq, Hash)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub struct GasTracker {
gas_limit: u64,
remaining: u64,
reservoir: u64,
state_gas_spent: u64,
refunded: i64,
}
impl GasTracker {
#[inline]
pub const fn new(gas_limit: u64, remaining: u64, reservoir: u64) -> Self {
Self {
gas_limit,
remaining,
reservoir,
state_gas_spent: 0,
refunded: 0,
}
}
#[inline]
pub const fn new_used_gas(gas_limit: u64, used_gas: u64, reservoir: u64) -> Self {
Self::new(gas_limit, gas_limit - used_gas, reservoir)
}
#[inline]
pub const fn limit(&self) -> u64 {
self.gas_limit
}
#[inline]
pub fn set_limit(&mut self, val: u64) {
self.gas_limit = val;
}
#[inline]
pub const fn remaining(&self) -> u64 {
self.remaining
}
#[inline]
pub fn set_remaining(&mut self, val: u64) {
self.remaining = val;
}
#[inline]
pub const fn reservoir(&self) -> u64 {
self.reservoir
}
#[inline]
pub fn set_reservoir(&mut self, val: u64) {
self.reservoir = val;
}
#[inline]
pub const fn state_gas_spent(&self) -> u64 {
self.state_gas_spent
}
#[inline]
pub fn set_state_gas_spent(&mut self, val: u64) {
self.state_gas_spent = val;
}
#[inline]
pub const fn refunded(&self) -> i64 {
self.refunded
}
#[inline]
pub fn set_refunded(&mut self, val: i64) {
self.refunded = val;
}
#[inline]
#[must_use = "In case of not enough gas, the interpreter should halt with an out-of-gas error"]
pub fn record_regular_cost(&mut self, cost: u64) -> bool {
if let Some(new_remaining) = self.remaining.checked_sub(cost) {
self.remaining = new_remaining;
return true;
}
false
}
#[inline]
#[must_use = "In case of not enough gas, the interpreter should halt with an out-of-gas error"]
pub fn record_state_cost(&mut self, cost: u64) -> bool {
if self.reservoir >= cost {
self.state_gas_spent = self.state_gas_spent.saturating_add(cost);
self.reservoir -= cost;
return true;
}
let spill = cost - self.reservoir;
let success = self.record_regular_cost(spill);
if success {
self.state_gas_spent = self.state_gas_spent.saturating_add(cost);
self.reservoir = 0;
}
success
}
#[inline]
pub fn record_refund(&mut self, refund: i64) {
self.refunded += refund;
}
#[inline]
pub fn erase_cost(&mut self, returned: u64) {
self.remaining += returned;
}
#[inline]
pub fn spend_all(&mut self) {
self.remaining = 0;
}
}
pub const ZERO: u64 = 0;
pub const BASE: u64 = 2;
pub const VERYLOW: u64 = 3;
pub const DATA_LOADN_GAS: u64 = 3;
pub const CONDITION_JUMP_GAS: u64 = 4;
pub const RETF_GAS: u64 = 3;
pub const DATA_LOAD_GAS: u64 = 4;
pub const LOW: u64 = 5;
pub const MID: u64 = 8;
pub const HIGH: u64 = 10;
pub const JUMPDEST: u64 = 1;
pub const SELFDESTRUCT_REFUND: i64 = 24000;
pub const CREATE: u64 = 32000;
pub const CALLVALUE: u64 = 9000;
pub const NEWACCOUNT: u64 = 25000;
pub const EXP: u64 = 10;
pub const MEMORY: u64 = 3;
pub const LOG: u64 = 375;
pub const LOGDATA: u64 = 8;
pub const LOGTOPIC: u64 = 375;
pub const KECCAK256: u64 = 30;
pub const KECCAK256WORD: u64 = 6;
pub const COPY: u64 = 3;
pub const BLOCKHASH: u64 = 20;
pub const CODEDEPOSIT: u64 = 200;
pub const ISTANBUL_SLOAD_GAS: u64 = 800;
pub const SSTORE_SET: u64 = 20000;
pub const SSTORE_RESET: u64 = 5000;
pub const REFUND_SSTORE_CLEARS: i64 = 15000;
pub const STANDARD_TOKEN_COST: u64 = 4;
pub const NON_ZERO_BYTE_DATA_COST: u64 = 68;
pub const NON_ZERO_BYTE_MULTIPLIER: u64 = NON_ZERO_BYTE_DATA_COST / STANDARD_TOKEN_COST;
pub const NON_ZERO_BYTE_DATA_COST_ISTANBUL: u64 = 16;
pub const NON_ZERO_BYTE_MULTIPLIER_ISTANBUL: u64 =
NON_ZERO_BYTE_DATA_COST_ISTANBUL / STANDARD_TOKEN_COST;
pub const TOTAL_COST_FLOOR_PER_TOKEN: u64 = 10;
pub const EOF_CREATE_GAS: u64 = 32000;
pub const ACCESS_LIST_ADDRESS: u64 = 2400;
pub const ACCESS_LIST_STORAGE_KEY: u64 = 1900;
pub const COLD_SLOAD_COST: u64 = 2100;
pub const COLD_ACCOUNT_ACCESS_COST: u64 = 2600;
pub const COLD_ACCOUNT_ACCESS_COST_ADDITIONAL: u64 =
COLD_ACCOUNT_ACCESS_COST - WARM_STORAGE_READ_COST;
pub const WARM_STORAGE_READ_COST: u64 = 100;
pub const WARM_SSTORE_RESET: u64 = SSTORE_RESET - COLD_SLOAD_COST;
pub const INITCODE_WORD_COST: u64 = 2;
pub const CALL_STIPEND: u64 = 2300;
#[derive(Clone, Copy, Debug, Default, PartialEq, Eq)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub struct InitialAndFloorGas {
pub initial_total_gas: u64,
pub initial_state_gas: u64,
pub floor_gas: u64,
pub eip7702_reservoir_refund: u64,
}
impl InitialAndFloorGas {
#[inline]
pub const fn new(initial_total_gas: u64, floor_gas: u64) -> Self {
Self {
initial_total_gas,
initial_state_gas: 0,
floor_gas,
eip7702_reservoir_refund: 0,
}
}
#[inline]
pub const fn new_with_state_gas(
initial_total_gas: u64,
initial_state_gas: u64,
floor_gas: u64,
) -> Self {
Self {
initial_total_gas,
initial_state_gas,
floor_gas,
eip7702_reservoir_refund: 0,
}
}
#[inline]
pub const fn initial_regular_gas(&self) -> u64 {
self.initial_total_gas - self.initial_state_gas
}
pub fn initial_gas_and_reservoir(
&self,
tx_gas_limit: u64,
tx_gas_limit_cap: u64,
is_eip8037: bool,
) -> (u64, u64) {
let execution_gas = tx_gas_limit - self.initial_regular_gas();
let regular_gas_cap = if self.initial_total_gas == 0 {
u64::MAX
} else if is_eip8037 {
tx_gas_limit_cap.saturating_sub(self.initial_regular_gas())
} else {
tx_gas_limit_cap
};
let mut gas_limit = core::cmp::min(execution_gas, regular_gas_cap);
let mut reservoir = execution_gas - gas_limit;
if self.initial_state_gas > 0 {
if reservoir >= self.initial_state_gas {
reservoir -= self.initial_state_gas;
} else {
gas_limit -= self.initial_state_gas - reservoir;
reservoir = 0;
}
}
if self.eip7702_reservoir_refund > 0 {
reservoir += self.eip7702_reservoir_refund;
}
(gas_limit, reservoir)
}
}
pub fn calculate_initial_tx_gas(
spec_id: SpecId,
input: &[u8],
is_create: bool,
access_list_accounts: u64,
access_list_storages: u64,
authorization_list_num: u64,
) -> InitialAndFloorGas {
GasParams::new_spec(spec_id).initial_tx_gas(
input,
is_create,
access_list_accounts,
access_list_storages,
authorization_list_num,
)
}
pub fn calculate_initial_tx_gas_for_tx(tx: impl Transaction, spec: SpecId) -> InitialAndFloorGas {
let mut accounts = 0;
let mut storages = 0;
if tx.tx_type() != TransactionType::Legacy {
(accounts, storages) = tx
.access_list()
.map(|al| {
al.fold((0, 0), |(mut num_accounts, mut num_storage_slots), item| {
num_accounts += 1;
num_storage_slots += item.storage_slots().count();
(num_accounts, num_storage_slots)
})
})
.unwrap_or_default();
}
calculate_initial_tx_gas(
spec,
tx.input(),
tx.kind().is_create(),
accounts as u64,
storages as u64,
tx.authorization_list_len() as u64,
)
}
#[inline]
pub fn get_tokens_in_calldata_istanbul(input: &[u8]) -> u64 {
get_tokens_in_calldata(input, NON_ZERO_BYTE_MULTIPLIER_ISTANBUL)
}
#[inline]
pub fn get_tokens_in_calldata(input: &[u8], non_zero_data_multiplier: u64) -> u64 {
let zero_data_len = input.iter().filter(|v| **v == 0).count() as u64;
let non_zero_data_len = input.len() as u64 - zero_data_len;
zero_data_len + non_zero_data_len * non_zero_data_multiplier
}