Skip to content

Commit ad9c02b

Browse files
committed
basic support IOCP Operator
1 parent 0525d65 commit ad9c02b

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

core/src/net/operator/windows/mod.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,7 @@ impl<'o> Operator<'o> {
119119
result
120120
}
121121

122+
#[allow(clippy::cast_ptr_alignment)]
122123
fn do_select(
123124
&self,
124125
timeout: Option<Duration>,

core/src/net/operator/windows/tests.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ fn crate_server2(port: u16, server_started: Arc<AtomicBool>) -> anyhow::Result<(
104104
}
105105
Token::Read { fd, buf_index } => {
106106
println!("server received");
107-
let ret = cqe.bytes_transferred as _;
107+
let ret = cqe.result as _;
108108
if ret == 0 {
109109
bufpool.push(buf_index);
110110
_ = token_alloc.remove(token_index);
@@ -131,7 +131,7 @@ fn crate_server2(port: u16, server_started: Arc<AtomicBool>) -> anyhow::Result<(
131131
len,
132132
} => {
133133
println!("server sent");
134-
let write_len = cqe.bytes_transferred as usize;
134+
let write_len = cqe.result as usize;
135135
if offset + write_len >= len {
136136
bufpool.push(buf_index);
137137
let (buf_index, buf) = match bufpool.pop() {

0 commit comments

Comments
 (0)