| Index: net/websockets/websocket_job.cc
|
| diff --git a/net/websockets/websocket_job.cc b/net/websockets/websocket_job.cc
|
| index 56faefb25037465445c69914ab51343d532ce436..ff60ebeaa1ad45386df31f12462418afa64acd99 100644
|
| --- a/net/websockets/websocket_job.cc
|
| +++ b/net/websockets/websocket_job.cc
|
| @@ -80,6 +80,7 @@ WebSocketJob::WebSocketJob(SocketStream::Delegate* delegate)
|
| started_to_send_handshake_request_(false),
|
| handshake_request_sent_(0),
|
| response_cookies_save_index_(0),
|
| + spdy_protocol_version_(0),
|
| ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)),
|
| ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_for_send_pending_(this)) {
|
| }
|
| @@ -312,7 +313,9 @@ int WebSocketJob::OnReceivedSpdyResponseHeader(
|
| if (status != OK)
|
| return status;
|
| // TODO(toyoshim): Fallback to non-spdy connection?
|
| - handshake_response_->ParseResponseHeaderBlock(headers, challenge_);
|
| + handshake_response_->ParseResponseHeaderBlock(headers,
|
| + challenge_,
|
| + spdy_protocol_version_);
|
|
|
| SaveCookiesAndNotifyHeaderComplete();
|
| return OK;
|
| @@ -389,7 +392,7 @@ void WebSocketJob::DoSendData() {
|
| if (spdy_websocket_stream_.get()) {
|
| scoped_ptr<SpdyHeaderBlock> headers(new SpdyHeaderBlock);
|
| handshake_request_->GetRequestHeaderBlock(
|
| - socket_->url(), headers.get(), &challenge_);
|
| + socket_->url(), headers.get(), &challenge_, spdy_protocol_version_);
|
| spdy_websocket_stream_->SendRequest(headers.Pass());
|
| } else {
|
| const std::string& handshake_request =
|
| @@ -567,6 +570,7 @@ int WebSocketJob::TrySpdyStream() {
|
| return OK;
|
|
|
| // Create SpdyWebSocketStream.
|
| + spdy_protocol_version_ = spdy_session->GetProtocolVersion();
|
| spdy_websocket_stream_.reset(new SpdyWebSocketStream(spdy_session, this));
|
|
|
| int result = spdy_websocket_stream_->InitializeStream(
|
|
|