itsscb/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2025-09-28 12:10:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: fix new clippy lint (#2631)

Browse Source
This commit is contained in:
João Oliveira 2020-06-25 16:32:16 +01:00 committed by GitHub
parent f75e5a7ef4
commit f0b2b708a7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 26 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
tokio/tests/fs_file_mocked.rs
View File

@ -257,27 +257,27 @@ fn flush_while_idle() {
#[test] #[test]
fn read_with_buffer_larger_than_max() { fn read_with_buffer_larger_than_max() {
// Chunks // Chunks
let a = 16 * 1024; let chunk_a = 16 * 1024;
let b = a * 2; let chunk_b = chunk_a * 2;
let c = a * 3; let chunk_c = chunk_a * 3;
let d = a * 4; let chunk_d = chunk_a * 4;
assert_eq!(d / 1024, 64); assert_eq!(chunk_d / 1024, 64);
let mut data = vec![]; let mut data = vec![];
for i in 0..(d - 1) { for i in 0..(chunk_d - 1) {
data.push((i % 151) as u8); data.push((i % 151) as u8);
} }
let (mock, file) = sys::File::mock(); let (mock, file) = sys::File::mock();
mock.read(&data[0..a]) mock.read(&data[0..chunk_a])
.read(&data[a..b]) .read(&data[chunk_a..chunk_b])
.read(&data[b..c]) .read(&data[chunk_b..chunk_c])
.read(&data[c..]); .read(&data[chunk_c..]);
let mut file = File::from_std(file); let mut file = File::from_std(file);
let mut actual = vec![0; d]; let mut actual = vec![0; chunk_d];
let mut pos = 0; let mut pos = 0;
while pos < data.len() { while pos < data.len() {
@ -288,7 +288,7 @@ fn read_with_buffer_larger_than_max() {
assert!(t.is_woken()); assert!(t.is_woken());
let n = assert_ready_ok!(t.poll()); let n = assert_ready_ok!(t.poll());
assert!(n <= a); assert!(n <= chunk_a);
pos += n; pos += n;
} }
@ -300,23 +300,23 @@ fn read_with_buffer_larger_than_max() {
#[test] #[test]
fn write_with_buffer_larger_than_max() { fn write_with_buffer_larger_than_max() {
// Chunks // Chunks
let a = 16 * 1024; let chunk_a = 16 * 1024;
let b = a * 2; let chunk_b = chunk_a * 2;
let c = a * 3; let chunk_c = chunk_a * 3;
let d = a * 4; let chunk_d = chunk_a * 4;
assert_eq!(d / 1024, 64); assert_eq!(chunk_d / 1024, 64);
let mut data = vec![]; let mut data = vec![];
for i in 0..(d - 1) { for i in 0..(chunk_d - 1) {
data.push((i % 151) as u8); data.push((i % 151) as u8);
} }
let (mock, file) = sys::File::mock(); let (mock, file) = sys::File::mock();
mock.write(&data[0..a]) mock.write(&data[0..chunk_a])
.write(&data[a..b]) .write(&data[chunk_a..chunk_b])
.write(&data[b..c]) .write(&data[chunk_b..chunk_c])
.write(&data[c..]); .write(&data[chunk_c..]);
let mut file = File::from_std(file); let mut file = File::from_std(file);
@ -325,17 +325,17 @@ fn write_with_buffer_larger_than_max() {
let mut first = true; let mut first = true;
while !rem.is_empty() { while !rem.is_empty() {
let mut t = task::spawn(file.write(rem)); let mut task = task::spawn(file.write(rem));
if !first { if !first {
assert_pending!(t.poll()); assert_pending!(task.poll());
pool::run_one(); pool::run_one();
assert!(t.is_woken()); assert!(task.is_woken());
} }
first = false; first = false;
let n = assert_ready_ok!(t.poll()); let n = assert_ready_ok!(task.poll());
rem = &rem[n..]; rem = &rem[n..];
} }