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 #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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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_ |
OLD | NEW |