Mercurial > lbo > hg > syslog

changeset 24:ed9eb9cfeb83 draft

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Add some notes and fix mod statements
author Lewin Bormann <lbo@spheniscida.de>
date Sun, 04 Dec 2016 16:32:49 +0100
parents 2b5e442c8bbb
children feacaba90cbe
files src/dispatch.rs src/main.rs
diffstat 2 files changed, 4 insertions(+), 0 deletions(-) [+]
line wrap: on
line diff
--- a/src/dispatch.rs	Sun Dec 04 16:32:37 2016 +0100
+++ b/src/dispatch.rs	Sun Dec 04 16:32:49 2016 +0100
@@ -17,8 +17,11 @@
     let handle = LOOP.handle();
 
     let log_socket = try!(UnixDatagram::bind(cfg.general.bind_path, &handle));
+    // TODO: If we're listening to local messages as well as remote ones, build a custom future or
+    // use Select.
     let log_incoming_stream = dgram_stream::new_unix_dgram_stream(cfg.general.max_msg_len, log_socket);
 
+    // NOTE: Maybe a dedicated Future for this is simpler than for_each.
     let finished = log_incoming_stream.for_each(|msg_buf| {
         let msg = String::from_utf8(msg_buf).unwrap_or("<UTF8 decoding error>".to_string());
         println!("{}", msg);
--- a/src/main.rs	Sun Dec 04 16:32:37 2016 +0100
+++ b/src/main.rs	Sun Dec 04 16:32:49 2016 +0100
@@ -10,6 +10,7 @@
 mod dispatch;
 mod error;
 mod priority;
+mod rule;
 
 fn main() {
     let mut cfg = config::Config::default();