Trust the recorder not to give us more than we can serialize
Also run client for 10 seconds, 5 is bit too short
This commit is contained in:
parent
5ad6061c3f
commit
3e73fb9233
|
@ -160,10 +160,9 @@ impl AccountantSkel {
|
||||||
// See that we made progress and a single
|
// See that we made progress and a single
|
||||||
// vec of Events wasn't too big for a single packet
|
// vec of Events wasn't too big for a single packet
|
||||||
if end <= start {
|
if end <= start {
|
||||||
eprintln!("Event too big for the blob!");
|
// Trust the recorder to not package more than we can
|
||||||
start += 1;
|
// serialize
|
||||||
end = start;
|
end += 1;
|
||||||
continue;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
let b = blob_recycler.allocate();
|
let b = blob_recycler.allocate();
|
||||||
|
|
|
@ -137,7 +137,7 @@ fn main() {
|
||||||
|
|
||||||
println!("Waiting for transactions to complete...",);
|
println!("Waiting for transactions to complete...",);
|
||||||
let mut tx_count;
|
let mut tx_count;
|
||||||
for _ in 0..5 {
|
for _ in 0..10 {
|
||||||
tx_count = acc.transaction_count();
|
tx_count = acc.transaction_count();
|
||||||
duration = now.elapsed();
|
duration = now.elapsed();
|
||||||
let txs = tx_count - initial_tx_count;
|
let txs = tx_count - initial_tx_count;
|
||||||
|
|
Loading…
Reference in New Issue