| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/quic/core/quic_headers_stream.h" | 5 #include "net/quic/core/quic_headers_stream.h" |
| 6 | 6 |
| 7 #include <cstdint> | 7 #include <cstdint> |
| 8 #include <ostream> | 8 #include <ostream> |
| 9 #include <string> | 9 #include <string> |
| 10 #include <tuple> | 10 #include <tuple> |
| (...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 67 MOCK_METHOD1(OnStreamEnd, void(SpdyStreamId stream_id)); | 67 MOCK_METHOD1(OnStreamEnd, void(SpdyStreamId stream_id)); |
| 68 MOCK_METHOD2(OnStreamPadding, void(SpdyStreamId stream_id, size_t len)); | 68 MOCK_METHOD2(OnStreamPadding, void(SpdyStreamId stream_id, size_t len)); |
| 69 MOCK_METHOD1(OnHeaderFrameStart, | 69 MOCK_METHOD1(OnHeaderFrameStart, |
| 70 SpdyHeadersHandlerInterface*(SpdyStreamId stream_id)); | 70 SpdyHeadersHandlerInterface*(SpdyStreamId stream_id)); |
| 71 MOCK_METHOD2(OnHeaderFrameEnd, void(SpdyStreamId stream_id, bool end)); | 71 MOCK_METHOD2(OnHeaderFrameEnd, void(SpdyStreamId stream_id, bool end)); |
| 72 MOCK_METHOD3(OnControlFrameHeaderData, | 72 MOCK_METHOD3(OnControlFrameHeaderData, |
| 73 bool(SpdyStreamId stream_id, | 73 bool(SpdyStreamId stream_id, |
| 74 const char* header_data, | 74 const char* header_data, |
| 75 size_t len)); | 75 size_t len)); |
| 76 MOCK_METHOD2(OnRstStream, | 76 MOCK_METHOD2(OnRstStream, |
| 77 void(SpdyStreamId stream_id, SpdyRstStreamStatus status)); | 77 void(SpdyStreamId stream_id, SpdyErrorCode error_code)); |
| 78 MOCK_METHOD1(OnSettings, void(bool clear_persisted)); | 78 MOCK_METHOD1(OnSettings, void(bool clear_persisted)); |
| 79 MOCK_METHOD2(OnSetting, void(SpdySettingsIds id, uint32_t value)); | 79 MOCK_METHOD2(OnSetting, void(SpdySettingsIds id, uint32_t value)); |
| 80 MOCK_METHOD0(OnSettingsAck, void()); | 80 MOCK_METHOD0(OnSettingsAck, void()); |
| 81 MOCK_METHOD0(OnSettingsEnd, void()); | 81 MOCK_METHOD0(OnSettingsEnd, void()); |
| 82 MOCK_METHOD2(OnPing, void(SpdyPingId unique_id, bool is_ack)); | 82 MOCK_METHOD2(OnPing, void(SpdyPingId unique_id, bool is_ack)); |
| 83 MOCK_METHOD2(OnGoAway, | 83 MOCK_METHOD2(OnGoAway, |
| 84 void(SpdyStreamId last_accepted_stream_id, | 84 void(SpdyStreamId last_accepted_stream_id, |
| 85 SpdyGoAwayStatus status)); | 85 SpdyErrorCode error_code)); |
| 86 MOCK_METHOD7(OnHeaders, | 86 MOCK_METHOD7(OnHeaders, |
| 87 void(SpdyStreamId stream_id, | 87 void(SpdyStreamId stream_id, |
| 88 bool has_priority, | 88 bool has_priority, |
| 89 int weight, | 89 int weight, |
| 90 SpdyStreamId parent_stream_id, | 90 SpdyStreamId parent_stream_id, |
| 91 bool exclusive, | 91 bool exclusive, |
| 92 bool fin, | 92 bool fin, |
| 93 bool end)); | 93 bool end)); |
| 94 MOCK_METHOD2(OnWindowUpdate, | 94 MOCK_METHOD2(OnWindowUpdate, |
| 95 void(SpdyStreamId stream_id, int delta_window_size)); | 95 void(SpdyStreamId stream_id, int delta_window_size)); |
| (...skipping 613 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 709 SpdyDataIR data(2, ""); | 709 SpdyDataIR data(2, ""); |
| 710 data.set_fin(true); | 710 data.set_fin(true); |
| 711 SpdySerializedFrame frame(framer_->SerializeFrame(data)); | 711 SpdySerializedFrame frame(framer_->SerializeFrame(data)); |
| 712 EXPECT_CALL(session_, OnStreamFrameData(2, _, 0, true)); | 712 EXPECT_CALL(session_, OnStreamFrameData(2, _, 0, true)); |
| 713 stream_frame_.data_buffer = frame.data(); | 713 stream_frame_.data_buffer = frame.data(); |
| 714 stream_frame_.data_length = frame.size(); | 714 stream_frame_.data_length = frame.size(); |
| 715 headers_stream_->OnStreamFrame(stream_frame_); | 715 headers_stream_->OnStreamFrame(stream_frame_); |
| 716 } | 716 } |
| 717 | 717 |
| 718 TEST_P(QuicHeadersStreamTest, ProcessSpdyRstStreamFrame) { | 718 TEST_P(QuicHeadersStreamTest, ProcessSpdyRstStreamFrame) { |
| 719 SpdyRstStreamIR data(2, RST_STREAM_PROTOCOL_ERROR); | 719 SpdyRstStreamIR data(2, ERROR_CODE_PROTOCOL_ERROR); |
| 720 SpdySerializedFrame frame(framer_->SerializeFrame(data)); | 720 SpdySerializedFrame frame(framer_->SerializeFrame(data)); |
| 721 EXPECT_CALL(*connection_, | 721 EXPECT_CALL(*connection_, |
| 722 CloseConnection(QUIC_INVALID_HEADERS_STREAM_DATA, | 722 CloseConnection(QUIC_INVALID_HEADERS_STREAM_DATA, |
| 723 "SPDY RST_STREAM frame received.", _)) | 723 "SPDY RST_STREAM frame received.", _)) |
| 724 .WillOnce(InvokeWithoutArgs( | 724 .WillOnce(InvokeWithoutArgs( |
| 725 this, &QuicHeadersStreamTest::TearDownLocalConnectionState)); | 725 this, &QuicHeadersStreamTest::TearDownLocalConnectionState)); |
| 726 stream_frame_.data_buffer = frame.data(); | 726 stream_frame_.data_buffer = frame.data(); |
| 727 stream_frame_.data_length = frame.size(); | 727 stream_frame_.data_length = frame.size(); |
| 728 headers_stream_->OnStreamFrame(stream_frame_); | 728 headers_stream_->OnStreamFrame(stream_frame_); |
| 729 } | 729 } |
| (...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 810 EXPECT_CALL(*connection_, CloseConnection(QUIC_INVALID_HEADERS_STREAM_DATA, | 810 EXPECT_CALL(*connection_, CloseConnection(QUIC_INVALID_HEADERS_STREAM_DATA, |
| 811 "SPDY PING frame received.", _)) | 811 "SPDY PING frame received.", _)) |
| 812 .WillOnce(InvokeWithoutArgs( | 812 .WillOnce(InvokeWithoutArgs( |
| 813 this, &QuicHeadersStreamTest::TearDownLocalConnectionState)); | 813 this, &QuicHeadersStreamTest::TearDownLocalConnectionState)); |
| 814 stream_frame_.data_buffer = frame.data(); | 814 stream_frame_.data_buffer = frame.data(); |
| 815 stream_frame_.data_length = frame.size(); | 815 stream_frame_.data_length = frame.size(); |
| 816 headers_stream_->OnStreamFrame(stream_frame_); | 816 headers_stream_->OnStreamFrame(stream_frame_); |
| 817 } | 817 } |
| 818 | 818 |
| 819 TEST_P(QuicHeadersStreamTest, ProcessSpdyGoAwayFrame) { | 819 TEST_P(QuicHeadersStreamTest, ProcessSpdyGoAwayFrame) { |
| 820 SpdyGoAwayIR data(1, GOAWAY_PROTOCOL_ERROR, "go away"); | 820 SpdyGoAwayIR data(1, ERROR_CODE_PROTOCOL_ERROR, "go away"); |
| 821 SpdySerializedFrame frame(framer_->SerializeFrame(data)); | 821 SpdySerializedFrame frame(framer_->SerializeFrame(data)); |
| 822 EXPECT_CALL(*connection_, CloseConnection(QUIC_INVALID_HEADERS_STREAM_DATA, | 822 EXPECT_CALL(*connection_, CloseConnection(QUIC_INVALID_HEADERS_STREAM_DATA, |
| 823 "SPDY GOAWAY frame received.", _)) | 823 "SPDY GOAWAY frame received.", _)) |
| 824 .WillOnce(InvokeWithoutArgs( | 824 .WillOnce(InvokeWithoutArgs( |
| 825 this, &QuicHeadersStreamTest::TearDownLocalConnectionState)); | 825 this, &QuicHeadersStreamTest::TearDownLocalConnectionState)); |
| 826 stream_frame_.data_buffer = frame.data(); | 826 stream_frame_.data_buffer = frame.data(); |
| 827 stream_frame_.data_length = frame.size(); | 827 stream_frame_.data_length = frame.size(); |
| 828 headers_stream_->OnStreamFrame(stream_frame_); | 828 headers_stream_->OnStreamFrame(stream_frame_); |
| 829 } | 829 } |
| 830 | 830 |
| (...skipping 210 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1041 consumed_data = session_.WritevStreamData(id, MakeIOVector(data, &iov), | 1041 consumed_data = session_.WritevStreamData(id, MakeIOVector(data, &iov), |
| 1042 offset, fin, nullptr); | 1042 offset, fin, nullptr); |
| 1043 | 1043 |
| 1044 EXPECT_EQ(consumed_data.bytes_consumed, 0u); | 1044 EXPECT_EQ(consumed_data.bytes_consumed, 0u); |
| 1045 EXPECT_EQ(consumed_data.fin_consumed, false); | 1045 EXPECT_EQ(consumed_data.fin_consumed, false); |
| 1046 } | 1046 } |
| 1047 | 1047 |
| 1048 } // namespace | 1048 } // namespace |
| 1049 } // namespace test | 1049 } // namespace test |
| 1050 } // namespace net | 1050 } // namespace net |
| OLD | NEW |