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 |