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 formatting

Browse Source
This commit is contained in:
Roman Zeyde 2018-06-28 11:15:59 +03:00
parent 70743c9a10
commit 1a2bd66454
No known key found for this signature in database
GPG Key ID: 87CAE5FA46917CBB
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/bulk.rs
View File

@ -77,7 +77,10 @@ impl Parser {
pub fn start(mut self) -> Receiver<Result<Vec<Vec<Row>>>> { pub fn start(mut self) -> Receiver<Result<Vec<Vec<Row>>>> {
info!("indexing {} blk*.dat files", self.files.len()); info!("indexing {} blk*.dat files", self.files.len());
debug!("{} blocks are already indexed", self.indexed_blockhashes.len()); debug!(
"{} blocks are already indexed",
self.indexed_blockhashes.len()
);
let chan = SyncChannel::new(1); let chan = SyncChannel::new(1);
let tx = chan.sender(); let tx = chan.sender();
let parser = parse_files(self.files.split_off(0), self.duration.clone(), self.magic); let parser = parse_files(self.files.split_off(0), self.duration.clone(), self.magic);

6
src/mempool.rs
View File

@ -193,7 +193,11 @@ impl Tracker {
.getmempooltxids() .getmempooltxids()
.chain_err(|| "failed to update mempool from daemon")?; .chain_err(|| "failed to update mempool from daemon")?;
let old_txids = HashSet::from_iter(self.items.keys().cloned()); let old_txids = HashSet::from_iter(self.items.keys().cloned());
trace!("{} transactions in mempool (previosly {})", new_txids.len(), old_txids.len()); trace!(
"{} transactions in mempool (previosly {})",
new_txids.len(),
old_txids.len()
);
timer.observe_duration(); timer.observe_duration();
let timer = self.stats.start_timer("add"); let timer = self.stats.start_timer("add");