]> OzVa Git service - ozva-cloud/commitdiff
feat: aware RUST_LOG
authorsigoden <sigoden@gmail.com>
Sat, 28 May 2022 12:42:32 +0000 (20:42 +0800)
committersigoden <sigoden@gmail.com>
Sat, 28 May 2022 12:43:20 +0000 (20:43 +0800)
Cargo.lock
Cargo.toml
README.md
src/main.rs
src/server.rs

index f290aa086019ae4b1f5973a7157f8f61ea7baa1b..e2d6949c201c8bd99abbc3ede3b5c56194aab0ed 100644 (file)
@@ -258,7 +258,7 @@ dependencies = [
 
 [[package]]
 name = "duf"
-version = "0.2.0"
+version = "0.2.1"
 dependencies = [
  "async-walkdir",
  "async_zip",
index 5739f506c4e40978234646a7593c54c2304667a0..beb81b489874055e3ae878509d3bdbd30993d12d 100644 (file)
@@ -1,6 +1,6 @@
 [package]
 name = "duf"
-version = "0.2.0"
+version = "0.2.1"
 edition = "2021"
 authors = ["sigoden <sigoden@gmail.com>"]
 description = "Duf is a simple file server."
index c90559bf05ffed43fb77359f85e55ec8afad4674..79ebe8f9155457b5ad56381557be9e817b623622 100644 (file)
--- a/README.md
+++ b/README.md
@@ -49,8 +49,6 @@ duf --static
 
 Finally, run this command to see a list of all available option
 
-
-
 ### Curl
 
 Download a file
index 208eb169ab88d493c0e7dbc586ffb01ca3d3fedf..7472ec649492a2c3c700aa84ba584557713c36c6 100644 (file)
@@ -25,14 +25,18 @@ async fn main() {
 async fn run() -> BoxResult<()> {
     let args = Args::parse(matches())?;
 
-    let level = if args.log {
-        LevelFilter::Info
+    if std::env::var("RUST_LOG").is_ok() {
+        simple_logger::init()?;
     } else {
-        LevelFilter::Error
-    };
-    simple_logger::SimpleLogger::default()
-        .with_level(level)
-        .init()?;
+        let level = if args.log {
+            LevelFilter::Info
+        } else {
+            LevelFilter::Error
+        };
+        simple_logger::SimpleLogger::default()
+            .with_level(level)
+            .init()?;
+    }
     serve(args).await
 }
 
index f4967b4cf3987656efe1cebbf504f41a5cb63e6c..534b3c92a5f2e53ce9a00c7bf7b8dc1be60c893c 100644 (file)
@@ -187,7 +187,7 @@ impl InnerService {
     }
 
     async fn handle_send_dir_zip(&self, path: &Path) -> BoxResult<Response> {
-        let (mut writer, reader) = tokio::io::duplex(65536);
+        let (mut writer, reader) = tokio::io::duplex(1024 * 1024 * 20);
         dir_zip(&mut writer, path).await?;
         let stream = ReaderStream::new(reader);
         let body = Body::wrap_stream(stream);