summaryrefslogtreecommitdiffstats
path: root/content/child/websocket_bridge.cc
diff options
context:
space:
mode:
Diffstat (limited to 'content/child/websocket_bridge.cc')
-rw-r--r--content/child/websocket_bridge.cc16
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;