| 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 <limits> | 8 #include <limits> |
| 9 #include <map> | 9 #include <map> |
| 10 #include <utility> | 10 #include <utility> |
| (...skipping 625 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 636 } | 636 } |
| 637 | 637 |
| 638 SpdySession::SpdySession(const SpdySessionKey& spdy_session_key, | 638 SpdySession::SpdySession(const SpdySessionKey& spdy_session_key, |
| 639 HttpServerProperties* http_server_properties, | 639 HttpServerProperties* http_server_properties, |
| 640 TransportSecurityState* transport_security_state, | 640 TransportSecurityState* transport_security_state, |
| 641 bool enable_sending_initial_data, | 641 bool enable_sending_initial_data, |
| 642 bool enable_ping_based_connection_checking, | 642 bool enable_ping_based_connection_checking, |
| 643 size_t session_max_recv_window_size, | 643 size_t session_max_recv_window_size, |
| 644 size_t stream_max_recv_window_size, | 644 size_t stream_max_recv_window_size, |
| 645 TimeFunc time_func, | 645 TimeFunc time_func, |
| 646 ServerPushDelegate* push_delegate, |
| 646 ProxyDelegate* proxy_delegate, | 647 ProxyDelegate* proxy_delegate, |
| 647 NetLog* net_log) | 648 NetLog* net_log) |
| 648 : in_io_loop_(false), | 649 : in_io_loop_(false), |
| 649 spdy_session_key_(spdy_session_key), | 650 spdy_session_key_(spdy_session_key), |
| 650 pool_(NULL), | 651 pool_(NULL), |
| 651 http_server_properties_(http_server_properties), | 652 http_server_properties_(http_server_properties), |
| 652 transport_security_state_(transport_security_state), | 653 transport_security_state_(transport_security_state), |
| 653 read_buffer_(new IOBuffer(kReadBufferSize)), | 654 read_buffer_(new IOBuffer(kReadBufferSize)), |
| 654 stream_hi_water_mark_(kFirstStreamId), | 655 stream_hi_water_mark_(kFirstStreamId), |
| 655 last_accepted_push_stream_id_(0), | 656 last_accepted_push_stream_id_(0), |
| 656 unclaimed_pushed_streams_(this), | 657 unclaimed_pushed_streams_(this), |
| 657 push_delegate_(nullptr), | 658 push_delegate_(push_delegate), |
| 658 num_pushed_streams_(0u), | 659 num_pushed_streams_(0u), |
| 659 num_active_pushed_streams_(0u), | 660 num_active_pushed_streams_(0u), |
| 660 bytes_pushed_count_(0u), | 661 bytes_pushed_count_(0u), |
| 661 bytes_pushed_and_unclaimed_count_(0u), | 662 bytes_pushed_and_unclaimed_count_(0u), |
| 662 in_flight_write_frame_type_(DATA), | 663 in_flight_write_frame_type_(DATA), |
| 663 in_flight_write_frame_size_(0), | 664 in_flight_write_frame_size_(0), |
| 664 is_secure_(false), | 665 is_secure_(false), |
| 665 availability_state_(STATE_AVAILABLE), | 666 availability_state_(STATE_AVAILABLE), |
| 666 read_state_(READ_STATE_DO_READ), | 667 read_state_(READ_STATE_DO_READ), |
| 667 write_state_(WRITE_STATE_IDLE), | 668 write_state_(WRITE_STATE_IDLE), |
| (...skipping 2343 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3011 if (!queue->empty()) { | 3012 if (!queue->empty()) { |
| 3012 SpdyStreamId stream_id = queue->front(); | 3013 SpdyStreamId stream_id = queue->front(); |
| 3013 queue->pop_front(); | 3014 queue->pop_front(); |
| 3014 return stream_id; | 3015 return stream_id; |
| 3015 } | 3016 } |
| 3016 } | 3017 } |
| 3017 return 0; | 3018 return 0; |
| 3018 } | 3019 } |
| 3019 | 3020 |
| 3020 } // namespace net | 3021 } // namespace net |
| OLD | NEW |