| Index: mojo/services/network/http_server_impl.cc
|
| diff --git a/mojo/services/network/http_server_impl.cc b/mojo/services/network/http_server_impl.cc
|
| deleted file mode 100644
|
| index b7e080a6bae9964376e973987c8e9490ebe55c32..0000000000000000000000000000000000000000
|
| --- a/mojo/services/network/http_server_impl.cc
|
| +++ /dev/null
|
| @@ -1,119 +0,0 @@
|
| -// Copyright 2015 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 "mojo/services/network/http_server_impl.h"
|
| -
|
| -#include <utility>
|
| -
|
| -#include "base/logging.h"
|
| -#include "mojo/services/network/http_connection_impl.h"
|
| -#include "mojo/services/network/net_adapters.h"
|
| -#include "mojo/services/network/net_address_type_converters.h"
|
| -#include "net/base/ip_endpoint.h"
|
| -#include "net/base/net_errors.h"
|
| -#include "net/log/net_log.h"
|
| -#include "net/socket/tcp_server_socket.h"
|
| -
|
| -namespace mojo {
|
| -
|
| -namespace {
|
| -
|
| -const int kBackLog = 10;
|
| -
|
| -} // namespace
|
| -
|
| -// static
|
| -void HttpServerImpl::Create(
|
| - NetAddressPtr local_address,
|
| - HttpServerDelegatePtr delegate,
|
| - scoped_ptr<mojo::MessageLoopRef> app_refcount,
|
| - const Callback<void(NetworkErrorPtr, NetAddressPtr)>& callback) {
|
| - HttpServerImpl* http_server =
|
| - new HttpServerImpl(std::move(delegate), std::move(app_refcount));
|
| -
|
| - int net_error = http_server->Start(std::move(local_address));
|
| - if (net_error != net::OK) {
|
| - callback.Run(MakeNetworkError(net_error), nullptr);
|
| - delete http_server;
|
| - return;
|
| - }
|
| - callback.Run(MakeNetworkError(net::OK), http_server->GetLocalAddress());
|
| -}
|
| -
|
| -HttpServerImpl::HttpServerImpl(HttpServerDelegatePtr delegate,
|
| - scoped_ptr<mojo::MessageLoopRef> app_refcount)
|
| - : delegate_(std::move(delegate)), app_refcount_(std::move(app_refcount)) {
|
| - DCHECK(delegate_);
|
| - delegate_.set_connection_error_handler([this]() { delete this; });
|
| -}
|
| -
|
| -HttpServerImpl::~HttpServerImpl() {}
|
| -
|
| -int HttpServerImpl::Start(NetAddressPtr local_address) {
|
| - DCHECK(local_address);
|
| -
|
| - scoped_ptr<net::ServerSocket> socket(
|
| - new net::TCPServerSocket(nullptr, net::NetLog::Source()));
|
| - int net_result = socket->Listen(local_address.To<net::IPEndPoint>(),
|
| - kBackLog);
|
| - if (net_result != net::OK)
|
| - return net_result;
|
| -
|
| - server_.reset(new net::HttpServer(std::move(socket), this));
|
| -
|
| - return net::OK;
|
| -}
|
| -
|
| -NetAddressPtr HttpServerImpl::GetLocalAddress() const {
|
| - if (!server_)
|
| - return nullptr;
|
| -
|
| - net::IPEndPoint address;
|
| - int net_result = server_->GetLocalAddress(&address);
|
| - if (net_result != net::OK)
|
| - return nullptr;
|
| -
|
| - return NetAddress::From(address);
|
| -}
|
| -
|
| -void HttpServerImpl::OnConnect(int connection_id) {
|
| - DCHECK(connections_.find(connection_id) == connections_.end());
|
| -
|
| - HttpConnectionPtr connection;
|
| - HttpConnectionDelegatePtr connection_delegate;
|
| - InterfaceRequest<HttpConnectionDelegate> delegate_request =
|
| - GetProxy(&connection_delegate);
|
| - linked_ptr<HttpConnectionImpl> connection_impl(new HttpConnectionImpl(
|
| - connection_id, this, std::move(connection_delegate), &connection));
|
| -
|
| - connections_[connection_id] = connection_impl;
|
| -
|
| - delegate_->OnConnected(std::move(connection), std::move(delegate_request));
|
| -}
|
| -
|
| -void HttpServerImpl::OnHttpRequest(int connection_id,
|
| - const net::HttpServerRequestInfo& info) {
|
| - DCHECK(connections_.find(connection_id) != connections_.end());
|
| - connections_[connection_id]->OnReceivedHttpRequest(info);
|
| -}
|
| -
|
| -void HttpServerImpl::OnWebSocketRequest(
|
| - int connection_id,
|
| - const net::HttpServerRequestInfo& info) {
|
| - DCHECK(connections_.find(connection_id) != connections_.end());
|
| - connections_[connection_id]->OnReceivedWebSocketRequest(info);
|
| -}
|
| -
|
| -void HttpServerImpl::OnWebSocketMessage(int connection_id,
|
| - const std::string& data) {
|
| - DCHECK(connections_.find(connection_id) != connections_.end());
|
| - connections_[connection_id]->OnReceivedWebSocketMessage(data);
|
| -}
|
| -
|
| -void HttpServerImpl::OnClose(int connection_id) {
|
| - DCHECK(connections_.find(connection_id) != connections_.end());
|
| - connections_.erase(connection_id);
|
| -}
|
| -
|
| -} // namespace mojo
|
|
|