rust-toolchain: Upgrade to 1.85.0, update rust edition to 2024

Signed-off-by: Eval EXEC <execvy@gmail.com>

Author: eval-exec

bench/Cargo.toml

@@ -2,7 +2,7 @@
 name = "bench"
 version = "0.1.0"
 authors = ["piaoliu <441594700@qq.com>"]
-edition = "2021"
+edition = "2024"
 
 [lib]
 name = "bench"

bench/src/main.rs

@@ -13,17 +13,20 @@ use p2p::{
     traits::{ServiceHandle, ServiceProtocol},
     ProtocolId,
 };
-use std::{sync::Once, thread};
+use std::{
+    sync::{Once, OnceLock},
+    thread,
+};
 use tokio_util::codec::length_delimited::Builder;
 
 static START_SECIO: Once = Once::new();
 static START_NO_SECIO: Once = Once::new();
 
-static mut SECIO_CONTROL: Option<ServiceControl> = None;
-static mut NO_SECIO_CONTROL: Option<ServiceControl> = None;
+static SECIO_CONTROL: OnceLock<ServiceControl> = OnceLock::new();
+static NO_SECIO_CONTROL: OnceLock<ServiceControl> = OnceLock::new();
 
-static mut SECIO_RECV: Option<crossbeam_channel::Receiver<Notify>> = None;
-static mut NO_SECIO_RECV: Option<crossbeam_channel::Receiver<Notify>> = None;
+static SECIO_RECV: OnceLock<crossbeam_channel::Receiver<Notify>> = OnceLock::new();
+static NO_SECIO_RECV: OnceLock<crossbeam_channel::Receiver<Notify>> = OnceLock::new();
 
 #[derive(Debug, PartialEq)]
 enum Notify {
@@ -134,10 +137,8 @@ pub fn init() {
         });
 
         assert_eq!(client_receiver.recv(), Ok(Notify::Connected));
-        unsafe {
-            SECIO_CONTROL = Some(control.into());
-            SECIO_RECV = Some(client_receiver);
-        }
+        assert!(SECIO_CONTROL.set(control.into()).is_ok());
+        assert!(SECIO_RECV.set(client_receiver).is_ok());
     });
 
     // init no secio two peers
@@ -174,43 +175,37 @@ pub fn init() {
         });
 
         assert_eq!(client_receiver.recv(), Ok(Notify::Connected));
-        unsafe {
-            NO_SECIO_CONTROL = Some(control.into());
-            NO_SECIO_RECV = Some(client_receiver);
-        }
+        assert!(NO_SECIO_CONTROL.set(control.into()).is_ok());
+        assert!(NO_SECIO_RECV.set(client_receiver).is_ok());
     });
 }
 
 fn secio_and_send_data(data: &[u8]) {
-    unsafe {
-        SECIO_CONTROL.as_mut().map(|control| {
-            control.filter_broadcast(
-                TargetSession::All,
-                ProtocolId::new(1),
-                Bytes::from(data.to_owned()),
-            )
-        });
-        if let Some(rev) = SECIO_RECV.as_ref() {
-            assert_eq!(
-                rev.recv(),
-                Ok(Notify::Message(bytes::Bytes::from(data.to_owned())))
-            )
-        }
+    SECIO_CONTROL.get().map(|control| {
+        control.filter_broadcast(
+            TargetSession::All,
+            ProtocolId::new(1),
+            Bytes::from(data.to_owned()),
+        )
+    });
+    if let Some(rev) = SECIO_RECV.get() {
+        assert_eq!(
+            rev.recv(),
+            Ok(Notify::Message(bytes::Bytes::from(data.to_owned())))
+        )
     }
 }
 
 fn no_secio_and_send_data(data: &[u8]) {
-    unsafe {
-        NO_SECIO_CONTROL.as_mut().map(|control| {
-            control.filter_broadcast(TargetSession::All, 1.into(), Bytes::from(data.to_owned()))
-        });
+    NO_SECIO_CONTROL.get().map(|control| {
+        control.filter_broadcast(TargetSession::All, 1.into(), Bytes::from(data.to_owned()))
+    });
 
-        if let Some(rev) = NO_SECIO_RECV.as_ref() {
-            assert_eq!(
-                rev.recv(),
-                Ok(Notify::Message(bytes::Bytes::from(data.to_owned())))
-            )
-        }
+    if let Some(rev) = NO_SECIO_RECV.get() {
+        assert_eq!(
+            rev.recv(),
+            Ok(Notify::Message(bytes::Bytes::from(data.to_owned())))
+        )
     }
 }
 

fuzz/Cargo.toml

@@ -3,7 +3,7 @@ name = "tentacle-fuzz"
 version = "0.0.1"
 license = "MIT"
 authors = ["Nervos Core Dev <dev@nervos.org>"]
-edition = "2021"
+edition = "2024"
 
 [package.metadata]
 cargo-fuzz = true

multiaddr/Cargo.toml

@@ -2,8 +2,8 @@
 name = "tentacle-multiaddr"
 version = "0.3.5"
 authors = ["driftluo <driftluo@foxmail.com>"]
-edition = "2021"
-rust-version = "1.61.0"
+edition = "2024"
+rust-version = "1.85.0"
 repository = "https://github.com/nervosnetwork/tentacle"
 license = "MIT"
 description = "Mini Implementation of multiaddr"

multiaddr/src/lib.rs

@@ -1,4 +1,4 @@
-///! Mini Implementation of [multiaddr](https://github.com/jbenet/multiaddr) in Rust.
+//! Mini Implementation of [multiaddr](https://github.com/jbenet/multiaddr) in Rust.
 mod error;
 mod onion_addr;
 mod protocol;

multiaddr/src/onion_addr.rs

@@ -4,7 +4,7 @@ use std::{borrow::Cow, fmt};
 #[derive(Clone)]
 pub struct Onion3Addr<'a>(Cow<'a, [u8; 35]>, u16);
 
-impl<'a> Onion3Addr<'a> {
+impl Onion3Addr<'_> {
     /// Return the hash of the public key as bytes
     pub fn hash(&self) -> &[u8; 35] {
         self.0.as_ref()

multiaddr/src/protocol.rs

@@ -258,7 +258,7 @@ impl<'a> Protocol<'a> {
     }
 }
 
-impl<'a> fmt::Display for Protocol<'a> {
+impl fmt::Display for Protocol<'_> {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         use self::Protocol::*;
         match self {
@@ -280,7 +280,7 @@ impl<'a> fmt::Display for Protocol<'a> {
     }
 }
 
-impl<'a> From<IpAddr> for Protocol<'a> {
+impl From<IpAddr> for Protocol<'_> {
     #[inline]
     fn from(addr: IpAddr) -> Self {
         match addr {
@@ -290,14 +290,14 @@ impl<'a> From<IpAddr> for Protocol<'a> {
     }
 }
 
-impl<'a> From<Ipv4Addr> for Protocol<'a> {
+impl From<Ipv4Addr> for Protocol<'_> {
     #[inline]
     fn from(addr: Ipv4Addr) -> Self {
         Protocol::Ip4(addr)
     }
 }
 
-impl<'a> From<Ipv6Addr> for Protocol<'a> {
+impl From<Ipv6Addr> for Protocol<'_> {
     #[inline]
     fn from(addr: Ipv6Addr) -> Self {
         Protocol::Ip6(addr)

protocols/discovery/Cargo.toml

@@ -7,7 +7,7 @@ description = "p2p discovery protocol main reference bitcoin"
 keywords = ["network", "peer-to-peer", "p2p", "discovery"]
 repository = "https://github.com/nervosnetwork/tentacle"
 categories = ["network-programming", "asynchronous"]
-edition = "2018"
+edition = "2024"
 
 [package.metadata.docs.rs]
 features = []

protocols/identify/Cargo.toml

@@ -7,7 +7,7 @@ description = "p2p identify protocol"
 keywords = ["network", "peer-to-peer", "p2p", "identify"]
 repository = "https://github.com/nervosnetwork/tentacle"
 categories = ["network-programming", "asynchronous"]
-edition = "2018"
+edition = "2024"
 
 [package.metadata.docs.rs]
 features = []

protocols/ping/Cargo.toml

@@ -7,7 +7,7 @@ keywords = ["network", "peer-to-peer", "p2p", "ping"]
 categories = ["network-programming", "asynchronous"]
 repository = "https://github.com/nervosnetwork/tentacle"
 description = "ping protocol implementation for tentacle"
-edition = "2018"
+edition = "2024"
 
 [package.metadata.docs.rs]
 features = []