gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

BlobFetchStage cleanup post shred work (#6254)

Browse Source
This commit is contained in:
Pankaj Garg
2019-10-07 11:08:01 -07:00
committed by GitHub
parent 6662986169
commit 17f169f446
4 changed files with 12 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/replicator.rs
View File

@@ -1,4 +1,3 @@
use crate::blob_fetch_stage::BlobFetchStage;
use crate::blocktree::Blocktree;
use crate::chacha::{chacha_cbc_encrypt_ledger, CHACHA_BLOCK_SIZE};
use crate::cluster_info::{ClusterInfo, Node, FULLNODE_PORT_RANGE};
@@ -12,6 +11,7 @@ use crate::repair_service::{RepairService, RepairSlotRange, RepairStrategy};
use crate::result::{Error, Result};
use crate::service::Service;
use crate::shred::Shred;
use crate::shred_fetch_stage::ShredFetchStage;
use crate::storage_stage::NUM_STORAGE_SAMPLES;
use crate::streamer::{receiver, responder, PacketReceiver};
use crate::window_service::WindowService;
@@ -263,7 +263,7 @@ impl Replicator {
.map(Arc::new)
.collect();
let (blob_fetch_sender, blob_fetch_receiver) = channel();
let fetch_stage = BlobFetchStage::new_multi_socket_packet(
let fetch_stage = ShredFetchStage::new_multi_socket(
blob_sockets,
blob_forward_sockets,
&blob_fetch_sender,