Index: sky/framework/inspector/server/inspector_frontend_impl.cc |
diff --git a/sky/framework/inspector/server/inspector_frontend_impl.cc b/sky/framework/inspector/server/inspector_frontend_impl.cc |
deleted file mode 100644 |
index 0865e91b9e3961dffeb14a2c9ca5c91d0a849248..0000000000000000000000000000000000000000 |
--- a/sky/framework/inspector/server/inspector_frontend_impl.cc |
+++ /dev/null |
@@ -1,97 +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 "sky/framework/inspector/server/inspector_frontend_impl.h" |
- |
-#include "base/lazy_instance.h" |
-#include "net/server/http_server.h" |
-#include "net/socket/tcp_server_socket.h" |
- |
-namespace sky { |
-namespace inspector { |
-namespace { |
-const int kNotConnected = -1; |
-static base::LazyInstance<std::map<int, InspectorFronendImpl*>> g_servers = |
- LAZY_INSTANCE_INITIALIZER; |
-} |
- |
-InspectorFronendImpl::InspectorFronendImpl() |
- : connection_id_(kNotConnected) { |
-} |
- |
-InspectorFronendImpl::~InspectorFronendImpl() { |
- StopListening(); |
-} |
- |
-void InspectorFronendImpl::OnConnect(int connection_id) { |
-} |
- |
-void InspectorFronendImpl::OnHttpRequest( |
- int connection_id, const net::HttpServerRequestInfo& info) { |
- web_server_->Send500(connection_id, "websockets protocol only"); |
-} |
- |
-void InspectorFronendImpl::OnWebSocketRequest( |
- int connection_id, const net::HttpServerRequestInfo& info) { |
- if (connection_id_ != kNotConnected) { |
- web_server_->Close(connection_id); |
- return; |
- } |
- web_server_->AcceptWebSocket(connection_id, info); |
- connection_id_ = connection_id; |
- client()->OnConnect(); |
-} |
- |
-void InspectorFronendImpl::OnWebSocketMessage( |
- int connection_id, const std::string& data) { |
- DCHECK_EQ(connection_id, connection_id_); |
- client()->OnMessage(data); |
-} |
- |
-void InspectorFronendImpl::OnClose(int connection_id) { |
- if (connection_id != connection_id_) |
- return; |
- connection_id_ = kNotConnected; |
- client()->OnDisconnect(); |
-} |
- |
-void InspectorFronendImpl::Listen(int32_t port) { |
- Register(port); |
- scoped_ptr<net::ServerSocket> server_socket( |
- new net::TCPServerSocket(NULL, net::NetLog::Source())); |
- server_socket->ListenWithAddressAndPort("0.0.0.0", port, 1); |
- web_server_.reset(new net::HttpServer(server_socket.Pass(), this)); |
-} |
- |
-void InspectorFronendImpl::StopListening() { |
- if (!web_server_) |
- return; |
- web_server_.reset(); |
- Unregister(); |
-} |
- |
-void InspectorFronendImpl::Register(int port) { |
- auto& servers = g_servers.Get(); |
- auto iter = servers.find(port); |
- if (iter != servers.end()) |
- iter->second->StopListening(); |
- DCHECK(servers.find(port) == servers.end()); |
- servers[port] = this; |
- port_ = port; |
-} |
- |
-void InspectorFronendImpl::Unregister() { |
- DCHECK(g_servers.Get().find(port_)->second == this); |
- g_servers.Get().erase(port_); |
- port_ = kNotConnected; |
-} |
- |
-void InspectorFronendImpl::SendMessage(const mojo::String& message) { |
- if (connection_id_ == kNotConnected) |
- return; |
- web_server_->SendOverWebSocket(connection_id_, message); |
-} |
- |
-} // namespace inspector |
-} // namespace sky |