Merge pull request #7 from Trivernis/develop

Add more logging

Cargo.lock

@@ -148,7 +148,7 @@ dependencies = [
 
 [[package]]
 name = "rmp-ipc"
-version = "0.4.1"
+version = "0.4.2"
 dependencies = [
  "lazy_static",
  "log",

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "rmp-ipc"
-version = "0.4.1"
+version = "0.4.2"
 authors = ["trivernis <trivernis@protonmail.com>"]
 edition = "2018"
 readme = "README.md"

src/events/event.rs

@@ -69,6 +69,7 @@ impl Event {
     /// Reads an event message
     pub async fn from_async_read<R: AsyncRead + Unpin>(reader: &mut R) -> Result<Self> {
         let length = reader.read_u32().await?;
+        log::trace!("Parsing event of length {}", length);
         let mut data = vec![0u8; length as usize];
         reader.read_exact(&mut data).await?;
         let event = rmp_serde::from_read(&data[..])?;

src/ipc/client.rs

@@ -32,6 +32,7 @@ impl IPCClient {
         );
         let handler = Arc::new(self.handler);
         let namespaces = Arc::new(self.namespaces);
+        log::debug!("IPC client connected to {}", address);
 
         tokio::spawn({
             let ctx = Context::clone(&ctx);

src/ipc/mod.rs

@@ -21,9 +21,11 @@ async fn handle_connection(
     ctx: Context,
 ) {
     while let Ok(event) = Event::from_async_read(&mut read_half).await {
+        log::debug!("Received {:?}:{} event", event.namespace(), event.name());
         // check if the event is a reply
         if let Some(ref_id) = event.reference_id() {
             // get the listener for replies
+            log::trace!("Event is response to {}", ref_id);
             if let Some(sender) = ctx.get_reply_sender(ref_id).await {
                 // try sending the event to the listener for replies
                 if let Err(event) = sender.send(event) {
@@ -31,11 +33,14 @@ async fn handle_connection(
                 }
                 continue;
             }
+            log::trace!("No response listener found for event. Passing to regular listener.");
         }
         if let Some(namespace) = event.namespace().clone().and_then(|n| namespaces.get(&n)) {
+            log::trace!("Passing event to namespace listener");
             let handler = Arc::clone(&namespace.handler);
             handle_event(Context::clone(&ctx), handler, event);
         } else {
+            log::trace!("Passing event to global listener");
             handle_event(Context::clone(&ctx), Arc::clone(&handler), event);
         }
     }

src/ipc/server.rs

@@ -27,6 +27,7 @@ impl IPCServer {
         let handler = Arc::new(self.handler);
         let namespaces = Arc::new(self.namespaces);
         let data = Arc::new(RwLock::new(self.data));
+        log::debug!("IPC server listening on {}", address);
 
         while let Ok((stream, _)) = listener.accept().await {
             let handler = Arc::clone(&handler);

src/ipc/stream_emitter.rs

@@ -30,6 +30,8 @@ impl StreamEmitter {
         res_id: Option<u64>,
     ) -> Result<EmitMetadata> {
         let data_bytes = rmp_serde::to_vec(&data)?;
+        log::debug!("Emitting event {:?}:{}", namespace, event);
+
         let event = if let Some(namespace) = namespace {
             Event::with_namespace(namespace.to_string(), event.to_string(), data_bytes, res_id)
         } else {
@@ -38,6 +40,7 @@ impl StreamEmitter {
 
         let event_bytes = event.to_bytes()?;
         {
+            log::trace!("Writing {} bytes", event_bytes.len());
             let mut stream = self.stream.lock().await;
             (*stream).write_all(&event_bytes[..]).await?;
         }