Apply feedback from @aeyakovenko

This commit is contained in:
Greg Fitzgerald
2018-06-15 15:27:06 -06:00
committed by Greg Fitzgerald
parent 22885c3e64
commit 327ee1dae8
2 changed files with 24 additions and 24 deletions

View File

@ -15,14 +15,14 @@ pub struct ReplicateStage {
}
impl ReplicateStage {
/// Process verified blobs, already in order
/// Process entry blobs, already in order
fn replicate_requests(
bank: &Arc<Bank>,
verified_receiver: &streamer::BlobReceiver,
blob_receiver: &streamer::BlobReceiver,
blob_recycler: &packet::BlobRecycler,
) -> Result<()> {
let timer = Duration::new(1, 0);
let blobs = verified_receiver.recv_timeout(timer)?;
let blobs = blob_receiver.recv_timeout(timer)?;
let entries = ledger::reconstruct_entries_from_blobs(&blobs);
let res = bank.process_entries(entries);
if res.is_err() {

View File

@ -2,27 +2,27 @@
//! 3-stage transaction validation pipeline in software.
//!
//! ```text
//! .----------------------------------------.
//! | TVU |
//! | |
//! | |
//! | |
//! | |
//! | .-------. .--------. .-----------. |
//! .--------. | | Blob | | Window | | Replicate | | .------------.
//! | Leader |--->| Fetch |->| Stage |->| Stage |---->| Validators |
//! `--------` | | Stage | | | | | | `------------`
//! | `-------` `----+---` `----+------` |
//! | | | |
//! | | | |
//! | | | |
//! | | | |
//! `------------------|-----------|---------`
//! | |
//! v v
//! .--------. .------.
//! | Window | | Bank |
//! `--------` `------`
//! .------------------------------------------.
//! | TVU |
//! | |
//! | | .------------.
//! | .------------------------>| Validators |
//! | .-------. | | `------------`
//! .--------. | | | .----+---. .-----------. |
//! | Leader |--------->| Blob | | Window | | Replicate | |
//! `--------` | | Fetch |-->| Stage |-->| Stage | |
//! .------------. | | Stage | | | | | |
//! | Validators |----->| | `--------` `----+------` |
//! `------------` | `-------` | |
//! | | |
//! | | |
//! | | |
//! `--------------------------------|---------`
//! |
//! v
//! .------.
//! | Bank |
//! `------`
//! ```
//
// TODO: @aeyakovenko, these comments no longer refect the code in this module: