| Index: content/browser/trace_subscriber_stdio.cc
|
| ===================================================================
|
| --- content/browser/trace_subscriber_stdio.cc (revision 180062)
|
| +++ content/browser/trace_subscriber_stdio.cc (working copy)
|
| @@ -1,104 +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/trace_subscriber_stdio.h"
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/debug/trace_event.h"
|
| -#include "base/logging.h"
|
| -#include "base/threading/sequenced_worker_pool.h"
|
| -#include "content/public/browser/browser_thread.h"
|
| -
|
| -namespace content {
|
| -
|
| -// All method calls on this class are done on a SequencedWorkerPool thread.
|
| -class TraceSubscriberStdioImpl
|
| - : public base::RefCountedThreadSafe<TraceSubscriberStdioImpl> {
|
| - public:
|
| - explicit TraceSubscriberStdioImpl(const FilePath& path)
|
| - : path_(path),
|
| - file_(0) {}
|
| -
|
| - void OnStart() {
|
| - DCHECK(!file_);
|
| - trace_buffer_.SetOutputCallback(
|
| - base::Bind(&TraceSubscriberStdioImpl::Write, this));
|
| - file_ = file_util::OpenFile(path_, "w+");
|
| - if (IsValid()) {
|
| - LOG(INFO) << "Logging performance trace to file: " << path_.value();
|
| - trace_buffer_.Start();
|
| - } else {
|
| - LOG(ERROR) << "Failed to open performance trace file: " << path_.value();
|
| - }
|
| - }
|
| -
|
| - void OnData(const scoped_refptr<base::RefCountedString>& data_ptr) {
|
| - trace_buffer_.AddFragment(data_ptr->data());
|
| - }
|
| -
|
| - void OnEnd() {
|
| - trace_buffer_.Finish();
|
| - CloseFile();
|
| - }
|
| -
|
| - private:
|
| - friend class base::RefCountedThreadSafe<TraceSubscriberStdioImpl>;
|
| -
|
| - ~TraceSubscriberStdioImpl() {
|
| - CloseFile();
|
| - }
|
| -
|
| - bool IsValid() const {
|
| - return file_ && (0 == ferror(file_));
|
| - }
|
| -
|
| - void CloseFile() {
|
| - if (file_) {
|
| - fclose(file_);
|
| - file_ = 0;
|
| - }
|
| - // This is important, as it breaks a reference cycle.
|
| - trace_buffer_.SetOutputCallback(
|
| - base::debug::TraceResultBuffer::OutputCallback());
|
| - }
|
| -
|
| - void Write(const std::string& output_str) {
|
| - if (IsValid()) {
|
| - size_t written = fwrite(output_str.data(), 1, output_str.size(), file_);
|
| - if (written != output_str.size()) {
|
| - LOG(ERROR) << "Error " << ferror(file_) << " in fwrite() to trace file";
|
| - CloseFile();
|
| - }
|
| - }
|
| - }
|
| -
|
| - FilePath path_;
|
| - FILE* file_;
|
| - base::debug::TraceResultBuffer trace_buffer_;
|
| -};
|
| -
|
| -TraceSubscriberStdio::TraceSubscriberStdio(const FilePath& path)
|
| - : impl_(new TraceSubscriberStdioImpl(path)) {
|
| - BrowserThread::PostBlockingPoolSequencedTask(
|
| - __FILE__, FROM_HERE,
|
| - base::Bind(&TraceSubscriberStdioImpl::OnStart, impl_));
|
| -}
|
| -
|
| -TraceSubscriberStdio::~TraceSubscriberStdio() {
|
| -}
|
| -
|
| -void TraceSubscriberStdio::OnEndTracingComplete() {
|
| - BrowserThread::PostBlockingPoolSequencedTask(
|
| - __FILE__, FROM_HERE,
|
| - base::Bind(&TraceSubscriberStdioImpl::OnEnd, impl_));
|
| -}
|
| -
|
| -void TraceSubscriberStdio::OnTraceDataCollected(
|
| - const scoped_refptr<base::RefCountedString>& data_ptr) {
|
| - BrowserThread::PostBlockingPoolSequencedTask(
|
| - __FILE__, FROM_HERE,
|
| - base::Bind(&TraceSubscriberStdioImpl::OnData, impl_, data_ptr));
|
| -}
|
| -
|
| -} // namespace content
|
|
|