logos-blockchain/logos-blockchain-specs
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-specs.git synced 2026-01-27 01:13:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Building QC or Timeout QC

Browse Source
This commit is contained in:
mjalalzai 2023-10-15 23:12:26 -07:00
parent 7c9992942b
commit 89c4960ead
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
carnot/carnot-vote-aggregation.py
View File

@ -357,16 +357,18 @@ class Carnot:
from typing import Optional, Set, List
def build_qc(self, view: int, block: Optional[Block] = None, new_views: Optional[Set[NewView]] = None,
# A committee member builds a QC or timeout QC with at least two-thirds of votes from its sub-branch within the overlay.
def build_qc(self, view: int, block: Optional[Block] = None, Timeouts: Optional[Set[Timeout]] = None,
votes: Optional[List[Vote]] = None) -> Qc:
if new_views:
if Timeout:
# Unhappy path: Aggregate QC
new_views_list = list(new_views)
highest_qc = max(new_views_list, key=lambda x: x.high_qc.view).high_qc
new_timeout_list = list(Timeouts)
highest_qc = max(new_timeout_list, key=lambda x: x.high_qc.view).high_qc
return AggregateQc(
qcs=[msg.high_qc.view for msg in new_views_list],
qcs=[msg.high_qc.view for msg in new_timeout_list],
highest_qc=highest_qc,
view=new_views_list[0].view
view=new_timeout_list[0].view
)
else:
# Happy path: Standard QC
@ -482,6 +484,8 @@ def receive_timeout_qc(self, timeout_qc: TimeoutQc):
# Optionally, rebuild the overlay from the timeout QC
# self.rebuild_overlay_from_timeout_qc(timeout_qc)
# The overlay can be built using a random seed for any random source.
# Here we assume the TimeoutQC is the seed.
def rebuild_overlay_from_timeout_qc(self, timeout_qc: TimeoutQc):
# Ensure the timeout QC view is greater than or equal to the current view
assert timeout_qc.view >= self.current_view, "Timeout QC view should be greater than or equal to current view"