mirror of
https://github.com/0glabs/0g-storage-node.git
synced 2025-04-04 15:35:18 +00:00
Compare commits
2 Commits
150c5394e0
...
ba16e11017
Author | SHA1 | Date | |
---|---|---|---|
![]() |
ba16e11017 | ||
![]() |
649f6e5e9f |
@ -178,7 +178,10 @@ impl LogEntryFetcher {
|
|||||||
|
|
||||||
if let Some(finalized_block_number) = finalized_block_number {
|
if let Some(finalized_block_number) = finalized_block_number {
|
||||||
let safe_block_number = std::cmp::min(
|
let safe_block_number = std::cmp::min(
|
||||||
std::cmp::min(log_latest_block_number, finalized_block_number),
|
std::cmp::min(
|
||||||
|
log_latest_block_number.saturating_sub(1),
|
||||||
|
finalized_block_number,
|
||||||
|
),
|
||||||
processed_block_number,
|
processed_block_number,
|
||||||
);
|
);
|
||||||
let mut pending_keys = vec![];
|
let mut pending_keys = vec![];
|
||||||
@ -657,7 +660,7 @@ async fn check_watch_process(
|
|||||||
);
|
);
|
||||||
match provider.get_block(*progress - 1).await {
|
match provider.get_block(*progress - 1).await {
|
||||||
Ok(Some(v)) => {
|
Ok(Some(v)) => {
|
||||||
v.hash.expect("parent block hash expect exist");
|
break v.hash.expect("parent block hash expect exist");
|
||||||
}
|
}
|
||||||
Ok(None) => {
|
Ok(None) => {
|
||||||
panic!("parent block {} expect exist", *progress - 1);
|
panic!("parent block {} expect exist", *progress - 1);
|
||||||
|
Loading…
Reference in New Issue
Block a user