fix: some warnings

340Lab · Jun 30, 2024 · bcaf1d2 · bcaf1d2
1 parent bf73e72
commit bcaf1d2
Show file tree

Hide file tree

Showing 10 changed files with 12 additions and 19 deletions.
diff --git a/src/general/m_appmeta_manager/fn_event.rs b/src/general/m_appmeta_manager/fn_event.rs
@@ -1,11 +1,9 @@
 use crate::general::{
-    kv_interface::KvOps,
     network::proto::sche::distribute_task_req::{Trigger, TriggerKvSet},
 };
 
 use super::{
     super::network::proto::{self, kv::KvRequest},
-    AppMetas,
 };
 
 pub struct EventTriggerInfo {

diff --git a/src/general/m_appmeta_manager/mod.rs b/src/general/m_appmeta_manager/mod.rs
@@ -29,7 +29,6 @@ use crate::{
     worker::func::m_instance_manager::InstanceManager,
 };
 use crate::{
-    result::{WSError, WsIoErr},
     worker::m_executor::Executor,
 };
 use async_trait::async_trait;
@@ -44,7 +43,7 @@ use std::{
     path::Path,
 };
 use tokio::sync::RwLock;
-use uuid::Uuid;
+
 use ws_derive::LogicalModule;
 
 logical_module_view_impl!(View);

diff --git a/src/general/m_data_general.rs b/src/general/m_data_general.rs
@@ -18,7 +18,7 @@ use crate::{
     util::JoinHandleWrapper,
 };
 use crate::{
-    result::{WSError, WsDataError},
+    result::{WsDataError},
     sys::LogicalModulesRef,
 };
 use async_trait::async_trait;

diff --git a/src/general/m_os/zip.rs b/src/general/m_os/zip.rs
@@ -1,13 +1,13 @@
 use super::OperatingSystem;
-use crate::result::{ErrCvt, WSError, WSResult, WsIoErr};
+use crate::result::{WSError, WSResult, WsIoErr};
 use std::{
     fs::{self, File},
     io::{self, Cursor, Read, Seek, Write},
     os::unix::fs::PermissionsExt,
     path::Path,
 };
 use walkdir::WalkDir;
-use zip::{result::ZipError, write::FileOptions, ZipWriter};
+use zip::{result::ZipError, write::FileOptions};
 
 impl OperatingSystem {
     pub fn unzip_data_2_path(&self, p: impl AsRef<Path>, data: Vec<u8>) -> WSResult<()> {

diff --git a/src/master/m_master_kv.rs b/src/master/m_master_kv.rs
@@ -11,7 +11,7 @@ use ws_derive::LogicalModule;
 use crate::{
     general::{
         m_appmeta_manager::{
-            fn_event::{self, EventTriggerInfo},
+            fn_event::{EventTriggerInfo},
             AppMetaManager,
         },
         m_kv_store_engine::{KeyTypeKv, KeyTypeKvPosition, KvStoreEngine},

diff --git a/src/worker/func/shared/java.rs b/src/worker/func/shared/java.rs
@@ -1,4 +1,4 @@
-use std::{fmt::format, str::from_utf8};
+use std::{str::from_utf8};
 
 use tokio::process::{self, Command};
 

diff --git a/src/worker/func/shared/process.rs b/src/worker/func/shared/process.rs
@@ -1,7 +1,6 @@
 // process function just run in unique process
 
 use std::{
-    process::{self, Stdio},
     sync::Arc,
 };
 
@@ -12,10 +11,9 @@ use tokio::{process::Command, sync::oneshot};
 
 use crate::{
     general::{
-        m_appmeta_manager::{AppType, HttpMethod},
+        m_appmeta_manager::{AppType},
         network::rpc_model::{self, HashValue},
     },
-    result::WsFuncError,
     worker::func::{shared::java, InstanceTrait},
 };
 

diff --git a/src/worker/func/shared/process_instance_man_related.rs b/src/worker/func/shared/process_instance_man_related.rs
@@ -5,7 +5,6 @@ use tokio::process::Command;
 use crate::{
     general::m_appmeta_manager::AppType,
     result::{WSResult, WsFuncError},
-    util,
     worker::func::{
         m_instance_manager::{EachAppCache, InstanceManager},
         shared::java,

diff --git a/src/worker/m_data_follower.rs b/src/worker/m_data_follower.rs
@@ -1,7 +1,7 @@
-use std::collections::HashSet;
 
-use crate::general::m_data_general::{DataGeneral, DataSetMeta};
-use crate::general::m_kv_store_engine::{KeyTypeDataSetMeta, KvStoreEngine};
+
+use crate::general::m_data_general::{DataGeneral};
+use crate::general::m_kv_store_engine::{KvStoreEngine};
 use crate::general::network::m_p2p::{P2PModule, RPCHandler, RPCResponsor};
 use crate::general::network::proto::{self, DataVersionRequest, DataVersionResponse};
 use crate::result::{WSError, WSResult, WsDataError};

diff --git a/src/worker/m_http_handler.rs b/src/worker/m_http_handler.rs
@@ -1,14 +1,13 @@
 use crate::{
-    general::network::http_handler::{start_http_handler, HttpHandler, LocalReqIdAllocator},
+    general::network::http_handler::{start_http_handler, HttpHandler},
     logical_module_view_impl,
     result::WSResult,
     sys::{LogicalModule, LogicalModuleNewArgs, LogicalModulesRef},
     util::{JoinHandleWrapper, WithBind},
 };
 use async_trait::async_trait;
 use axum::{
-    http::StatusCode,
-    response::{IntoResponse, Response},
+    response::{Response},
     Router,
 };
 use parking_lot::Mutex;