remove custom log code in favor of macro crate

Cargo.toml

@@ -38,6 +38,7 @@ mio-uds = "0.6.7"
 num_cpus = "1.10.1"
 pin-utils = "0.1.0-alpha.4"
 slab = "0.4.2"
+kv-log-macro = "1.0.4"
 
 [dev-dependencies]
 femme = "1.2.0"

src/task/block_on.rs

@@ -6,13 +6,14 @@ use std::sync::Arc;
 use std::task::{RawWaker, RawWakerVTable};
 use std::thread::{self, Thread};
 
-use super::log_utils;
 use super::pool;
 use super::task;
 use crate::future::Future;
 use crate::task::{Context, Poll, Waker};
 use crate::utils::abort_on_panic;
 
+use kv_log_macro::trace;
+
 /// Spawns a task and blocks the current thread on its result.
 ///
 /// Calling this function is similar to [spawning] a thread and immediately [joining] it, except an
@@ -58,13 +59,11 @@ where
         // Log this `block_on` operation.
         let child_id = tag.task_id().as_u64();
         let parent_id = pool::get_task(|t| t.id().as_u64()).unwrap_or(0);
-        log_utils::print(
-            format_args!("block_on"),
-            log_utils::LogData {
-                parent_id,
-                child_id,
-            },
-        );
+
+        trace!("block_on", {
+            parent_id: parent_id,
+            child_id: child_id,
+        });
 
         // Wrap the future into one that drops task-local variables on exit.
         let future = async move {
@@ -73,13 +72,11 @@ where
             // Abort on panic because thread-local variables behave the same way.
             abort_on_panic(|| pool::get_task(|task| task.metadata().local_map.clear()));
 
-            log_utils::print(
-                format_args!("block_on completed"),
-                log_utils::LogData {
-                    parent_id,
-                    child_id,
-                },
-            );
+            trace!("block_on completed", {
+                parent_id: parent_id,
+                child_id: child_id,
+            });
+
             res
         };
 

src/task/mod.rs

@@ -32,7 +32,6 @@ pub use task::{JoinHandle, Task, TaskId};
 
 mod block_on;
 mod local;
-mod log_utils;
 mod pool;
 mod sleep;
 mod task;

src/task/pool.rs

@@ -3,9 +3,9 @@ use std::ptr;
 use std::thread;
 
 use crossbeam_channel::{unbounded, Sender};
+use kv_log_macro::trace;
 use lazy_static::lazy_static;
 
-use super::log_utils;
 use super::task;
 use super::{JoinHandle, Task};
 use crate::future::Future;
@@ -130,13 +130,11 @@ where
     // Log this `spawn` operation.
     let child_id = tag.task_id().as_u64();
     let parent_id = get_task(|t| t.id().as_u64()).unwrap_or(0);
-    log_utils::print(
-        format_args!("spawn"),
-        log_utils::LogData {
-            parent_id,
-            child_id,
-        },
-    );
+
+    trace!("spawn", {
+        parent_id: parent_id,
+        child_id: child_id,
+    });
 
     // Wrap the future into one that drops task-local variables on exit.
     let future = async move {
@@ -145,13 +143,11 @@ where
         // Abort on panic because thread-local variables behave the same way.
         abort_on_panic(|| get_task(|task| task.metadata().local_map.clear()));
 
-        log_utils::print(
-            format_args!("spawn completed"),
-            log_utils::LogData {
-                parent_id,
-                child_id,
-            },
-        );
+        trace!("spawn completed", {
+            parent_id: parent_id,
+            child_id: child_id,
+        });
+
         res
     };