| Index: mojo/services/network/http_connection_impl.cc
|
| diff --git a/mojo/services/network/http_connection_impl.cc b/mojo/services/network/http_connection_impl.cc
|
| index e42fd1e4599af9f751d02517d9e23ef3d8856cf8..b6f27deac7a1bab15c41a67079b3365558b7c14e 100644
|
| --- a/mojo/services/network/http_connection_impl.cc
|
| +++ b/mojo/services/network/http_connection_impl.cc
|
| @@ -11,7 +11,7 @@
|
| #include "base/logging.h"
|
| #include "base/stl_util.h"
|
| #include "base/strings/string_util.h"
|
| -#include "mojo/common/handle_watcher.h"
|
| +#include "mojo/message_pump/handle_watcher.h"
|
| #include "mojo/services/network/http_server_impl.h"
|
| #include "mojo/services/network/interfaces/web_socket.mojom.h"
|
| #include "mojo/services/network/net_adapters.h"
|
| @@ -91,10 +91,10 @@ class HttpConnectionImpl::WebSocketImpl : public WebSocket {
|
| WebSocketImpl(HttpConnectionImpl* connection,
|
| InterfaceRequest<WebSocket> request,
|
| ScopedDataPipeConsumerHandle send_stream,
|
| - WebSocketClientPtr client)
|
| + InterfaceHandle<WebSocketClient> client)
|
| : connection_(connection),
|
| binding_(this, request.Pass()),
|
| - client_(client.Pass()),
|
| + client_(WebSocketClientPtr::Create(client.Pass())),
|
| send_stream_(send_stream.Pass()),
|
| read_send_stream_(new WebSocketReadQueue(send_stream_.get())),
|
| pending_send_count_(0) {
|
| @@ -145,7 +145,7 @@ class HttpConnectionImpl::WebSocketImpl : public WebSocket {
|
| Array<String> protocols,
|
| const String& origin,
|
| ScopedDataPipeConsumerHandle send_stream,
|
| - WebSocketClientPtr client) override {
|
| + InterfaceHandle<WebSocketClient> client) override {
|
| NOTREACHED();
|
| }
|
|
|
| @@ -250,10 +250,11 @@ struct TypeConverter<HttpRequestPtr, net::HttpServerRequestInfo> {
|
| }
|
| };
|
|
|
| -HttpConnectionImpl::HttpConnectionImpl(int connection_id,
|
| - HttpServerImpl* server,
|
| - HttpConnectionDelegatePtr delegate,
|
| - HttpConnectionPtr* connection)
|
| +HttpConnectionImpl::HttpConnectionImpl(
|
| + int connection_id,
|
| + HttpServerImpl* server,
|
| + HttpConnectionDelegatePtr delegate,
|
| + InterfaceHandle<HttpConnection>* connection)
|
| : connection_id_(connection_id),
|
| server_(server),
|
| delegate_(delegate.Pass()),
|
| @@ -297,7 +298,7 @@ void HttpConnectionImpl::OnReceivedWebSocketRequest(
|
| HttpRequest::From(info),
|
| [this, info](InterfaceRequest<WebSocket> web_socket,
|
| ScopedDataPipeConsumerHandle send_stream,
|
| - WebSocketClientPtr web_socket_client) {
|
| + InterfaceHandle<WebSocketClient> web_socket_client) {
|
| if (!web_socket.is_pending() || !send_stream.is_valid() ||
|
| !web_socket_client) {
|
| Close();
|
|
|