Skip to content

Commit 56665c7

Browse files
committed
trigger catchup for membership every 200 views
1 parent a54aea5 commit 56665c7

File tree

2 files changed

+6
-20
lines changed
  • crates/hotshot/task-impls/src/consensus
  • sequencer/src

2 files changed

+6
-20
lines changed

crates/hotshot/task-impls/src/consensus/mod.rs

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -153,10 +153,12 @@ impl<TYPES: NodeType, I: NodeImplementation<TYPES>, V: Versions> ConsensusTaskSt
153153
HotShotEvent::ViewChange(new_view_number, epoch_number) => {
154154
// Request the randomized stake table for the subsequent epoch,
155155
// to trigger catchup and the DRB calculation if it happens to be missing.
156-
let _ = self
157-
.membership_coordinator
158-
.membership_for_epoch(epoch_number.map(|e| e + 1))
159-
.await;
156+
if **new_view_number % 200 == 0 {
157+
let _ = self
158+
.membership_coordinator
159+
.membership_for_epoch(epoch_number.map(|e| e + 1))
160+
.await;
161+
}
160162

161163
if let Err(e) =
162164
handle_view_change(*new_view_number, *epoch_number, &sender, self).await

sequencer/src/api.rs

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -923,22 +923,6 @@ impl<
923923
self.inner().get_chain_config(commitment).await
924924
}
925925
async fn get_leaf_chain(&self, height: u64) -> anyhow::Result<Vec<Leaf2>> {
926-
{
927-
let decided_height = self
928-
.as_ref()
929-
.consensus()
930-
.await
931-
.read()
932-
.await
933-
.decided_leaf()
934-
.await
935-
.height();
936-
937-
ensure!(
938-
decided_height >= height,
939-
"Requested leaf chain at height {height} but decided height is {decided_height}"
940-
);
941-
}
942926
// Check if we have the desired state in memory.
943927
match self.as_ref().get_leaf_chain(height).await {
944928
Ok(cf) => return Ok(cf),

0 commit comments

Comments
 (0)