Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "services/http_server/http_server_factory_impl.h" | 5 #include "services/http_server/http_server_factory_impl.h" |
| 6 | 6 |
| 7 #include "base/stl_util.h" | 7 #include "base/stl_util.h" |
| 8 #include "services/http_server/http_server_impl.h" | 8 #include "services/http_server/http_server_impl.h" |
| 9 #include "services/http_server/public/http_server.mojom.h" | 9 #include "services/http_server/public/http_server.mojom.h" |
| 10 | 10 |
| 11 namespace http_server { | 11 namespace http_server { |
| 12 | 12 |
| 13 HttpServerFactoryImpl::HttpServerFactoryImpl(mojo::ApplicationImpl* app) { | 13 HttpServerFactoryImpl::HttpServerFactoryImpl(mojo::ApplicationImpl* app) { |
| 14 app_ = app; | 14 app_ = app; |
| 15 } | 15 } |
| 16 | 16 |
| 17 HttpServerFactoryImpl::~HttpServerFactoryImpl() { | 17 HttpServerFactoryImpl::~HttpServerFactoryImpl() { |
| 18 // Free the http servers. | 18 // Free the http servers. |
| 19 STLDeleteContainerPairSecondPointers(port_indicated_servers_.begin(), | 19 STLDeleteContainerPairSecondPointers(port_indicated_servers_.begin(), |
| 20 port_indicated_servers_.end()); | 20 port_indicated_servers_.end()); |
| 21 STLDeleteContainerPointers(port_any_servers_.begin(), | 21 STLDeleteContainerPointers(port_any_servers_.begin(), |
| 22 port_any_servers_.end()); | 22 port_any_servers_.end()); |
| 23 } | 23 } |
| 24 | 24 |
| 25 void HttpServerFactoryImpl::AddBinding( | 25 void HttpServerFactoryImpl::AddBinding( |
| 26 mojo::InterfaceRequest<HttpServerFactory> request) { | 26 mojo::InterfaceRequest<HttpServerFactory> request) { |
| 27 bindings_.AddBinding(this, request.Pass()); | 27 bindings_.AddBinding(this, request.Pass()); |
| 28 } | 28 } |
| 29 | 29 |
| 30 void HttpServerFactoryImpl::DeleteServer(HttpServerImpl* server, | 30 void HttpServerFactoryImpl::DeleteServer( |
| 31 uint16_t requested_port) { | 31 HttpServerImpl* server, |
| 32 if (requested_port) { | 32 mojo::NetAddressPtr requested_address) { |
|
qsr
2015/02/23 17:14:01
Take a mojo::NetAddress* instead, so you do not ne
ppi
2015/02/24 10:59:54
Done.
| |
| 33 DCHECK(port_indicated_servers_.count(requested_port)); | 33 ServerKey key = GetServerKey(requested_address.Pass()); |
| 34 DCHECK_EQ(server, port_indicated_servers_[requested_port]); | 34 |
| 35 if (key.second) { // If the port is non-zero. | |
| 36 DCHECK(port_indicated_servers_.count(key)); | |
| 37 DCHECK_EQ(server, port_indicated_servers_[key]); | |
| 35 | 38 |
| 36 delete server; | 39 delete server; |
| 37 port_indicated_servers_.erase(requested_port); | 40 port_indicated_servers_.erase(key); |
| 38 } else { | 41 } else { |
| 39 DCHECK(port_any_servers_.count(server)); | 42 DCHECK(port_any_servers_.count(server)); |
| 40 | 43 |
| 41 delete server; | 44 delete server; |
| 42 port_any_servers_.erase(server); | 45 port_any_servers_.erase(server); |
| 43 } | 46 } |
| 44 } | 47 } |
| 45 | 48 |
| 49 HttpServerFactoryImpl::ServerKey HttpServerFactoryImpl::GetServerKey( | |
| 50 mojo::NetAddressPtr local_address) { | |
| 51 if (!local_address) { | |
| 52 return ServerKey(); | |
| 53 } | |
| 54 | |
| 55 if (local_address->family == mojo::NET_ADDRESS_FAMILY_IPV6) { | |
| 56 return ServerKey(local_address->ipv6->addr, local_address->ipv6->port); | |
| 57 } else if (local_address->family == mojo::NET_ADDRESS_FAMILY_IPV4) { | |
| 58 return ServerKey(local_address->ipv4->addr, local_address->ipv4->port); | |
| 59 } else { | |
| 60 return ServerKey(); | |
| 61 } | |
| 62 } | |
| 63 | |
| 46 void HttpServerFactoryImpl::CreateHttpServer( | 64 void HttpServerFactoryImpl::CreateHttpServer( |
| 47 mojo::InterfaceRequest<HttpServer> server_request, | 65 mojo::InterfaceRequest<HttpServer> server_request, |
| 48 uint16_t port) { | 66 mojo::NetAddressPtr local_address) { |
|
qsr
2015/02/23 17:14:01
local_address is optional, what about making it 0.
ppi
2015/02/24 10:59:54
Done.
| |
| 49 if (port) { | 67 ServerKey key = GetServerKey(local_address.Clone()); |
| 50 if (!port_indicated_servers_.count(port)) { | 68 |
| 51 port_indicated_servers_[port] = new HttpServerImpl(app_, this, port); | 69 if (key.second) { // If the port is non-zero. |
| 70 if (!port_indicated_servers_.count(key)) { | |
| 71 port_indicated_servers_[key] = | |
| 72 new HttpServerImpl(app_, this, local_address.Pass()); | |
| 52 } | 73 } |
| 53 port_indicated_servers_[port]->AddBinding(server_request.Pass()); | 74 port_indicated_servers_[key]->AddBinding(server_request.Pass()); |
| 54 } else { | 75 } else { |
| 55 HttpServerImpl* server = new HttpServerImpl(app_, this, port); | 76 HttpServerImpl* server = |
| 77 new HttpServerImpl(app_, this, local_address.Pass()); | |
| 56 server->AddBinding(server_request.Pass()); | 78 server->AddBinding(server_request.Pass()); |
| 57 port_any_servers_.insert(server); | 79 port_any_servers_.insert(server); |
| 58 } | 80 } |
| 59 } | 81 } |
| 60 | 82 |
| 61 } // namespace http_server | 83 } // namespace http_server |
| OLD | NEW |