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 // Common utilities for Quic tests | 5 // Common utilities for Quic tests |
6 | 6 |
7 #ifndef NET_QUIC_TEST_TOOLS_QUIC_TEST_UTILS_H_ | 7 #ifndef NET_QUIC_TEST_TOOLS_QUIC_TEST_UTILS_H_ |
8 #define NET_QUIC_TEST_TOOLS_QUIC_TEST_UTILS_H_ | 8 #define NET_QUIC_TEST_TOOLS_QUIC_TEST_UTILS_H_ |
9 | 9 |
10 #include <string> | 10 #include <string> |
(...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
101 MOCK_METHOD1(OnUnauthenticatedHeader, bool(const QuicPacketHeader& header)); | 101 MOCK_METHOD1(OnUnauthenticatedHeader, bool(const QuicPacketHeader& header)); |
102 // The constructor sets this up to return true by default. | 102 // The constructor sets this up to return true by default. |
103 MOCK_METHOD1(OnUnauthenticatedPublicHeader, bool( | 103 MOCK_METHOD1(OnUnauthenticatedPublicHeader, bool( |
104 const QuicPacketPublicHeader& header)); | 104 const QuicPacketPublicHeader& header)); |
105 MOCK_METHOD1(OnPacketHeader, bool(const QuicPacketHeader& header)); | 105 MOCK_METHOD1(OnPacketHeader, bool(const QuicPacketHeader& header)); |
106 MOCK_METHOD1(OnFecProtectedPayload, void(base::StringPiece payload)); | 106 MOCK_METHOD1(OnFecProtectedPayload, void(base::StringPiece payload)); |
107 MOCK_METHOD1(OnStreamFrame, bool(const QuicStreamFrame& frame)); | 107 MOCK_METHOD1(OnStreamFrame, bool(const QuicStreamFrame& frame)); |
108 MOCK_METHOD1(OnAckFrame, bool(const QuicAckFrame& frame)); | 108 MOCK_METHOD1(OnAckFrame, bool(const QuicAckFrame& frame)); |
109 MOCK_METHOD1(OnCongestionFeedbackFrame, | 109 MOCK_METHOD1(OnCongestionFeedbackFrame, |
110 bool(const QuicCongestionFeedbackFrame& frame)); | 110 bool(const QuicCongestionFeedbackFrame& frame)); |
| 111 MOCK_METHOD1(OnStopWaitingFrame, bool(const QuicStopWaitingFrame& frame)); |
111 MOCK_METHOD1(OnFecData, void(const QuicFecData& fec)); | 112 MOCK_METHOD1(OnFecData, void(const QuicFecData& fec)); |
112 MOCK_METHOD1(OnRstStreamFrame, bool(const QuicRstStreamFrame& frame)); | 113 MOCK_METHOD1(OnRstStreamFrame, bool(const QuicRstStreamFrame& frame)); |
113 MOCK_METHOD1(OnConnectionCloseFrame, | 114 MOCK_METHOD1(OnConnectionCloseFrame, |
114 bool(const QuicConnectionCloseFrame& frame)); | 115 bool(const QuicConnectionCloseFrame& frame)); |
115 MOCK_METHOD1(OnGoAwayFrame, bool(const QuicGoAwayFrame& frame)); | 116 MOCK_METHOD1(OnGoAwayFrame, bool(const QuicGoAwayFrame& frame)); |
116 MOCK_METHOD1(OnWindowUpdateFrame, bool(const QuicWindowUpdateFrame& frame)); | 117 MOCK_METHOD1(OnWindowUpdateFrame, bool(const QuicWindowUpdateFrame& frame)); |
117 MOCK_METHOD1(OnBlockedFrame, bool(const QuicBlockedFrame& frame)); | 118 MOCK_METHOD1(OnBlockedFrame, bool(const QuicBlockedFrame& frame)); |
118 MOCK_METHOD0(OnPacketComplete, void()); | 119 MOCK_METHOD0(OnPacketComplete, void()); |
119 | 120 |
120 private: | 121 private: |
(...skipping 14 matching lines...) Expand all Loading... |
135 virtual bool OnProtocolVersionMismatch(QuicVersion version) OVERRIDE; | 136 virtual bool OnProtocolVersionMismatch(QuicVersion version) OVERRIDE; |
136 virtual bool OnUnauthenticatedHeader(const QuicPacketHeader& header) OVERRIDE; | 137 virtual bool OnUnauthenticatedHeader(const QuicPacketHeader& header) OVERRIDE; |
137 virtual bool OnUnauthenticatedPublicHeader( | 138 virtual bool OnUnauthenticatedPublicHeader( |
138 const QuicPacketPublicHeader& header) OVERRIDE; | 139 const QuicPacketPublicHeader& header) OVERRIDE; |
139 virtual bool OnPacketHeader(const QuicPacketHeader& header) OVERRIDE; | 140 virtual bool OnPacketHeader(const QuicPacketHeader& header) OVERRIDE; |
140 virtual void OnFecProtectedPayload(base::StringPiece payload) OVERRIDE {} | 141 virtual void OnFecProtectedPayload(base::StringPiece payload) OVERRIDE {} |
141 virtual bool OnStreamFrame(const QuicStreamFrame& frame) OVERRIDE; | 142 virtual bool OnStreamFrame(const QuicStreamFrame& frame) OVERRIDE; |
142 virtual bool OnAckFrame(const QuicAckFrame& frame) OVERRIDE; | 143 virtual bool OnAckFrame(const QuicAckFrame& frame) OVERRIDE; |
143 virtual bool OnCongestionFeedbackFrame( | 144 virtual bool OnCongestionFeedbackFrame( |
144 const QuicCongestionFeedbackFrame& frame) OVERRIDE; | 145 const QuicCongestionFeedbackFrame& frame) OVERRIDE; |
| 146 virtual bool OnStopWaitingFrame( |
| 147 const QuicStopWaitingFrame& frame) OVERRIDE; |
145 virtual void OnFecData(const QuicFecData& fec) OVERRIDE {} | 148 virtual void OnFecData(const QuicFecData& fec) OVERRIDE {} |
146 virtual bool OnRstStreamFrame(const QuicRstStreamFrame& frame) OVERRIDE; | 149 virtual bool OnRstStreamFrame(const QuicRstStreamFrame& frame) OVERRIDE; |
147 virtual bool OnConnectionCloseFrame( | 150 virtual bool OnConnectionCloseFrame( |
148 const QuicConnectionCloseFrame& frame) OVERRIDE; | 151 const QuicConnectionCloseFrame& frame) OVERRIDE; |
149 virtual bool OnGoAwayFrame(const QuicGoAwayFrame& frame) OVERRIDE; | 152 virtual bool OnGoAwayFrame(const QuicGoAwayFrame& frame) OVERRIDE; |
150 virtual bool OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame) OVERRIDE; | 153 virtual bool OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame) OVERRIDE; |
151 virtual bool OnBlockedFrame(const QuicBlockedFrame& frame) OVERRIDE; | 154 virtual bool OnBlockedFrame(const QuicBlockedFrame& frame) OVERRIDE; |
152 virtual void OnPacketComplete() OVERRIDE {} | 155 virtual void OnPacketComplete() OVERRIDE {} |
153 | 156 |
154 private: | 157 private: |
(...skipping 25 matching lines...) Expand all Loading... |
180 void Reset(); | 183 void Reset(); |
181 | 184 |
182 // NoOpFramerVisitor | 185 // NoOpFramerVisitor |
183 virtual void OnVersionNegotiationPacket( | 186 virtual void OnVersionNegotiationPacket( |
184 const QuicVersionNegotiationPacket& packet) OVERRIDE; | 187 const QuicVersionNegotiationPacket& packet) OVERRIDE; |
185 virtual bool OnPacketHeader(const QuicPacketHeader& header) OVERRIDE; | 188 virtual bool OnPacketHeader(const QuicPacketHeader& header) OVERRIDE; |
186 virtual bool OnStreamFrame(const QuicStreamFrame& frame) OVERRIDE; | 189 virtual bool OnStreamFrame(const QuicStreamFrame& frame) OVERRIDE; |
187 virtual bool OnAckFrame(const QuicAckFrame& frame) OVERRIDE; | 190 virtual bool OnAckFrame(const QuicAckFrame& frame) OVERRIDE; |
188 virtual bool OnCongestionFeedbackFrame( | 191 virtual bool OnCongestionFeedbackFrame( |
189 const QuicCongestionFeedbackFrame& frame) OVERRIDE; | 192 const QuicCongestionFeedbackFrame& frame) OVERRIDE; |
| 193 virtual bool OnStopWaitingFrame( |
| 194 const QuicStopWaitingFrame& frame) OVERRIDE; |
190 virtual bool OnRstStreamFrame(const QuicRstStreamFrame& frame) OVERRIDE; | 195 virtual bool OnRstStreamFrame(const QuicRstStreamFrame& frame) OVERRIDE; |
191 virtual bool OnConnectionCloseFrame( | 196 virtual bool OnConnectionCloseFrame( |
192 const QuicConnectionCloseFrame& frame) OVERRIDE; | 197 const QuicConnectionCloseFrame& frame) OVERRIDE; |
193 virtual bool OnGoAwayFrame(const QuicGoAwayFrame& frame) OVERRIDE; | 198 virtual bool OnGoAwayFrame(const QuicGoAwayFrame& frame) OVERRIDE; |
194 | 199 |
195 size_t frame_count() const { return frame_count_; } | 200 size_t frame_count() const { return frame_count_; } |
196 QuicPacketHeader* header() { return &header_; } | 201 QuicPacketHeader* header() { return &header_; } |
197 const std::vector<QuicStreamFrame>* stream_frames() const { | 202 const std::vector<QuicStreamFrame>* stream_frames() const { |
198 return &stream_frames_; | 203 return &stream_frames_; |
199 } | 204 } |
200 const std::vector<string*>& stream_data() const { | 205 const std::vector<string*>& stream_data() const { |
201 return stream_data_; | 206 return stream_data_; |
202 } | 207 } |
203 QuicAckFrame* ack() { return ack_.get(); } | 208 QuicAckFrame* ack() { return ack_.get(); } |
204 QuicCongestionFeedbackFrame* feedback() { return feedback_.get(); } | 209 QuicCongestionFeedbackFrame* feedback() { return feedback_.get(); } |
| 210 QuicStopWaitingFrame* stop_waiting() { return stop_waiting_.get(); } |
205 QuicRstStreamFrame* rst() { return rst_.get(); } | 211 QuicRstStreamFrame* rst() { return rst_.get(); } |
206 QuicConnectionCloseFrame* close() { return close_.get(); } | 212 QuicConnectionCloseFrame* close() { return close_.get(); } |
207 QuicGoAwayFrame* goaway() { return goaway_.get(); } | 213 QuicGoAwayFrame* goaway() { return goaway_.get(); } |
208 QuicVersionNegotiationPacket* version_negotiation_packet() { | 214 QuicVersionNegotiationPacket* version_negotiation_packet() { |
209 return version_negotiation_packet_.get(); | 215 return version_negotiation_packet_.get(); |
210 } | 216 } |
211 | 217 |
212 private: | 218 private: |
213 size_t frame_count_; | 219 size_t frame_count_; |
214 QuicPacketHeader header_; | 220 QuicPacketHeader header_; |
215 std::vector<QuicStreamFrame> stream_frames_; | 221 std::vector<QuicStreamFrame> stream_frames_; |
216 std::vector<std::string*> stream_data_; | 222 std::vector<std::string*> stream_data_; |
217 scoped_ptr<QuicAckFrame> ack_; | 223 scoped_ptr<QuicAckFrame> ack_; |
218 scoped_ptr<QuicCongestionFeedbackFrame> feedback_; | 224 scoped_ptr<QuicCongestionFeedbackFrame> feedback_; |
| 225 scoped_ptr<QuicStopWaitingFrame> stop_waiting_; |
219 scoped_ptr<QuicRstStreamFrame> rst_; | 226 scoped_ptr<QuicRstStreamFrame> rst_; |
220 scoped_ptr<QuicConnectionCloseFrame> close_; | 227 scoped_ptr<QuicConnectionCloseFrame> close_; |
221 scoped_ptr<QuicGoAwayFrame> goaway_; | 228 scoped_ptr<QuicGoAwayFrame> goaway_; |
222 scoped_ptr<QuicVersionNegotiationPacket> version_negotiation_packet_; | 229 scoped_ptr<QuicVersionNegotiationPacket> version_negotiation_packet_; |
223 | 230 |
224 DISALLOW_COPY_AND_ASSIGN(FramerVisitorCapturingFrames); | 231 DISALLOW_COPY_AND_ASSIGN(FramerVisitorCapturingFrames); |
225 }; | 232 }; |
226 | 233 |
227 class MockConnectionVisitor : public QuicConnectionVisitorInterface { | 234 class MockConnectionVisitor : public QuicConnectionVisitorInterface { |
228 public: | 235 public: |
(...skipping 106 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
335 }; | 342 }; |
336 | 343 |
337 class MockSession : public QuicSession { | 344 class MockSession : public QuicSession { |
338 public: | 345 public: |
339 explicit MockSession(QuicConnection* connection); | 346 explicit MockSession(QuicConnection* connection); |
340 virtual ~MockSession(); | 347 virtual ~MockSession(); |
341 MOCK_METHOD2(OnConnectionClosed, void(QuicErrorCode error, bool from_peer)); | 348 MOCK_METHOD2(OnConnectionClosed, void(QuicErrorCode error, bool from_peer)); |
342 MOCK_METHOD1(CreateIncomingDataStream, QuicDataStream*(QuicStreamId id)); | 349 MOCK_METHOD1(CreateIncomingDataStream, QuicDataStream*(QuicStreamId id)); |
343 MOCK_METHOD0(GetCryptoStream, QuicCryptoStream*()); | 350 MOCK_METHOD0(GetCryptoStream, QuicCryptoStream*()); |
344 MOCK_METHOD0(CreateOutgoingDataStream, QuicDataStream*()); | 351 MOCK_METHOD0(CreateOutgoingDataStream, QuicDataStream*()); |
345 MOCK_METHOD6(WritevData, | 352 MOCK_METHOD5(WritevData, |
346 QuicConsumedData(QuicStreamId id, | 353 QuicConsumedData(QuicStreamId id, |
347 const struct iovec* iov, | 354 const IOVector& data, |
348 int count, | |
349 QuicStreamOffset offset, | 355 QuicStreamOffset offset, |
350 bool fin, | 356 bool fin, |
351 QuicAckNotifier::DelegateInterface*)); | 357 QuicAckNotifier::DelegateInterface*)); |
352 MOCK_METHOD2(OnStreamHeaders, void(QuicStreamId stream_id, | 358 MOCK_METHOD2(OnStreamHeaders, void(QuicStreamId stream_id, |
353 base::StringPiece headers_data)); | 359 base::StringPiece headers_data)); |
354 MOCK_METHOD2(OnStreamHeadersPriority, void(QuicStreamId stream_id, | 360 MOCK_METHOD2(OnStreamHeadersPriority, void(QuicStreamId stream_id, |
355 QuicPriority priority)); | 361 QuicPriority priority)); |
356 MOCK_METHOD3(OnStreamHeadersComplete, void(QuicStreamId stream_id, | 362 MOCK_METHOD3(OnStreamHeadersComplete, void(QuicStreamId stream_id, |
357 bool fin, | 363 bool fin, |
358 size_t frame_len)); | 364 size_t frame_len)); |
(...skipping 114 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
473 | 479 |
474 protected: | 480 protected: |
475 // Object is ref counted. | 481 // Object is ref counted. |
476 virtual ~MockAckNotifierDelegate(); | 482 virtual ~MockAckNotifierDelegate(); |
477 }; | 483 }; |
478 | 484 |
479 } // namespace test | 485 } // namespace test |
480 } // namespace net | 486 } // namespace net |
481 | 487 |
482 #endif // NET_QUIC_TEST_TOOLS_QUIC_TEST_UTILS_H_ | 488 #endif // NET_QUIC_TEST_TOOLS_QUIC_TEST_UTILS_H_ |
OLD | NEW |