OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "net/quic/quic_connection.h" | 5 #include "net/quic/quic_connection.h" |
6 | 6 |
7 #include <string.h> | 7 #include <string.h> |
8 #include <sys/types.h> | 8 #include <sys/types.h> |
9 | 9 |
10 #include <algorithm> | 10 #include <algorithm> |
(...skipping 1580 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1591 // The caller of this function is responsible for checking CanWrite(). | 1591 // The caller of this function is responsible for checking CanWrite(). |
1592 if (packet.serialized_packet.packet == nullptr) { | 1592 if (packet.serialized_packet.packet == nullptr) { |
1593 LOG(DFATAL) | 1593 LOG(DFATAL) |
1594 << "packet.serialized_packet.packet == nullptr in to SendOrQueuePacket"; | 1594 << "packet.serialized_packet.packet == nullptr in to SendOrQueuePacket"; |
1595 return; | 1595 return; |
1596 } | 1596 } |
1597 | 1597 |
1598 sent_entropy_manager_.RecordPacketEntropyHash( | 1598 sent_entropy_manager_.RecordPacketEntropyHash( |
1599 packet.serialized_packet.sequence_number, | 1599 packet.serialized_packet.sequence_number, |
1600 packet.serialized_packet.entropy_hash); | 1600 packet.serialized_packet.entropy_hash); |
1601 LOG_IF(DFATAL, !queued_packets_.empty() && !writer_->IsWriteBlocked()) | |
1602 << "Packets should only be left queued if we're write blocked."; | |
1603 if (!WritePacket(&packet)) { | 1601 if (!WritePacket(&packet)) { |
1604 queued_packets_.push_back(packet); | 1602 queued_packets_.push_back(packet); |
1605 } | 1603 } |
1606 } | 1604 } |
1607 | 1605 |
1608 void QuicConnection::UpdateStopWaiting(QuicStopWaitingFrame* stop_waiting) { | 1606 void QuicConnection::UpdateStopWaiting(QuicStopWaitingFrame* stop_waiting) { |
1609 stop_waiting->least_unacked = GetLeastUnacked(); | 1607 stop_waiting->least_unacked = GetLeastUnacked(); |
1610 stop_waiting->entropy_hash = sent_entropy_manager_.GetCumulativeEntropy( | 1608 stop_waiting->entropy_hash = sent_entropy_manager_.GetCumulativeEntropy( |
1611 stop_waiting->least_unacked - 1); | 1609 stop_waiting->least_unacked - 1); |
1612 } | 1610 } |
(...skipping 455 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2068 } | 2066 } |
2069 for (size_t i = 0; i < retransmittable_frames->frames().size(); ++i) { | 2067 for (size_t i = 0; i < retransmittable_frames->frames().size(); ++i) { |
2070 if (retransmittable_frames->frames()[i].type == CONNECTION_CLOSE_FRAME) { | 2068 if (retransmittable_frames->frames()[i].type == CONNECTION_CLOSE_FRAME) { |
2071 return true; | 2069 return true; |
2072 } | 2070 } |
2073 } | 2071 } |
2074 return false; | 2072 return false; |
2075 } | 2073 } |
2076 | 2074 |
2077 } // namespace net | 2075 } // namespace net |
OLD | NEW |