| 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 2542 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2553 return; | 2553 return; |
| 2554 } | 2554 } |
| 2555 | 2555 |
| 2556 CHECK_EQ(it->second.stream->stream_id(), stream_id); | 2556 CHECK_EQ(it->second.stream->stream_id(), stream_id); |
| 2557 it->second.stream->IncreaseSendWindowSize( | 2557 it->second.stream->IncreaseSendWindowSize( |
| 2558 static_cast<int32>(delta_window_size)); | 2558 static_cast<int32>(delta_window_size)); |
| 2559 } | 2559 } |
| 2560 } | 2560 } |
| 2561 | 2561 |
| 2562 void SpdySession::OnPushPromise(SpdyStreamId stream_id, | 2562 void SpdySession::OnPushPromise(SpdyStreamId stream_id, |
| 2563 SpdyStreamId promised_stream_id) { | 2563 SpdyStreamId promised_stream_id, |
| 2564 const SpdyHeaderBlock& headers) { |
| 2564 // TODO(akalin): Handle PUSH_PROMISE frames. | 2565 // TODO(akalin): Handle PUSH_PROMISE frames. |
| 2565 } | 2566 } |
| 2566 | 2567 |
| 2567 void SpdySession::SendStreamWindowUpdate(SpdyStreamId stream_id, | 2568 void SpdySession::SendStreamWindowUpdate(SpdyStreamId stream_id, |
| 2568 uint32 delta_window_size) { | 2569 uint32 delta_window_size) { |
| 2569 CHECK_GE(flow_control_state_, FLOW_CONTROL_STREAM); | 2570 CHECK_GE(flow_control_state_, FLOW_CONTROL_STREAM); |
| 2570 ActiveStreamMap::const_iterator it = active_streams_.find(stream_id); | 2571 ActiveStreamMap::const_iterator it = active_streams_.find(stream_id); |
| 2571 CHECK(it != active_streams_.end()); | 2572 CHECK(it != active_streams_.end()); |
| 2572 CHECK_EQ(it->second.stream->stream_id(), stream_id); | 2573 CHECK_EQ(it->second.stream->stream_id(), stream_id); |
| 2573 SendWindowUpdateFrame( | 2574 SendWindowUpdateFrame( |
| (...skipping 531 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3105 if (!queue->empty()) { | 3106 if (!queue->empty()) { |
| 3106 SpdyStreamId stream_id = queue->front(); | 3107 SpdyStreamId stream_id = queue->front(); |
| 3107 queue->pop_front(); | 3108 queue->pop_front(); |
| 3108 return stream_id; | 3109 return stream_id; |
| 3109 } | 3110 } |
| 3110 } | 3111 } |
| 3111 return 0; | 3112 return 0; |
| 3112 } | 3113 } |
| 3113 | 3114 |
| 3114 } // namespace net | 3115 } // namespace net |
| OLD | NEW |