Skip to content

Commit 566addf

Browse files
committed
fix: as_io_slices[_mut] -> io_slices[_mut]
1 parent bf327fe commit 566addf

File tree

2 files changed

+10
-10
lines changed

2 files changed

+10
-10
lines changed

compio-driver/src/iocp/op.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -448,7 +448,7 @@ impl<T: IoVectoredBufMut, S> IntoInner for RecvVectored<T, S> {
448448
impl<T: IoVectoredBufMut, S: AsRawFd> OpCode for RecvVectored<T, S> {
449449
unsafe fn operate(self: Pin<&mut Self>, optr: *mut OVERLAPPED) -> Poll<io::Result<usize>> {
450450
let fd = self.fd.as_raw_fd();
451-
let slices = self.get_unchecked_mut().buffer.as_io_slices_mut();
451+
let slices = self.get_unchecked_mut().buffer.io_slices_mut();
452452
let mut flags = 0;
453453
let mut received = 0;
454454
let res = WSARecv(
@@ -541,7 +541,7 @@ impl<T: IoVectoredBuf, S> IntoInner for SendVectored<T, S> {
541541

542542
impl<T: IoVectoredBuf, S: AsRawFd> OpCode for SendVectored<T, S> {
543543
unsafe fn operate(self: Pin<&mut Self>, optr: *mut OVERLAPPED) -> Poll<io::Result<usize>> {
544-
let slices = self.buffer.as_io_slices();
544+
let slices = self.buffer.io_slices();
545545
let mut sent = 0;
546546
let res = WSASend(
547547
self.fd.as_raw_fd() as _,
@@ -650,7 +650,7 @@ impl<T: IoVectoredBufMut, S: AsRawFd> OpCode for RecvFromVectored<T, S> {
650650
unsafe fn operate(self: Pin<&mut Self>, optr: *mut OVERLAPPED) -> Poll<io::Result<usize>> {
651651
let this = self.get_unchecked_mut();
652652
let fd = this.fd.as_raw_fd();
653-
let buffer = this.buffer.as_io_slices_mut();
653+
let buffer = this.buffer.io_slices_mut();
654654
let mut flags = 0;
655655
let mut received = 0;
656656
let res = WSARecvFrom(
@@ -753,7 +753,7 @@ impl<T: IoVectoredBuf, S> IntoInner for SendToVectored<T, S> {
753753

754754
impl<T: IoVectoredBuf, S: AsRawFd> OpCode for SendToVectored<T, S> {
755755
unsafe fn operate(self: Pin<&mut Self>, optr: *mut OVERLAPPED) -> Poll<io::Result<usize>> {
756-
let buffer = self.buffer.as_io_slices();
756+
let buffer = self.buffer.io_slices();
757757
let mut sent = 0;
758758
let res = WSASendTo(
759759
self.fd.as_raw_fd() as _,

compio-driver/src/iour/op.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ impl<T: IoBufMut, S: AsRawFd> OpCode for ReadAt<T, S> {
148148
impl<T: IoVectoredBufMut, S: AsRawFd> OpCode for ReadVectoredAt<T, S> {
149149
fn create_entry(self: Pin<&mut Self>) -> OpEntry {
150150
let this = unsafe { self.get_unchecked_mut() };
151-
this.slices = unsafe { this.buffer.as_io_slices_mut() };
151+
this.slices = unsafe { this.buffer.io_slices_mut() };
152152
opcode::Readv::new(
153153
Fd(this.fd.as_raw_fd()),
154154
this.slices.as_ptr() as _,
@@ -173,7 +173,7 @@ impl<T: IoBuf, S: AsRawFd> OpCode for WriteAt<T, S> {
173173
impl<T: IoVectoredBuf, S: AsRawFd> OpCode for WriteVectoredAt<T, S> {
174174
fn create_entry(self: Pin<&mut Self>) -> OpEntry {
175175
let this = unsafe { self.get_unchecked_mut() };
176-
this.slices = unsafe { this.buffer.as_io_slices() };
176+
this.slices = unsafe { this.buffer.io_slices() };
177177
opcode::Writev::new(
178178
Fd(this.fd.as_raw_fd()),
179179
this.slices.as_ptr() as _,
@@ -318,7 +318,7 @@ impl<T: IoBufMut, S: AsRawFd> OpCode for Recv<T, S> {
318318
impl<T: IoVectoredBufMut, S: AsRawFd> OpCode for RecvVectored<T, S> {
319319
fn create_entry(self: Pin<&mut Self>) -> OpEntry {
320320
let this = unsafe { self.get_unchecked_mut() };
321-
this.slices = unsafe { this.buffer.as_io_slices_mut() };
321+
this.slices = unsafe { this.buffer.io_slices_mut() };
322322
opcode::Readv::new(
323323
Fd(this.fd.as_raw_fd()),
324324
this.slices.as_ptr() as _,
@@ -341,7 +341,7 @@ impl<T: IoBuf, S: AsRawFd> OpCode for Send<T, S> {
341341
impl<T: IoVectoredBuf, S: AsRawFd> OpCode for SendVectored<T, S> {
342342
fn create_entry(self: Pin<&mut Self>) -> OpEntry {
343343
let this = unsafe { self.get_unchecked_mut() };
344-
this.slices = unsafe { this.buffer.as_io_slices() };
344+
this.slices = unsafe { this.buffer.io_slices() };
345345
opcode::Writev::new(
346346
Fd(this.fd.as_raw_fd()),
347347
this.slices.as_ptr() as _,
@@ -443,7 +443,7 @@ impl<T: IoVectoredBufMut, S> RecvFromVectored<T, S> {
443443
impl<T: IoVectoredBufMut, S: AsRawFd> OpCode for RecvFromVectored<T, S> {
444444
fn create_entry(self: Pin<&mut Self>) -> OpEntry {
445445
let this = unsafe { self.get_unchecked_mut() };
446-
this.slice = unsafe { this.buffer.as_io_slices_mut() };
446+
this.slice = unsafe { this.buffer.io_slices_mut() };
447447
this.header.create_entry(&mut this.slice)
448448
}
449449
}
@@ -543,7 +543,7 @@ impl<T: IoVectoredBuf, S> SendToVectored<T, S> {
543543
impl<T: IoVectoredBuf, S: AsRawFd> OpCode for SendToVectored<T, S> {
544544
fn create_entry(self: Pin<&mut Self>) -> OpEntry {
545545
let this = unsafe { self.get_unchecked_mut() };
546-
this.slice = unsafe { this.buffer.as_io_slices() };
546+
this.slice = unsafe { this.buffer.io_slices() };
547547
this.header.create_entry(&mut this.slice)
548548
}
549549
}

0 commit comments

Comments
 (0)