smeb_y/0g-storage-node
1
0
Fork 0
mirror of https://github.com/0glabs/0g-storage-node.git synced 2025-04-02 22:45:41 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge 03e071a676 into 74074dfa2f

Browse Source
This commit is contained in:
Fallengirl 2025-03-24 17:05:03 +08:00 committed by GitHub
commit 26642fedf7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
node/log_entry_sync/src/sync_manager/data_cache.rs
View File

@ -50,7 +50,7 @@ impl DataCache {
/// Remove timeout data entries according to TTL. /// Remove timeout data entries according to TTL.
pub fn garbage_collect(&mut self, latest_tx_seq: u64) { 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| { self.root_to_data.retain(|_, cached| {
cached.last_seen_tx_seq + self.config.tx_seq_ttl as u64 >= latest_tx_seq cached.last_seen_tx_seq + self.config.tx_seq_ttl as u64 >= latest_tx_seq
}) })

2
node/log_entry_sync/src/sync_manager/log_entry_fetcher.rs
View File

@ -673,7 +673,7 @@ async fn check_watch_process(
} }
} else { } else {
warn!( 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 *progress - 1
); );
let hash = loop { let hash = loop {

2
node/network/src/rpc/codec/ssz_snappy.rs
View File

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