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

Side by Side Diff: net/quic/core/quic_crypto_server_stream.cc

Issue 2679783003: Deprecate FLAGS_quic_reloadable_flag_enable_async_get_proof (Closed)
Patch Set: Address gredner's comments. Created 3 years, 10 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
« no previous file with comments | « net/quic/core/quic_crypto_client_stream_test.cc ('k') | net/quic/core/quic_flags_list.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 #include "net/quic/core/quic_crypto_server_stream.h" 5 #include "net/quic/core/quic_crypto_server_stream.h"
6 6
7 #include <memory> 7 #include <memory>
8 8
9 #include "net/quic/core/crypto/crypto_protocol.h" 9 #include "net/quic/core/crypto/crypto_protocol.h"
10 #include "net/quic/core/crypto/crypto_utils.h" 10 #include "net/quic/core/crypto/crypto_utils.h"
(...skipping 266 matching lines...) Expand 10 before | Expand all | Expand 10 after
277 handshake_confirmed_ = true; 277 handshake_confirmed_ = true;
278 session()->OnCryptoHandshakeEvent(QuicSession::HANDSHAKE_CONFIRMED); 278 session()->OnCryptoHandshakeEvent(QuicSession::HANDSHAKE_CONFIRMED);
279 } 279 }
280 280
281 void QuicCryptoServerStream::SendServerConfigUpdate( 281 void QuicCryptoServerStream::SendServerConfigUpdate(
282 const CachedNetworkParameters* cached_network_params) { 282 const CachedNetworkParameters* cached_network_params) {
283 if (!handshake_confirmed_) { 283 if (!handshake_confirmed_) {
284 return; 284 return;
285 } 285 }
286 286
287 if (FLAGS_quic_reloadable_flag_enable_async_get_proof) { 287 if (send_server_config_update_cb_ != nullptr) {
288 if (send_server_config_update_cb_ != nullptr) { 288 QUIC_DVLOG(1)
289 QUIC_DVLOG(1) 289 << "Skipped server config update since one is already in progress";
290 << "Skipped server config update since one is already in progress";
291 return;
292 }
293
294 std::unique_ptr<SendServerConfigUpdateCallback> cb(
295 new SendServerConfigUpdateCallback(this));
296 send_server_config_update_cb_ = cb.get();
297
298 crypto_config_->BuildServerConfigUpdateMessage(
299 session()->connection()->version(), chlo_hash_,
300 previous_source_address_tokens_,
301 session()->connection()->self_address(),
302 session()->connection()->peer_address().host(),
303 session()->connection()->clock(),
304 session()->connection()->random_generator(), compressed_certs_cache_,
305 *crypto_negotiated_params_, cached_network_params,
306 (session()->config()->HasReceivedConnectionOptions()
307 ? session()->config()->ReceivedConnectionOptions()
308 : QuicTagVector()),
309 std::move(cb));
310 return; 290 return;
311 } 291 }
312 292
313 CryptoHandshakeMessage server_config_update_message; 293 std::unique_ptr<SendServerConfigUpdateCallback> cb(
314 if (!crypto_config_->BuildServerConfigUpdateMessage( 294 new SendServerConfigUpdateCallback(this));
315 session()->connection()->version(), chlo_hash_, 295 send_server_config_update_cb_ = cb.get();
316 previous_source_address_tokens_,
317 session()->connection()->self_address(),
318 session()->connection()->peer_address().host(),
319 session()->connection()->clock(),
320 session()->connection()->random_generator(), compressed_certs_cache_,
321 *crypto_negotiated_params_, cached_network_params,
322 (session()->config()->HasReceivedConnectionOptions()
323 ? session()->config()->ReceivedConnectionOptions()
324 : QuicTagVector()),
325 &server_config_update_message)) {
326 QUIC_DVLOG(1) << "Server: Failed to build server config update (SCUP)!";
327 return;
328 }
329 296
330 QUIC_DVLOG(1) << "Server: Sending server config update: " 297 crypto_config_->BuildServerConfigUpdateMessage(
331 << server_config_update_message.DebugString(); 298 session()->connection()->version(), chlo_hash_,
332 const QuicData& data = server_config_update_message.GetSerialized(); 299 previous_source_address_tokens_, session()->connection()->self_address(),
333 WriteOrBufferData(StringPiece(data.data(), data.length()), false, nullptr); 300 session()->connection()->peer_address().host(),
334 301 session()->connection()->clock(),
335 ++num_server_config_update_messages_sent_; 302 session()->connection()->random_generator(), compressed_certs_cache_,
303 *crypto_negotiated_params_, cached_network_params,
304 (session()->config()->HasReceivedConnectionOptions()
305 ? session()->config()->ReceivedConnectionOptions()
306 : QuicTagVector()),
307 std::move(cb));
336 } 308 }
337 309
338 QuicCryptoServerStream::SendServerConfigUpdateCallback:: 310 QuicCryptoServerStream::SendServerConfigUpdateCallback::
339 SendServerConfigUpdateCallback(QuicCryptoServerStream* parent) 311 SendServerConfigUpdateCallback(QuicCryptoServerStream* parent)
340 : parent_(parent) {} 312 : parent_(parent) {}
341 313
342 void QuicCryptoServerStream::SendServerConfigUpdateCallback::Cancel() { 314 void QuicCryptoServerStream::SendServerConfigUpdateCallback::Cancel() {
343 parent_ = nullptr; 315 parent_ = nullptr;
344 } 316 }
345 317
(...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after
488 QuicConnectionId QuicCryptoServerStream::GenerateConnectionIdForReject( 460 QuicConnectionId QuicCryptoServerStream::GenerateConnectionIdForReject(
489 bool use_stateless_rejects) { 461 bool use_stateless_rejects) {
490 if (!use_stateless_rejects) { 462 if (!use_stateless_rejects) {
491 return 0; 463 return 0;
492 } 464 }
493 return helper_->GenerateConnectionIdForReject( 465 return helper_->GenerateConnectionIdForReject(
494 session()->connection()->connection_id()); 466 session()->connection()->connection_id());
495 } 467 }
496 468
497 } // namespace net 469 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/core/quic_crypto_client_stream_test.cc ('k') | net/quic/core/quic_flags_list.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698