DevTools. Add V8 Application Remote Debugging Protocol support by apavlov. Original CL: http://codereview.chromium.org/56109

Review URL: http://codereview.chromium.org/66031

git-svn-id: svn://svn.chromium.org/chrome/trunk/src@13502 0039d316-1c4b-4281-b951-d872f2087c98

1 files changed, 107 insertions, 0 deletions

diff --git a/chrome/browser/debugger/devtools_protocol_handler.cc b/chrome/browser/debugger/devtools_protocol_handler.cc
new file mode 100644
index 0000000..5350298
--- /dev/null
+++ b/chrome/browser/debugger/devtools_protocol_handler.cc
@@ -0,0 +1,107 @@
+// Copyright (c) 2009 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 "chrome/browser/debugger/devtools_protocol_handler.h"
+
+#include "base/logging.h"
+#include "base/thread.h"
+#include "chrome/browser/browser_process.h"
+#include "chrome/browser/debugger/inspectable_tab_proxy.h"
+#include "chrome/browser/debugger/devtools_remote_message.h"
+#include "chrome/browser/debugger/devtools_remote_listen_socket.h"
+#include "chrome/browser/tab_contents/tab_contents.h"
+
+DevToolsProtocolHandler::DevToolsProtocolHandler(int port)
+    : port_(port),
+      connection_(NULL),
+      server_(NULL) {
+  ui_loop_ = MessageLoop::current();
+  io_loop_ = g_browser_process->io_thread()->message_loop();
+  inspectable_tab_proxy_.reset(new InspectableTabProxy);
+}
+
+DevToolsProtocolHandler::~DevToolsProtocolHandler() {
+  // Stop() must be called prior to this being called
+  DCHECK(server_.get() == NULL);
+  DCHECK(connection_.get() == NULL);
+}
+
+void DevToolsProtocolHandler::Start() {
+  io_loop_->PostTask(FROM_HERE, NewRunnableMethod(
+      this, &DevToolsProtocolHandler::Init));
+}
+
+void DevToolsProtocolHandler::Init() {
+  server_ = DevToolsRemoteListenSocket::Listen(
+      "127.0.0.1", port_, this, this);
+}
+
+void DevToolsProtocolHandler::Stop() {
+  io_loop_->PostTask(FROM_HERE, NewRunnableMethod(
+      this, &DevToolsProtocolHandler::Teardown));
+  tool_to_listener_map_.clear();  // Releases all scoped_refptr's to listeners
+}
+
+// Run in I/O thread
+void DevToolsProtocolHandler::Teardown() {
+  connection_ = NULL;
+  server_ = NULL;
+}
+
+void DevToolsProtocolHandler::RegisterDestination(
+    DevToolsRemoteListener* listener,
+    const std::string& tool_name) {
+  DCHECK(tool_to_listener_map_.find(tool_name) == tool_to_listener_map_.end());
+  tool_to_listener_map_.insert(std::make_pair(tool_name, listener));
+}
+
+void DevToolsProtocolHandler::UnregisterDestination(
+    DevToolsRemoteListener* listener,
+    const std::string& tool_name) {
+  DCHECK(tool_to_listener_map_.find(tool_name) != tool_to_listener_map_.end());
+  DCHECK(tool_to_listener_map_.find(tool_name)->second == listener);
+  tool_to_listener_map_.erase(tool_name);
+}
+
+void DevToolsProtocolHandler::HandleMessage(
+    const DevToolsRemoteMessage& message) {
+  std::string tool = message.GetHeaderWithEmptyDefault(
+      DevToolsRemoteMessageHeaders::kTool);
+  ToolToListenerMap::const_iterator it = tool_to_listener_map_.find(tool);
+  if (it == tool_to_listener_map_.end()) {
+    NOTREACHED();  // an unsupported tool, bail out
+    return;
+  }
+  DCHECK(MessageLoop::current() == io_loop_);
+  ui_loop_->PostTask(FROM_HERE, NewRunnableMethod(
+      it->second.get(), &DevToolsRemoteListener::HandleMessage, message));
+}
+
+void DevToolsProtocolHandler::Send(const DevToolsRemoteMessage& message) {
+  if (connection_ != NULL) {
+    connection_->Send(message.ToString());
+  }
+}
+
+void DevToolsProtocolHandler::DidAccept(ListenSocket *server,
+                                        ListenSocket *connection) {
+  DCHECK(MessageLoop::current() == io_loop_);
+  if (connection_ == NULL) {
+    connection_ = connection;
+    connection_->AddRef();
+  }
+  // else the connection will get deleted itself with scoped_refptr
+}
+
+void DevToolsProtocolHandler::DidRead(ListenSocket *connection,
+                                      const std::string& data) {
+  // This method is not used.
+}
+
+void DevToolsProtocolHandler::DidClose(ListenSocket *sock) {
+  DCHECK(MessageLoop::current() == io_loop_);
+  DCHECK(connection_ == sock);
+  connection_ = NULL;
+  sock->Release();
+}