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

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

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