move bank.process_entries() to firsties
This commit is contained in:
parent
9fabd34156
commit
637d403415
|
@ -41,6 +41,8 @@ impl ReplicateStage {
|
||||||
}
|
}
|
||||||
let entries = reconstruct_entries_from_blobs(blobs.clone())?;
|
let entries = reconstruct_entries_from_blobs(blobs.clone())?;
|
||||||
|
|
||||||
|
let res = bank.process_entries(entries.clone());
|
||||||
|
|
||||||
while let Some(blob) = blobs.pop_front() {
|
while let Some(blob) = blobs.pop_front() {
|
||||||
blob_recycler.recycle(blob);
|
blob_recycler.recycle(blob);
|
||||||
}
|
}
|
||||||
|
@ -56,8 +58,6 @@ impl ReplicateStage {
|
||||||
entries.iter().map(|x| x.transactions.len()).sum()
|
entries.iter().map(|x| x.transactions.len()).sum()
|
||||||
);
|
);
|
||||||
|
|
||||||
let res = bank.process_entries(entries.clone());
|
|
||||||
|
|
||||||
// TODO: move this to another stage?
|
// TODO: move this to another stage?
|
||||||
if let Some(ledger_writer) = ledger_writer {
|
if let Some(ledger_writer) = ledger_writer {
|
||||||
ledger_writer.write_entries(entries)?;
|
ledger_writer.write_entries(entries)?;
|
||||||
|
|
Loading…
Reference in New Issue