We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent df48149 commit 78971c1Copy full SHA for 78971c1
monoio/src/driver/op/recv.rs
@@ -114,7 +114,7 @@ impl<T: IoBufMut> OpAble for Recv<T> {
114
recv(
115
fd as _,
116
self.buf.write_ptr(),
117
- self.buf.bytes_total() as _,
+ self.buf.bytes_total().min(i32::MAX as usize) as _,
118
0
119
),
120
PartialOrd::lt,
monoio/src/driver/shared_fd.rs
@@ -495,7 +495,7 @@ impl Inner {
495
}
496
UringState::Waiting(Some(waker)) => {
497
if !waker.will_wake(cx.waker()) {
498
- *waker = cx.waker().clone();
+ waker.clone_from(cx.waker());
499
500
501
Poll::Pending
0 commit comments