| OLD | NEW |
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 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/tools/quic/quic_simple_server_stream.h" | 5 #include "net/tools/quic/quic_simple_server_stream.h" |
| 6 | 6 |
| 7 #include <list> | 7 #include <list> |
| 8 #include <memory> | 8 #include <memory> |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 99 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 110 .WillByDefault(testing::Return(QuicConsumedData(0, false))); | 110 .WillByDefault(testing::Return(QuicConsumedData(0, false))); |
| 111 } | 111 } |
| 112 | 112 |
| 113 ~MockQuicSimpleServerSession() override {} | 113 ~MockQuicSimpleServerSession() override {} |
| 114 | 114 |
| 115 MOCK_METHOD3(OnConnectionClosed, | 115 MOCK_METHOD3(OnConnectionClosed, |
| 116 void(QuicErrorCode error, | 116 void(QuicErrorCode error, |
| 117 const string& error_details, | 117 const string& error_details, |
| 118 ConnectionCloseSource source)); | 118 ConnectionCloseSource source)); |
| 119 MOCK_METHOD1(CreateIncomingDynamicStream, QuicSpdyStream*(QuicStreamId id)); | 119 MOCK_METHOD1(CreateIncomingDynamicStream, QuicSpdyStream*(QuicStreamId id)); |
| 120 MOCK_METHOD6(WritevData, | 120 MOCK_METHOD6( |
| 121 QuicConsumedData(QuicStream* stream, | 121 WritevData, |
| 122 QuicStreamId id, | 122 QuicConsumedData(QuicStream* stream, |
| 123 QuicIOVector data, | 123 QuicStreamId id, |
| 124 QuicStreamOffset offset, | 124 QuicIOVector data, |
| 125 bool fin, | 125 QuicStreamOffset offset, |
| 126 scoped_refptr<QuicAckListenerInterface>)); | 126 bool fin, |
| 127 QuicReferenceCountedPointer<QuicAckListenerInterface>)); |
| 127 MOCK_METHOD4(OnStreamHeaderList, | 128 MOCK_METHOD4(OnStreamHeaderList, |
| 128 void(QuicStreamId stream_id, | 129 void(QuicStreamId stream_id, |
| 129 bool fin, | 130 bool fin, |
| 130 size_t frame_len, | 131 size_t frame_len, |
| 131 const QuicHeaderList& header_list)); | 132 const QuicHeaderList& header_list)); |
| 132 MOCK_METHOD2(OnStreamHeadersPriority, | 133 MOCK_METHOD2(OnStreamHeadersPriority, |
| 133 void(QuicStreamId stream_id, SpdyPriority priority)); | 134 void(QuicStreamId stream_id, SpdyPriority priority)); |
| 134 // Methods taking non-copyable types like SpdyHeaderBlock by value cannot be | 135 // Methods taking non-copyable types like SpdyHeaderBlock by value cannot be |
| 135 // mocked directly. | 136 // mocked directly. |
| 136 size_t WriteHeaders( | 137 size_t WriteHeaders(QuicStreamId id, |
| 137 QuicStreamId id, | 138 SpdyHeaderBlock headers, |
| 138 SpdyHeaderBlock headers, | 139 bool fin, |
| 139 bool fin, | 140 SpdyPriority priority, |
| 140 SpdyPriority priority, | 141 QuicReferenceCountedPointer<QuicAckListenerInterface> |
| 141 scoped_refptr<QuicAckListenerInterface> ack_notifier_delegate) override { | 142 ack_notifier_delegate) override { |
| 142 return WriteHeadersMock(id, headers, fin, priority, ack_notifier_delegate); | 143 return WriteHeadersMock(id, headers, fin, priority, ack_notifier_delegate); |
| 143 } | 144 } |
| 144 MOCK_METHOD5(WriteHeadersMock, | 145 MOCK_METHOD5( |
| 145 size_t(QuicStreamId id, | 146 WriteHeadersMock, |
| 146 const SpdyHeaderBlock& headers, | 147 size_t(QuicStreamId id, |
| 147 bool fin, | 148 const SpdyHeaderBlock& headers, |
| 148 SpdyPriority priority, | 149 bool fin, |
| 149 const scoped_refptr<QuicAckListenerInterface>& | 150 SpdyPriority priority, |
| 150 ack_notifier_delegate)); | 151 const QuicReferenceCountedPointer<QuicAckListenerInterface>& |
| 152 ack_notifier_delegate)); |
| 151 MOCK_METHOD3(SendRstStream, | 153 MOCK_METHOD3(SendRstStream, |
| 152 void(QuicStreamId stream_id, | 154 void(QuicStreamId stream_id, |
| 153 QuicRstStreamErrorCode error, | 155 QuicRstStreamErrorCode error, |
| 154 QuicStreamOffset bytes_written)); | 156 QuicStreamOffset bytes_written)); |
| 155 MOCK_METHOD1(OnHeadersHeadOfLineBlocking, void(QuicTime::Delta delta)); | 157 MOCK_METHOD1(OnHeadersHeadOfLineBlocking, void(QuicTime::Delta delta)); |
| 156 // Matchers cannot be used on non-copyable types like SpdyHeaderBlock. | 158 // Matchers cannot be used on non-copyable types like SpdyHeaderBlock. |
| 157 void PromisePushResources( | 159 void PromisePushResources( |
| 158 const string& request_url, | 160 const string& request_url, |
| 159 const std::list<QuicHttpResponseCache::ServerPushInfo>& resources, | 161 const std::list<QuicHttpResponseCache::ServerPushInfo>& resources, |
| 160 QuicStreamId original_stream_id, | 162 QuicStreamId original_stream_id, |
| (...skipping 481 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 642 }; | 644 }; |
| 643 StringPiece data(arr, arraysize(arr)); | 645 StringPiece data(arr, arraysize(arr)); |
| 644 QuicStreamFrame frame(stream_->id(), true, 0, data); | 646 QuicStreamFrame frame(stream_->id(), true, 0, data); |
| 645 // Verify that we don't crash when we get a invalid headers in stream frame. | 647 // Verify that we don't crash when we get a invalid headers in stream frame. |
| 646 stream_->OnStreamFrame(frame); | 648 stream_->OnStreamFrame(frame); |
| 647 } | 649 } |
| 648 | 650 |
| 649 } // namespace | 651 } // namespace |
| 650 } // namespace test | 652 } // namespace test |
| 651 } // namespace net | 653 } // namespace net |
| OLD | NEW |