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/tools/quic/quic_dispatcher.h" | 5 #include "net/tools/quic/quic_dispatcher.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/macros.h" | 9 #include "base/macros.h" |
10 #include "net/quic/core/crypto/quic_random.h" | 10 #include "net/quic/core/crypto/quic_random.h" |
(...skipping 507 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
518 if (!writer_->IsWriteBlocked()) { | 518 if (!writer_->IsWriteBlocked()) { |
519 QUIC_BUG << "QuicDispatcher::OnWriteBlocked called when the writer is " | 519 QUIC_BUG << "QuicDispatcher::OnWriteBlocked called when the writer is " |
520 "not blocked."; | 520 "not blocked."; |
521 // Return without adding the connection to the blocked list, to avoid | 521 // Return without adding the connection to the blocked list, to avoid |
522 // infinite loops in OnCanWrite. | 522 // infinite loops in OnCanWrite. |
523 return; | 523 return; |
524 } | 524 } |
525 write_blocked_list_.insert(std::make_pair(blocked_writer, true)); | 525 write_blocked_list_.insert(std::make_pair(blocked_writer, true)); |
526 } | 526 } |
527 | 527 |
| 528 void QuicDispatcher::OnRstStreamReceived(const QuicRstStreamFrame& frame) {} |
| 529 |
528 void QuicDispatcher::OnConnectionAddedToTimeWaitList( | 530 void QuicDispatcher::OnConnectionAddedToTimeWaitList( |
529 QuicConnectionId connection_id) { | 531 QuicConnectionId connection_id) { |
530 QUIC_DLOG(INFO) << "Connection " << connection_id | 532 QUIC_DLOG(INFO) << "Connection " << connection_id |
531 << " added to time wait list."; | 533 << " added to time wait list."; |
532 } | 534 } |
533 | 535 |
534 void QuicDispatcher::OnPacket() {} | 536 void QuicDispatcher::OnPacket() {} |
535 | 537 |
536 void QuicDispatcher::OnError(QuicFramer* framer) { | 538 void QuicDispatcher::OnError(QuicFramer* framer) { |
537 QuicErrorCode error = framer->error(); | 539 QuicErrorCode error = framer->error(); |
(...skipping 448 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
986 void QuicDispatcher::DeliverPacketsToSession( | 988 void QuicDispatcher::DeliverPacketsToSession( |
987 const std::list<BufferedPacket>& packets, | 989 const std::list<BufferedPacket>& packets, |
988 QuicSession* session) { | 990 QuicSession* session) { |
989 for (const BufferedPacket& packet : packets) { | 991 for (const BufferedPacket& packet : packets) { |
990 session->ProcessUdpPacket(packet.server_address, packet.client_address, | 992 session->ProcessUdpPacket(packet.server_address, packet.client_address, |
991 *(packet.packet)); | 993 *(packet.packet)); |
992 } | 994 } |
993 } | 995 } |
994 | 996 |
995 } // namespace net | 997 } // namespace net |
OLD | NEW |