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

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

Issue 1916783003: QUIC - enable "delay_tcp_race" parameter by default. This feature showed (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Deleted unneeded hanging get calls from unittests Created 4 years, 8 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/quic_network_transaction_unittest.cc ('k') | net/quic/quic_stream_factory.cc » ('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 #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 137 matching lines...) Expand 10 before | Expand all | Expand 10 after
148 bool enable_connection_racing, 148 bool enable_connection_racing,
149 bool enable_non_blocking_io, 149 bool enable_non_blocking_io,
150 bool disable_disk_cache, 150 bool disable_disk_cache,
151 bool prefer_aes, 151 bool prefer_aes,
152 int max_number_of_lossy_connections, 152 int max_number_of_lossy_connections,
153 float packet_loss_threshold, 153 float packet_loss_threshold,
154 int max_recent_disabled_reasons, 154 int max_recent_disabled_reasons,
155 int threshold_timeouts_with_streams_open, 155 int threshold_timeouts_with_streams_open,
156 int threshold_public_resets_post_handshake, 156 int threshold_public_resets_post_handshake,
157 int socket_receive_buffer_size, 157 int socket_receive_buffer_size,
158 bool delay_tcp_race,
159 int max_server_configs_stored_in_properties, 158 int max_server_configs_stored_in_properties,
160 bool close_sessions_on_ip_change, 159 bool close_sessions_on_ip_change,
161 bool disable_quic_on_timeout_with_open_streams, 160 bool disable_quic_on_timeout_with_open_streams,
162 int idle_connection_timeout_seconds, 161 int idle_connection_timeout_seconds,
163 bool migrate_sessions_on_network_change, 162 bool migrate_sessions_on_network_change,
164 bool migrate_sessions_early, 163 bool migrate_sessions_early,
165 const QuicTagVector& connection_options, 164 const QuicTagVector& connection_options,
166 bool enable_token_binding); 165 bool enable_token_binding);
167 ~QuicStreamFactory() override; 166 ~QuicStreamFactory() override;
168 167
(...skipping 146 matching lines...) Expand 10 before | Expand all | Expand 10 after
315 void set_quic_server_info_factory( 314 void set_quic_server_info_factory(
316 QuicServerInfoFactory* quic_server_info_factory); 315 QuicServerInfoFactory* quic_server_info_factory);
317 316
318 bool enable_connection_racing() const { return enable_connection_racing_; } 317 bool enable_connection_racing() const { return enable_connection_racing_; }
319 void set_enable_connection_racing(bool enable_connection_racing) { 318 void set_enable_connection_racing(bool enable_connection_racing) {
320 enable_connection_racing_ = enable_connection_racing; 319 enable_connection_racing_ = enable_connection_racing;
321 } 320 }
322 321
323 int socket_receive_buffer_size() const { return socket_receive_buffer_size_; } 322 int socket_receive_buffer_size() const { return socket_receive_buffer_size_; }
324 323
325 bool delay_tcp_race() const { return delay_tcp_race_; }
326
327 private: 324 private:
328 class Job; 325 class Job;
329 friend class test::QuicStreamFactoryPeer; 326 friend class test::QuicStreamFactoryPeer;
330 FRIEND_TEST_ALL_PREFIXES(HttpStreamFactoryTest, QuicLossyProxyMarkedAsBad); 327 FRIEND_TEST_ALL_PREFIXES(HttpStreamFactoryTest, QuicLossyProxyMarkedAsBad);
331 328
332 typedef std::map<QuicServerId, QuicChromiumClientSession*> SessionMap; 329 typedef std::map<QuicServerId, QuicChromiumClientSession*> SessionMap;
333 typedef std::map<QuicChromiumClientSession*, QuicServerId> SessionIdMap; 330 typedef std::map<QuicChromiumClientSession*, QuicServerId> SessionIdMap;
334 typedef std::set<QuicServerId> AliasSet; 331 typedef std::set<QuicServerId> AliasSet;
335 typedef std::map<QuicChromiumClientSession*, AliasSet> SessionAliasMap; 332 typedef std::map<QuicChromiumClientSession*, AliasSet> SessionAliasMap;
336 typedef std::set<QuicChromiumClientSession*> SessionSet; 333 typedef std::set<QuicChromiumClientSession*> SessionSet;
(...skipping 172 matching lines...) Expand 10 before | Expand all | Expand 10 after
509 // determine good threshold values. 506 // determine good threshold values.
510 int max_public_resets_post_handshake_; 507 int max_public_resets_post_handshake_;
511 int max_timeouts_with_open_streams_; 508 int max_timeouts_with_open_streams_;
512 // Thresholds if greater than zero, determine when to 509 // Thresholds if greater than zero, determine when to
513 int threshold_timeouts_with_open_streams_; 510 int threshold_timeouts_with_open_streams_;
514 int threshold_public_resets_post_handshake_; 511 int threshold_public_resets_post_handshake_;
515 512
516 // Size of the UDP receive buffer. 513 // Size of the UDP receive buffer.
517 int socket_receive_buffer_size_; 514 int socket_receive_buffer_size_;
518 515
519 // Set if we do want to delay TCP connection when it is racing with QUIC.
520 bool delay_tcp_race_;
521
522 // If more than |yield_after_packets_| packets have been read or more than 516 // If more than |yield_after_packets_| packets have been read or more than
523 // |yield_after_duration_| time has passed, then 517 // |yield_after_duration_| time has passed, then
524 // QuicChromiumPacketReader::StartReading() yields by doing a PostTask(). 518 // QuicChromiumPacketReader::StartReading() yields by doing a PostTask().
525 int yield_after_packets_; 519 int yield_after_packets_;
526 QuicTime::Delta yield_after_duration_; 520 QuicTime::Delta yield_after_duration_;
527 521
528 // Set if all sessions should be closed when any local IP address changes. 522 // Set if all sessions should be closed when any local IP address changes.
529 const bool close_sessions_on_ip_change_; 523 const bool close_sessions_on_ip_change_;
530 524
531 // Set if migration should be attempted on active sessions when primary 525 // Set if migration should be attempted on active sessions when primary
(...skipping 30 matching lines...) Expand all
562 base::TaskRunner* task_runner_; 556 base::TaskRunner* task_runner_;
563 557
564 base::WeakPtrFactory<QuicStreamFactory> weak_factory_; 558 base::WeakPtrFactory<QuicStreamFactory> weak_factory_;
565 559
566 DISALLOW_COPY_AND_ASSIGN(QuicStreamFactory); 560 DISALLOW_COPY_AND_ASSIGN(QuicStreamFactory);
567 }; 561 };
568 562
569 } // namespace net 563 } // namespace net
570 564
571 #endif // NET_QUIC_QUIC_STREAM_FACTORY_H_ 565 #endif // NET_QUIC_QUIC_STREAM_FACTORY_H_
OLDNEW
« no previous file with comments | « net/quic/quic_network_transaction_unittest.cc ('k') | net/quic/quic_stream_factory.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698