feat:v2.31.0

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "hyperlane"
-version = "2.30.0"
+version = "2.31.0"
 edition = "2021"
 authors = ["ltpp-universe <root@ltpp.vip>"] 
 license = "MIT"
@@ -17,9 +17,9 @@ exclude = [
 
 [dependencies]
 color-output = "6.1.4"
-http-request = "8.26.0"
-http-type = "2.20.0"
-hyperlane-log = "0.15.0"
+http-request = "8.29.0"
+http-type = "2.21.0"
+hyperlane-log = "0.16.0"
 hyperlane-time = "0.0.1"
 lombok-macros = "1.5.0"
 std-macro-extensions = "0.17.6"

src/server/config/impl.rs

@@ -2,6 +2,7 @@ use super::r#type::ServerConfig;
 use crate::*;
 
 impl<'a> Default for ServerConfig<'a> {
+    #[inline]
     fn default() -> Self {
         Self {
             host: DEFAULT_HOST,

src/server/controller_data/impl.rs

@@ -3,6 +3,7 @@ use http_type::{Request, Response};
 use hyperlane_log::*;
 
 impl ControllerData {
+    #[inline]
     pub fn new() -> Self {
         ControllerData {
             stream: None,

src/server/error/impl.rs

@@ -8,6 +8,7 @@ use std::{
 impl StdError for Error {}
 
 impl Display for Error {
+    #[inline]
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         match self {
             Self::TcpBindError(data) => write!(f, "Tcp bind error{}{}", COLON_SPACE, data),

src/server/impl.rs

@@ -14,6 +14,7 @@ use hyperlane_time::*;
 use std_macro_extensions::*;
 
 impl Default for Server {
+    #[inline]
     fn default() -> Self {
         Self {
             cfg: Arc::new(RwLock::new(ServerConfig::default())),
@@ -25,10 +26,12 @@ impl Default for Server {
 }
 
 impl Server {
+    #[inline]
     pub fn new() -> Self {
         Self::default()
     }
 
+    #[inline]
     pub fn host(&mut self, host: &'static str) -> &mut Self {
         let _ = self.get_cfg().write().and_then(|mut cfg| {
             cfg.set_host(host);
@@ -37,6 +40,7 @@ impl Server {
         self
     }
 
+    #[inline]
     pub fn port(&mut self, port: usize) -> &mut Self {
         let _ = self.get_cfg().write().and_then(|mut cfg| {
             cfg.set_port(port);
@@ -45,6 +49,7 @@ impl Server {
         self
     }
 
+    #[inline]
     pub fn thread_pool_size(&mut self, thread_pool_size: usize) -> &mut Self {
         let _ = self.get_cfg().write().and_then(|mut cfg| {
             cfg.set_thread_pool_size(thread_pool_size);
@@ -53,6 +58,7 @@ impl Server {
         self
     }
 
+    #[inline]
     pub fn log_dir(&mut self, log_dir: &'static str) -> &mut Self {
         let _ = self.get_cfg().write().and_then(|mut cfg| {
             cfg.set_log_dir(log_dir);
@@ -65,6 +71,7 @@ impl Server {
         self
     }
 
+    #[inline]
     pub fn log_size(&mut self, log_size: usize) -> &mut Self {
         let _ = self.get_cfg().write().and_then(|mut cfg| {
             cfg.set_log_size(log_size);
@@ -77,6 +84,7 @@ impl Server {
         self
     }
 
+    #[inline]
     pub fn router<F>(&mut self, route: &'static str, func: F) -> &mut Self
     where
         F: 'static + Send + Sync + Fn(&mut ControllerData),
@@ -87,6 +95,7 @@ impl Server {
         self
     }
 
+    #[inline]
     pub fn middleware<F>(&mut self, func: F) -> &mut Self
     where
         F: 'static + Send + Sync + Fn(&mut ControllerData),
@@ -97,10 +106,12 @@ impl Server {
         self
     }
 
+    #[inline]
     fn common_log(data: &String) -> String {
         format!("{}: {}{}", current_time(), data.to_string(), HTTP_BR)
     }
 
+    #[inline]
     pub fn listen(&mut self) -> &mut Self {
         self.init();
         let mut host: &str = EMPTY_STR;
@@ -194,13 +205,15 @@ impl Server {
         self
     }
 
+    #[inline]
     fn init_log(&self) {
         let _ = self.get_tmp().read().and_then(|tmp| {
             log_run(tmp.get_log());
             Ok(())
         });
     }
 
+    #[inline]
     fn init(&self) {
         self.init_log();
     }

src/server/thread_pool/impl.rs

@@ -4,6 +4,7 @@ use crate::*;
 use std::sync::mpsc::{self, Receiver};
 
 impl ThreadPool {
+    #[inline]
     pub fn new(size: usize) -> ThreadPool {
         let (sender, receiver) = mpsc::channel();
         let receiver: ArcMutex<Receiver<Box<dyn FnOnce() + Send>>> = Arc::new(Mutex::new(receiver));
@@ -14,6 +15,7 @@ impl ThreadPool {
         ThreadPool { workers, sender }
     }
 
+    #[inline]
     pub fn execute<F>(&self, job: F)
     where
         F: FnOnce() + Send + 'static,

src/server/tmp/impl.rs

@@ -2,6 +2,7 @@ use super::r#type::Tmp;
 use crate::*;
 
 impl Default for Tmp {
+    #[inline]
     fn default() -> Self {
         Self {
             running_thread_num: Arc::new(Mutex::new(0)),
@@ -11,6 +12,7 @@ impl Default for Tmp {
 }
 
 impl Tmp {
+    #[inline]
     pub fn add_thread_num(&mut self) {
         let _ = self
             .running_thread_num
@@ -21,6 +23,7 @@ impl Tmp {
             });
     }
 
+    #[inline]
     pub fn sub_thread_num(&mut self) {
         let _ = self
             .running_thread_num

src/server/worker/impl.rs

@@ -4,6 +4,7 @@ use crate::*;
 use std::{sync::mpsc::Receiver, thread::spawn};
 
 impl Worker {
+    #[inline]
     pub fn new(id: usize, receiver: ArcMutex<Receiver<Job>>) -> Worker {
         let thread = spawn(move || loop {
             let job = receiver.lock().unwrap().recv().unwrap();

src/utils/thread.rs

@@ -1,3 +1,4 @@
+#[inline]
 pub fn get_thread_count() -> usize {
     match std::thread::available_parallelism() {
         Ok(count) => count.get(),