Index: net/spdy/spdy_session.cc |
diff --git a/net/spdy/spdy_session.cc b/net/spdy/spdy_session.cc |
index 714ce85dac3db5f50fd1cf836521046d2ef8f561..8b6b1eddd931a77856cf7354739dae7c1e2e1f7f 100644 |
--- a/net/spdy/spdy_session.cc |
+++ b/net/spdy/spdy_session.cc |
@@ -238,6 +238,7 @@ SpdyStreamRequest::~SpdyStreamRequest() { |
} |
int SpdyStreamRequest::StartRequest( |
+ SpdyStreamType type, |
const scoped_refptr<SpdySession>& session, |
const GURL& url, |
RequestPriority priority, |
@@ -248,6 +249,7 @@ int SpdyStreamRequest::StartRequest( |
DCHECK(!stream_); |
DCHECK(callback_.is_null()); |
+ type_ = type; |
session_ = session; |
url_ = url; |
priority_ = priority; |
@@ -300,6 +302,7 @@ void SpdyStreamRequest::OnRequestCompleteFailure(int rv) { |
} |
void SpdyStreamRequest::Reset() { |
+ type_ = SPDY_BIDIRECTIONAL_STREAM; |
session_ = NULL; |
stream_.reset(); |
url_ = GURL(); |
@@ -584,10 +587,10 @@ int SpdySession::CreateStream(const SpdyStreamRequest& request, |
const std::string& path = request.url().PathForRequest(); |
scoped_ptr<SpdyStream> new_stream( |
- new SpdyStream(this, path, request.priority(), |
+ new SpdyStream(request.type(), this, path, request.priority(), |
stream_initial_send_window_size_, |
stream_initial_recv_window_size_, |
- false, request.net_log())); |
+ request.net_log())); |
*stream = new_stream->GetWeakPtr(); |
InsertCreatedStream(new_stream.Pass()); |
@@ -1697,10 +1700,11 @@ void SpdySession::OnSynStream(SpdyStreamId stream_id, |
} |
scoped_ptr<SpdyStream> stream( |
- new SpdyStream(this, gurl.PathForRequest(), request_priority, |
+ new SpdyStream(SPDY_PUSH_STREAM, this, gurl.PathForRequest(), |
+ request_priority, |
stream_initial_send_window_size_, |
stream_initial_recv_window_size_, |
- true, net_log_)); |
+ net_log_)); |
stream->set_stream_id(stream_id); |
DeleteExpiredPushedStreams(); |