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
3 // found in the LICENSE file.
5 #ifndef NET_TOOLS_QUIC_TEST_TOOLS_QUIC_TEST_CLIENT_H_
6 #define NET_TOOLS_QUIC_TEST_TOOLS_QUIC_TEST_CLIENT_H_
10 #include "base/basictypes.h"
11 #include "base/memory/scoped_ptr.h"
12 #include "net/base/ip_endpoint.h"
13 #include "net/quic/quic_framer.h"
14 #include "net/quic/quic_packet_creator.h"
15 #include "net/quic/quic_protocol.h"
16 #include "net/tools/balsa/balsa_frame.h"
17 #include "net/tools/epoll_server/epoll_server.h"
18 #include "net/tools/quic/quic_client.h"
19 #include "net/tools/quic/test_tools/simple_client.h"
27 class QuicPacketWriterWrapper
;
32 class MockableQuicClient
;
34 // A quic client which allows mocking out writes.
35 class MockableQuicClient
: public QuicClient
{
37 MockableQuicClient(IPEndPoint server_address
,
38 const QuicServerId
& server_id
,
39 const QuicVersionVector
& supported_versions
,
40 EpollServer
* epoll_server
);
42 MockableQuicClient(IPEndPoint server_address
,
43 const QuicServerId
& server_id
,
44 const QuicConfig
& config
,
45 const QuicVersionVector
& supported_versions
,
46 EpollServer
* epoll_server
);
48 virtual ~MockableQuicClient() OVERRIDE
;
49 virtual QuicPacketWriter
* CreateQuicPacketWriter() OVERRIDE
;
50 virtual QuicConnectionId
GenerateConnectionId() OVERRIDE
;
51 void UseWriter(QuicPacketWriterWrapper
* writer
);
52 void UseConnectionId(QuicConnectionId connection_id
);
55 QuicConnectionId override_connection_id_
; // ConnectionId to use, if nonzero
56 QuicPacketWriterWrapper
* test_writer_
;
58 DISALLOW_COPY_AND_ASSIGN(MockableQuicClient
);
61 // A toy QUIC client used for testing, mostly following the SimpleClient APIs.
62 class QuicTestClient
: public SimpleClient
,
63 public QuicDataStream::Visitor
{
65 QuicTestClient(IPEndPoint server_address
,
66 const string
& server_hostname
,
67 const QuicVersionVector
& supported_versions
);
68 QuicTestClient(IPEndPoint server_address
,
69 const string
& server_hostname
,
71 const QuicVersionVector
& supported_versions
);
72 QuicTestClient(IPEndPoint server_address
,
73 const string
& server_hostname
,
75 const QuicConfig
& config
,
76 const QuicVersionVector
& supported_versions
);
78 virtual ~QuicTestClient();
80 // ExpectCertificates controls whether the server is expected to provide
81 // certificates. The certificates, if any, are not verified, but the common
82 // name is recorded and available with |cert_common_name()|.
83 void ExpectCertificates(bool on
);
85 // Sets the |user_agent_id| of the |client_|.
86 void SetUserAgentID(const string
& user_agent_id
);
88 // Wraps data in a quic packet and sends it.
89 ssize_t
SendData(string data
, bool last_data
);
92 // Clears any outstanding state and sends a simple GET of 'uri' to the
93 // server. Returns 0 if the request failed and no bytes were written.
94 virtual ssize_t
SendRequest(const string
& uri
) OVERRIDE
;
95 virtual ssize_t
SendMessage(const HTTPMessage
& message
) OVERRIDE
;
96 virtual string
SendCustomSynchronousRequest(
97 const HTTPMessage
& message
) OVERRIDE
;
98 virtual string
SendSynchronousRequest(const string
& uri
) OVERRIDE
;
99 virtual void Connect() OVERRIDE
;
100 virtual void ResetConnection() OVERRIDE
;
101 virtual void Disconnect() OVERRIDE
;
102 virtual IPEndPoint
LocalSocketAddress() const OVERRIDE
;
103 virtual void ClearPerRequestState() OVERRIDE
;
104 virtual void WaitForResponseForMs(int timeout_ms
) OVERRIDE
;
105 virtual void WaitForInitialResponseForMs(int timeout_ms
) OVERRIDE
;
106 virtual ssize_t
Send(const void *buffer
, size_t size
) OVERRIDE
;
107 virtual bool response_complete() const OVERRIDE
;
108 virtual bool response_headers_complete() const OVERRIDE
;
109 virtual const BalsaHeaders
* response_headers() const OVERRIDE
;
110 virtual int64
response_size() const OVERRIDE
;
111 virtual int response_header_size() const OVERRIDE
;
112 virtual int64
response_body_size() const OVERRIDE
;
113 virtual size_t bytes_read() const OVERRIDE
;
114 virtual size_t bytes_written() const OVERRIDE
;
115 virtual bool buffer_body() const OVERRIDE
;
116 virtual void set_buffer_body(bool buffer_body
) OVERRIDE
;
117 virtual bool ServerInLameDuckMode() const OVERRIDE
;
118 virtual const string
& response_body() OVERRIDE
;
119 virtual bool connected() const OVERRIDE
;
120 // These functions are all unimplemented functions from SimpleClient, and log
121 // DFATAL if called by users of SimpleClient.
122 virtual ssize_t
SendAndWaitForResponse(const void *buffer
,
123 size_t size
) OVERRIDE
;
124 virtual void Bind(IPEndPoint
* local_address
) OVERRIDE
;
125 virtual string
SerializeMessage(const HTTPMessage
& message
) OVERRIDE
;
126 virtual IPAddressNumber
bind_to_address() const OVERRIDE
;
127 virtual void set_bind_to_address(IPAddressNumber address
) OVERRIDE
;
128 virtual const IPEndPoint
& address() const OVERRIDE
;
129 virtual size_t requests_sent() const OVERRIDE
;
131 // From QuicDataStream::Visitor
132 virtual void OnClose(QuicDataStream
* stream
) OVERRIDE
;
134 // Configures client_ to take ownership of and use the writer.
135 // Must be called before initial connect.
136 void UseWriter(QuicPacketWriterWrapper
* writer
);
137 // If the given ConnectionId is nonzero, configures client_ to use a specific
138 // ConnectionId instead of a random one.
139 void UseConnectionId(QuicConnectionId connection_id
);
141 // Returns NULL if the maximum number of streams have already been created.
142 QuicSpdyClientStream
* GetOrCreateStream();
144 QuicRstStreamErrorCode
stream_error() { return stream_error_
; }
145 QuicErrorCode
connection_error();
147 MockableQuicClient
* client();
149 // cert_common_name returns the common name value of the server's certificate,
150 // or the empty string if no certificate was presented.
151 const string
& cert_common_name() const;
153 // Get the server config map.
154 QuicTagValueMap
GetServerConfig() const;
156 void set_auto_reconnect(bool reconnect
) { auto_reconnect_
= reconnect
; }
158 void set_priority(QuicPriority priority
) { priority_
= priority
; }
160 // Sets client's FEC policy. This policy applies to the data stream(s), and
161 // also to the headers and crypto streams.
162 void SetFecPolicy(FecPolicy fec_policy
);
164 void WaitForWriteToFlush();
166 EpollServer
* epoll_server() { return &epoll_server_
; }
171 void Initialize(bool secure
);
173 void set_client(MockableQuicClient
* client
) { client_
.reset(client
); }
176 EpollServer epoll_server_
;
177 scoped_ptr
<MockableQuicClient
> client_
; // The actual client
178 QuicSpdyClientStream
* stream_
;
180 QuicRstStreamErrorCode stream_error_
;
182 bool response_complete_
;
183 bool response_headers_complete_
;
184 BalsaHeaders headers_
;
185 QuicPriority priority_
;
188 uint64 bytes_written_
;
189 // The number of uncompressed HTTP header bytes received.
190 int response_header_size_
;
191 // The number of HTTP body bytes received.
192 int64 response_body_size_
;
193 // True if we tried to connect already since the last call to Disconnect().
194 bool connect_attempted_
;
196 // The client will auto-connect exactly once before sending data. If
197 // something causes a connection reset, it will not automatically reconnect
198 // unless auto_reconnect_ is true.
199 bool auto_reconnect_
;
200 // Should we buffer the response body? Defaults to true.
202 // FEC policy for data sent by this client.
203 FecPolicy fec_policy_
;
204 // proof_verifier_ points to a RecordingProofVerifier that is owned by
206 ProofVerifier
* proof_verifier_
;
208 DISALLOW_COPY_AND_ASSIGN(QuicTestClient
);
216 #endif // NET_TOOLS_QUIC_TEST_TOOLS_QUIC_TEST_CLIENT_H_