Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(69)

Unified Diff: sky/tools/debugger/prompt/prompt.cc

Issue 883983004: Rename SkyDebugger to KioskWM and move to /services (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Rename to KioskWM per discussion with jamesr Created 5 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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);
-}

Powered by Google App Engine
This is Rietveld 408576698