mirror of
https://github.com/tokio-rs/tokio.git
synced 2026-08-07 00:00:09 +02:00
refactor: fix variable name typos (#8267)
This commit is contained in:
+4
-4
@@ -73,7 +73,7 @@ impl SlowHddWriter {
|
||||
fn write_bytes(
|
||||
mut self: std::pin::Pin<&mut Self>,
|
||||
cx: &mut std::task::Context<'_>,
|
||||
writeable: usize,
|
||||
writable: usize,
|
||||
) -> std::task::Poll<Result<usize, std::io::Error>> {
|
||||
let service_res = self.as_mut().service_write(cx);
|
||||
|
||||
@@ -86,7 +86,7 @@ impl SlowHddWriter {
|
||||
assert!(service_res.is_pending());
|
||||
Poll::Pending
|
||||
} else {
|
||||
let written = available.min(writeable);
|
||||
let written = available.min(writable);
|
||||
self.buffer_used += written;
|
||||
Poll::Ready(Ok(written))
|
||||
}
|
||||
@@ -123,8 +123,8 @@ impl AsyncWrite for SlowHddWriter {
|
||||
cx: &mut std::task::Context<'_>,
|
||||
bufs: &[std::io::IoSlice<'_>],
|
||||
) -> std::task::Poll<Result<usize, std::io::Error>> {
|
||||
let writeable = bufs.iter().fold(0, |acc, buf| acc + buf.len());
|
||||
self.write_bytes(cx, writeable)
|
||||
let writable = bufs.iter().fold(0, |acc, buf| acc + buf.len());
|
||||
self.write_bytes(cx, writable)
|
||||
}
|
||||
|
||||
fn is_write_vectored(&self) -> bool {
|
||||
|
||||
@@ -148,7 +148,7 @@ fn advance_slices<'a>(bufs: &mut &mut [IoSlice<'a>], n: usize) {
|
||||
*bufs = &mut std::mem::take(bufs)[remove..];
|
||||
if let Some(first) = bufs.first_mut() {
|
||||
let buf = &first[left..];
|
||||
// necessary due to limitating in the borrow checker,
|
||||
// Necessary due to a limitation in the borrow checker,
|
||||
// when tokio MSRV reaches 1.81.0 this entire function
|
||||
// can be replaced with `IoSlice::advance_slices`
|
||||
//
|
||||
|
||||
@@ -700,7 +700,7 @@ fn wake_deferred_tasks_before_block_in_place() {
|
||||
let (tx2, rx2) = oneshot::channel::<()>();
|
||||
|
||||
let deferred_task = tokio_test::task::spawn(tokio::task::yield_now());
|
||||
let deffered_task = Arc::new(Mutex::new(deferred_task));
|
||||
let deferred_task = Arc::new(Mutex::new(deferred_task));
|
||||
|
||||
let rt = runtime::Builder::new_multi_thread()
|
||||
.worker_threads(1)
|
||||
@@ -708,7 +708,7 @@ fn wake_deferred_tasks_before_block_in_place() {
|
||||
.unwrap();
|
||||
|
||||
let jh = {
|
||||
let deferred_task = Arc::clone(&deffered_task);
|
||||
let deferred_task = Arc::clone(&deferred_task);
|
||||
rt.spawn(async move {
|
||||
{
|
||||
let mut lock = deferred_task.lock().unwrap();
|
||||
@@ -728,7 +728,7 @@ fn wake_deferred_tasks_before_block_in_place() {
|
||||
|
||||
// check that the deferred task was woken before the `block_in_place` ends
|
||||
let is_woken = {
|
||||
let lock = deffered_task.lock().unwrap();
|
||||
let lock = deferred_task.lock().unwrap();
|
||||
lock.is_woken()
|
||||
};
|
||||
|
||||
|
||||
Reference in New Issue
Block a user