mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-06-13 04:41:02 +00:00
Make it possible to disable RocksDB completely (#11537)
* Make it possible to disable RocksDB completely * Make ParityDB non-optional * Address review comments
This commit is contained in:
@@ -30,15 +30,13 @@
|
||||
|
||||
pub mod offchain;
|
||||
|
||||
#[cfg(any(feature = "with-kvdb-rocksdb", test))]
|
||||
pub mod bench;
|
||||
|
||||
mod children;
|
||||
#[cfg(feature = "with-parity-db")]
|
||||
mod parity_db;
|
||||
mod stats;
|
||||
mod storage_cache;
|
||||
#[cfg(any(feature = "with-kvdb-rocksdb", test))]
|
||||
#[cfg(any(feature = "rocksdb", test))]
|
||||
mod upgrade;
|
||||
mod utils;
|
||||
|
||||
@@ -94,7 +92,6 @@ use sp_trie::{prefixed_key, MemoryDB, PrefixedMemoryDB};
|
||||
pub use sc_state_db::PruningMode;
|
||||
pub use sp_database::Database;
|
||||
|
||||
#[cfg(any(feature = "with-kvdb-rocksdb", test))]
|
||||
pub use bench::BenchmarkingState;
|
||||
|
||||
const CACHE_HEADERS: usize = 8;
|
||||
@@ -106,7 +103,6 @@ const DEFAULT_CHILD_RATIO: (usize, usize) = (1, 10);
|
||||
pub type DbState<B> =
|
||||
sp_state_machine::TrieBackend<Arc<dyn sp_state_machine::Storage<HashFor<B>>>, HashFor<B>>;
|
||||
|
||||
#[cfg(feature = "with-parity-db")]
|
||||
/// Length of a [`DbHash`].
|
||||
const DB_HASH_LEN: usize = 32;
|
||||
|
||||
@@ -330,6 +326,7 @@ pub enum DatabaseSource {
|
||||
cache_size: usize,
|
||||
},
|
||||
/// Load a RocksDB database from a given path. Recommended for most uses.
|
||||
#[cfg(feature = "rocksdb")]
|
||||
RocksDb {
|
||||
/// Path to the database.
|
||||
path: PathBuf,
|
||||
@@ -362,7 +359,9 @@ impl DatabaseSource {
|
||||
// IIUC this is needed for polkadot to create its own dbs, so until it can use parity db
|
||||
// I would think rocksdb, but later parity-db.
|
||||
DatabaseSource::Auto { paritydb_path, .. } => Some(paritydb_path),
|
||||
DatabaseSource::RocksDb { path, .. } | DatabaseSource::ParityDb { path } => Some(path),
|
||||
#[cfg(feature = "rocksdb")]
|
||||
DatabaseSource::RocksDb { path, .. } => Some(path),
|
||||
DatabaseSource::ParityDb { path } => Some(path),
|
||||
DatabaseSource::Custom { .. } => None,
|
||||
}
|
||||
}
|
||||
@@ -374,7 +373,11 @@ impl DatabaseSource {
|
||||
*paritydb_path = p.into();
|
||||
true
|
||||
},
|
||||
DatabaseSource::RocksDb { ref mut path, .. } |
|
||||
#[cfg(feature = "rocksdb")]
|
||||
DatabaseSource::RocksDb { ref mut path, .. } => {
|
||||
*path = p.into();
|
||||
true
|
||||
},
|
||||
DatabaseSource::ParityDb { ref mut path } => {
|
||||
*path = p.into();
|
||||
true
|
||||
@@ -388,6 +391,7 @@ impl std::fmt::Display for DatabaseSource {
|
||||
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
|
||||
let name = match self {
|
||||
DatabaseSource::Auto { .. } => "Auto",
|
||||
#[cfg(feature = "rocksdb")]
|
||||
DatabaseSource::RocksDb { .. } => "RocksDb",
|
||||
DatabaseSource::ParityDb { .. } => "ParityDb",
|
||||
DatabaseSource::Custom { .. } => "Custom",
|
||||
|
||||
@@ -34,12 +34,6 @@ use sp_trie::DBValue;
|
||||
|
||||
/// Number of columns in the db. Must be the same for both full && light dbs.
|
||||
/// Otherwise RocksDb will fail to open database && check its type.
|
||||
#[cfg(any(
|
||||
feature = "with-kvdb-rocksdb",
|
||||
feature = "with-parity-db",
|
||||
feature = "test-helpers",
|
||||
test
|
||||
))]
|
||||
pub const NUM_COLUMNS: u32 = 13;
|
||||
/// Meta column. The set of keys in the column is shared by full && light storages.
|
||||
pub const COLUMN_META: u32 = 0;
|
||||
@@ -198,6 +192,7 @@ fn open_database_at<Block: BlockT>(
|
||||
) -> OpenDbResult {
|
||||
let db: Arc<dyn Database<DbHash>> = match &db_source {
|
||||
DatabaseSource::ParityDb { path } => open_parity_db::<Block>(path, db_type, create)?,
|
||||
#[cfg(feature = "rocksdb")]
|
||||
DatabaseSource::RocksDb { path, cache_size } =>
|
||||
open_kvdb_rocksdb::<Block>(path, db_type, create, *cache_size)?,
|
||||
DatabaseSource::Custom { db, require_create_flag } => {
|
||||
@@ -266,7 +261,6 @@ impl From<OpenDbError> for sp_blockchain::Error {
|
||||
}
|
||||
}
|
||||
|
||||
#[cfg(feature = "with-parity-db")]
|
||||
impl From<parity_db::Error> for OpenDbError {
|
||||
fn from(err: parity_db::Error) -> Self {
|
||||
if matches!(err, parity_db::Error::DatabaseNotFound) {
|
||||
@@ -287,7 +281,6 @@ impl From<io::Error> for OpenDbError {
|
||||
}
|
||||
}
|
||||
|
||||
#[cfg(feature = "with-parity-db")]
|
||||
fn open_parity_db<Block: BlockT>(path: &Path, db_type: DatabaseType, create: bool) -> OpenDbResult {
|
||||
match crate::parity_db::open(path, db_type, create, false) {
|
||||
Ok(db) => Ok(db),
|
||||
@@ -300,16 +293,7 @@ fn open_parity_db<Block: BlockT>(path: &Path, db_type: DatabaseType, create: boo
|
||||
}
|
||||
}
|
||||
|
||||
#[cfg(not(feature = "with-parity-db"))]
|
||||
fn open_parity_db<Block: BlockT>(
|
||||
_path: &Path,
|
||||
_db_type: DatabaseType,
|
||||
_create: bool,
|
||||
) -> OpenDbResult {
|
||||
Err(OpenDbError::NotEnabled("with-parity-db"))
|
||||
}
|
||||
|
||||
#[cfg(any(feature = "with-kvdb-rocksdb", test))]
|
||||
#[cfg(any(feature = "rocksdb", test))]
|
||||
fn open_kvdb_rocksdb<Block: BlockT>(
|
||||
path: &Path,
|
||||
db_type: DatabaseType,
|
||||
@@ -359,7 +343,7 @@ fn open_kvdb_rocksdb<Block: BlockT>(
|
||||
Ok(sp_database::as_database(db))
|
||||
}
|
||||
|
||||
#[cfg(not(any(feature = "with-kvdb-rocksdb", test)))]
|
||||
#[cfg(not(any(feature = "rocksdb", test)))]
|
||||
fn open_kvdb_rocksdb<Block: BlockT>(
|
||||
_path: &Path,
|
||||
_db_type: DatabaseType,
|
||||
@@ -602,7 +586,7 @@ mod tests {
|
||||
use std::path::PathBuf;
|
||||
type Block = RawBlock<ExtrinsicWrapper<u32>>;
|
||||
|
||||
#[cfg(any(feature = "with-kvdb-rocksdb", test))]
|
||||
#[cfg(any(feature = "rocksdb", test))]
|
||||
#[test]
|
||||
fn database_type_subdir_migration() {
|
||||
type Block = RawBlock<ExtrinsicWrapper<u64>>;
|
||||
@@ -639,7 +623,6 @@ mod tests {
|
||||
"db_version",
|
||||
);
|
||||
|
||||
#[cfg(feature = "with-parity-db")]
|
||||
check_dir_for_db_type(
|
||||
DatabaseType::Full,
|
||||
DatabaseSource::ParityDb { path: PathBuf::new() },
|
||||
@@ -702,8 +685,6 @@ mod tests {
|
||||
assert_eq!(joined.remaining_len().unwrap(), Some(0));
|
||||
}
|
||||
|
||||
#[cfg(feature = "with-parity-db")]
|
||||
#[cfg(any(feature = "with-kvdb-rocksdb", test))]
|
||||
#[test]
|
||||
fn test_open_database_auto_new() {
|
||||
let db_dir = tempfile::TempDir::new().unwrap();
|
||||
@@ -749,8 +730,6 @@ mod tests {
|
||||
}
|
||||
}
|
||||
|
||||
#[cfg(feature = "with-parity-db")]
|
||||
#[cfg(any(feature = "with-kvdb-rocksdb", test))]
|
||||
#[test]
|
||||
fn test_open_database_rocksdb_new() {
|
||||
let db_dir = tempfile::TempDir::new().unwrap();
|
||||
@@ -801,8 +780,6 @@ mod tests {
|
||||
}
|
||||
}
|
||||
|
||||
#[cfg(feature = "with-parity-db")]
|
||||
#[cfg(any(feature = "with-kvdb-rocksdb", test))]
|
||||
#[test]
|
||||
fn test_open_database_paritydb_new() {
|
||||
let db_dir = tempfile::TempDir::new().unwrap();
|
||||
|
||||
Reference in New Issue
Block a user