YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-01 10:15:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

http load test: add config fields num connections, creation interval

Browse source 
Also update defaults
This commit is contained in:
Joakim Frostegård 2020-08-01 23:17:24 +02:00
parent 7d4b1ab610
commit aa0094164a
2 changed files with 9 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

9
aquatic_http_load_test/src/network.rs
View file

@ -175,18 +175,15 @@ impl Connection {
pub type ConnectionMap = Slab<Connection>;
const NUM_CONNECTIONS: usize = 128;
const CREATE_CONN_INTERVAL: usize = 2 ^ 18;
pub fn run_socket_thread(
config: &Config,
state: LoadTestState,
num_initial_requests: usize,
) {
let timeout = Duration::from_micros(config.network.poll_timeout_microseconds);
let create_conn_interval = 2 ^ config.network.connection_creation_interval;
let mut connections: ConnectionMap = Slab::with_capacity(NUM_CONNECTIONS);
let mut connections: ConnectionMap = Slab::with_capacity(config.num_connections);
let mut poll = Poll::new().expect("create poll");
let mut events = Events::with_capacity(config.network.poll_event_capacity);
let mut rng = SmallRng::from_entropy();
@ -244,7 +241,7 @@ pub fn run_socket_thread(
}
// Slowly create new connections
if token_counter < NUM_CONNECTIONS && iter_counter % CREATE_CONN_INTERVAL == 0 {
if token_counter < config.num_connections && iter_counter % create_conn_interval == 0 {
Connection::create_and_register(
config,
&mut connections,