| 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 #include <algorithm> | 9 #include <algorithm> |
| 10 #include <iterator> | 10 #include <iterator> |
| (...skipping 564 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 575 } | 575 } |
| 576 | 576 |
| 577 return true; | 577 return true; |
| 578 } | 578 } |
| 579 | 579 |
| 580 void QuicConnection::OnFecData(const QuicFecData& fec) { | 580 void QuicConnection::OnFecData(const QuicFecData& fec) { |
| 581 DCHECK_EQ(IN_FEC_GROUP, last_header_.is_in_fec_group); | 581 DCHECK_EQ(IN_FEC_GROUP, last_header_.is_in_fec_group); |
| 582 DCHECK_NE(0u, last_header_.fec_group); | 582 DCHECK_NE(0u, last_header_.fec_group); |
| 583 QuicFecGroup* group = GetFecGroup(); | 583 QuicFecGroup* group = GetFecGroup(); |
| 584 if (group != NULL) { | 584 if (group != NULL) { |
| 585 group->UpdateFec(last_header_.packet_sequence_number, | 585 group->UpdateFec(last_header_.packet_sequence_number, fec); |
| 586 last_header_.entropy_flag, fec); | |
| 587 } | 586 } |
| 588 } | 587 } |
| 589 | 588 |
| 590 bool QuicConnection::OnRstStreamFrame(const QuicRstStreamFrame& frame) { | 589 bool QuicConnection::OnRstStreamFrame(const QuicRstStreamFrame& frame) { |
| 591 DCHECK(connected_); | 590 DCHECK(connected_); |
| 592 if (debug_visitor_) { | 591 if (debug_visitor_) { |
| 593 debug_visitor_->OnRstStreamFrame(frame); | 592 debug_visitor_->OnRstStreamFrame(frame); |
| 594 } | 593 } |
| 595 DVLOG(1) << ENDPOINT << "Stream reset with error " | 594 DVLOG(1) << ENDPOINT << "Stream reset with error " |
| 596 << QuicUtils::StreamErrorToString(frame.error_code); | 595 << QuicUtils::StreamErrorToString(frame.error_code); |
| (...skipping 1068 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1665 // If we changed the generator's batch state, restore original batch state. | 1664 // If we changed the generator's batch state, restore original batch state. |
| 1666 if (!already_in_batch_mode_) { | 1665 if (!already_in_batch_mode_) { |
| 1667 DVLOG(1) << "Leaving Batch Mode."; | 1666 DVLOG(1) << "Leaving Batch Mode."; |
| 1668 connection_->packet_generator_.FinishBatchOperations(); | 1667 connection_->packet_generator_.FinishBatchOperations(); |
| 1669 } | 1668 } |
| 1670 DCHECK_EQ(already_in_batch_mode_, | 1669 DCHECK_EQ(already_in_batch_mode_, |
| 1671 connection_->packet_generator_.InBatchMode()); | 1670 connection_->packet_generator_.InBatchMode()); |
| 1672 } | 1671 } |
| 1673 | 1672 |
| 1674 } // namespace net | 1673 } // namespace net |
| OLD | NEW |