Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(92)

Side by Side Diff: net/quic/quic_connection.h

Issue 366863002: Land Recent QUIC Changes. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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 // The entity that handles framing writes for a Quic client or server. 5 // The entity that handles framing writes for a Quic client or server.
6 // Each QuicSession will have a connection associated with it. 6 // Each QuicSession will have a connection associated with it.
7 // 7 //
8 // On the server side, the Dispatcher handles the raw reads, and hands off 8 // On the server side, the Dispatcher handles the raw reads, and hands off
9 // packets via ProcessUdpPacket for framing and processing. 9 // packets via ProcessUdpPacket for framing and processing.
10 // 10 //
(...skipping 288 matching lines...) Expand 10 before | Expand all | Expand 10 after
299 299
300 // Called when a packet has been finally sent to the network. 300 // Called when a packet has been finally sent to the network.
301 bool OnPacketSent(WriteResult result); 301 bool OnPacketSent(WriteResult result);
302 302
303 // If the socket is not blocked, writes queued packets. 303 // If the socket is not blocked, writes queued packets.
304 void WriteIfNotBlocked(); 304 void WriteIfNotBlocked();
305 305
306 // Do any work which logically would be done in OnPacket but can not be 306 // Do any work which logically would be done in OnPacket but can not be
307 // safely done until the packet is validated. Returns true if the packet 307 // safely done until the packet is validated. Returns true if the packet
308 // can be handled, false otherwise. 308 // can be handled, false otherwise.
309 bool ProcessValidatedPacket(); 309 virtual bool ProcessValidatedPacket();
wtc 2014/07/02 22:56:48 Why does this method need to be virtual? I don't s
ramant (doing other things) 2014/07/16 19:43:35 Our internal code override's this method. It is no
310 310
311 // The version of the protocol this connection is using. 311 // The version of the protocol this connection is using.
312 QuicVersion version() const { return framer_.version(); } 312 QuicVersion version() const { return framer_.version(); }
313 313
314 // The versions of the protocol that this connection supports. 314 // The versions of the protocol that this connection supports.
315 const QuicVersionVector& supported_versions() const { 315 const QuicVersionVector& supported_versions() const {
316 return framer_.supported_versions(); 316 return framer_.supported_versions();
317 } 317 }
318 318
319 // From QuicFramerVisitorInterface 319 // From QuicFramerVisitorInterface
(...skipping 185 matching lines...) Expand 10 before | Expand all | Expand 10 after
505 505
506 QuicConnectionHelperInterface* helper() { return helper_; } 506 QuicConnectionHelperInterface* helper() { return helper_; }
507 507
508 // Selects and updates the version of the protocol being used by selecting a 508 // Selects and updates the version of the protocol being used by selecting a
509 // version from |available_versions| which is also supported. Returns true if 509 // version from |available_versions| which is also supported. Returns true if
510 // such a version exists, false otherwise. 510 // such a version exists, false otherwise.
511 bool SelectMutualVersion(const QuicVersionVector& available_versions); 511 bool SelectMutualVersion(const QuicVersionVector& available_versions);
512 512
513 QuicPacketWriter* writer() { return writer_; } 513 QuicPacketWriter* writer() { return writer_; }
514 514
515 bool peer_port_changed() const { return peer_port_changed_; }
516
517 const QuicReceivedPacketManager& received_packet_manager() {
wtc 2014/07/02 22:56:48 Mark this method const?
ramant (doing other things) 2014/07/16 19:43:35 Done.
518 return received_packet_manager_;
519 }
520
521 QuicPacketSequenceNumber sequence_number_of_last_sent_packet() const {
522 return sequence_number_of_last_sent_packet_;
523 }
524
515 private: 525 private:
516 friend class test::QuicConnectionPeer; 526 friend class test::QuicConnectionPeer;
517 527
518 // Packets which have not been written to the wire. 528 // Packets which have not been written to the wire.
519 // Owns the QuicPacket* packet. 529 // Owns the QuicPacket* packet.
520 struct QueuedPacket { 530 struct QueuedPacket {
521 QueuedPacket(SerializedPacket packet, 531 QueuedPacket(SerializedPacket packet,
522 EncryptionLevel level, 532 EncryptionLevel level,
523 TransmissionType transmission_type); 533 TransmissionType transmission_type);
524 534
(...skipping 238 matching lines...) Expand 10 before | Expand all | Expand 10 after
763 // If non-empty this contains the set of versions received in a 773 // If non-empty this contains the set of versions received in a
764 // version negotiation packet. 774 // version negotiation packet.
765 QuicVersionVector server_supported_versions_; 775 QuicVersionVector server_supported_versions_;
766 776
767 DISALLOW_COPY_AND_ASSIGN(QuicConnection); 777 DISALLOW_COPY_AND_ASSIGN(QuicConnection);
768 }; 778 };
769 779
770 } // namespace net 780 } // namespace net
771 781
772 #endif // NET_QUIC_QUIC_CONNECTION_H_ 782 #endif // NET_QUIC_QUIC_CONNECTION_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698