| Index: sky/tools/debugger/prompt/prompt.cc
|
| diff --git a/sky/tools/debugger/prompt/prompt.cc b/sky/tools/debugger/prompt/prompt.cc
|
| deleted file mode 100644
|
| index f46aaeee5626163fef6580a0ade825cb457a1074..0000000000000000000000000000000000000000
|
| --- a/sky/tools/debugger/prompt/prompt.cc
|
| +++ /dev/null
|
| @@ -1,230 +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/memory/weak_ptr.h"
|
| -#include "base/strings/string_number_conversions.h"
|
| -#include "base/strings/stringprintf.h"
|
| -#include "mojo/application/application_runner_chromium.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 "net/base/net_errors.h"
|
| -#include "net/server/http_server.h"
|
| -#include "net/server/http_server_request_info.h"
|
| -#include "net/socket/tcp_server_socket.h"
|
| -#include "services/tracing/tracing.mojom.h"
|
| -#include "sky/tools/debugger/debugger.mojom.h"
|
| -#include "sky/tools/debugger/prompt/trace_collector.h"
|
| -
|
| -namespace sky {
|
| -namespace debugger {
|
| -namespace {
|
| -
|
| -const size_t kMinSendBufferSize = 1024 * 1024;
|
| -}
|
| -
|
| -class Prompt : public mojo::ApplicationDelegate,
|
| - public net::HttpServer::Delegate {
|
| - public:
|
| - Prompt()
|
| - : is_tracing_(false),
|
| - weak_ptr_factory_(this) {
|
| - }
|
| - virtual ~Prompt() {
|
| - }
|
| -
|
| - private:
|
| - // Overridden from mojo::ApplicationDelegate:
|
| - virtual void Initialize(mojo::ApplicationImpl* app) override {
|
| - app->ConnectToService("mojo:tracing", &tracing_);
|
| - // 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;
|
| - }
|
| -
|
| - base::StringToUint(app->args()[1], &command_port_);
|
| -
|
| - scoped_ptr<net::ServerSocket> server_socket(
|
| - new net::TCPServerSocket(NULL, net::NetLog::Source()));
|
| - int result = server_socket->ListenWithAddressAndPort("0.0.0.0", command_port_, 1);
|
| - if (result != net::OK) {
|
| - LOG(ERROR) << "Failed to bind to port " << command_port_
|
| - << " skydb commands will not work.";
|
| - mojo::ApplicationImpl::Terminate();
|
| - return;
|
| - }
|
| - web_server_.reset(new net::HttpServer(server_socket.Pass(), this));
|
| - }
|
| -
|
| - virtual bool ConfigureIncomingConnection(
|
| - mojo::ApplicationConnection* connection) override {
|
| - connection->ConnectToService(&debugger_);
|
| - return true;
|
| - }
|
| -
|
| - // net::HttpServer::Delegate
|
| - void OnConnect(int connection_id) override {
|
| - }
|
| -
|
| - void OnClose(int connection_id) override {
|
| - }
|
| -
|
| - void OnHttpRequest(
|
| - int connection_id, const net::HttpServerRequestInfo& info) override {
|
| -
|
| - // FIXME: We should use use a fancier lookup system more like what
|
| - // services/http_server/http_server.cc does with AddHandler.
|
| - if (info.path == "/reload")
|
| - Load(connection_id, url_);
|
| - else if (info.path == "/inspect")
|
| - Inspect(connection_id);
|
| - else if (info.path == "/quit")
|
| - Quit(connection_id);
|
| - else if (info.path == "/load")
|
| - Load(connection_id, info.data);
|
| - else if (info.path == "/start_profiling")
|
| - StartProfiling(connection_id);
|
| - else if (info.path == "/stop_profiling")
|
| - StopProfiling(connection_id);
|
| - else if (info.path == "/start_tracing")
|
| - StartTracing(connection_id);
|
| - else if (info.path == "/stop_tracing")
|
| - StopTracing(connection_id);
|
| - else
|
| - Help(info.path, connection_id);
|
| - }
|
| -
|
| - void OnWebSocketRequest(
|
| - int connection_id, const net::HttpServerRequestInfo& info) override {
|
| - Error(connection_id, "OnWebSocketRequest not implemented");
|
| - }
|
| -
|
| - void OnWebSocketMessage(
|
| - int connection_id, const std::string& data) override {
|
| - Error(connection_id, "OnWebSocketMessage not implemented");
|
| - }
|
| -
|
| - void Error(int connection_id, std::string message) {
|
| - web_server_->Send500(connection_id, message);
|
| - }
|
| -
|
| - void Respond(int connection_id, std::string response) {
|
| - // When sending tracing data back over the wire to the client, we can blow
|
| - // through the default send buffer size.
|
| - web_server_->SetSendBufferSize(
|
| - connection_id, std::max(kMinSendBufferSize, response.length()));
|
| - web_server_->Send200(connection_id, response, "text/plain");
|
| - }
|
| -
|
| - void Help(std::string path, int connection_id) {
|
| - 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(connection_id, help);
|
| - }
|
| -
|
| - void Load(int connection_id, std::string url) {
|
| - url_ = url;
|
| - Reload();
|
| - std::string response = std::string("Loaded ") + url + "\n";
|
| - Respond(connection_id, response);
|
| - }
|
| -
|
| - void Reload() {
|
| - debugger_->NavigateToURL(url_);
|
| - }
|
| -
|
| - void Inspect(int connection_id) {
|
| - debugger_->InjectInspector();
|
| - Respond(connection_id,
|
| - "Open the following URL in Chrome:\n"
|
| - "chrome-devtools://devtools/bundled/devtools.html?ws=localhost:9898\n");
|
| - }
|
| -
|
| - void Quit(int connection_id) {
|
| - debugger_->Shutdown();
|
| - }
|
| -
|
| - void StartTracing(int connection_id) {
|
| - if (is_tracing_) {
|
| - Error(connection_id, "Already tracing. Use stop_tracing to stop.\n");
|
| - return;
|
| - }
|
| -
|
| - is_tracing_ = true;
|
| - mojo::DataPipe pipe;
|
| - tracing_->Start(pipe.producer_handle.Pass(), mojo::String("*"));
|
| - trace_collector_.reset(new TraceCollector(pipe.consumer_handle.Pass()));
|
| - Respond(connection_id, "Starting trace (type 'stop_tracing' to stop)\n");
|
| - }
|
| -
|
| - void StopTracing(int connection_id) {
|
| - if (!is_tracing_) {
|
| - Error(connection_id, "Not tracing yet. Use start_tracing to start.\n");
|
| - return;
|
| - }
|
| -
|
| - is_tracing_ = false;
|
| - tracing_->StopAndFlush();
|
| - trace_collector_->GetTrace(base::Bind(
|
| - &Prompt::OnTraceAvailable, base::Unretained(this), connection_id));
|
| - }
|
| -
|
| - void OnTraceAvailable(int connection_id, std::string trace) {
|
| - trace_collector_.reset();
|
| - Respond(connection_id, trace);
|
| - }
|
| -
|
| - void StartProfiling(int connection_id) {
|
| -#if !defined(NDEBUG) || !defined(ENABLE_PROFILING)
|
| - Error(connection_id,
|
| - "Profiling requires is_debug=false and enable_profiling=true");
|
| - return;
|
| -#else
|
| - base::debug::StartProfiling("sky_viewer.pprof");
|
| - Respond(connection_id, "Starting profiling (stop with 'stop_profiling')");
|
| -#endif
|
| - }
|
| -
|
| - void StopProfiling(int connection_id) {
|
| - if (!base::debug::BeingProfiled()) {
|
| - Error(connection_id, "Profiling not started");
|
| - return;
|
| - }
|
| - base::debug::StopProfiling();
|
| - Respond(connection_id, "Stopped profiling");
|
| - }
|
| -
|
| - bool is_tracing_;
|
| - DebuggerPtr debugger_;
|
| - tracing::TraceCoordinatorPtr tracing_;
|
| - std::string url_;
|
| - base::WeakPtrFactory<Prompt> weak_ptr_factory_;
|
| - scoped_ptr<net::HttpServer> web_server_;
|
| - uint32_t command_port_;
|
| -
|
| - scoped_ptr<TraceCollector> trace_collector_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(Prompt);
|
| -};
|
| -
|
| -} // namespace debugger
|
| -} // namespace sky
|
| -
|
| -MojoResult MojoMain(MojoHandle shell_handle) {
|
| - mojo::ApplicationRunnerChromium runner(new sky::debugger::Prompt);
|
| - runner.set_message_loop_type(base::MessageLoop::TYPE_IO);
|
| - return runner.Run(shell_handle);
|
| -}
|
|
|