maybe release log file guard to allow parallel request processing :)

1 files changed, 39 insertions, 37 deletions

diff --git a/src/modules/log.rs b/src/modules/log.rs
index 6122624..3705657 100644
--- a/src/modules/log.rs
+++ b/src/modules/log.rs
@@ -214,47 +214,49 @@ impl Node for Log {
                     String::from_utf8_lossy_owned(out.into_inner())
                 }
             };
-
-            let mut g = self.file.write().await;
-            if let Some((log, otime)) = g.as_mut() {
-                if otime.elapsed() > Duration::from_secs(self.config.file_duration) {
-                    info!("closing log file (age)");
-                    log.flush().await?;
-                    *g = None;
+            {
+                let mut g = self.file.write().await;
+                if let Some((log, otime)) = g.as_mut() {
+                    if otime.elapsed() > Duration::from_secs(self.config.file_duration) {
+                        info!("closing log file");
+                        log.flush().await?;
+                        *g = None;
+                    }
                 }
-            }
-            if g.is_none() {
-                if self.config.output_temp.exists() {
-                    info!("moving log file");
-                    rename(
-                        &self.config.output_temp,
-                        self.config.output_done.join(
-                            SystemTime::UNIX_EPOCH
-                                .elapsed()
-                                .unwrap()
-                                .as_secs()
-                                .to_string(),
+                if g.is_none() {
+                    if self.config.output_temp.exists() {
+                        info!("moving log file");
+                        rename(
+                            &self.config.output_temp,
+                            self.config.output_done.join(
+                                SystemTime::UNIX_EPOCH
+                                    .elapsed()
+                                    .unwrap()
+                                    .as_secs()
+                                    .to_string(),
+                            ),
+                        )
+                        .await?;
+                    }
+                    info!("opening new log file");
+                    *g = Some((
+                        BufWriter::new(
+                            OpenOptions::new()
+                                .append(true)
+                                .create(true)
+                                .open(&self.config.output_temp)
+                                .await?,
                         ),
-                    )
-                    .await?;
+                        Instant::now(),
+                    ));
+                }
+                let log = &mut g.as_mut().unwrap().0;
+                log.write_all(line.as_bytes()).await?;
+                if self.config.flush {
+                    log.flush().await?;
                 }
-                info!("opening new log file");
-                *g = Some((
-                    BufWriter::new(
-                        OpenOptions::new()
-                            .append(true)
-                            .create(true)
-                            .open(&self.config.output_temp)
-                            .await?,
-                    ),
-                    Instant::now(),
-                ));
-            }
-            let log = &mut g.as_mut().unwrap().0;
-            log.write_all(line.as_bytes()).await?;
-            if self.config.flush {
-                log.flush().await?;
             }
+
             self.config.next.handle(context, request).await
         })
     }