parent
e210e76bd5
commit
3313b2ff58
|
@ -61,6 +61,10 @@ impl FetchStage {
|
||||||
while let Ok(more) = recvr.try_recv() {
|
while let Ok(more) = recvr.try_recv() {
|
||||||
len += more.packets.len();
|
len += more.packets.len();
|
||||||
batch.push(more);
|
batch.push(more);
|
||||||
|
// Read at most 1K transactions in a loop
|
||||||
|
if len > 1024 {
|
||||||
|
break;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if poh_recorder.lock().unwrap().would_be_leader(
|
if poh_recorder.lock().unwrap().would_be_leader(
|
||||||
|
|
Loading…
Reference in New Issue