mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-06-20 21:01:03 +00:00
Fixed block import (#368)
* Fixed decoding from file * Increased progress frequency
This commit is contained in:
committed by
Gav Wood
parent
4dfa17ab37
commit
8bcfb16fad
@@ -430,8 +430,8 @@ fn import_blocks<E>(matches: &clap::ArgMatches, exit: E) -> error::Result<()>
|
|||||||
None => Box::new(stdin()),
|
None => Box::new(stdin()),
|
||||||
};
|
};
|
||||||
|
|
||||||
info!("Importing blocks");
|
|
||||||
let count: u32 = Decode::decode(&mut file).ok_or("Error reading file")?;
|
let count: u32 = Decode::decode(&mut file).ok_or("Error reading file")?;
|
||||||
|
info!("Importing {} blocks", count);
|
||||||
let mut block = 0;
|
let mut block = 0;
|
||||||
for _ in 0 .. count {
|
for _ in 0 .. count {
|
||||||
if exit_recv.try_recv().is_ok() {
|
if exit_recv.try_recv().is_ok() {
|
||||||
@@ -448,7 +448,7 @@ fn import_blocks<E>(matches: &clap::ArgMatches, exit: E) -> error::Result<()>
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
block += 1;
|
block += 1;
|
||||||
if block % 10000 == 0 {
|
if block % 1000 == 0 {
|
||||||
info!("#{}", block);
|
info!("#{}", block);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -49,7 +49,10 @@ impl<'a> Input for &'a [u8] {
|
|||||||
#[cfg(feature = "std")]
|
#[cfg(feature = "std")]
|
||||||
impl<R: ::std::io::Read> Input for R {
|
impl<R: ::std::io::Read> Input for R {
|
||||||
fn read(&mut self, into: &mut [u8]) -> usize {
|
fn read(&mut self, into: &mut [u8]) -> usize {
|
||||||
(self as &mut ::std::io::Read).read(into).unwrap_or(0)
|
match (self as &mut ::std::io::Read).read_exact(into) {
|
||||||
|
Ok(()) => into.len(),
|
||||||
|
Err(_) => 0,
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user