X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/24bebc0ecf83446c7371eff69042322aab34976a..c279db4240a3a3c30f069ab9dea8055cf94280da:/threaded_log.cc

diff --git a/threaded_log.cc b/threaded_log.cc
index c44266e..3218e33 100644
--- a/threaded_log.cc
+++ b/threaded_log.cc
@@ -1,8 +1,34 @@
+#include "t4.h"
+#include "types.h"
 #include "threaded_log.h"
 
-mutex cerr_mutex;
-map<thread::id, int> thread_name_map;
-int next_thread_num = 0;
-map<void *, int> instance_name_map;
-int next_instance_num = 0;
-int DEBUG_LEVEL = 0;
+using namespace std::chrono;
+
+locked_ostream && _log_prefix(locked_ostream && f, const string & file, const string & func) {
+    auto thread = std::this_thread::get_id();
+    int tid = global->thread_name_map[thread];
+    if (tid==0)
+        tid = global->thread_name_map[thread] = ++global->next_thread_num;
+    auto utime = duration_cast<microseconds>(
+            system_clock::now().time_since_epoch()).count() % 1000000000;
+    f << std::setfill('0') << std::dec << std::left << std::setw(9) << utime << " ";
+    f << std::setfill(' ') << global->log_thread_prefix << std::left << std::setw(2) << tid;
+    f << " " << std::setw(20) << file << " " << std::setw(18) << func;
+    return std::move(f);
+}
+
+locked_ostream && _log_member(locked_ostream && f, const void *ptr) {
+    int id = global->instance_name_map[ptr];
+    if (id == 0)
+        id = global->instance_name_map[ptr] = ++global->next_instance_num;
+    f << "#" << std::left << std::setw(2) << id << " ";
+    return std::move(f);
+}
+
+int _log_debug_level() {
+    return global->DEBUG_LEVEL;
+}
+
+lock _log_lock() {
+    return lock(global->log_mutex);
+}