1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
// Copyright 2013 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chrome/renderer/media/webrtc_logging_handler_impl.h"
#include "base/logging.h"
#include "base/message_loop/message_loop_proxy.h"
#include "chrome/common/partial_circular_buffer.h"
#include "chrome/renderer/media/webrtc_logging_message_filter.h"
WebRtcLoggingHandlerImpl::WebRtcLoggingHandlerImpl(
const scoped_refptr<base::MessageLoopProxy>& io_message_loop,
WebRtcLoggingMessageFilter* message_filter)
: io_message_loop_(io_message_loop),
message_filter_(message_filter),
log_initialized_(false) {
content::InitWebRtcLoggingDelegate(this);
}
WebRtcLoggingHandlerImpl::~WebRtcLoggingHandlerImpl() {
DCHECK(CalledOnValidThread());
}
void WebRtcLoggingHandlerImpl::InitLogging(const std::string& app_session_id,
const std::string& app_url) {
DCHECK(CalledOnValidThread());
if (!log_initialized_) {
log_initialized_ = true;
message_filter_->InitLogging(app_session_id, app_url);
}
}
void WebRtcLoggingHandlerImpl::LogMessage(const std::string& message) {
if (!CalledOnValidThread()) {
io_message_loop_->PostTask(
FROM_HERE, base::Bind(
&WebRtcLoggingHandlerImpl::LogMessage,
base::Unretained(this),
message));
return;
}
if (circular_buffer_) {
circular_buffer_->Write(message.c_str(), message.length());
const char eol = '\n';
circular_buffer_->Write(&eol, 1);
}
}
void WebRtcLoggingHandlerImpl::OnFilterRemoved() {
DCHECK(CalledOnValidThread());
message_filter_ = NULL;
}
void WebRtcLoggingHandlerImpl::OnLogOpened(
base::SharedMemoryHandle handle,
uint32 length) {
DCHECK(CalledOnValidThread());
shared_memory_.reset(new base::SharedMemory(handle, false));
CHECK(shared_memory_->Map(length));
circular_buffer_.reset(
new PartialCircularBuffer(shared_memory_->memory(),
length,
length / 2));
}
void WebRtcLoggingHandlerImpl::OnOpenLogFailed() {
DCHECK(CalledOnValidThread());
DLOG(ERROR) << "Could not open log.";
// TODO(grunell): Implement.
NOTIMPLEMENTED();
}
|
