Remove TraceController

content/browser/tracing/trace_controller_impl.cc

Index: content/browser/tracing/trace_controller_impl.cc
diff --git a/content/browser/tracing/trace_controller_impl.cc b/content/browser/tracing/trace_controller_impl.cc
deleted file mode 100644
index 8b8433848aba0d96be432bd0b16d354ded6b0265..0000000000000000000000000000000000000000
--- a/content/browser/tracing/trace_controller_impl.cc
+++ /dev/null
@@ -1,371 +0,0 @@
-// Copyright (c) 2012 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/browser/tracing/trace_controller_impl.h"
-
-#include "base/bind.h"
-#include "base/command_line.h"
-#include "base/debug/trace_event.h"
-#include "base/strings/string_number_conversions.h"
-#include "components/tracing/tracing_messages.h"
-#include "content/browser/tracing/trace_message_filter.h"
-#include "content/browser/tracing/trace_subscriber_stdio.h"
-#include "content/common/child_process_messages.h"
-#include "content/public/browser/browser_message_filter.h"
-#include "content/public/common/content_switches.h"
-
-using base::debug::TraceLog;
-
-namespace content {
-
-namespace {
-
-base::LazyInstance<TraceControllerImpl>::Leaky g_controller =
-    LAZY_INSTANCE_INITIALIZER;
-
-}  // namespace
-
-TraceController* TraceController::GetInstance() {
-  return TraceControllerImpl::GetInstance();
-}
-
-TraceControllerImpl::TraceControllerImpl() :
-    subscriber_(NULL),
-    pending_end_ack_count_(0),
-    pending_bpf_ack_count_(0),
-    maximum_bpf_(0.0f),
-    is_tracing_(false),
-    is_get_category_groups_(false),
-    category_filter_(
-        base::debug::CategoryFilter::kDefaultCategoryFilterString) {
-  TraceLog::GetInstance()->SetNotificationCallback(
-      base::Bind(&TraceControllerImpl::OnTraceNotification,
-                 base::Unretained(this)));
-}
-
-TraceControllerImpl::~TraceControllerImpl() {
-  // No need to SetNotificationCallback(nil) on the TraceLog since this is a
-  // Leaky instance.
-  NOTREACHED();
-}
-
-TraceControllerImpl* TraceControllerImpl::GetInstance() {
-  return g_controller.Pointer();
-}
-
-bool TraceControllerImpl::GetKnownCategoryGroupsAsync(
-    TraceSubscriber* subscriber) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-
-  // Known categories come back from child processes with the EndTracingAck
-  // message. So to get known categories, just begin and end tracing immediately
-  // afterwards. This will ping all the child processes for categories.
-  is_get_category_groups_ = true;
-  bool success = BeginTracing(subscriber, "*",
-                              TraceLog::GetInstance()->trace_options()) &&
-                 EndTracingAsync(subscriber);
-  is_get_category_groups_ = success;
-  return success;
-}
-
-bool TraceControllerImpl::BeginTracing(TraceSubscriber* subscriber,
-                                       const std::string& category_patterns,
-                                       base::debug::TraceLog::Options options) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-
-  if (!can_begin_tracing(subscriber))
-    return false;
-
-#if defined(OS_ANDROID)
-  if (!is_get_category_groups_)
-    TraceLog::GetInstance()->AddClockSyncMetadataEvent();
-#endif
-
-  // Enable tracing
-  TraceLog::GetInstance()->SetEnabled(
-      base::debug::CategoryFilter(category_patterns), options);
-
-  OnTracingBegan(subscriber);
-
-  return true;
-}
-
-bool TraceControllerImpl::EndTracingAsync(TraceSubscriber* subscriber) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-
-  if (!can_end_tracing() || subscriber != subscriber_)
-    return false;
-
-  // Disable local trace early to avoid traces during end-tracing process from
-  // interfering with the process.
-  TraceLog::GetInstance()->SetDisabled();
-
-#if defined(OS_ANDROID)
-  if (!is_get_category_groups_)
-    TraceLog::GetInstance()->AddClockSyncMetadataEvent();
-#endif
-
-  // There could be a case where there are no child processes and filters_
-  // is empty. In that case we can immediately tell the subscriber that tracing
-  // has ended. To avoid recursive calls back to the subscriber, we will just
-  // use the existing asynchronous OnEndTracingAck code.
-  // Count myself (local trace) in pending_end_ack_count_, acked below.
-  pending_end_ack_count_ = filters_.size() + 1;
-
-  // Handle special case of zero child processes.
-  if (pending_end_ack_count_ == 1) {
-    // Ack asynchronously now, because we don't have any children to wait for.
-    std::vector<std::string> category_groups;
-    TraceLog::GetInstance()->GetKnownCategoryGroups(&category_groups);
-    BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-        base::Bind(&TraceControllerImpl::OnEndTracingAck,
-                   base::Unretained(this), category_groups));
-  }
-
-  // Notify all child processes.
-  for (FilterMap::iterator it = filters_.begin(); it != filters_.end(); ++it) {
-    it->get()->SendEndTracing();
-  }
-
-  return true;
-}
-
-bool TraceControllerImpl::GetTraceBufferPercentFullAsync(
-    TraceSubscriber* subscriber) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-
-  if (!can_get_buffer_percent_full() || subscriber != subscriber_)
-    return false;
-
-  maximum_bpf_ = 0.0f;
-  pending_bpf_ack_count_ = filters_.size() + 1;
-
-  // Handle special case of zero child processes.
-  if (pending_bpf_ack_count_ == 1) {
-    // Ack asynchronously now, because we don't have any children to wait for.
-    float bpf = TraceLog::GetInstance()->GetBufferPercentFull();
-    BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-        base::Bind(&TraceControllerImpl::OnTraceBufferPercentFullReply,
-                   base::Unretained(this), bpf));
-  }
-
-  // Message all child processes.
-  for (FilterMap::iterator it = filters_.begin(); it != filters_.end(); ++it) {
-    it->get()->SendGetTraceBufferPercentFull();
-  }
-
-  return true;
-}
-
-bool TraceControllerImpl::SetWatchEvent(TraceSubscriber* subscriber,
-                                        const std::string& category_name,
-                                        const std::string& event_name) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-  if (subscriber != subscriber_)
-    return false;
-
-  watch_category_ = category_name;
-  watch_name_ = event_name;
-
-  TraceLog::GetInstance()->SetWatchEvent(category_name, event_name);
-  for (FilterMap::iterator it = filters_.begin(); it != filters_.end(); ++it)
-    it->get()->SendSetWatchEvent(category_name, event_name);
-
-  return true;
-}
-
-bool TraceControllerImpl::CancelWatchEvent(TraceSubscriber* subscriber) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-  if (subscriber != subscriber_)
-    return false;
-
-  watch_category_.clear();
-  watch_name_.clear();
-
-  TraceLog::GetInstance()->CancelWatchEvent();
-  for (FilterMap::iterator it = filters_.begin(); it != filters_.end(); ++it)
-    it->get()->SendCancelWatchEvent();
-
-  return true;
-}
-
-void TraceControllerImpl::CancelSubscriber(TraceSubscriber* subscriber) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-
-  if (subscriber == subscriber_) {
-    subscriber_ = NULL;
-    // End tracing if necessary.
-    if (is_tracing_ && pending_end_ack_count_ == 0)
-      EndTracingAsync(NULL);
-  }
-}
-
-void TraceControllerImpl::AddFilter(TraceMessageFilter* filter) {
-  if (!BrowserThread::CurrentlyOn(BrowserThread::UI)) {
-    BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-        base::Bind(&TraceControllerImpl::AddFilter, base::Unretained(this),
-                   make_scoped_refptr(filter)));
-    return;
-  }
-
-  filters_.insert(filter);
-  if (is_tracing_enabled()) {
-    std::string cf_str = category_filter_.ToString();
-    filter->SendBeginTracing(cf_str, trace_options_);
-    if (!watch_category_.empty())
-      filter->SendSetWatchEvent(watch_category_, watch_name_);
-  }
-}
-
-void TraceControllerImpl::RemoveFilter(TraceMessageFilter* filter) {
-  if (!BrowserThread::CurrentlyOn(BrowserThread::UI)) {
-    BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-        base::Bind(&TraceControllerImpl::RemoveFilter, base::Unretained(this),
-                   make_scoped_refptr(filter)));
-    return;
-  }
-
-  filters_.erase(filter);
-}
-
-void TraceControllerImpl::OnTracingBegan(TraceSubscriber* subscriber) {
-  is_tracing_ = true;
-
-  subscriber_ = subscriber;
-
-  category_filter_ = TraceLog::GetInstance()->GetCurrentCategoryFilter();
-  trace_options_ = TraceLog::GetInstance()->trace_options();
-
-  // Notify all child processes.
-  for (FilterMap::iterator it = filters_.begin(); it != filters_.end(); ++it) {
-    it->get()->SendBeginTracing(category_filter_.ToString(), trace_options_);
-  }
-}
-
-void TraceControllerImpl::OnEndTracingAck(
-    const std::vector<std::string>& known_category_groups) {
-  if (!BrowserThread::CurrentlyOn(BrowserThread::UI)) {
-    BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-        base::Bind(&TraceControllerImpl::OnEndTracingAck,
-                   base::Unretained(this), known_category_groups));
-    return;
-  }
-
-  // Merge known_category_groups with known_category_groups_
-  known_category_groups_.insert(known_category_groups.begin(),
-                                known_category_groups.end());
-
-  if (pending_end_ack_count_ == 0)
-    return;
-
-
-  if (--pending_end_ack_count_ == 1) {
-    // All acks from subprocesses have been received. Now flush the local trace.
-    // During or after this call, our OnLocalTraceDataCollected will be
-    // called with the last of the local trace data.
-    TraceLog::GetInstance()->Flush(
-        base::Bind(&TraceControllerImpl::OnLocalTraceDataCollected,
-                   base::Unretained(this)));
-  }
-
-  if (pending_end_ack_count_ == 0) {
-    // All acks (including from the subprocesses and the local trace) have been
-    // received.
-    is_tracing_ = false;
-
-    // Trigger callback if one is set.
-    if (subscriber_) {
-      if (is_get_category_groups_)
-        subscriber_->OnKnownCategoriesCollected(known_category_groups_);
-      else
-        subscriber_->OnEndTracingComplete();
-      // Clear subscriber so that others can use TraceController.
-      subscriber_ = NULL;
-    }
-
-    is_get_category_groups_ = false;
-  }
-}
-
-void TraceControllerImpl::OnTraceDataCollected(
-    const scoped_refptr<base::RefCountedString>& events_str_ptr) {
-  // OnTraceDataCollected may be called from any browser thread, either by the
-  // local event trace system or from child processes via TraceMessageFilter.
-  if (!BrowserThread::CurrentlyOn(BrowserThread::UI)) {
-    BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-        base::Bind(&TraceControllerImpl::OnTraceDataCollected,
-                   base::Unretained(this), events_str_ptr));
-    return;
-  }
-
-  // Drop trace events if we are just getting categories.
-  if (subscriber_ && !is_get_category_groups_)
-    subscriber_->OnTraceDataCollected(events_str_ptr);
-}
-
-void TraceControllerImpl::OnLocalTraceDataCollected(
-    const scoped_refptr<base::RefCountedString>& events_str_ptr,
-    bool has_more_events) {
-  if (events_str_ptr->data().size())
-    OnTraceDataCollected(events_str_ptr);
-
-  if (!has_more_events) {
-    // Simulate an EndTrackingAck for the local trace.
-    std::vector<std::string> category_groups;
-    TraceLog::GetInstance()->GetKnownCategoryGroups(&category_groups);
-    OnEndTracingAck(category_groups);
-  }
-}
-
-void TraceControllerImpl::OnTraceNotification(int notification) {
-  // OnTraceNotification may be called from any browser thread, either by the
-  // local event trace system or from child processes via TraceMessageFilter.
-  if (!BrowserThread::CurrentlyOn(BrowserThread::UI)) {
-    BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-        base::Bind(&TraceControllerImpl::OnTraceNotification,
-                   base::Unretained(this), notification));
-    return;
-  }
-
-  if (notification & base::debug::TraceLog::TRACE_BUFFER_FULL) {
-    // EndTracingAsync may return false if tracing is already in the process
-    // of being ended. That is ok.
-    EndTracingAsync(subscriber_);
-  }
-  if (notification & base::debug::TraceLog::EVENT_WATCH_NOTIFICATION) {
-    if (subscriber_)
-      subscriber_->OnEventWatchNotification();
-  }
-}
-
-void TraceControllerImpl::OnTraceBufferPercentFullReply(float percent_full) {
-  if (!BrowserThread::CurrentlyOn(BrowserThread::UI)) {
-    BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-        base::Bind(&TraceControllerImpl::OnTraceBufferPercentFullReply,
-                   base::Unretained(this), percent_full));
-    return;
-  }
-
-  if (pending_bpf_ack_count_ == 0)
-    return;
-
-  maximum_bpf_ = (maximum_bpf_ > percent_full)? maximum_bpf_ : percent_full;
-
-  if (--pending_bpf_ack_count_ == 0) {
-    // Trigger callback if one is set.
-    if (subscriber_)
-      subscriber_->OnTraceBufferPercentFullReply(maximum_bpf_);
-  }
-
-  if (pending_bpf_ack_count_ == 1) {
-    // The last ack represents local trace, so we need to ack it now. Note that
-    // this code only executes if there were child processes.
-    float bpf = TraceLog::GetInstance()->GetBufferPercentFull();
-    BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-        base::Bind(&TraceControllerImpl::OnTraceBufferPercentFullReply,
-                   base::Unretained(this), bpf));
-  }
-}
-
-}  // namespace content