mirrors/electrs
1
0
Fork 0
mirror of https://github.com/romanz/electrs.git synced 2024-11-19 09:54:09 +01:00
Code Issues Projects Releases Wiki Activity

Fix cache methods' scope

Browse Source
This commit is contained in:
Roman Zeyde 2021-10-04 14:19:28 +03:00
parent ced9796bde
commit 9a45d9c798
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/cache.rs
View File

@ -7,24 +7,24 @@ use std::sync::Arc;
use crate::merkle::Proof; use crate::merkle::Proof;
#[derive(Default)] #[derive(Default)]
pub struct Cache { pub(crate) struct Cache {
txs: Arc<RwLock<HashMap<Txid, Transaction>>>, txs: Arc<RwLock<HashMap<Txid, Transaction>>>,
proofs: Arc<RwLock<HashMap<(BlockHash, Txid), Proof>>>, proofs: Arc<RwLock<HashMap<(BlockHash, Txid), Proof>>>,
} }
impl Cache { impl Cache {
pub(crate) fn add_tx(&self, txid: Txid, f: impl FnOnce() -> Transaction) { pub fn add_tx(&self, txid: Txid, f: impl FnOnce() -> Transaction) {
self.txs.write().entry(txid).or_insert_with(f); self.txs.write().entry(txid).or_insert_with(f);
} }
pub(crate) fn get_tx<F, T>(&self, txid: &Txid, f: F) -> Option<T> pub fn get_tx<F, T>(&self, txid: &Txid, f: F) -> Option<T>
where where
F: FnOnce(&Transaction) -> T, F: FnOnce(&Transaction) -> T,
{ {
self.txs.read().get(txid).map(f) self.txs.read().get(txid).map(f)
} }
pub(crate) fn add_proof<F>(&self, blockhash: BlockHash, txid: Txid, f: F) pub fn add_proof<F>(&self, blockhash: BlockHash, txid: Txid, f: F)
where where
F: FnOnce() -> Proof, F: FnOnce() -> Proof,
{ {
@ -34,7 +34,7 @@ impl Cache {
.or_insert_with(f); .or_insert_with(f);
} }
pub(crate) fn get_proof<F, T>(&self, blockhash: BlockHash, txid: Txid, f: F) -> Option<T> pub fn get_proof<F, T>(&self, blockhash: BlockHash, txid: Txid, f: F) -> Option<T>
where where
F: FnOnce(&Proof) -> T, F: FnOnce(&Proof) -> T,
{ {