Index: net/quic/quic_session.cc |
diff --git a/net/quic/quic_session.cc b/net/quic/quic_session.cc |
index e9a9173a01677860393b9562278bd0a960b4f94d..9be3a3bdd478c7bd8775575a6f46a0dcd5343501 100644 |
--- a/net/quic/quic_session.cc |
+++ b/net/quic/quic_session.cc |
@@ -273,8 +273,7 @@ bool QuicSession::OnCanWrite() { |
// may be modifying the list as we loop. |
int remaining_writes = write_blocked_streams_.NumBlockedStreams(); |
- while (!connection_->HasQueuedData() && |
- remaining_writes > 0) { |
+ while (remaining_writes > 0 && connection_->CanWriteStreamData()) { |
DCHECK(write_blocked_streams_.HasWriteBlockedStreams()); |
if (!write_blocked_streams_.HasWriteBlockedStreams()) { |
LOG(DFATAL) << "WriteBlockedStream is missing"; |
@@ -613,7 +612,7 @@ void QuicSession::MarkWriteBlocked(QuicStreamId id, QuicPriority priority) { |
write_blocked_streams_.PushBack(id, priority, connection()->version()); |
} |
-bool QuicSession::HasQueuedData() const { |
+bool QuicSession::HasDataToWrite() const { |
return write_blocked_streams_.HasWriteBlockedStreams() || |
connection_->HasQueuedData(); |
} |