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

Side by Side Diff: net/quic/chromium/quic_stream_factory.h

Issue 2267603002: Revert of QUIC - Race Cert Verification with host resolution if certs are (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Fixup Created 4 years, 4 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
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 #ifndef NET_QUIC_QUIC_STREAM_FACTORY_H_ 5 #ifndef NET_QUIC_QUIC_STREAM_FACTORY_H_
6 #define NET_QUIC_QUIC_STREAM_FACTORY_H_ 6 #define NET_QUIC_QUIC_STREAM_FACTORY_H_
7 7
8 #include <stddef.h> 8 #include <stddef.h>
9 #include <stdint.h> 9 #include <stdint.h>
10 10
(...skipping 176 matching lines...) Expand 10 before | Expand all | Expand 10 after
187 int socket_receive_buffer_size, 187 int socket_receive_buffer_size,
188 bool delay_tcp_race, 188 bool delay_tcp_race,
189 int max_server_configs_stored_in_properties, 189 int max_server_configs_stored_in_properties,
190 bool close_sessions_on_ip_change, 190 bool close_sessions_on_ip_change,
191 bool disable_quic_on_timeout_with_open_streams, 191 bool disable_quic_on_timeout_with_open_streams,
192 int idle_connection_timeout_seconds, 192 int idle_connection_timeout_seconds,
193 bool migrate_sessions_on_network_change, 193 bool migrate_sessions_on_network_change,
194 bool migrate_sessions_early, 194 bool migrate_sessions_early,
195 bool allow_server_migration, 195 bool allow_server_migration,
196 bool force_hol_blocking, 196 bool force_hol_blocking,
197 bool race_cert_verification,
198 const QuicTagVector& connection_options, 197 const QuicTagVector& connection_options,
199 bool enable_token_binding); 198 bool enable_token_binding);
200 ~QuicStreamFactory() override; 199 ~QuicStreamFactory() override;
201 200
202 // Returns true if there is an existing session for |server_id| or if the 201 // Returns true if there is an existing session for |server_id| or if the
203 // request can be pooled to an existing session to the IP address of 202 // request can be pooled to an existing session to the IP address of
204 // |destination|. 203 // |destination|.
205 bool CanUseExistingSession(const QuicServerId& server_id, 204 bool CanUseExistingSession(const QuicServerId& server_id,
206 const HostPortPair& destination); 205 const HostPortPair& destination);
207 206
(...skipping 161 matching lines...) Expand 10 before | Expand all | Expand 10 after
369 void set_enable_connection_racing(bool enable_connection_racing) { 368 void set_enable_connection_racing(bool enable_connection_racing) {
370 enable_connection_racing_ = enable_connection_racing; 369 enable_connection_racing_ = enable_connection_racing;
371 } 370 }
372 371
373 int socket_receive_buffer_size() const { return socket_receive_buffer_size_; } 372 int socket_receive_buffer_size() const { return socket_receive_buffer_size_; }
374 373
375 bool delay_tcp_race() const { return delay_tcp_race_; } 374 bool delay_tcp_race() const { return delay_tcp_race_; }
376 375
377 private: 376 private:
378 class Job; 377 class Job;
379 class CertVerifierJob;
380 friend class test::QuicStreamFactoryPeer; 378 friend class test::QuicStreamFactoryPeer;
381 FRIEND_TEST_ALL_PREFIXES(HttpStreamFactoryTest, QuicLossyProxyMarkedAsBad); 379 FRIEND_TEST_ALL_PREFIXES(HttpStreamFactoryTest, QuicLossyProxyMarkedAsBad);
382 380
383 typedef std::map<QuicServerId, QuicChromiumClientSession*> SessionMap; 381 typedef std::map<QuicServerId, QuicChromiumClientSession*> SessionMap;
384 typedef std::map<QuicChromiumClientSession*, QuicSessionKey> SessionIdMap; 382 typedef std::map<QuicChromiumClientSession*, QuicSessionKey> SessionIdMap;
385 typedef std::set<QuicSessionKey> AliasSet; 383 typedef std::set<QuicSessionKey> AliasSet;
386 typedef std::map<QuicChromiumClientSession*, AliasSet> SessionAliasMap; 384 typedef std::map<QuicChromiumClientSession*, AliasSet> SessionAliasMap;
387 typedef std::set<QuicChromiumClientSession*> SessionSet; 385 typedef std::set<QuicChromiumClientSession*> SessionSet;
388 typedef std::map<IPEndPoint, SessionSet> IPAliasMap; 386 typedef std::map<IPEndPoint, SessionSet> IPAliasMap;
389 typedef std::set<Job*> JobSet; 387 typedef std::set<Job*> JobSet;
390 typedef std::map<QuicServerId, JobSet> JobMap; 388 typedef std::map<QuicServerId, JobSet> JobMap;
391 typedef std::map<QuicStreamRequest*, QuicServerId> RequestMap; 389 typedef std::map<QuicStreamRequest*, QuicServerId> RequestMap;
392 typedef std::set<QuicStreamRequest*> RequestSet; 390 typedef std::set<QuicStreamRequest*> RequestSet;
393 typedef std::map<QuicServerId, RequestSet> ServerIDRequestsMap; 391 typedef std::map<QuicServerId, RequestSet> ServerIDRequestsMap;
394 typedef std::deque<enum QuicChromiumClientSession::QuicDisabledReason> 392 typedef std::deque<enum QuicChromiumClientSession::QuicDisabledReason>
395 DisabledReasonsQueue; 393 DisabledReasonsQueue;
396 typedef std::map<QuicServerId, std::unique_ptr<CertVerifierJob>>
397 CertVerifierJobMap;
398 394
399 enum FactoryStatus { 395 enum FactoryStatus {
400 OPEN, // New streams may be created. 396 OPEN, // New streams may be created.
401 CLOSED, // No new streams may be created temporarily. 397 CLOSED, // No new streams may be created temporarily.
402 DISABLED // No more streams may be created until the network changes. 398 DISABLED // No more streams may be created until the network changes.
403 }; 399 };
404 400
405 // Creates a job which doesn't wait for server config to be loaded from the 401 // Creates a job which doesn't wait for server config to be loaded from the
406 // disk cache. This job is started via a PostTask. 402 // disk cache. This job is started via a PostTask.
407 void CreateAuxilaryJob(const QuicSessionKey& key, 403 void CreateAuxilaryJob(const QuicSessionKey& key,
408 int cert_verify_flags, 404 int cert_verify_flags,
409 const BoundNetLog& net_log); 405 const BoundNetLog& net_log);
410 406
411 // Returns a newly created QuicHttpStream owned by the caller. 407 // Returns a newly created QuicHttpStream owned by the caller.
412 std::unique_ptr<QuicHttpStream> CreateFromSession( 408 std::unique_ptr<QuicHttpStream> CreateFromSession(
413 QuicChromiumClientSession* session); 409 QuicChromiumClientSession* session);
414 410
415 bool OnResolution(const QuicSessionKey& key, const AddressList& address_list); 411 bool OnResolution(const QuicSessionKey& key, const AddressList& address_list);
416 void OnJobComplete(Job* job, int rv); 412 void OnJobComplete(Job* job, int rv);
417 void OnCertVerifyJobComplete(CertVerifierJob* job, int rv);
418 bool HasActiveSession(const QuicServerId& server_id) const; 413 bool HasActiveSession(const QuicServerId& server_id) const;
419 bool HasActiveJob(const QuicServerId& server_id) const; 414 bool HasActiveJob(const QuicServerId& server_id) const;
420 bool HasActiveCertVerifierJob(const QuicServerId& server_id) const;
421 int CreateSession(const QuicSessionKey& key, 415 int CreateSession(const QuicSessionKey& key,
422 int cert_verify_flags, 416 int cert_verify_flags,
423 std::unique_ptr<QuicServerInfo> quic_server_info, 417 std::unique_ptr<QuicServerInfo> quic_server_info,
424 const AddressList& address_list, 418 const AddressList& address_list,
425 base::TimeTicks dns_resolution_end_time, 419 base::TimeTicks dns_resolution_end_time,
426 const BoundNetLog& net_log, 420 const BoundNetLog& net_log,
427 QuicChromiumClientSession** session); 421 QuicChromiumClientSession** session);
428 void ActivateSession(const QuicSessionKey& key, 422 void ActivateSession(const QuicSessionKey& key,
429 QuicChromiumClientSession* session); 423 QuicChromiumClientSession* session);
430 424
431 // Returns |srtt| in micro seconds from ServerNetworkStats. Returns 0 if there 425 // Returns |srtt| in micro seconds from ServerNetworkStats. Returns 0 if there
432 // is no |http_server_properties_| or if |http_server_properties_| doesn't 426 // is no |http_server_properties_| or if |http_server_properties_| doesn't
433 // have ServerNetworkStats for the given |server_id|. 427 // have ServerNetworkStats for the given |server_id|.
434 int64_t GetServerNetworkStatsSmoothedRttInMicroseconds( 428 int64_t GetServerNetworkStatsSmoothedRttInMicroseconds(
435 const QuicServerId& server_id) const; 429 const QuicServerId& server_id) const;
436 430
437 // Helper methods. 431 // Helper methods.
438 bool WasQuicRecentlyBroken(const QuicServerId& server_id) const; 432 bool WasQuicRecentlyBroken(const QuicServerId& server_id) const;
439 433
440 bool CryptoConfigCacheIsEmpty(const QuicServerId& server_id); 434 bool CryptoConfigCacheIsEmpty(const QuicServerId& server_id);
441 435
442 // Starts an asynchronous job for cert verification if
443 // |race_cert_verification_| is enabled and if there are cached certs for the
444 // given |server_id|.
445 QuicAsyncStatus StartCertVerifyJob(const QuicServerId& server_id,
446 int cert_verify_flags,
447 const BoundNetLog& net_log);
448
449 // Initializes the cached state associated with |server_id| in 436 // Initializes the cached state associated with |server_id| in
450 // |crypto_config_| with the information in |server_info|. Populates 437 // |crypto_config_| with the information in |server_info|. Populates
451 // |connection_id| with the next server designated connection id, 438 // |connection_id| with the next server designated connection id,
452 // if any, and otherwise leaves it unchanged. 439 // if any, and otherwise leaves it unchanged.
453 void InitializeCachedStateInCryptoConfig( 440 void InitializeCachedStateInCryptoConfig(
454 const QuicServerId& server_id, 441 const QuicServerId& server_id,
455 const std::unique_ptr<QuicServerInfo>& server_info, 442 const std::unique_ptr<QuicServerInfo>& server_info,
456 QuicConnectionId* connection_id); 443 QuicConnectionId* connection_id);
457 444
458 // Initialize |quic_supported_servers_at_startup_| with the list of servers 445 // Initialize |quic_supported_servers_at_startup_| with the list of servers
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after
516 // Origins which have gone away recently. 503 // Origins which have gone away recently.
517 AliasSet gone_away_aliases_; 504 AliasSet gone_away_aliases_;
518 505
519 const QuicConfig config_; 506 const QuicConfig config_;
520 QuicCryptoClientConfig crypto_config_; 507 QuicCryptoClientConfig crypto_config_;
521 508
522 JobMap active_jobs_; 509 JobMap active_jobs_;
523 ServerIDRequestsMap job_requests_map_; 510 ServerIDRequestsMap job_requests_map_;
524 RequestMap active_requests_; 511 RequestMap active_requests_;
525 512
526 CertVerifierJobMap active_cert_verifier_jobs_;
527
528 QuicVersionVector supported_versions_; 513 QuicVersionVector supported_versions_;
529 514
530 // Determine if we should consistently select a client UDP port. If false, 515 // Determine if we should consistently select a client UDP port. If false,
531 // then we will just let the OS select a random client port for each new 516 // then we will just let the OS select a random client port for each new
532 // connection. 517 // connection.
533 bool enable_port_selection_; 518 bool enable_port_selection_;
534 519
535 // Set if we always require handshake confirmation. If true, this will 520 // Set if we always require handshake confirmation. If true, this will
536 // introduce at least one RTT for the handshake before the client sends data. 521 // introduce at least one RTT for the handshake before the client sends data.
537 bool always_require_handshake_confirmation_; 522 bool always_require_handshake_confirmation_;
(...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after
607 // experiences poor connectivity. 592 // experiences poor connectivity.
608 const bool migrate_sessions_early_; 593 const bool migrate_sessions_early_;
609 594
610 // If set, allows migration of connection to server-specified alternate 595 // If set, allows migration of connection to server-specified alternate
611 // server address. 596 // server address.
612 const bool allow_server_migration_; 597 const bool allow_server_migration_;
613 598
614 // If set, force HOL blocking. For measurement purposes. 599 // If set, force HOL blocking. For measurement purposes.
615 const bool force_hol_blocking_; 600 const bool force_hol_blocking_;
616 601
617 // Set if cert verification is to be raced with host resolution.
618 bool race_cert_verification_;
619
620 // Each profile will (probably) have a unique port_seed_ value. This value 602 // Each profile will (probably) have a unique port_seed_ value. This value
621 // is used to help seed a pseudo-random number generator (PortSuggester) so 603 // is used to help seed a pseudo-random number generator (PortSuggester) so
622 // that we consistently (within this profile) suggest the same ephemeral 604 // that we consistently (within this profile) suggest the same ephemeral
623 // port when we re-connect to any given server/port. The differences between 605 // port when we re-connect to any given server/port. The differences between
624 // profiles (probablistically) prevent two profiles from colliding in their 606 // profiles (probablistically) prevent two profiles from colliding in their
625 // ephemeral port requests. 607 // ephemeral port requests.
626 uint64_t port_seed_; 608 uint64_t port_seed_;
627 609
628 // Local address of socket that was created in CreateSession. 610 // Local address of socket that was created in CreateSession.
629 IPEndPoint local_address_; 611 IPEndPoint local_address_;
(...skipping 15 matching lines...) Expand all
645 const scoped_refptr<SSLConfigService> ssl_config_service_; 627 const scoped_refptr<SSLConfigService> ssl_config_service_;
646 628
647 base::WeakPtrFactory<QuicStreamFactory> weak_factory_; 629 base::WeakPtrFactory<QuicStreamFactory> weak_factory_;
648 630
649 DISALLOW_COPY_AND_ASSIGN(QuicStreamFactory); 631 DISALLOW_COPY_AND_ASSIGN(QuicStreamFactory);
650 }; 632 };
651 633
652 } // namespace net 634 } // namespace net
653 635
654 #endif // NET_QUIC_QUIC_STREAM_FACTORY_H_ 636 #endif // NET_QUIC_QUIC_STREAM_FACTORY_H_
OLDNEW
« no previous file with comments | « net/quic/chromium/crypto/proof_verifier_chromium_test.cc ('k') | net/quic/chromium/quic_stream_factory.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698