Skip to content

Commit 8db4cfd

Browse files
starknet_patricia_storage: change cache size to u64
1 parent ab3c80d commit 8db4cfd

File tree

4 files changed

+8
-14
lines changed

4 files changed

+8
-14
lines changed

crates/apollo_committer_config/src/config.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
use std::collections::BTreeMap;
2-
use std::num::NonZeroUsize;
32
use std::path::PathBuf;
43

54
use apollo_config::dumping::{prepend_sub_config_name, ser_param, SerializeConfig};
@@ -12,14 +11,14 @@ use starknet_patricia_storage::storage_trait::{Storage, StorageConfigTrait};
1211
use validator::Validate;
1312

1413
// 1M size cache.
15-
pub const DEFAULT_CACHE_MAX_ENTRIES: usize = 1000000;
14+
pub const DEFAULT_CACHE_MAX_ENTRIES: u64 = 1000000;
1615

1716
pub type ApolloStorage = CachedStorage<RocksDbStorage>;
1817

1918
pub type ApolloCommitterConfig = CommitterConfig<<ApolloStorage as Storage>::Config>;
2019

2120
pub const APOLLO_CACHE_STORAGE_CONFIG: CachedStorageConfig = CachedStorageConfig {
22-
cache_size: NonZeroUsize::new(DEFAULT_CACHE_MAX_ENTRIES).unwrap(),
21+
cache_size: DEFAULT_CACHE_MAX_ENTRIES,
2322
cache_on_write: true,
2423
include_inner_stats: true,
2524
};

crates/starknet_committer_cli/src/args.rs

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
use std::fs;
22
use std::future::Future;
3-
use std::num::NonZeroUsize;
43
use std::path::Path;
54
use std::sync::LazyLock;
65

@@ -212,7 +211,7 @@ pub struct CachedStorageArgs<A: StorageFromArgs> {
212211

213212
/// The size of the cache.
214213
#[clap(long, default_value = "1000000")]
215-
pub cache_size: usize,
214+
pub cache_size: u64,
216215
}
217216

218217
impl<A: StorageFromArgs + Sync> StorageFromArgs for CachedStorageArgs<A> {
@@ -222,8 +221,8 @@ impl<A: StorageFromArgs + Sync> StorageFromArgs for CachedStorageArgs<A> {
222221
}
223222

224223
impl<A: StorageFromArgs> CachedStorageArgs<A> {
225-
pub fn cache_size(&self) -> NonZeroUsize {
226-
NonZeroUsize::new(self.cache_size).unwrap()
224+
pub fn cache_size(&self) -> u64 {
225+
self.cache_size
227226
}
228227

229228
pub fn cached_storage_config(&self) -> CachedStorageConfig {

crates/starknet_patricia_storage/src/map_storage.rs

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
use std::fmt::Display;
2-
use std::num::NonZeroUsize;
32

43
use moka::sync::Cache;
54
use serde::Serialize;
@@ -76,7 +75,7 @@ pub struct CachedStorage<S: Storage> {
7675

7776
pub struct CachedStorageConfig {
7877
// Max number of entries in the cache.
79-
pub cache_size: NonZeroUsize, // TODO(Nimrod): Change type to `u64`.
78+
pub cache_size: u64,
8079

8180
// If true, the cache is updated on write operations even if the value is not in the cache.
8281
pub cache_on_write: bool,
@@ -135,9 +134,7 @@ impl<S: Storage> CachedStorage<S> {
135134
// TODO(Nimrod): Consider defining custom eviction policies.
136135
Self {
137136
storage,
138-
cache: Cache::builder()
139-
.max_capacity(config.cache_size.get().try_into().unwrap())
140-
.build(),
137+
cache: Cache::builder().max_capacity(config.cache_size).build(),
141138
cache_on_write: config.cache_on_write,
142139
reads: 0,
143140
cached_reads: 0,

crates/starknet_patricia_storage/src/map_storage_test.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
use std::collections::HashMap;
2-
use std::num::NonZeroUsize;
32

43
use rstest::rstest;
54

@@ -10,7 +9,7 @@ use crate::storage_trait::{DbKey, DbValue, Storage};
109
#[case::map_storage(MapStorage::default())]
1110
#[case::cached_storage(
1211
CachedStorage::new(MapStorage::default(), CachedStorageConfig {
13-
cache_size: NonZeroUsize::new(2).unwrap(),
12+
cache_size: 2,
1413
cache_on_write: true,
1514
include_inner_stats: false,
1615
})

0 commit comments

Comments
 (0)