Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(462)

Side by Side Diff: net/quic/core/quic_headers_stream_test.cc

Issue 2675593002: Spdy{RstStream,GoAway}Status -> SpdyErrorCode. (Closed)
Patch Set: Merged master, which includes 145087791. Created 3 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « net/http/http_proxy_client_socket_pool_unittest.cc ('k') | net/quic/core/quic_spdy_session.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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
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
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
OLDNEW
« no previous file with comments | « net/http/http_proxy_client_socket_pool_unittest.cc ('k') | net/quic/core/quic_spdy_session.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698