Skip to content

Commit

Permalink
Also initialize safe head
Browse files Browse the repository at this point in the history
  • Loading branch information
danyalprout committed Jul 16, 2024
1 parent c1f1f70 commit e77d0c5
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions crates/storage/provider/src/providers/chain_info.rs
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,8 @@ pub(crate) struct ChainInfoTracker {
impl ChainInfoTracker {
/// Create a new chain info container for the given canonical head.
pub(crate) fn new(head: SealedHeader, finalized: SealedHeader) -> Self {
let (finalized_block, _) = watch::channel(Some(finalized));
let (safe_block, _) = watch::channel(None);
let (finalized_block, _) = watch::channel(Some(finalized.clone()));
let (safe_block, _) = watch::channel(Some(finalized));

Self {
inner: Arc::new(ChainInfoInner {
Expand Down
8 changes: 4 additions & 4 deletions crates/storage/provider/src/providers/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -117,19 +117,19 @@ where
let best: ChainInfo = provider.chain_info()?;
let latest_header = provider
.header_by_number(best.best_number)?
.ok_or_else(|| ProviderError::HeaderNotFound(best.best_number.into()))?;
.ok_or(ProviderError::HeaderNotFound(best.best_number.into()))?;

let finalized_block_number = provider.last_finalized_block_number()?;
let finalized_header = provider
.header_by_number(finalized_block_number)?
.ok_or_else(|| ProviderError::HeaderNotFound(finalized_block_number.into()))?;
.sealed_header(finalized_block_number)?
.ok_or(ProviderError::HeaderNotFound(finalized_block_number.into()))?;

drop(provider);
Ok(Self::with_block_information(
database,
tree,
latest_header.seal(best.best_hash),
finalized_header.seal_slow(),
finalized_header,
))
}
}
Expand Down

0 comments on commit e77d0c5

Please sign in to comment.