diff options
Diffstat (limited to 'content/child/websocket_bridge.cc')
-rw-r--r-- | content/child/websocket_bridge.cc | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/content/child/websocket_bridge.cc b/content/child/websocket_bridge.cc index 5b32702..e091023 100644 --- a/content/child/websocket_bridge.cc +++ b/content/child/websocket_bridge.cc @@ -11,7 +11,7 @@ #include "base/logging.h" #include "base/strings/string_util.h" -#include "content/child/child_thread.h" +#include "content/child/child_thread_impl.h" #include "content/child/websocket_dispatcher.h" #include "content/common/websocket.h" #include "content/common/websocket_messages.h" @@ -52,7 +52,7 @@ WebSocketBridge::~WebSocketBridge() { if (channel_id_ != kInvalidChannelId) { // The connection is abruptly disconnected by the renderer without // closing handshake. - ChildThread::current()->Send( + ChildThreadImpl::current()->Send( new WebSocketMsg_DropChannel(channel_id_, false, kAbnormalShutdownOpCode, @@ -214,7 +214,7 @@ void WebSocketBridge::connect( WebSocketHandleClient* client) { DCHECK_EQ(kInvalidChannelId, channel_id_); WebSocketDispatcher* dispatcher = - ChildThread::current()->websocket_dispatcher(); + ChildThreadImpl::current()->websocket_dispatcher(); channel_id_ = dispatcher->AddBridge(this); client_ = client; @@ -227,7 +227,7 @@ void WebSocketBridge::connect( << JoinString(protocols_to_pass, ", ") << "), " << origin_to_pass.string() << ")"; - ChildThread::current()->Send(new WebSocketHostMsg_AddChannelRequest( + ChildThreadImpl::current()->Send(new WebSocketHostMsg_AddChannelRequest( channel_id_, url, protocols_to_pass, origin_to_pass, render_frame_id_)); } @@ -255,7 +255,7 @@ void WebSocketBridge::send(bool fin, << fin << ", " << type_to_pass << ", " << "(data size = " << size << "))"; - ChildThread::current()->Send( + ChildThreadImpl::current()->Send( new WebSocketMsg_SendFrame(channel_id_, fin, type_to_pass, @@ -268,7 +268,7 @@ void WebSocketBridge::flowControl(int64_t quota) { DVLOG(1) << "Bridge #" << channel_id_ << " FlowControl(" << quota << ")"; - ChildThread::current()->Send( + ChildThreadImpl::current()->Send( new WebSocketMsg_FlowControl(channel_id_, quota)); } @@ -281,7 +281,7 @@ void WebSocketBridge::close(unsigned short code, DVLOG(1) << "Bridge #" << channel_id_ << " Close(" << code << ", " << reason_to_pass << ")"; // This method is for closing handshake and hence |was_clean| shall be true. - ChildThread::current()->Send( + ChildThreadImpl::current()->Send( new WebSocketMsg_DropChannel(channel_id_, true, code, reason_to_pass)); } @@ -289,7 +289,7 @@ void WebSocketBridge::Disconnect() { if (channel_id_ == kInvalidChannelId) return; WebSocketDispatcher* dispatcher = - ChildThread::current()->websocket_dispatcher(); + ChildThreadImpl::current()->websocket_dispatcher(); dispatcher->RemoveBridge(channel_id_); channel_id_ = kInvalidChannelId; |