Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

authority_aggregator: always request for events when asked #19251

Merged
merged 3 commits into from
Sep 6, 2024
Merged

authority_aggregator: always request for events when asked #19251

Changes from 1 commit
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
4af0261
authority_aggregator: always request for events when asked
bmwill Sep 6, 2024
7938859
m
bmwill Sep 6, 2024
2b4c9d7
m
bmwill Sep 6, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 11 additions & 2 deletions crates/sui-core/src/authority_aggregator.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -454,6 +454,7 @@ struct ProcessCertificateState {
input_objects: Option<Vec<Object>>,
output_objects: Option<Vec<Object>>,
auxiliary_data: Option<Vec<u8>>,
request: HandleCertificateRequestV3,
}

#[derive(Debug)]
Expand Down Expand Up @@ -1497,13 +1498,14 @@ where
input_objects: None,
output_objects: None,
auxiliary_data: None,
request: request.clone(),
};

// create a set of validators that we should sample to request input/output objects from
let validators_to_sample =
if request.include_input_objects || request.include_output_objects {
// Number of validators to request input/output objects from
const NUMBER_TO_SAMPLE: usize = 5;
const NUMBER_TO_SAMPLE: usize = 10;

self.committee
.choose_multiple_weighted_iter(NUMBER_TO_SAMPLE)
Expand Down Expand Up @@ -1547,7 +1549,6 @@ where
request_ref
} else {
HandleCertificateRequestV3 {
include_events: false,
include_input_objects: false,
include_output_objects: false,
include_auxiliary_data: false,
Expand Down Expand Up @@ -1758,6 +1759,14 @@ where
signed_effects.into_data(),
cert_sig,
);

if (state.request.include_input_objects && state.input_objects.is_none())
|| (state.request.include_output_objects
&& state.output_objects.is_none())
{
debug!(?tx_digest, "Quorum Reached but requested input/output objects were not returned");
}

ct.verify(&committee).map(|ct| {
debug!(?tx_digest, "Got quorum for validators handle_certificate.");
Some(QuorumDriverResponse {
Expand Down
Loading