Index: net/quic/quic_session.cc |
diff --git a/net/quic/quic_session.cc b/net/quic/quic_session.cc |
index 5ec68ee609050bab06774f8c6c901e95463d617a..e9a9173a01677860393b9562278bd0a960b4f94d 100644 |
--- a/net/quic/quic_session.cc |
+++ b/net/quic/quic_session.cc |
@@ -281,8 +281,7 @@ bool QuicSession::OnCanWrite() { |
connection_->CloseConnection(QUIC_INTERNAL_ERROR, false); |
return true; // We have no write blocked streams. |
} |
- int index = write_blocked_streams_.GetHighestPriorityWriteBlockedList(); |
- QuicStreamId stream_id = write_blocked_streams_.PopFront(index); |
+ QuicStreamId stream_id = write_blocked_streams_.PopFront(); |
if (stream_id == kCryptoStreamId) { |
has_pending_handshake_ = false; // We just popped it. |
} |
@@ -611,11 +610,11 @@ void QuicSession::MarkWriteBlocked(QuicStreamId id, QuicPriority priority) { |
// kHighestPriority. |
priority = kHighestPriority; |
} |
- write_blocked_streams_.PushBack(id, priority); |
+ write_blocked_streams_.PushBack(id, priority, connection()->version()); |
} |
bool QuicSession::HasQueuedData() const { |
- return write_blocked_streams_.NumBlockedStreams() || |
+ return write_blocked_streams_.HasWriteBlockedStreams() || |
connection_->HasQueuedData(); |
} |