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_simple_client.h" | 5 #include "net/tools/quic/quic_simple_client.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/run_loop.h" | 10 #include "base/run_loop.h" |
(...skipping 243 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
254 LOG(DFATAL) << "stream creation failed!"; | 254 LOG(DFATAL) << "stream creation failed!"; |
255 return; | 255 return; |
256 } | 256 } |
257 SpdyHeaderBlock header_block; | 257 SpdyHeaderBlock header_block; |
258 CreateSpdyHeadersFromHttpRequest(headers, headers.extra_headers, net::HTTP2, | 258 CreateSpdyHeadersFromHttpRequest(headers, headers.extra_headers, net::HTTP2, |
259 true, &header_block); | 259 true, &header_block); |
260 stream->set_visitor(this); | 260 stream->set_visitor(this); |
261 stream->SendRequest(std::move(header_block), body, fin); | 261 stream->SendRequest(std::move(header_block), body, fin); |
262 if (FLAGS_enable_quic_stateless_reject_support) { | 262 if (FLAGS_enable_quic_stateless_reject_support) { |
263 // Record this in case we need to resend. | 263 // Record this in case we need to resend. |
264 auto new_headers = new HttpRequestInfo; | 264 auto* new_headers = new HttpRequestInfo; |
265 *new_headers = headers; | 265 *new_headers = headers; |
266 auto data_to_resend = | 266 auto* data_to_resend = |
267 new ClientQuicDataToResend(new_headers, body, fin, this); | 267 new ClientQuicDataToResend(new_headers, body, fin, this); |
268 MaybeAddQuicDataToResend(data_to_resend); | 268 MaybeAddQuicDataToResend(data_to_resend); |
269 } | 269 } |
270 } | 270 } |
271 | 271 |
272 void QuicSimpleClient::MaybeAddQuicDataToResend( | 272 void QuicSimpleClient::MaybeAddQuicDataToResend( |
273 QuicDataToResend* data_to_resend) { | 273 QuicDataToResend* data_to_resend) { |
274 DCHECK(FLAGS_enable_quic_stateless_reject_support); | 274 DCHECK(FLAGS_enable_quic_stateless_reject_support); |
275 if (session()->IsCryptoHandshakeConfirmed()) { | 275 if (session()->IsCryptoHandshakeConfirmed()) { |
276 // The handshake is confirmed. No need to continue saving requests to | 276 // The handshake is confirmed. No need to continue saving requests to |
(...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
407 session()->connection()->ProcessUdpPacket(local_address, peer_address, | 407 session()->connection()->ProcessUdpPacket(local_address, peer_address, |
408 packet); | 408 packet); |
409 if (!session()->connection()->connected()) { | 409 if (!session()->connection()->connected()) { |
410 return false; | 410 return false; |
411 } | 411 } |
412 | 412 |
413 return true; | 413 return true; |
414 } | 414 } |
415 | 415 |
416 } // namespace net | 416 } // namespace net |
OLD | NEW |