Skip to content

Commit ca5d3b0

Browse files
authored
chore(tree): make on_engine_message more concise (paradigmxyz#10605)
1 parent 4227055 commit ca5d3b0

File tree

1 file changed

+1
-7
lines changed
  • crates/engine/tree/src/tree

1 file changed

+1
-7
lines changed

crates/engine/tree/src/tree/mod.rs

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -919,18 +919,15 @@ where
919919
FromOrchestrator::BackfillSyncStarted => {
920920
debug!(target: "consensus::engine", "received backfill sync started event");
921921
self.backfill_sync_state = BackfillSyncState::Active;
922-
Ok(())
923922
}
924923
FromOrchestrator::BackfillSyncFinished(ctrl) => {
925924
self.on_backfill_sync_finished(ctrl)?;
926-
Ok(())
927925
}
928926
},
929927
FromEngine::Request(request) => {
930928
match request {
931929
EngineApiRequest::InsertExecutedBlock(block) => {
932930
self.state.tree_state.insert_executed(block);
933-
Ok(())
934931
}
935932
EngineApiRequest::Beacon(request) => {
936933
match request {
@@ -958,7 +955,6 @@ where
958955
{
959956
error!("Failed to send event: {err:?}");
960957
}
961-
Ok(())
962958
}
963959
BeaconEngineMessage::NewPayload { payload, cancun_fields, tx } => {
964960
let output = self.on_new_payload(payload, cancun_fields);
@@ -969,14 +965,12 @@ where
969965
})) {
970966
error!("Failed to send event: {err:?}");
971967
}
972-
Ok(())
973968
}
974969
BeaconEngineMessage::TransitionConfigurationExchanged => {
975970
// triggering this hook will record that we received a request from
976971
// the CL
977972
self.canonical_in_memory_state
978973
.on_transition_configuration_exchanged();
979-
Ok(())
980974
}
981975
}
982976
}
@@ -986,9 +980,9 @@ where
986980
if let Some(event) = self.on_downloaded(blocks)? {
987981
self.on_tree_event(event);
988982
}
989-
Ok(())
990983
}
991984
}
985+
Ok(())
992986
}
993987

994988
/// Invoked if the backfill sync has finished to target.

0 commit comments

Comments
 (0)