Moving WebRTC logging related files from content to chrome.

chrome/renderer/media/webrtc_logging_handler_impl.cc

 // Copyright (c) 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 "content/renderer/media/webrtc_logging_handler_impl.h"
+#include "chrome/renderer/media/webrtc_logging_handler_impl.h"
 
 #include "base/logging.h"
 #include "base/message_loop_proxy.h"
-#include "content/common/partial_circular_buffer.h"
-#include "content/renderer/media/webrtc_logging_message_filter.h"
-#include "third_party/libjingle/overrides/talk/base/logging.h"
-
-namespace content {
+#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)
-    : io_message_loop_(io_message_loop) {
+    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 (!io_message_loop_->BelongsToCurrentThread()) {
+  if (!CalledOnValidThread()) {
     io_message_loop_->PostTask(
         FROM_HERE, base::Bind(
             &WebRtcLoggingHandlerImpl::LogMessage,
             base::Unretained(this),
             message));
     return;
   }
 
-  circular_buffer_->Write(message.c_str(), message.length());
-  const char eol = '\n';
-  circular_buffer_->Write(&eol, 1);
+  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 content::PartialCircularBuffer(shared_memory_->memory(),
-                                         length,
-                                         length / 2));
-
-  talk_base::InitDiagnosticLoggingDelegate(this);
+      new PartialCircularBuffer(shared_memory_->memory(),
+                                length,
+                                length / 2));
 }
 
 void WebRtcLoggingHandlerImpl::OnOpenLogFailed() {
   DCHECK(CalledOnValidThread());
   DLOG(ERROR) << "Could not open log.";
   // TODO(grunell): Implement.
   NOTIMPLEMENTED();
 }
-
-}  // namespace content