Skip to content

Commit cf47b66

Browse files
committed
Deduplicate HandleChainInfo queries.
1 parent 1fcaeec commit cf47b66

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
@@ -883,7 +883,10 @@ impl<Env: Environment> Client<Env> {
883883
loop {
884884
trace!("get_received_log_from_validator: looping");
885885
let query = ChainInfoQuery::new(chain_id).with_received_log_excluding_first_n(offset);
886-
let info = remote_node.handle_chain_info_query(query).await?;
886+
let info = self
887+
.requests_scheduler
888+
.handle_chain_info_query(remote_node, query)
889+
.await?;
887890
let received_entries = info.requested_received_log.len();
888891
offset += received_entries as u64;
889892
remote_log.extend(info.requested_received_log);
@@ -1069,7 +1072,10 @@ impl<Env: Environment> Client<Env> {
10691072
) -> Result<(), ChainClientError> {
10701073
let mut local_info = self.local_node.chain_info(chain_id).await?;
10711074
let query = ChainInfoQuery::new(chain_id).with_manager_values();
1072-
let remote_info = remote_node.handle_chain_info_query(query).await?;
1075+
let remote_info = self
1076+
.requests_scheduler
1077+
.handle_chain_info_query(remote_node, query)
1078+
.await?;
10731079
if let Some(new_info) = self
10741080
.download_certificates_from(remote_node, chain_id, remote_info.next_block_height)
10751081
.await?

0 commit comments

Comments
 (0)