relnote: moves ProcessPacketInterface from quic_dispatcher.h to

net/tools/quic/quic_client.h

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 //
 // A toy client, which connects to a specified port and sends QUIC
 // request to that endpoint.
 
 #ifndef NET_TOOLS_QUIC_QUIC_CLIENT_H_
 #define NET_TOOLS_QUIC_QUIC_CLIENT_H_
 
 #include <string>
 
 #include "base/basictypes.h"
 #include "base/command_line.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/strings/string_piece.h"
 #include "net/base/ip_endpoint.h"
 #include "net/quic/quic_config.h"
 #include "net/quic/quic_data_stream.h"
 #include "net/tools/balsa/balsa_headers.h"
 #include "net/tools/epoll_server/epoll_server.h"
 #include "net/tools/quic/quic_client_base.h"
+#include "net/tools/quic/quic_packet_reader.h"
 
 namespace net {
 
 class QuicServerId;
 
 namespace tools {
 
 class QuicEpollConnectionHelper;
 
 namespace test {
 class QuicClientPeer;
 }  // namespace test
 
 class QuicClient : public QuicClientBase,
                    public EpollCallbackInterface,
-                   public QuicDataStream::Visitor {
+                   public QuicDataStream::Visitor,
+                   public ProcessPacketInterface {
  public:
   class ResponseListener {
    public:
     ResponseListener() {}
     virtual ~ResponseListener() {}
     virtual void OnCompleteResponse(QuicStreamId id,
                                     const BalsaHeaders& response_headers,
                                     const std::string& response_body) = 0;
   };
 
@@ skipping 109 matching lines @@
   void set_response_listener(ResponseListener* listener) {
     response_listener_.reset(listener);
   }
 
   void set_store_response(bool val) { store_response_ = val; }
 
   size_t latest_response_code() const;
   const std::string& latest_response_headers() const;
   const std::string& latest_response_body() const;
 
+  // Implements ProcessPacketInterface. This will be called for each received
+  // packet.
+  void ProcessPacket(const IPEndPoint& self_address,
+                     const IPEndPoint& peer_address,
+                     const QuicEncryptedPacket& packet) override;
+
  protected:
   virtual QuicEpollConnectionHelper* CreateQuicConnectionHelper();
   virtual QuicPacketWriter* CreateQuicPacketWriter();
+  virtual QuicPacketReader* CreateQuicPacketReader();
 
   virtual int ReadPacket(char* buffer,
                          int buffer_len,
                          IPEndPoint* server_address,
                          IPAddressNumber* client_ip);
 
   EpollServer* epoll_server() { return epoll_server_; }
 
   // If the socket has been created, then unregister and close() the FD.
   virtual void CleanUpUDPSocket();
@@ skipping 27 matching lines @@
   // Used during initialization: creates the UDP socket FD, sets socket options,
   // and binds the socket to our address.
   bool CreateUDPSocket();
 
   // Actually clean up the socket.
   void CleanUpUDPSocketImpl();
 
   // Read a UDP packet and hand it to the framer.
   bool ReadAndProcessPacket();
 
+  // Read available UDP packets up to kNumPacketsPerReadCall
+  // and hand them to the connection.
+  bool ReadAndProcessPackets();
+
   // Address of the server.
   const IPEndPoint server_address_;
 
   // Address of the client if the client is connected to the server.
   IPEndPoint client_address_;
 
   // If initialized, the address to bind to.
   IPAddressNumber bind_to_address_;
   // Local port to bind to. Initialize to 0.
   int local_port_;
@@ skipping 29 matching lines @@
   // Body of most recent response.
   std::string latest_response_body_;
 
   // Keeps track of any data sent before the handshake.
   std::vector<QuicDataToResend*> data_sent_before_handshake_;
 
   // Once the client receives a stateless reject, keeps track of any data that
   // must be resent upon a subsequent successful connection.
   std::vector<QuicDataToResend*> data_to_resend_on_connect_;
 
+  // Point to a QuicPacketReader object on the heap. The reader allocates more
+  // space than allowed on the stack.
+  scoped_ptr<QuicPacketReader> packet_reader_;
+
   DISALLOW_COPY_AND_ASSIGN(QuicClient);
 };
 
 }  // namespace tools
 }  // namespace net
 
 #endif  // NET_TOOLS_QUIC_QUIC_CLIENT_H_