Skip to content

Commit a10fa0e

Browse files
committed
Deduplicate HandleChainInfo queries.
1 parent 930189d commit a10fa0e

File tree

4 files changed

+1392
-7
lines changed

4 files changed

+1392
-7
lines changed

linera-core/src/client/mod.rs

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -884,7 +884,10 @@ impl<Env: Environment> Client<Env> {
884884
loop {
885885
trace!("get_received_log_from_validator: looping");
886886
let query = ChainInfoQuery::new(chain_id).with_received_log_excluding_first_n(offset);
887-
let info = remote_node.handle_chain_info_query(query).await?;
887+
let info = self
888+
.requests_scheduler
889+
.handle_chain_info_query(remote_node, query)
890+
.await?;
888891
let received_entries = info.requested_received_log.len();
889892
offset += received_entries as u64;
890893
remote_log.extend(info.requested_received_log);
@@ -1070,7 +1073,10 @@ impl<Env: Environment> Client<Env> {
10701073
) -> Result<(), ChainClientError> {
10711074
let mut local_info = self.local_node.chain_info(chain_id).await?;
10721075
let query = ChainInfoQuery::new(chain_id).with_manager_values();
1073-
let remote_info = remote_node.handle_chain_info_query(query).await?;
1076+
let remote_info = self
1077+
.requests_scheduler
1078+
.handle_chain_info_query(remote_node, query)
1079+
.await?;
10741080
if let Some(new_info) = self
10751081
.download_certificates_from(remote_node, chain_id, remote_info.next_block_height)
10761082
.await?

0 commit comments

Comments
 (0)