Update nix requirement from 0.29 to 0.30

Author: loongs-zhang

Cargo.toml

@@ -39,7 +39,7 @@ corosensei = "0.2"
 core_affinity = "0.8"
 crossbeam-utils = "0.8"
 crossbeam-skiplist = "0.1"
-nix = "0.29"
+nix = "0.30"
 io-uring = "0.7"
 windows-sys = "0.59"
 anyhow = "1.0"

core/src/common/beans.rs

@@ -56,6 +56,7 @@ impl BeanFactory<'_> {
     ///
     /// # Safety
     /// Only one mutable reference can be held for a given bean at a time.
+    #[allow(clippy::mut_from_ref)]
     #[must_use]
     pub unsafe fn get_mut_bean<B>(bean_name: &str) -> Option<&mut B> {
         Self::get_instance()

core/src/common/ordered_work_steal.rs

@@ -367,7 +367,7 @@ impl<'l, T: Debug> OrderedLocalQueue<'l, T> {
                         //本地队列超过一半，不再steal
                         break;
                     }
-                    if std::ptr::eq(&another, &self.queue) {
+                    if std::ptr::eq(&raw const another, &raw const self.queue) {
                         //不能偷自己
                         continue;
                     }

core/src/common/work_steal.rs

@@ -299,7 +299,7 @@ impl<'l, T: Debug> LocalQueue<'l, T> {
                         //本地队列超过一半，不再steal
                         break;
                     }
-                    if std::ptr::eq(&another, &self.queue) {
+                    if std::ptr::eq(&raw const another, &raw const self.queue) {
                         //不能偷自己
                         continue;
                     }

core/src/coroutine/local.rs

@@ -27,6 +27,7 @@ impl<'c> CoroutineLocal<'c> {
     }
 
     /// Get a mut value ref from the coroutine local.
+    #[allow(clippy::mut_from_ref)]
     pub fn get_mut<V>(&self, key: &'c str) -> Option<&mut V> {
         self.0
             .get(key)

core/src/syscall/unix/connect.rs

@@ -73,7 +73,7 @@ impl<I: ConnectSyscall> ConnectSyscall for NioConnectSyscall<I> {
                         libc::SOL_SOCKET,
                         libc::SO_ERROR,
                         std::ptr::addr_of_mut!(err).cast::<c_void>(),
-                        &mut len,
+                        &raw mut len,
                     );
                 }
                 if r != 0 {
@@ -88,7 +88,7 @@ impl<I: ConnectSyscall> ConnectSyscall for NioConnectSyscall<I> {
                 unsafe {
                     let mut address = std::mem::zeroed();
                     let mut address_len = socklen_t::try_from(size_of_val(&address)).expect("overflow");
-                    r = libc::getpeername(fd, &mut address, &mut address_len);
+                    r = libc::getpeername(fd, &raw mut address, &raw mut address_len);
                 }
             } else if errno != Some(libc::EINTR) {
                 break;

core/src/syscall/unix/mod.rs

@@ -1027,7 +1027,7 @@ pub extern "C" fn send_time_limit(fd: c_int) -> u64 {
                 libc::SOL_SOCKET,
                 libc::SO_SNDTIMEO,
                 std::ptr::from_mut(&mut tv).cast(),
-                &mut len,
+                &raw mut len,
             ) == -1
             {
                 let error = std::io::Error::last_os_error();
@@ -1056,7 +1056,7 @@ pub extern "C" fn recv_time_limit(fd: c_int) -> u64 {
                 libc::SOL_SOCKET,
                 libc::SO_RCVTIMEO,
                 std::ptr::from_mut(&mut tv).cast(),
-                &mut len,
+                &raw mut len,
             ) == -1
             {
                 let error = std::io::Error::last_os_error();

core/src/syscall/unix/recvmsg.rs

@@ -101,7 +101,7 @@ impl<I: RecvmsgSyscall> RecvmsgSyscall for NioRecvmsgSyscall<I> {
                     msg_controllen: msghdr.msg_controllen,
                     msg_flags: msghdr.msg_flags,
                 };
-                r = self.inner.recvmsg(fn_ptr, fd, &mut arg, flags);
+                r = self.inner.recvmsg(fn_ptr, fd, &raw mut arg, flags);
                 if r == 0 {
                     std::mem::forget(vec);
                     if blocking {

core/src/syscall/unix/select.rs

@@ -84,7 +84,7 @@ impl<I: SelectSyscall> SelectSyscall for NioSelectSyscall<I> {
         loop {
             r = self
                 .inner
-                .select(fn_ptr, nfds, readfds, writefds, errorfds, &mut o);
+                .select(fn_ptr, nfds, readfds, writefds, errorfds, &raw mut o);
             if r != 0 || t == 0 {
                 break;
             }

core/src/syscall/unix/sendmsg.rs

@@ -101,7 +101,7 @@ impl<I: SendmsgSyscall> SendmsgSyscall for NioSendmsgSyscall<I> {
                     msg_controllen: msghdr.msg_controllen,
                     msg_flags: msghdr.msg_flags,
                 };
-                r = self.inner.sendmsg(fn_ptr, fd, &arg, flags);
+                r = self.inner.sendmsg(fn_ptr, fd, &raw const arg, flags);
                 if r != -1 {
                     reset_errno();
                     sent += libc::size_t::try_from(r).expect("r overflow");