| Index: content/common/socket_stream_dispatcher.cc
|
| diff --git a/content/common/socket_stream_dispatcher.cc b/content/common/socket_stream_dispatcher.cc
|
| index d2a332fe67f2f2282fbda58c579e3c950cd52ee0..b90cf766591f50e7b01425276cca5a1694f57eb9 100644
|
| --- a/content/common/socket_stream_dispatcher.cc
|
| +++ b/content/common/socket_stream_dispatcher.cc
|
| @@ -17,6 +17,7 @@
|
| #include "googleurl/src/gurl.h"
|
| #include "webkit/glue/websocketstreamhandle_bridge.h"
|
| #include "webkit/glue/websocketstreamhandle_delegate.h"
|
| +#include "webkit/glue/websocketstreamhandle_impl.h"
|
|
|
| // IPCWebSocketStreamHandleBridge is owned by each SocketStreamHandle.
|
| // It communicates with the main browser process via SocketStreamDispatcher.
|
| @@ -146,8 +147,14 @@ void IPCWebSocketStreamHandleBridge::DoConnect(const GURL& url) {
|
|
|
| socket_id_ = all_bridges.Get().Add(this);
|
| DCHECK_NE(socket_id_, content_common::kNoSocketId);
|
| + int routing_id = MSG_ROUTING_NONE;
|
| + webkit_glue::WebSocketStreamHandleImpl* handle =
|
| + static_cast<webkit_glue::WebSocketStreamHandleImpl*>(handle_);
|
| + if (handle)
|
| + routing_id = handle->RequestorId();
|
| AddRef(); // Released in OnClosed().
|
| - if (child_thread_->Send(new SocketStreamHostMsg_Connect(url, socket_id_))) {
|
| + if (child_thread_->Send(
|
| + new SocketStreamHostMsg_Connect(routing_id, url, socket_id_))) {
|
| DVLOG(1) << "Connect socket_id=" << socket_id_;
|
| // TODO(ukai): timeout to OnConnected.
|
| } else {
|
|
|