Execute cargo fmt --all

Author: eval-exec

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,7 +11,6 @@ use p2p::{
         ProtocolHandle, ProtocolMeta, Service, ServiceControl, TargetProtocol, TargetSession,
     },
     traits::{ServiceHandle, ServiceProtocol},
-    ProtocolId,
 };
 use std::{
     sync::{Once, OnceLock},

multiaddr/src/lib.rs

@@ -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/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;

secio/benches/bench.rs

@@ -1,5 +1,5 @@
-use criterion::{criterion_group, criterion_main, Bencher, Criterion};
-use tentacle_secio::crypto::{cipher::CipherType, new_stream, CryptoMode};
+use criterion::{Bencher, Criterion, criterion_group, criterion_main};
+use tentacle_secio::crypto::{CryptoMode, cipher::CipherType, new_stream};
 
 fn decode_encode(data: &[u8], cipher: CipherType) {
     let cipher_key = (0..cipher.key_size())

secio/examples/secio_simple.rs

@@ -1,6 +1,6 @@
 use bytes::BytesMut;
 use log::info;
-use tentacle_secio::{handshake::Config, SecioKeyPair};
+use tentacle_secio::{SecioKeyPair, handshake::Config};
 use tokio::{
     io::{AsyncReadExt, AsyncWriteExt},
     net::{TcpListener, TcpStream},

secio/src/codec/secure_stream.rs

@@ -2,7 +2,7 @@ use bytes::{Buf, Bytes, BytesMut};
 use futures::{SinkExt, StreamExt};
 use log::{debug, trace};
 use tokio::io::{AsyncRead, AsyncReadExt, AsyncWrite, ReadBuf};
-use tokio_util::codec::{length_delimited::LengthDelimitedCodec, Framed};
+use tokio_util::codec::{Framed, length_delimited::LengthDelimitedCodec};
 
 use std::{
     cmp::min,
@@ -231,14 +231,14 @@ where
 #[cfg(test)]
 mod tests {
     use super::SecureStream;
-    use crate::crypto::{cipher::CipherType, new_stream, CryptoMode};
+    use crate::crypto::{CryptoMode, cipher::CipherType, new_stream};
     use bytes::BytesMut;
     use futures::channel;
     use tokio::{
         io::{AsyncReadExt, AsyncWriteExt},
         net::{TcpListener, TcpStream},
     };
-    use tokio_util::codec::{length_delimited::LengthDelimitedCodec, Framed};
+    use tokio_util::codec::{Framed, length_delimited::LengthDelimitedCodec};
 
     fn rt() -> &'static tokio::runtime::Runtime {
         static RT: std::sync::OnceLock<tokio::runtime::Runtime> = std::sync::OnceLock::new();

secio/src/crypto/mod.rs

@@ -100,8 +100,8 @@ fn nonce_advance(nonce: &mut [u8]) {
 #[cfg(all(test, unix))]
 mod test {
     use super::{
-        cipher::CipherType, openssl_impl::OpenSsLCrypt, ring_impl::RingAeadCipher,
-        wasm_compat::WasmCrypt, CryptoMode,
+        CryptoMode, cipher::CipherType, openssl_impl::OpenSsLCrypt, ring_impl::RingAeadCipher,
+        wasm_compat::WasmCrypt,
     };
     use proptest::prelude::*;
 

secio/src/crypto/openssl_impl.rs

@@ -2,7 +2,7 @@ use bytes::{Bytes, BytesMut};
 use openssl::symm;
 
 use crate::{
-    crypto::{cipher::CipherType, nonce_advance, StreamCipher},
+    crypto::{StreamCipher, cipher::CipherType, nonce_advance},
     error::SecioError,
 };
 

secio/src/crypto/ring_impl.rs

@@ -1,16 +1,16 @@
 use bytes::BytesMut;
 use ring::{
     aead::{
-        Aad, BoundKey, Nonce, NonceSequence, OpeningKey, SealingKey, UnboundKey, AES_128_GCM,
-        AES_256_GCM, CHACHA20_POLY1305,
+        AES_128_GCM, AES_256_GCM, Aad, BoundKey, CHACHA20_POLY1305, Nonce, NonceSequence,
+        OpeningKey, SealingKey, UnboundKey,
     },
     error::Unspecified,
 };
 
 use std::ptr;
 
 use crate::{
-    crypto::{cipher::CipherType, nonce_advance, CryptoMode, StreamCipher},
+    crypto::{CryptoMode, StreamCipher, cipher::CipherType, nonce_advance},
     error::SecioError,
 };