Merge pull request #402 from eval-exec/exec/upgrade-rust-2024

Rust Toolchain: Upgrade to rust edition 2024

Author: driftluo

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

@@ -68,7 +68,7 @@ impl Bench {
             self.cycles,
             total,
             total / self.cycles,
-            self.executed_time_list[(self.cycles/2) as usize],
+            self.executed_time_list[(self.cycles / 2) as usize],
             self.executed_time_list[self.cycles as usize - 1],
             self.executed_time_list[0]
         )

bench/src/main.rs

@@ -2,7 +2,7 @@ use bench::Bench;
 use bytes::Bytes;
 use futures::channel;
 use p2p::{
-    async_trait,
+    ProtocolId, async_trait,
     builder::{MetaBuilder, ServiceBuilder},
     context::{ProtocolContext, ProtocolContextMutRef},
     multiaddr::Multiaddr,
@@ -11,19 +11,21 @@ use p2p::{
         ProtocolHandle, ProtocolMeta, Service, ServiceControl, TargetProtocol, TargetSession,
     },
     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 +136,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 +174,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;
@@ -8,8 +8,8 @@ pub use self::onion_addr::Onion3Addr;
 pub use self::protocol::Protocol;
 use bytes::{Bytes, BytesMut};
 use serde::{
-    de::{self, Error as DeserializerError},
     Deserialize, Deserializer, Serialize, Serializer,
+    de::{self, Error as DeserializerError},
 };
 use std::{
     fmt,

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

@@ -10,7 +10,7 @@ use std::{
     str::{self, FromStr},
 };
 
-use crate::{error::Error, Onion3Addr};
+use crate::{Onion3Addr, error::Error};
 
 const DNS4: u32 = 0x36;
 const DNS6: u32 = 0x37;
@@ -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 = []