Compare commits

...

3 Commits

Author SHA1 Message Date
Fallengirl
03e071a676
Update log_entry_fetcher.rs 2025-02-19 10:13:51 +01:00
Fallengirl
4460bcfe7c
Update ssz_snappy.rs 2025-02-19 10:12:20 +01:00
Fallengirl
ecbf3ae4c8
Update data_cache.rs 2025-02-19 10:11:48 +01:00
3 changed files with 3 additions and 3 deletions

View File

@ -50,7 +50,7 @@ impl DataCache {
/// Remove timeout data entries according to TTL.
pub fn garbage_collect(&mut self, latest_tx_seq: u64) {
// We won't keep too many data, so it's okay to just iterate here.
// We won't keep too much data, so it's okay to just iterate here.
self.root_to_data.retain(|_, cached| {
cached.last_seen_tx_seq + self.config.tx_seq_ttl as u64 >= latest_tx_seq
})

View File

@ -673,7 +673,7 @@ async fn check_watch_process(
}
} else {
warn!(
"get block hash for block {} from RPC, assume there is no org",
"get block hash for block {} from RPC, assume there is no reorg",
*progress - 1
);
let hash = loop {

View File

@ -66,7 +66,7 @@ impl Encoder<RPCCodedResponse> for SSZSnappyInboundCodec {
}
// Inserts the length prefix of the uncompressed bytes into dst
// encoded as a unsigned varint
// encoded as an unsigned varint
self.inner
.encode(bytes.len(), dst)
.map_err(RPCError::from)?;