Update nix requirement from 0.29 to 0.30 (#406)

Author: loongs-zhang

.github/workflows/coverage.yml

@@ -24,7 +24,7 @@ jobs:
       - name: Install toolchain
         uses: actions-rs/toolchain@v1
         with:
-          toolchain: 1.81.0
+          toolchain: stable
           profile: minimal
           override: true
           components: llvm-tools-preview

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/mod.rs

@@ -160,7 +160,7 @@ pub fn page_size() -> usize {
             cfg_if::cfg_if! {
                 if #[cfg(windows)] {
                     let mut info = std::mem::zeroed();
-                    windows_sys::Win32::System::SystemInformation::GetSystemInfo(&mut info);
+                    windows_sys::Win32::System::SystemInformation::GetSystemInfo(&raw mut info);
                     ret = usize::try_from(info.dwPageSize).expect("get page size failed");
                 } else {
                     ret = usize::try_from(libc::sysconf(libc::_SC_PAGESIZE)).expect("get page size failed");

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/net/operator/linux/mod.rs

@@ -235,7 +235,9 @@ impl Operator<'_> {
                 self,
                 SUPPORT_TIMEOUT_ADD,
                 Timeout,
-                Timeout::new(&timeout).build().user_data(user_data as u64)
+                Timeout::new(&raw const timeout)
+                    .build()
+                    .user_data(user_data as u64)
             )
         }
         Ok(())
@@ -254,7 +256,7 @@ impl Operator<'_> {
                 self,
                 SUPPORT_TIMEOUT_UPDATE,
                 TimeoutUpdate,
-                TimeoutUpdate::new(user_data as u64, &timeout)
+                TimeoutUpdate::new(user_data as u64, &raw const timeout)
                     .build()
                     .user_data(user_data as u64)
             )

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();