OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "remoting/host/native_messaging/log_message_handler.h" | 5 #include "remoting/host/native_messaging/log_message_handler.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/lazy_instance.h" | 8 #include "base/lazy_instance.h" |
9 #include "base/single_thread_task_runner.h" | 9 #include "base/single_thread_task_runner.h" |
10 #include "base/strings/string_util.h" | 10 #include "base/strings/string_util.h" |
(...skipping 19 matching lines...) Expand all Loading... |
30 const Delegate& delegate) | 30 const Delegate& delegate) |
31 : delegate_(delegate), | 31 : delegate_(delegate), |
32 suppress_logging_(false), | 32 suppress_logging_(false), |
33 caller_task_runner_(base::ThreadTaskRunnerHandle::Get()), | 33 caller_task_runner_(base::ThreadTaskRunnerHandle::Get()), |
34 weak_ptr_factory_(this) { | 34 weak_ptr_factory_(this) { |
35 base::AutoLock lock(g_log_message_handler_lock.Get()); | 35 base::AutoLock lock(g_log_message_handler_lock.Get()); |
36 if (g_log_message_handler) { | 36 if (g_log_message_handler) { |
37 LOG(FATAL) << "LogMessageHandler is already registered. Only one instance " | 37 LOG(FATAL) << "LogMessageHandler is already registered. Only one instance " |
38 << "per process is allowed."; | 38 << "per process is allowed."; |
39 } | 39 } |
40 previous_log_message_handler_ = logging::GetLogMessageHandler(); | |
41 logging::SetLogMessageHandler(&LogMessageHandler::OnLogMessage); | |
42 g_log_message_handler = this; | 40 g_log_message_handler = this; |
43 } | 41 } |
44 | 42 |
45 LogMessageHandler::~LogMessageHandler() { | 43 LogMessageHandler::~LogMessageHandler() { |
46 base::AutoLock lock(g_log_message_handler_lock.Get()); | 44 base::AutoLock lock(g_log_message_handler_lock.Get()); |
47 if (logging::GetLogMessageHandler() != &LogMessageHandler::OnLogMessage) { | |
48 LOG(FATAL) << "LogMessageHandler is not the top-most message handler. " | |
49 << "Cannot unregister."; | |
50 } | |
51 logging::SetLogMessageHandler(previous_log_message_handler_); | |
52 g_log_message_handler = nullptr; | 45 g_log_message_handler = nullptr; |
53 } | 46 } |
54 | 47 |
55 // static | 48 // static |
56 const char* LogMessageHandler::kDebugMessageTypeName = "_debug_log"; | 49 const char* LogMessageHandler::kDebugMessageTypeName = "_debug_log"; |
57 | 50 |
58 // static | 51 bool LogMessageHandler::OnMessage(logging::LogSeverity severity, |
59 bool LogMessageHandler::OnLogMessage( | 52 const char* file, |
60 logging::LogSeverity severity, | 53 int line, |
61 const char* file, | 54 size_t message_start, |
62 int line, | 55 const std::string& str) { |
63 size_t message_start, | |
64 const std::string& str) { | |
65 base::AutoLock lock(g_log_message_handler_lock.Get()); | 56 base::AutoLock lock(g_log_message_handler_lock.Get()); |
66 if (g_log_message_handler) { | 57 if (g_log_message_handler) { |
67 g_log_message_handler->PostLogMessageToCorrectThread( | 58 g_log_message_handler->PostLogMessageToCorrectThread( |
68 severity, file, line, message_start, str); | 59 severity, file, line, message_start, str); |
69 } | 60 } |
70 return false; | 61 return false; |
71 } | 62 } |
72 | 63 |
73 void LogMessageHandler::PostLogMessageToCorrectThread( | 64 void LogMessageHandler::PostLogMessageToCorrectThread( |
74 logging::LogSeverity severity, | 65 logging::LogSeverity severity, |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
124 dictionary->SetString("message", message); | 115 dictionary->SetString("message", message); |
125 dictionary->SetString("file", file); | 116 dictionary->SetString("file", file); |
126 dictionary->SetInteger("line", line); | 117 dictionary->SetInteger("line", line); |
127 | 118 |
128 delegate_.Run(std::move(dictionary)); | 119 delegate_.Run(std::move(dictionary)); |
129 | 120 |
130 suppress_logging_ = false; | 121 suppress_logging_ = false; |
131 } | 122 } |
132 | 123 |
133 } // namespace remoting | 124 } // namespace remoting |
OLD | NEW |