file: print an error message if writing to the file fails

HISTORY.md

@@ -1,10 +1,3 @@
-## [Unreleased]
-
-### Added
-
-- get logger's plugins and targets
-- create directory in FileTarget
-
 ### Todo
 
 - predefined fields do not need invoked every time
@@ -14,6 +7,17 @@
 - highlight keywords in console output
 - sampling by level
 
+## [0.3.2] - 2024-03-07
+
+### Added
+
+- Retrieve logger's plugins and targets
+- Automatically create the directory in FileTarget
+
+### Changed
+
+- Print an error message if writing to the file fails
+
 ## [0.3.1] - 2024-02-02
 
 ### Changed

examples/multi_thread.rs

@@ -1,10 +1,15 @@
 #[macro_use] extern crate logkit;
 
 #[tokio::main]
-async fn main() {
+async fn main() -> anyhow::Result<()> {
     let mut logger = logkit::Logger::new(Some(&logkit::StdoutTarget));
     logger.mount(logkit::LevelPlugin);
     logger.mount(logkit::TimePlugin::from_millis());
+
+    let mut sample = std::env::temp_dir();
+    sample.push("sample.log");
+    logger.route(logkit::FileTarget::new(sample)?);
+
     logkit::set_default_logger(logger);
 
     let mut handles = vec![];
@@ -16,4 +21,6 @@ async fn main() {
     }
 
     futures::future::join_all(handles).await;
+
+    Ok(())
 }

src/define.rs

@@ -3,6 +3,7 @@ pub(crate) use std::io::Write;
 pub(crate) use std::path::Path;
 pub(crate) use std::cell::RefCell;
 pub(crate) use parking_lot::Mutex;
+pub(crate) use parking_lot::ReentrantMutex;
 
 /// Any support
 pub trait Any: std::any::Any {

src/target.rs

@@ -56,7 +56,7 @@ impl Target for StderrTarget {
 /// ```
 pub struct FileTarget {
     /// file handle
-    pub file: Mutex<RefCell<std::fs::File>>,
+    pub file: ReentrantMutex<RefCell<std::fs::File>>,
 }
 
 impl FileTarget {
@@ -66,14 +66,17 @@ impl FileTarget {
             std::fs::create_dir_all(dir)?;
         }
 
-        Ok(Self {file: Mutex::new(RefCell::new(std::fs::OpenOptions::new().create(true).append(true).open(path)?))})
+        Ok(Self {file: ReentrantMutex::new(RefCell::new(std::fs::OpenOptions::new().create(true).append(true).open(path)?))})
     }
 }
 
 impl Target for FileTarget {
     #[inline]
     fn write(&self, buf: &[u8]) {
         let file = self.file.lock();
-        let _ = file.borrow_mut().write_all(buf);
+        match file.borrow_mut().write_all(buf) {
+            Ok(_) => {}
+            Err(err) => { let _ = std::io::stderr().write_all(format!("Error: {}", err).as_bytes()); }
+        };
     }
 }