| 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/spdy/spdy_session.h" | 5 #include "net/spdy/spdy_session.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <map> | 8 #include <map> |
| 9 | 9 |
| 10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
| (...skipping 438 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 449 bool enable_sending_initial_data, | 449 bool enable_sending_initial_data, |
| 450 bool enable_compression, | 450 bool enable_compression, |
| 451 bool enable_ping_based_connection_checking, | 451 bool enable_ping_based_connection_checking, |
| 452 NextProto default_protocol, | 452 NextProto default_protocol, |
| 453 size_t stream_initial_recv_window_size, | 453 size_t stream_initial_recv_window_size, |
| 454 size_t initial_max_concurrent_streams, | 454 size_t initial_max_concurrent_streams, |
| 455 size_t max_concurrent_streams_limit, | 455 size_t max_concurrent_streams_limit, |
| 456 TimeFunc time_func, | 456 TimeFunc time_func, |
| 457 const HostPortPair& trusted_spdy_proxy, | 457 const HostPortPair& trusted_spdy_proxy, |
| 458 NetLog* net_log) | 458 NetLog* net_log) |
| 459 : weak_factory_(this), | 459 : in_io_loop_(false), |
| 460 in_io_loop_(false), | |
| 461 spdy_session_key_(spdy_session_key), | 460 spdy_session_key_(spdy_session_key), |
| 462 pool_(NULL), | 461 pool_(NULL), |
| 463 http_server_properties_(http_server_properties), | 462 http_server_properties_(http_server_properties), |
| 464 read_buffer_(new IOBuffer(kReadBufferSize)), | 463 read_buffer_(new IOBuffer(kReadBufferSize)), |
| 465 stream_hi_water_mark_(kFirstStreamId), | 464 stream_hi_water_mark_(kFirstStreamId), |
| 466 in_flight_write_frame_type_(DATA), | 465 in_flight_write_frame_type_(DATA), |
| 467 in_flight_write_frame_size_(0), | 466 in_flight_write_frame_size_(0), |
| 468 is_secure_(false), | 467 is_secure_(false), |
| 469 certificate_error_code_(OK), | 468 certificate_error_code_(OK), |
| 470 availability_state_(STATE_AVAILABLE), | 469 availability_state_(STATE_AVAILABLE), |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 504 enable_sending_initial_data_(enable_sending_initial_data), | 503 enable_sending_initial_data_(enable_sending_initial_data), |
| 505 enable_compression_(enable_compression), | 504 enable_compression_(enable_compression), |
| 506 enable_ping_based_connection_checking_( | 505 enable_ping_based_connection_checking_( |
| 507 enable_ping_based_connection_checking), | 506 enable_ping_based_connection_checking), |
| 508 protocol_(default_protocol), | 507 protocol_(default_protocol), |
| 509 connection_at_risk_of_loss_time_( | 508 connection_at_risk_of_loss_time_( |
| 510 base::TimeDelta::FromSeconds(kDefaultConnectionAtRiskOfLossSeconds)), | 509 base::TimeDelta::FromSeconds(kDefaultConnectionAtRiskOfLossSeconds)), |
| 511 hung_interval_( | 510 hung_interval_( |
| 512 base::TimeDelta::FromSeconds(kHungIntervalSeconds)), | 511 base::TimeDelta::FromSeconds(kHungIntervalSeconds)), |
| 513 trusted_spdy_proxy_(trusted_spdy_proxy), | 512 trusted_spdy_proxy_(trusted_spdy_proxy), |
| 514 time_func_(time_func) { | 513 time_func_(time_func), |
| 514 weak_factory_(this) { |
| 515 DCHECK_GE(protocol_, kProtoSPDYMinimumVersion); | 515 DCHECK_GE(protocol_, kProtoSPDYMinimumVersion); |
| 516 DCHECK_LE(protocol_, kProtoSPDYMaximumVersion); | 516 DCHECK_LE(protocol_, kProtoSPDYMaximumVersion); |
| 517 DCHECK(HttpStreamFactory::spdy_enabled()); | 517 DCHECK(HttpStreamFactory::spdy_enabled()); |
| 518 net_log_.BeginEvent( | 518 net_log_.BeginEvent( |
| 519 NetLog::TYPE_SPDY_SESSION, | 519 NetLog::TYPE_SPDY_SESSION, |
| 520 base::Bind(&NetLogSpdySessionCallback, &host_port_proxy_pair())); | 520 base::Bind(&NetLogSpdySessionCallback, &host_port_proxy_pair())); |
| 521 next_unclaimed_push_stream_sweep_time_ = time_func_() + | 521 next_unclaimed_push_stream_sweep_time_ = time_func_() + |
| 522 base::TimeDelta::FromSeconds(kMinPushedStreamLifetimeSeconds); | 522 base::TimeDelta::FromSeconds(kMinPushedStreamLifetimeSeconds); |
| 523 // TODO(mbelshe): consider randomization of the stream_hi_water_mark. | 523 // TODO(mbelshe): consider randomization of the stream_hi_water_mark. |
| 524 } | 524 } |
| (...skipping 2550 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3075 if (!queue->empty()) { | 3075 if (!queue->empty()) { |
| 3076 SpdyStreamId stream_id = queue->front(); | 3076 SpdyStreamId stream_id = queue->front(); |
| 3077 queue->pop_front(); | 3077 queue->pop_front(); |
| 3078 return stream_id; | 3078 return stream_id; |
| 3079 } | 3079 } |
| 3080 } | 3080 } |
| 3081 return 0; | 3081 return 0; |
| 3082 } | 3082 } |
| 3083 | 3083 |
| 3084 } // namespace net | 3084 } // namespace net |
| OLD | NEW |