| 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 <map> | 7 #include <map> |
| 8 | 8 |
| 9 #include "base/basictypes.h" | 9 #include "base/basictypes.h" |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 1663 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1674 CHECK(IsStreamActive(stream_id)); | 1674 CHECK(IsStreamActive(stream_id)); |
| 1675 scoped_refptr<SpdyStream> stream = active_streams_[stream_id]; | 1675 scoped_refptr<SpdyStream> stream = active_streams_[stream_id]; |
| 1676 CHECK_EQ(stream->stream_id(), stream_id); | 1676 CHECK_EQ(stream->stream_id(), stream_id); |
| 1677 | 1677 |
| 1678 net_log_.AddEvent( | 1678 net_log_.AddEvent( |
| 1679 NetLog::TYPE_SPDY_SESSION_SENT_WINDOW_UPDATE, | 1679 NetLog::TYPE_SPDY_SESSION_SENT_WINDOW_UPDATE, |
| 1680 base::Bind(&NetLogSpdyWindowUpdateCallback, | 1680 base::Bind(&NetLogSpdyWindowUpdateCallback, |
| 1681 stream_id, delta_window_size)); | 1681 stream_id, delta_window_size)); |
| 1682 | 1682 |
| 1683 DCHECK(buffered_spdy_framer_.get()); | 1683 DCHECK(buffered_spdy_framer_.get()); |
| 1684 scoped_ptr<SpdyWindowUpdateControlFrame> window_update_frame( | 1684 scoped_ptr<SpdyFrame> window_update_frame( |
| 1685 buffered_spdy_framer_->CreateWindowUpdate(stream_id, delta_window_size)); | 1685 buffered_spdy_framer_->CreateWindowUpdate(stream_id, delta_window_size)); |
| 1686 QueueFrame(window_update_frame.release(), stream->priority()); | 1686 QueueFrame(window_update_frame.release(), stream->priority()); |
| 1687 } | 1687 } |
| 1688 | 1688 |
| 1689 // Given a cwnd that we would have sent to the server, modify it based on the | 1689 // Given a cwnd that we would have sent to the server, modify it based on the |
| 1690 // field trial policy. | 1690 // field trial policy. |
| 1691 uint32 ApplyCwndFieldTrialPolicy(int cwnd) { | 1691 uint32 ApplyCwndFieldTrialPolicy(int cwnd) { |
| 1692 base::FieldTrial* trial = base::FieldTrialList::Find("SpdyCwnd"); | 1692 base::FieldTrial* trial = base::FieldTrialList::Find("SpdyCwnd"); |
| 1693 if (!trial) { | 1693 if (!trial) { |
| 1694 LOG(WARNING) << "Could not find \"SpdyCwnd\" in FieldTrialList"; | 1694 LOG(WARNING) << "Could not find \"SpdyCwnd\" in FieldTrialList"; |
| (...skipping 290 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1985 SSLClientSocket* SpdySession::GetSSLClientSocket() const { | 1985 SSLClientSocket* SpdySession::GetSSLClientSocket() const { |
| 1986 if (!is_secure_) | 1986 if (!is_secure_) |
| 1987 return NULL; | 1987 return NULL; |
| 1988 SSLClientSocket* ssl_socket = | 1988 SSLClientSocket* ssl_socket = |
| 1989 reinterpret_cast<SSLClientSocket*>(connection_->socket()); | 1989 reinterpret_cast<SSLClientSocket*>(connection_->socket()); |
| 1990 DCHECK(ssl_socket); | 1990 DCHECK(ssl_socket); |
| 1991 return ssl_socket; | 1991 return ssl_socket; |
| 1992 } | 1992 } |
| 1993 | 1993 |
| 1994 } // namespace net | 1994 } // namespace net |
| OLD | NEW |