Skip to content

Commit b5d3fc3

Browse files
committed
Add digester cache to aggregator & signer
1 parent d463054 commit b5d3fc3

File tree

2 files changed

+11
-0
lines changed

2 files changed

+11
-0
lines changed

mithril-aggregator/src/command_args.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ use mithril_common::{
1414
chain_observer::{CardanoCliRunner, ChainObserver},
1515
crypto_helper::{key_decode_hex, ProtocolGenesisSigner, ProtocolGenesisVerifier},
1616
database::{ApplicationNodeType, DatabaseVersionChecker},
17+
digesters::cache::JsonImmutableFileDigestCacheProvider,
1718
digesters::{CardanoImmutableDigester, ImmutableFileSystemObserver},
1819
entities::{Epoch, HexEncodedGenesisSecretKey},
1920
store::{adapter::SQLiteAdapter, StakeStore},
@@ -357,6 +358,9 @@ impl ServeCommand {
357358
));
358359
let digester = Arc::new(CardanoImmutableDigester::new(
359360
config.db_directory.clone(),
361+
Arc::new(JsonImmutableFileDigestCacheProvider::new(
362+
&config.data_stores_directory.join("immutables_digests.json"),
363+
)),
360364
slog_scope::logger(),
361365
));
362366
let multi_signer = Arc::new(RwLock::new(MultiSignerImpl::new(

mithril-signer/src/runtime/signer_services.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ use std::error::Error as StdError;
22
use std::fs;
33
use std::sync::Arc;
44

5+
use mithril_common::digesters::cache::JsonImmutableFileDigestCacheProvider;
56
use mithril_common::{
67
chain_observer::{CardanoCliChainObserver, CardanoCliRunner, ChainObserver},
78
crypto_helper::{OpCert, ProtocolPartyId, SerDeShelleyFileFormat},
@@ -86,6 +87,12 @@ impl<'a> ServiceBuilder for ProductionServiceBuilder<'a> {
8687
));
8788
let digester = Arc::new(CardanoImmutableDigester::new(
8889
self.config.db_directory.clone(),
90+
Arc::new(JsonImmutableFileDigestCacheProvider::new(
91+
&self
92+
.config
93+
.data_stores_directory
94+
.join("immutables_digests.json"),
95+
)),
8996
slog_scope::logger(),
9097
));
9198
let stake_store = Arc::new(StakeStore::new(

0 commit comments

Comments
 (0)