diff options
Diffstat (limited to 'tests/perf-client/src/lib.rs')
| -rw-r--r-- | tests/perf-client/src/lib.rs | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/tests/perf-client/src/lib.rs b/tests/perf-client/src/lib.rs index a36147dbb..d709c7bd0 100644 --- a/tests/perf-client/src/lib.rs +++ b/tests/perf-client/src/lib.rs | |||
| @@ -30,6 +30,7 @@ pub async fn run<D: Driver>(stack: &Stack<D>, expected: Expected) { | |||
| 30 | } | 30 | } |
| 31 | 31 | ||
| 32 | const TEST_DURATION: usize = 10; | 32 | const TEST_DURATION: usize = 10; |
| 33 | const IO_BUFFER_SIZE: usize = 1024; | ||
| 33 | const RX_BUFFER_SIZE: usize = 4096; | 34 | const RX_BUFFER_SIZE: usize = 4096; |
| 34 | const TX_BUFFER_SIZE: usize = 4096; | 35 | const TX_BUFFER_SIZE: usize = 4096; |
| 35 | const SERVER_ADDRESS: Ipv4Address = Ipv4Address::new(192, 168, 2, 2); | 36 | const SERVER_ADDRESS: Ipv4Address = Ipv4Address::new(192, 168, 2, 2); |
| @@ -52,7 +53,7 @@ async fn test_download<D: Driver>(stack: &Stack<D>) -> usize { | |||
| 52 | } | 53 | } |
| 53 | info!("connected, testing..."); | 54 | info!("connected, testing..."); |
| 54 | 55 | ||
| 55 | let mut rx_buf = [0; 4096]; | 56 | let mut rx_buf = [0; IO_BUFFER_SIZE]; |
| 56 | let mut total: usize = 0; | 57 | let mut total: usize = 0; |
| 57 | with_timeout(Duration::from_secs(TEST_DURATION as _), async { | 58 | with_timeout(Duration::from_secs(TEST_DURATION as _), async { |
| 58 | loop { | 59 | loop { |
| @@ -92,7 +93,7 @@ async fn test_upload<D: Driver>(stack: &Stack<D>) -> usize { | |||
| 92 | } | 93 | } |
| 93 | info!("connected, testing..."); | 94 | info!("connected, testing..."); |
| 94 | 95 | ||
| 95 | let buf = [0; 4096]; | 96 | let buf = [0; IO_BUFFER_SIZE]; |
| 96 | let mut total: usize = 0; | 97 | let mut total: usize = 0; |
| 97 | with_timeout(Duration::from_secs(TEST_DURATION as _), async { | 98 | with_timeout(Duration::from_secs(TEST_DURATION as _), async { |
| 98 | loop { | 99 | loop { |
| @@ -134,8 +135,8 @@ async fn test_upload_download<D: Driver>(stack: &Stack<D>) -> usize { | |||
| 134 | 135 | ||
| 135 | let (mut reader, mut writer) = socket.split(); | 136 | let (mut reader, mut writer) = socket.split(); |
| 136 | 137 | ||
| 137 | let tx_buf = [0; 4096]; | 138 | let tx_buf = [0; IO_BUFFER_SIZE]; |
| 138 | let mut rx_buf = [0; 4096]; | 139 | let mut rx_buf = [0; IO_BUFFER_SIZE]; |
| 139 | let mut total: usize = 0; | 140 | let mut total: usize = 0; |
| 140 | let tx_fut = async { | 141 | let tx_fut = async { |
| 141 | loop { | 142 | loop { |
