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