| Index: webrtc/logging/rtc_event_log/rtc_event_log_helper_thread.cc
|
| diff --git a/webrtc/logging/rtc_event_log/rtc_event_log_helper_thread.cc b/webrtc/logging/rtc_event_log/rtc_event_log_helper_thread.cc
|
| index 4d55da354230ff806d8683504b79aa68a24b992f..e7edd9a93c07d86f40fe6be07a73872a91e2e01e 100644
|
| --- a/webrtc/logging/rtc_event_log/rtc_event_log_helper_thread.cc
|
| +++ b/webrtc/logging/rtc_event_log/rtc_event_log_helper_thread.cc
|
| @@ -13,6 +13,7 @@
|
| #include <algorithm>
|
|
|
| #include "webrtc/base/checks.h"
|
| +#include "webrtc/base/timeutils.h"
|
| #include "webrtc/system_wrappers/include/logging.h"
|
|
|
| #ifdef ENABLE_RTC_EVENT_LOG
|
| @@ -34,8 +35,7 @@ bool IsConfigEvent(const rtclog::Event& event) {
|
| // RtcEventLogImpl member functions.
|
| RtcEventLogHelperThread::RtcEventLogHelperThread(
|
| SwapQueue<ControlMessage>* message_queue,
|
| - SwapQueue<std::unique_ptr<rtclog::Event>>* event_queue,
|
| - const Clock* const clock)
|
| + SwapQueue<std::unique_ptr<rtclog::Event>>* event_queue)
|
| : message_queue_(message_queue),
|
| event_queue_(event_queue),
|
| history_(kEventsInHistory),
|
| @@ -51,18 +51,16 @@ RtcEventLogHelperThread::RtcEventLogHelperThread(
|
| output_string_(),
|
| wake_periodically_(false, false),
|
| wake_from_hibernation_(false, false),
|
| - file_finished_(false, false),
|
| - clock_(clock) {
|
| + file_finished_(false, false) {
|
| RTC_DCHECK(message_queue_);
|
| RTC_DCHECK(event_queue_);
|
| - RTC_DCHECK(clock_);
|
| thread_.Start();
|
| }
|
|
|
| RtcEventLogHelperThread::~RtcEventLogHelperThread() {
|
| ControlMessage message;
|
| message.message_type = ControlMessage::TERMINATE_THREAD;
|
| - message.stop_time = clock_->TimeInMicroseconds();
|
| + message.stop_time = rtc::TimeMicros();
|
| while (!message_queue_->Insert(&message)) {
|
| // We can't destroy the event log until we have stopped the thread,
|
| // so clear the message queue and try again. Note that if we clear
|
| @@ -112,7 +110,7 @@ bool RtcEventLogHelperThread::LogToMemory() {
|
|
|
| // Process each event earlier than the current time and append it to the
|
| // appropriate history_.
|
| - int64_t current_time = clock_->TimeInMicroseconds();
|
| + int64_t current_time = rtc::TimeMicros();
|
| if (!has_recent_event_) {
|
| has_recent_event_ = event_queue_->Remove(&most_recent_event_);
|
| }
|
| @@ -180,7 +178,7 @@ bool RtcEventLogHelperThread::LogToFile() {
|
|
|
| // Append each event older than both the current time and the stop time
|
| // to the output_string_.
|
| - int64_t current_time = clock_->TimeInMicroseconds();
|
| + int64_t current_time = rtc::TimeMicros();
|
| int64_t time_limit = std::min(current_time, stop_time_);
|
| if (!has_recent_event_) {
|
| has_recent_event_ = event_queue_->Remove(&most_recent_event_);
|
| @@ -228,7 +226,7 @@ void RtcEventLogHelperThread::StopLogFile() {
|
| // or because we have reached the log file size limit. Therefore, use the
|
| // current time if we have not reached the time limit.
|
| end_event.set_timestamp_us(
|
| - std::min(stop_time_, clock_->TimeInMicroseconds()));
|
| + std::min(stop_time_, rtc::TimeMicros()));
|
| end_event.set_type(rtclog::Event::LOG_END);
|
| AppendEventToString(&end_event);
|
|
|
|
|