src/chrome/renderer/media/chrome_webrtc_log_message_delegate.cc

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