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

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

Issue 23480054: Disable QUIC Zero-RTT until we shake out more bugs. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 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 | Annotate | Revision Log
« no previous file with comments | « no previous file | no next file » | 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 #include "net/quic/quic_stream_factory.h" 5 #include "net/quic/quic_stream_factory.h"
6 6
7 #include <set> 7 #include <set>
8 8
9 #include "base/logging.h" 9 #include "base/logging.h"
10 #include "base/message_loop/message_loop.h" 10 #include "base/message_loop/message_loop.h"
(...skipping 289 matching lines...) Expand 10 before | Expand all | Expand 10 after
300 } 300 }
301 if (rv == OK) { 301 if (rv == OK) {
302 DCHECK(HasActiveSession(host_port_proxy_pair)); 302 DCHECK(HasActiveSession(host_port_proxy_pair));
303 request->set_stream(CreateIfSessionExists(host_port_proxy_pair, net_log)); 303 request->set_stream(CreateIfSessionExists(host_port_proxy_pair, net_log));
304 } 304 }
305 return rv; 305 return rv;
306 } 306 }
307 307
308 void QuicStreamFactory::OnJobComplete(Job* job, int rv) { 308 void QuicStreamFactory::OnJobComplete(Job* job, int rv) {
309 if (rv == OK) { 309 if (rv == OK) {
310 require_confirmation_ = false; 310 // TODO(rch): Uncomment this once we trust 0-RTT
311 // require_confirmation_ = false;
312
311 // Create all the streams, but do not notify them yet. 313 // Create all the streams, but do not notify them yet.
312 for (RequestSet::iterator it = job_requests_map_[job].begin(); 314 for (RequestSet::iterator it = job_requests_map_[job].begin();
313 it != job_requests_map_[job].end() ; ++it) { 315 it != job_requests_map_[job].end() ; ++it) {
314 DCHECK(HasActiveSession(job->host_port_proxy_pair())); 316 DCHECK(HasActiveSession(job->host_port_proxy_pair()));
315 (*it)->set_stream(CreateIfSessionExists(job->host_port_proxy_pair(), 317 (*it)->set_stream(CreateIfSessionExists(job->host_port_proxy_pair(),
316 (*it)->net_log())); 318 (*it)->net_log()));
317 } 319 }
318 } 320 }
319 while (!job_requests_map_[job].empty()) { 321 while (!job_requests_map_[job].empty()) {
320 RequestSet::iterator it = job_requests_map_[job].begin(); 322 RequestSet::iterator it = job_requests_map_[job].begin();
(...skipping 174 matching lines...) Expand 10 before | Expand all | Expand 10 after
495 DCHECK(crypto_config); 497 DCHECK(crypto_config);
496 } else { 498 } else {
497 crypto_config = new QuicCryptoClientConfig(); 499 crypto_config = new QuicCryptoClientConfig();
498 crypto_config->SetDefaults(); 500 crypto_config->SetDefaults();
499 all_crypto_configs_[host_port_proxy_pair] = crypto_config; 501 all_crypto_configs_[host_port_proxy_pair] = crypto_config;
500 } 502 }
501 return crypto_config; 503 return crypto_config;
502 } 504 }
503 505
504 } // namespace net 506 } // namespace net
OLDNEW
« no previous file with comments | « no previous file | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698