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

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

Issue 2270583002: QUIC: Add packet_reader_yield_after_duration_milliseconds field trial param. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@new_master
Patch Set: Created 4 years, 3 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 #include "net/quic/chromium/quic_stream_factory.h" 5 #include "net/quic/chromium/quic_stream_factory.h"
6 6
7 #include <openssl/aead.h> 7 #include <openssl/aead.h>
8 8
9 #include <algorithm> 9 #include <algorithm>
10 #include <tuple> 10 #include <tuple>
(...skipping 718 matching lines...) Expand 10 before | Expand all | Expand 10 after
729 float packet_loss_threshold, 729 float packet_loss_threshold,
730 int max_disabled_reasons, 730 int max_disabled_reasons,
731 int threshold_public_resets_post_handshake, 731 int threshold_public_resets_post_handshake,
732 int threshold_timeouts_with_open_streams, 732 int threshold_timeouts_with_open_streams,
733 int socket_receive_buffer_size, 733 int socket_receive_buffer_size,
734 bool delay_tcp_race, 734 bool delay_tcp_race,
735 int max_server_configs_stored_in_properties, 735 int max_server_configs_stored_in_properties,
736 bool close_sessions_on_ip_change, 736 bool close_sessions_on_ip_change,
737 bool disable_quic_on_timeout_with_open_streams, 737 bool disable_quic_on_timeout_with_open_streams,
738 int idle_connection_timeout_seconds, 738 int idle_connection_timeout_seconds,
739 int packet_reader_yield_after_duration_milliseconds,
739 bool migrate_sessions_on_network_change, 740 bool migrate_sessions_on_network_change,
740 bool migrate_sessions_early, 741 bool migrate_sessions_early,
741 bool allow_server_migration, 742 bool allow_server_migration,
742 bool force_hol_blocking, 743 bool force_hol_blocking,
743 bool race_cert_verification, 744 bool race_cert_verification,
744 const QuicTagVector& connection_options, 745 const QuicTagVector& connection_options,
745 bool enable_token_binding) 746 bool enable_token_binding)
746 : require_confirmation_(true), 747 : require_confirmation_(true),
747 net_log_(net_log), 748 net_log_(net_log),
748 host_resolver_(host_resolver), 749 host_resolver_(host_resolver),
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
781 max_public_resets_post_handshake_(0), 782 max_public_resets_post_handshake_(0),
782 max_timeouts_with_open_streams_(0), 783 max_timeouts_with_open_streams_(0),
783 threshold_timeouts_with_open_streams_( 784 threshold_timeouts_with_open_streams_(
784 threshold_timeouts_with_open_streams), 785 threshold_timeouts_with_open_streams),
785 threshold_public_resets_post_handshake_( 786 threshold_public_resets_post_handshake_(
786 threshold_public_resets_post_handshake), 787 threshold_public_resets_post_handshake),
787 socket_receive_buffer_size_(socket_receive_buffer_size), 788 socket_receive_buffer_size_(socket_receive_buffer_size),
788 delay_tcp_race_(delay_tcp_race), 789 delay_tcp_race_(delay_tcp_race),
789 yield_after_packets_(kQuicYieldAfterPacketsRead), 790 yield_after_packets_(kQuicYieldAfterPacketsRead),
790 yield_after_duration_(QuicTime::Delta::FromMilliseconds( 791 yield_after_duration_(QuicTime::Delta::FromMilliseconds(
791 kQuicYieldAfterDurationMilliseconds)), 792 packet_reader_yield_after_duration_milliseconds)),
792 close_sessions_on_ip_change_(close_sessions_on_ip_change), 793 close_sessions_on_ip_change_(close_sessions_on_ip_change),
793 migrate_sessions_on_network_change_( 794 migrate_sessions_on_network_change_(
794 migrate_sessions_on_network_change && 795 migrate_sessions_on_network_change &&
795 NetworkChangeNotifier::AreNetworkHandlesSupported()), 796 NetworkChangeNotifier::AreNetworkHandlesSupported()),
796 migrate_sessions_early_(migrate_sessions_early && 797 migrate_sessions_early_(migrate_sessions_early &&
797 migrate_sessions_on_network_change_), 798 migrate_sessions_on_network_change_),
798 allow_server_migration_(allow_server_migration), 799 allow_server_migration_(allow_server_migration),
799 force_hol_blocking_(force_hol_blocking), 800 force_hol_blocking_(force_hol_blocking),
800 race_cert_verification_(race_cert_verification), 801 race_cert_verification_(race_cert_verification),
801 port_seed_(random_generator_->RandUint64()), 802 port_seed_(random_generator_->RandUint64()),
(...skipping 1240 matching lines...) Expand 10 before | Expand all | Expand 10 after
2042 // Since the session was active, there's no longer an 2043 // Since the session was active, there's no longer an
2043 // HttpStreamFactoryImpl::Job running which can mark it broken, unless the TCP 2044 // HttpStreamFactoryImpl::Job running which can mark it broken, unless the TCP
2044 // job also fails. So to avoid not using QUIC when we otherwise could, we mark 2045 // job also fails. So to avoid not using QUIC when we otherwise could, we mark
2045 // it as recently broken, which means that 0-RTT will be disabled but we'll 2046 // it as recently broken, which means that 0-RTT will be disabled but we'll
2046 // still race. 2047 // still race.
2047 http_server_properties_->MarkAlternativeServiceRecentlyBroken( 2048 http_server_properties_->MarkAlternativeServiceRecentlyBroken(
2048 alternative_service); 2049 alternative_service);
2049 } 2050 }
2050 2051
2051 } // namespace net 2052 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698