Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Distributed bench #1661

Merged
merged 24 commits into from
May 3, 2022
Merged

Distributed bench #1661

Changes from 1 commit
Commits
Show all changes
24 commits
Select commit Hold shift + click to select a range
3d49479
Remote benchmarking
oxade Apr 27, 2022
9272783
Merge branch 'main' of https://github.com/MystenLabs/fastnft
oxade Apr 27, 2022
1e0b423
use u64 max gas
oxade Apr 27, 2022
5f6aaf6
use u64 max gas
oxade Apr 27, 2022
aa01684
Remove prints
oxade Apr 27, 2022
0992526
SImpler genesis
oxade Apr 27, 2022
664f5ac
Fix out of order bug
oxade Apr 27, 2022
43e4e45
Not fail on disconnecr
oxade Apr 27, 2022
d2d4b84
improve genesis objectload
oxade Apr 28, 2022
2251d0a
Error expl
oxade Apr 28, 2022
43f08fb
simplify print
oxade Apr 29, 2022
76e4633
authority fix
oxade Apr 29, 2022
ef64273
Revert error
oxade May 2, 2022
a70ca6b
Sync to main
oxade May 2, 2022
49b40c0
Synced to main
oxade May 2, 2022
fb8e429
Sync to main
oxade May 2, 2022
28c71d1
Update to main
oxade May 3, 2022
610833b
Update to main
oxade May 3, 2022
7b7edc8
Merge branch 'main' of https://github.com/MystenLabs/fastnft
oxade May 3, 2022
f99e1b5
Merge branch 'main' into distributed_bench
oxade May 3, 2022
c67b42b
Synced to main
oxade May 3, 2022
a35f59d
license
oxade May 3, 2022
009eb7f
fix test
oxade May 3, 2022
9e110b7
Code cleanup
oxade May 3, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Remove prints
  • Loading branch information
@oxade
oxade committed Apr 27, 2022
commit aa01684584bb384cf7efb3fdd0fc8587459fdf7e
5 changes: 0 additions & 5 deletions sui/src/benchmark/multi_load_generator.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,6 @@ async fn send_tx_for_quorum(

tokio::spawn(async move {
send_tx_chunks_notif(notif, chunk, &mut ch_tx, net_client.clone(), stake, conn).await;
println!("Spawn for order {:?} with stake {}", net_client, stake);
});
}
drop(order_chann_tx);
Expand Down Expand Up @@ -128,7 +127,6 @@ async fn send_tx_for_quorum(
panic!("Quorum threshold not reached for orders")
}

println!("order {}", total);
// Confirmation step
let (conf_chann_tx, mut conf_chann_rx) = MpscChannel(net_clients.len() * 2);

Expand All @@ -139,7 +137,6 @@ async fn send_tx_for_quorum(
let mut chann_tx = conf_chann_tx.clone();
handles.push(tokio::spawn(async move {
let r = send_tx_chunks(chunk, net_client.clone(), conn).await;
println!("Spawn for conf {:?} with stake {}", net_client, stake);
match chann_tx.send((r.0, stake)).await {
Ok(_) => (),
Err(e) => {
Expand Down Expand Up @@ -174,8 +171,6 @@ async fn send_tx_for_quorum(
panic!("Quorum threshold not reached for confirmation")
}

println!("conf {}", total);

let elapsed = time_start.elapsed().as_micros();

// Send the total time over
Expand Down