| Index: services/debugger/debugger.cc
|
| diff --git a/services/debugger/debugger.cc b/services/debugger/debugger.cc
|
| deleted file mode 100644
|
| index 059c411889f1ca372e316bf7fb1ef8a49e8f4a09..0000000000000000000000000000000000000000
|
| --- a/services/debugger/debugger.cc
|
| +++ /dev/null
|
| @@ -1,224 +0,0 @@
|
| -// Copyright 2014 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 <algorithm>
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/debug/profiler.h"
|
| -#include "base/strings/string_number_conversions.h"
|
| -#include "base/strings/stringprintf.h"
|
| -#include "mojo/application/application_runner_chromium.h"
|
| -#include "mojo/data_pipe_utils/data_pipe_utils.h"
|
| -#include "mojo/public/c/system/main.h"
|
| -#include "mojo/public/cpp/application/application_delegate.h"
|
| -#include "mojo/public/cpp/application/application_impl.h"
|
| -#include "mojo/public/cpp/bindings/binding.h"
|
| -#include "mojo/services/http_server/cpp/http_server_util.h"
|
| -#include "mojo/services/http_server/interfaces/http_server.mojom.h"
|
| -#include "mojo/services/http_server/interfaces/http_server_factory.mojom.h"
|
| -#include "mojo/services/network/interfaces/net_address.mojom.h"
|
| -#include "mojo/services/tracing/interfaces/tracing.mojom.h"
|
| -#include "mojo/services/window_manager/interfaces/window_manager.mojom.h"
|
| -#include "services/debugger/trace_collector.h"
|
| -
|
| -// Debugger is a Mojo application that exposes an http server and talks to other
|
| -// mojo apps in response to url requests received by the server. Supported
|
| -// actions include tracing and profiling, allowing to interactively inspect how
|
| -// the shell is performing.
|
| -
|
| -namespace debugger {
|
| -
|
| -class Debugger : public mojo::ApplicationDelegate,
|
| - public http_server::HttpHandler {
|
| - public:
|
| - Debugger() : is_tracing_(false), app_(nullptr), handler_binding_(this) {}
|
| - ~Debugger() override {}
|
| -
|
| - private:
|
| - // mojo::ApplicationDelegate:
|
| - void Initialize(mojo::ApplicationImpl* app) override {
|
| - app_ = app;
|
| -
|
| - // Format: --args-for="app_url command_port"
|
| - if (app->args().size() < 2) {
|
| - LOG(ERROR) << "--args-for required to specify command_port";
|
| - mojo::ApplicationImpl::Terminate();
|
| - return;
|
| - }
|
| - if (app->args().size() == 3 && app->args()[2] == "--wm") {
|
| - // Connect to window manager only if requested, as the user might want to
|
| - // run the debugger without spawning one.
|
| - app_->ConnectToService("mojo:window_manager", &window_manager_);
|
| - }
|
| - base::StringToUint(app->args()[1], &command_port_);
|
| - http_server::HttpServerFactoryPtr http_server_factory;
|
| - app->ConnectToService("mojo:http_server", &http_server_factory);
|
| -
|
| - mojo::NetAddressPtr local_address(mojo::NetAddress::New());
|
| - local_address->family = mojo::NetAddressFamily::IPV4;
|
| - local_address->ipv4 = mojo::NetAddressIPv4::New();
|
| - local_address->ipv4->addr.resize(4);
|
| - local_address->ipv4->addr[0] = 127;
|
| - local_address->ipv4->addr[1] = 0;
|
| - local_address->ipv4->addr[2] = 0;
|
| - local_address->ipv4->addr[3] = 1;
|
| - local_address->ipv4->port = command_port_;
|
| - http_server_factory->CreateHttpServer(GetProxy(&http_server_).Pass(),
|
| - local_address.Pass());
|
| -
|
| - http_server::HttpHandlerPtr handler_ptr;
|
| - handler_binding_.Bind(GetProxy(&handler_ptr).Pass());
|
| - http_server_->SetHandler(".*", handler_ptr.Pass(),
|
| - [](bool result) { DCHECK(result); });
|
| - }
|
| -
|
| - bool ConfigureIncomingConnection(
|
| - mojo::ApplicationConnection* connection) override {
|
| - return true;
|
| - }
|
| -
|
| - // http_server::HttpHandler:
|
| - void HandleRequest(http_server::HttpRequestPtr request,
|
| - const HandleRequestCallback& callback) override {
|
| - // FIXME: We should use use a fancier lookup system more like what
|
| - // services/http_server/http_server.cc does with AddHandler.
|
| - if (request->relative_url == "/reload") {
|
| - Load(callback, url_);
|
| - } else if (request->relative_url == "/quit") {
|
| - Exit();
|
| - } else if (request->relative_url == "/load") {
|
| - std::string url;
|
| - mojo::common::BlockingCopyToString(request->body.Pass(), &url);
|
| - Load(callback, url);
|
| - } else if (request->relative_url == "/start_profiling") {
|
| - StartProfiling(callback);
|
| - } else if (request->relative_url == "/stop_profiling") {
|
| - StopProfiling(callback);
|
| - } else if (request->relative_url == "/start_tracing") {
|
| - StartTracing(callback);
|
| - } else if (request->relative_url == "/stop_tracing") {
|
| - StopTracing(callback);
|
| - } else {
|
| - Help(callback, request->relative_url);
|
| - }
|
| - }
|
| -
|
| - void Error(const HandleRequestCallback& callback, std::string message) {
|
| - callback.Run(http_server::CreateHttpResponse(500, message));
|
| - }
|
| -
|
| - void Respond(const HandleRequestCallback& callback, std::string response) {
|
| - callback.Run(http_server::CreateHttpResponse(200, response));
|
| - }
|
| -
|
| - void Help(const HandleRequestCallback& callback, std::string path) {
|
| - std::string help = base::StringPrintf(
|
| - "Sky Debugger running on port %d\n"
|
| - "Supported URLs:\n"
|
| - "/reload -- Reload the current page\n"
|
| - "/quit -- Quit\n"
|
| - "/load -- Load a new URL, url in POST body.\n",
|
| - command_port_);
|
| - if (path != "/")
|
| - help = "Unknown path: " + path + "\n\n" + help;
|
| - Respond(callback, help);
|
| - }
|
| -
|
| - void Load(const HandleRequestCallback& callback, std::string url) {
|
| - url_ = url;
|
| - Reload();
|
| - std::string response = std::string("Loaded ") + url + "\n";
|
| - Respond(callback, response);
|
| - }
|
| -
|
| - void Reload() {
|
| - if (!window_manager_) {
|
| - // If window_manager_ was not connected to eagerly on startup, we do that
|
| - // on the first demand.
|
| - app_->ConnectToService("mojo:window_manager", &window_manager_);
|
| - }
|
| -
|
| - // SimpleWindowManager will wire up necessary services on our behalf.
|
| - window_manager_->Embed(url_, nullptr, nullptr);
|
| - }
|
| -
|
| - void Exit() {
|
| - // TODO(eseidel): We should orderly shutdown once mojo can.
|
| - exit(0);
|
| - }
|
| -
|
| - void StartTracing(const HandleRequestCallback& callback) {
|
| - if (is_tracing_) {
|
| - Error(callback, "Already tracing. Use stop_tracing to stop.\n");
|
| - return;
|
| - }
|
| -
|
| - if (!tracing_)
|
| - app_->ConnectToService("mojo:tracing", &tracing_);
|
| - is_tracing_ = true;
|
| - mojo::DataPipe pipe;
|
| - tracing_->Start(pipe.producer_handle.Pass(), mojo::String("*"));
|
| - trace_collector_.reset(new TraceCollector(pipe.consumer_handle.Pass()));
|
| - Respond(callback, "Starting trace (type 'stop_tracing' to stop)\n");
|
| - }
|
| -
|
| - void StopTracing(const HandleRequestCallback& callback) {
|
| - if (!is_tracing_) {
|
| - Error(callback, "Not tracing yet. Use start_tracing to start.\n");
|
| - return;
|
| - }
|
| -
|
| - is_tracing_ = false;
|
| - tracing_->StopAndFlush();
|
| - trace_collector_->GetTrace(base::Bind(&Debugger::OnTraceAvailable,
|
| - base::Unretained(this), callback));
|
| - }
|
| -
|
| - void OnTraceAvailable(HandleRequestCallback callback, std::string trace) {
|
| - trace_collector_.reset();
|
| - Respond(callback, trace);
|
| - }
|
| -
|
| - void StartProfiling(const HandleRequestCallback& callback) {
|
| -#if !defined(NDEBUG) || !defined(ENABLE_PROFILING)
|
| - Error(callback,
|
| - "Profiling requires is_debug=false and enable_profiling=true");
|
| - return;
|
| -#else
|
| - base::debug::StartProfiling("sky_viewer.pprof");
|
| - Respond(callback, "Starting profiling (stop with 'stop_profiling')");
|
| -#endif
|
| - }
|
| -
|
| - void StopProfiling(const HandleRequestCallback& callback) {
|
| - if (!base::debug::BeingProfiled()) {
|
| - Error(callback, "Profiling not started");
|
| - return;
|
| - }
|
| - base::debug::StopProfiling();
|
| - Respond(callback, "Stopped profiling");
|
| - }
|
| -
|
| - bool is_tracing_;
|
| - mojo::ApplicationImpl* app_;
|
| - mojo::WindowManagerPtr window_manager_;
|
| - tracing::TraceCollectorPtr tracing_;
|
| - std::string url_;
|
| - uint32_t command_port_;
|
| -
|
| - http_server::HttpServerPtr http_server_;
|
| - mojo::Binding<http_server::HttpHandler> handler_binding_;
|
| -
|
| - scoped_ptr<TraceCollector> trace_collector_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(Debugger);
|
| -};
|
| -
|
| -} // namespace debugger
|
| -
|
| -MojoResult MojoMain(MojoHandle application_request) {
|
| - mojo::ApplicationRunnerChromium runner(new debugger::Debugger);
|
| - runner.set_message_loop_type(base::MessageLoop::TYPE_IO);
|
| - return runner.Run(application_request);
|
| -}
|
|
|