Code dump.

internal/platform/implementation/linux/log_message.cc

@@ -0,0 +1,111 @@
+#include <cassert>
+#include <cstdarg>
+#include <cstdio>
+#include <cstdlib>
+#include <ctime>
+#include <memory>
+#include <sys/syslog.h>
+
+#define SD_JOURNAL_SUPPRESS_LOCATION true
+#include <systemd/sd-journal.h>
+
+#include "absl/base/call_once.h"
+#include "internal/platform/implementation/linux/dbus.h"
+#include "internal/platform/implementation/linux/log_message.h"
+
+namespace nearby {
+static std::unique_ptr<linux::LogControl> global_log_control_;
+static absl::once_flag log_control_init_;
+
+static void init_log_control() {
+  global_log_control_ =
+      std::make_unique<linux::LogControl>(linux::getDefaultBusConnection());
+}
+
+namespace api {
+void LogMessage::SetMinLogSeverity(Severity severity) {
+  absl::call_once(log_control_init_, init_log_control, nullptr);
+  assert(global_log_control_ != nullptr);
+  global_log_control_->LogLevel(severity);
+}
+
+bool LogMessage::ShouldCreateLogMessage(Severity severity) {
+  absl::call_once(log_control_init_, init_log_control, nullptr);
+  assert(global_log_control_ != nullptr);
+  return severity >= global_log_control_->GetLogLevel();
+}
+
+} // namespace api
+namespace linux {
+
+static inline int ConvertSeverityToSyslog(google::LogSeverity severity) {
+  switch (severity) {
+  case google::GLOG_WARNING:
+    return LOG_WARNING;
+  case google::GLOG_ERROR:
+    return LOG_ERR;
+  case google::GLOG_FATAL:
+    return LOG_EMERG;
+  case google::GLOG_INFO:
+  default:
+    return LOG_INFO;
+  }
+}
+
+void LogControl::send(google::LogSeverity severity, const char *full_filename,
+                      const char *base_filename, int line,
+                      const struct ::tm *tm_time, const char *message,
+                      size_t message_len) {
+  switch (log_target_) {
+  case kJournal:
+    sd_journal_send("MESSAGE=%s", message, "PRIORITY=%d",
+                    ConvertSeverityToSyslog(severity), "CODE_FILE=%s",
+                    base_filename, "CODE_LINE=%d", line, NULL);
+    break;
+  case kSyslog: {
+    auto str = LogSink::ToString(severity, base_filename, line, tm_time,
+                                 message, message_len);
+    syslog(ConvertSeverityToSyslog(severity), "%s", str.c_str());
+  }
+  case kConsole:
+  default:
+    std::cout << LogSink::ToString(severity, base_filename, line, tm_time,
+                                   message, message_len)
+              << "\n";
+    break;
+  }
+}
+
+static inline google::LogSeverity
+ConvertSeverity(api::LogMessage::Severity severity) {
+  switch (severity) {
+  case api::LogMessage::Severity::kVerbose:
+  case api::LogMessage::Severity::kInfo:
+    return google::GLOG_INFO;
+  case api::LogMessage::Severity::kWarning:
+    return google::GLOG_WARNING;
+  case api::LogMessage::Severity::kError:
+    return google::GLOG_ERROR;
+  case api::LogMessage::Severity::kFatal:
+    return google::GLOG_FATAL;
+  }
+}
+
+// TODO: Set a LogSink depending on the target set by LogControl
+LogMessage::LogMessage(const char *file, int line, Severity severity)
+    : log_streamer_(file, line, ConvertSeverity(severity),
+                    global_log_control_.get(), false) {}
+
+void LogMessage::Print(const char *format, ...) {
+  va_list ap;
+  va_start(ap, format);
+  char *buf = nullptr;
+  vasprintf(&buf, format, ap);
+  va_end(ap);
+  log_streamer_.stream() << std::string(buf);
+}
+
+std::ostream &LogMessage::Stream() { return log_streamer_.stream(); }
+
+} // namespace linux
+} // namespace nearby