logger update, stderr stream is added

include/logging/logger.hpp

@@ -111,4 +111,3 @@ private:
     Log* log;
     std::string name;
 };
-

include/logging/streams/format.hpp

@@ -0,0 +1,30 @@
+#pragma once
+
+#include <fmt/format.h>
+#include <string>
+
+#include "logging/log.hpp"
+
+// TODO: in c++17 replace with logging::format
+namespace logging
+{
+    namespace format
+    {
+        std::string out = "{} {:<5} [{}] {}\n";
+        std::string err = out;
+
+        // TODO: configurable formats
+    }
+
+    class Formatter
+    {
+    public:
+        static std::string format(const std::string &format,
+                                  const Log::Record &record)
+        {
+            return fmt::format(format, static_cast<std::string>(record.when()),
+                               record.level_str(), record.where(),
+                               record.text());
+        }
+    };
+}

include/logging/streams/stderr.hpp

@@ -0,0 +1,9 @@
+#pragma once
+
+#include "logging/log.hpp"
+
+class Stderr : public Log::Stream
+{
+public:
+    void emit(const Log::Record&) override;
+};

src/logging/streams/stderr.cpp

@@ -0,0 +1,9 @@
+#include "logging/streams/stderr.hpp"
+
+#include <iostream>
+#include "logging/streams/format.hpp"
+
+void Stderr::emit(const Log::Record& record)
+{
+    std::cerr << logging::Formatter::format(logging::format::err, record);
+}

src/logging/streams/stdout.cpp

@@ -1,17 +1,9 @@
 #include "logging/streams/stdout.hpp"
 
 #include <iostream>
-#include <fmt/format.h>
+#include "logging/streams/format.hpp"
 
 void Stdout::emit(const Log::Record& record)
 {
-    auto s = fmt::format("{} {:<5} [{}] {}\n", static_cast<std::string>(
-                         record.when()), record.level_str(), record.where(),
-                         record.text());
-
-    std::cout << s;
-
-    /* fmt::printf("{} {:<5} [{}] {}\n", static_cast<std::string>(record.when()), */
-    /*             record.level_str(), record.where(), record.text()); */
+    std::cout << logging::Formatter::format(logging::format::out, record);
 }
-

tests/unit/concurrent_map.cpp

@@ -1,5 +1,7 @@
 #include <iostream>
 
+#include "logging/default.hpp"
+#include "logging/streams/stdout.hpp"
 #include "data_structures/concurrent/concurrent_map.hpp"
 #include "utils/assert.hpp"
 
@@ -8,7 +10,8 @@ using std::endl;
 
 using skiplist_t = ConcurrentMap<int, int>;
 
-void print_skiplist(const skiplist_t::Accessor &skiplist) {
+void print_skiplist(const skiplist_t::Accessor &skiplist)
+{
     cout << "---- skiplist now has: ";
 
     for (auto &kv : skiplist)
@@ -17,12 +20,17 @@ void print_skiplist(const skiplist_t::Accessor &skiplist) {
     cout << "----" << endl;
 }
 
-int main(void) {
+int main(void)
+{
+    logging::init_async();
+    logging::log->pipe(std::make_unique<Stdout>());
+
     skiplist_t skiplist;
     auto accessor = skiplist.access();
 
     // insert 10
-  permanent_assert(accessor.insert(1, 10).second == true, "add first element");
+    permanent_assert(accessor.insert(1, 10).second == true,
+                     "add first element");
 
     // try insert 10 again (should fail)
     permanent_assert(accessor.insert(1, 10).second == false,