forked from polkadot-evm/frontier
-
Notifications
You must be signed in to change notification settings - Fork 50
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
1bc27b1
commit c0aa620
Showing
21 changed files
with
587 additions
and
31 deletions.
There are no files selected for viewing
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,27 @@ | ||
// SPDX-License-Identifier: GPL-3.0-only | ||
pragma solidity ^0.8.2; | ||
|
||
contract StorageGrowthTest { | ||
mapping(uint256 => uint256) public map; | ||
uint256 foo; | ||
uint256 bar; | ||
uint256 baz; | ||
|
||
constructor() { | ||
foo = 1; | ||
bar = 2; | ||
baz = 3; | ||
} | ||
|
||
function store() public { | ||
map[0] = 1; | ||
map[1] = 2; | ||
map[2] = 3; | ||
} | ||
|
||
function update() public { | ||
foo = 2; | ||
bar = 3; | ||
baz = 4; | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
608060405234801561001057600080fd5b506001808190555060028081905550600380819055506101c7806100356000396000f3fe608060405234801561001057600080fd5b50600436106100415760003560e01c8063975057e714610046578063a2e6204514610050578063b8dda9c71461005a575b600080fd5b61004e61008a565b005b6100586100d6565b005b610074600480360381019061006f919061011d565b6100f0565b6040516100819190610155565b60405180910390f35b6001600080808152602001908152602001600020819055506002600080600181526020019081526020016000208190555060036000806002815260200190815260200160002081905550565b600260018190555060036002819055506004600381905550565b60006020528060005260406000206000915090505481565b6000813590506101178161017a565b92915050565b60006020828403121561012f57600080fd5b600061013d84828501610108565b91505092915050565b61014f81610170565b82525050565b600060208201905061016a6000830184610146565b92915050565b6000819050919050565b61018381610170565b811461018e57600080fd5b5056fea2646970667358221220b25685afab962e465f0b43f6c4de10c82a565f50f6995c1cd444b002bcdd43e964736f6c63430008020033 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,210 @@ | ||
// SPDX-License-Identifier: GPL-3.0-or-later WITH Classpath-exception-2.0 | ||
// This file is part of Frontier. | ||
// | ||
// Copyright (c) 2021-2022 Parity Technologies (UK) Ltd. | ||
// | ||
// This program is free software: you can redistribute it and/or modify | ||
// it under the terms of the GNU General Public License as published by | ||
// the Free Software Foundation, either version 3 of the License, or | ||
// (at your option) any later version. | ||
// | ||
// This program is distributed in the hope that it will be useful, | ||
// but WITHOUT ANY WARRANTY; without even the implied warranty of | ||
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||
// GNU General Public License for more details. | ||
// | ||
// You should have received a copy of the GNU General Public License | ||
// along with this program. If not, see <https://www.gnu.org/licenses/>. | ||
|
||
use evm::{ | ||
gasometer::{GasCost, StorageTarget}, | ||
Opcode, | ||
}; | ||
use fp_evm::ACCOUNT_STORAGE_PROOF_SIZE; | ||
use sp_core::{H160, H256}; | ||
use sp_std::collections::btree_set::BTreeSet; | ||
|
||
/// An error that is returned when the storage limit has been exceeded. | ||
#[derive(Debug, PartialEq)] | ||
pub enum MeterError { | ||
LimitExceeded, | ||
} | ||
|
||
/// A meter for tracking the storage growth. | ||
#[derive(Clone)] | ||
pub struct StorageMeter { | ||
usage: u64, | ||
limit: u64, | ||
recorded_new_entries: BTreeSet<(H160, H256)>, | ||
} | ||
|
||
impl StorageMeter { | ||
/// Creates a new storage meter with the given limit. | ||
pub fn new(limit: u64) -> Self { | ||
Self { | ||
usage: 0, | ||
limit, | ||
recorded_new_entries: BTreeSet::new(), | ||
} | ||
} | ||
|
||
/// Records the given amount of storage usage. The amount is added to the current usage. | ||
/// If the limit is reached, an error is returned. | ||
pub fn record(&mut self, amount: u64) -> Result<(), MeterError> { | ||
let usage = self | ||
.usage | ||
.checked_add(amount) | ||
.ok_or(MeterError::LimitExceeded)?; | ||
|
||
if usage > self.limit { | ||
return Err(MeterError::LimitExceeded); | ||
} | ||
self.usage = usage; | ||
Ok(()) | ||
} | ||
|
||
/// Records the storage growth for the given Opcode. | ||
pub fn record_dynamic_opcode_cost( | ||
&mut self, | ||
_opcode: Opcode, | ||
gas_cost: GasCost, | ||
target: StorageTarget, | ||
) -> Result<(), MeterError> { | ||
if let GasCost::SStore { original, new, .. } = gas_cost { | ||
// Validate if storage growth for the current slot has been accounted for within this transaction. | ||
// Comparing Original and new to determine if a new entry is being created is not sufficient, because | ||
// 'original' updates only at the end of the transaction. So, if a new entry | ||
// is created and updated multiple times within the same transaction, the storage growth is | ||
// accounted for multiple times, because 'original' is always zero for the subsequent updates. | ||
// To avoid this, we keep track of the new entries that are created within the transaction. | ||
let (address, index) = match target { | ||
StorageTarget::Slot(address, index) => (address, index), | ||
_ => return Ok(()), | ||
}; | ||
let recorded = self.recorded_new_entries.contains(&(address, index)); | ||
if !recorded && original == H256::default() && !new.is_zero() { | ||
self.record(ACCOUNT_STORAGE_PROOF_SIZE)?; | ||
self.recorded_new_entries.insert((address, index)); | ||
} | ||
} | ||
Ok(()) | ||
} | ||
|
||
/// Returns the current usage of storage. | ||
pub fn usage(&self) -> u64 { | ||
self.usage | ||
} | ||
|
||
/// Returns the limit of storage. | ||
pub fn limit(&self) -> u64 { | ||
self.limit | ||
} | ||
|
||
/// Returns the amount of storage that is available before the limit is reached. | ||
pub fn available(&self) -> u64 { | ||
self.limit.saturating_sub(self.usage) | ||
} | ||
|
||
/// Map storage usage to the gas cost. | ||
pub fn storage_to_gas(&self, ratio: u64) -> u64 { | ||
self.usage.saturating_mul(ratio) | ||
} | ||
} | ||
#[cfg(test)] | ||
mod test { | ||
use super::*; | ||
|
||
/// Tests the basic functionality of StorageMeter. | ||
#[test] | ||
fn test_basic_functionality() { | ||
let limit = 100; | ||
let mut meter = StorageMeter::new(limit); | ||
|
||
assert_eq!(meter.usage(), 0); | ||
assert_eq!(meter.limit(), limit); | ||
|
||
let amount = 10; | ||
meter.record(amount).unwrap(); | ||
assert_eq!(meter.usage(), amount); | ||
} | ||
|
||
/// Tests the behavior of StorageMeter when reaching the limit. | ||
#[test] | ||
fn test_reaching_limit() { | ||
let limit = 100; | ||
let mut meter = StorageMeter::new(limit); | ||
|
||
// Approaching the limit without exceeding | ||
meter.record(limit - 1).unwrap(); | ||
assert_eq!(meter.usage(), limit - 1); | ||
|
||
// Reaching the limit exactly | ||
meter.record(1).unwrap(); | ||
assert_eq!(meter.usage(), limit); | ||
|
||
// Exceeding the limit | ||
let res = meter.record(1); | ||
assert_eq!(meter.usage(), limit); | ||
assert!(res.is_err()); | ||
assert_eq!(res, Err(MeterError::LimitExceeded)); | ||
} | ||
|
||
/// Tests the record of dynamic opcode cost. | ||
#[test] | ||
fn test_record_dynamic_opcode_cost() { | ||
let limit = 200; | ||
let mut meter = StorageMeter::new(limit); | ||
|
||
// Existing storage entry is updated. No change in storage growth. | ||
let gas_cost = GasCost::SStore { | ||
original: H256::from_low_u64_be(1), | ||
current: Default::default(), | ||
new: H256::from_low_u64_be(2), | ||
target_is_cold: false, | ||
}; | ||
let target = StorageTarget::Slot(H160::default(), H256::from_low_u64_be(1)); | ||
|
||
meter | ||
.record_dynamic_opcode_cost(Opcode::SSTORE, gas_cost, target) | ||
.unwrap(); | ||
assert_eq!(meter.usage(), 0); | ||
|
||
// New storage entry is created. Storage growth is recorded. | ||
let gas_cost = GasCost::SStore { | ||
original: H256::default(), | ||
current: Default::default(), | ||
new: H256::from_low_u64_be(1), | ||
target_is_cold: false, | ||
}; | ||
meter | ||
.record_dynamic_opcode_cost(Opcode::SSTORE, gas_cost, target) | ||
.unwrap(); | ||
assert_eq!(meter.usage(), ACCOUNT_STORAGE_PROOF_SIZE); | ||
|
||
// Try to record the same storage growth again. No change in storage growth. | ||
let gas_cost = GasCost::SStore { | ||
original: H256::default(), | ||
current: Default::default(), | ||
new: H256::from_low_u64_be(1), | ||
target_is_cold: false, | ||
}; | ||
meter | ||
.record_dynamic_opcode_cost(Opcode::SSTORE, gas_cost, target) | ||
.unwrap(); | ||
assert_eq!(meter.usage(), ACCOUNT_STORAGE_PROOF_SIZE); | ||
|
||
// New storage entry is created. Storage growth is recorded. The limit is reached. | ||
let gas_cost = GasCost::SStore { | ||
original: H256::default(), | ||
current: Default::default(), | ||
new: H256::from_low_u64_be(2), | ||
target_is_cold: false, | ||
}; | ||
let target = StorageTarget::Slot(H160::default(), H256::from_low_u64_be(2)); | ||
|
||
let res = meter.record_dynamic_opcode_cost(Opcode::SSTORE, gas_cost, target); | ||
assert!(res.is_err()); | ||
assert_eq!(res, Err(MeterError::LimitExceeded)); | ||
assert_eq!(meter.usage(), 116); | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.