aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-06 01:34:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

use removed cb to complete copletion

Browse Source
This commit is contained in:
Ihor Andrianov
2025-07-09 17:16:22 +03:00
parent 2d41791f3d
commit 1100312354
1 changed files with 14 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
core/io/unix.rs
View File

@@ -258,14 +258,22 @@ impl IO for UnixIO {
};
match result {
Ok(n) => {
self.callbacks.remove(event.key);
match &cf {
CompletionCallback::Read(_, ref c, _) => c.complete(0),
CompletionCallback::Write(_, ref c, _, _) => c.complete(n as i32),
let cf = self
.callbacks
.remove(event.key)
.expect("callback should exist");
match cf {
CompletionCallback::Read(_, c, _) => c.complete(0),
CompletionCallback::Write(_, c, _, _) => c.complete(n as i32),
}
}
Err(Errno::AGAIN) => {}
Err(e) => return Err(e.into()),
Err(Errno::AGAIN) => (),
Err(e) => {
self.callbacks.remove(event.key);
trace!("run_once() error: {}", e);
return Err(e.into());
}
}
}
}