Resolve some TODOs

This commit is contained in:
dapplion
2025-05-22 01:06:57 -05:00
parent 4fb2ae658a
commit 801659d4ae
3 changed files with 2 additions and 8 deletions

View File

@@ -191,7 +191,6 @@ impl<T: BeaconChainTypes> BlockComponentsByRangeRequest<T> {
blocks_by_range_request,
} => {
if let Some((blocks, block_peer)) = blocks_by_range_request.to_finished() {
// TODO(das): use the peer group
let peer_group = BatchPeers::new_from_block_peer(*block_peer);
let rpc_blocks = couple_blocks_base(
blocks.to_vec(),
@@ -226,7 +225,6 @@ impl<T: BeaconChainTypes> BlockComponentsByRangeRequest<T> {
blocks_by_range_request,
} => {
if let Some((blocks, block_peer)) = blocks_by_range_request.to_finished() {
// TODO(das): use the peer group
let blocks_with_data = blocks
.iter()
.filter(|block| block.has_data())

View File

@@ -425,8 +425,7 @@ impl<T: BeaconChainTypes> ActiveCustodyByRangeRequest<T> {
// - Add a new peer that custodies the missing columns
// - Call `continue_requests`
//
// Otherwise this request should be dropped and failed after some time.
// TODO(das): implement the above
// Otherwise this request will be dropped and failed after some time.
}
}
}

View File

@@ -249,7 +249,6 @@ impl<T: BeaconChainTypes> ActiveCustodyByRootRequest<T> {
let active_request_count_by_peer = cx.active_request_count_by_peer();
let mut columns_to_request_by_peer = HashMap::<PeerId, Vec<ColumnIndex>>::new();
let lookup_peers = self.lookup_peers.read();
let mut indices_without_peers = vec![];
// Need to:
// - track how many active requests a peer has for load balancing
@@ -304,9 +303,7 @@ impl<T: BeaconChainTypes> ActiveCustodyByRootRequest<T> {
// - Add a new peer that custodies the missing columns
// - Call `continue_requests`
//
// Otherwise this request should be dropped and failed after some time.
// TODO(das): implement the above
indices_without_peers.push(column_index);
// Otherwise this request will be dropped and failed after some time.
}
}
}