| Index: net/tools/quic/quic_client.h
|
| diff --git a/net/tools/quic/quic_client.h b/net/tools/quic/quic_client.h
|
| index 5dff8cfe5055ffd92561ebf6ce7ceaf14cd47840..8b5735520689946a779aec4a1a70cec3725545ce 100644
|
| --- a/net/tools/quic/quic_client.h
|
| +++ b/net/tools/quic/quic_client.h
|
| @@ -25,6 +25,7 @@
|
| #include "net/tools/epoll_server/epoll_server.h"
|
| #include "net/tools/quic/quic_client_base.h"
|
| #include "net/tools/quic/quic_client_session.h"
|
| +#include "net/tools/quic/quic_packet_reader.h"
|
| #include "net/tools/quic/quic_process_packet_interface.h"
|
|
|
| namespace net {
|
| @@ -32,7 +33,6 @@ namespace net {
|
| class QuicServerId;
|
|
|
| class QuicEpollConnectionHelper;
|
| -class QuicPacketReader;
|
|
|
| namespace test {
|
| class QuicClientPeer;
|
| @@ -193,14 +193,7 @@ class QuicClient : public QuicClientBase,
|
| return &push_promise_index_;
|
| }
|
|
|
| - protected:
|
| virtual QuicPacketWriter* CreateQuicPacketWriter();
|
| - virtual QuicPacketReader* CreateQuicPacketReader();
|
| -
|
| - virtual int ReadPacket(char* buffer,
|
| - int buffer_len,
|
| - IPEndPoint* server_address,
|
| - IPAddress* client_ip);
|
|
|
| // If |fd| is an open UDP socket, unregister and close it. Otherwise, do
|
| // nothing.
|
| @@ -243,19 +236,11 @@ class QuicClient : public QuicClientBase,
|
|
|
| // Used during initialization: creates the UDP socket FD, sets socket options,
|
| // and binds the socket to our address.
|
| - bool CreateUDPSocket();
|
| + bool CreateUDPSocketAndBind();
|
|
|
| // Actually clean up |fd|.
|
| void CleanUpUDPSocketImpl(int fd);
|
|
|
| - // 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.
|
| - // TODO(rtenneti): Add support for ReadAndProcessPackets().
|
| - // bool ReadAndProcessPackets();
|
| -
|
| // If the request URL matches a push promise, bypass sending the
|
| // request.
|
| bool MaybeHandlePromised(const BalsaHeaders& headers,
|
| @@ -296,6 +281,9 @@ class QuicClient : public QuicClientBase,
|
| // because the socket would otherwise overflow.
|
| bool overflow_supported_;
|
|
|
| + // If true, use recvmmsg for reading.
|
| + bool use_recvmmsg_;
|
| +
|
| // If true, store the latest response code, headers, and body.
|
| bool store_response_;
|
| // HTTP response code from most recent response.
|
| @@ -319,7 +307,7 @@ class QuicClient : public QuicClientBase,
|
| //
|
| // TODO(rtenneti): Chromium code doesn't use |packet_reader_|. Add support for
|
| // QuicPacketReader
|
| - QuicPacketReader* packet_reader_;
|
| + scoped_ptr<QuicPacketReader> packet_reader_;
|
|
|
| std::unique_ptr<ClientQuicDataToResend> push_promise_data_to_resend_;
|
|
|
|
|