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/quic/chromium/quic_chromium_client_stream.h" | 5 #include "net/quic/chromium/quic_chromium_client_stream.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 | 8 |
9 #include "base/memory/ptr_util.h" | 9 #include "base/memory/ptr_util.h" |
10 #include "base/run_loop.h" | 10 #include "base/run_loop.h" |
11 #include "base/strings/string_number_conversions.h" | 11 #include "base/strings/string_number_conversions.h" |
12 #include "net/base/io_buffer.h" | 12 #include "net/base/io_buffer.h" |
13 #include "net/base/net_errors.h" | 13 #include "net/base/net_errors.h" |
14 #include "net/base/test_completion_callback.h" | 14 #include "net/base/test_completion_callback.h" |
15 #include "net/quic/chromium/quic_chromium_client_session.h" | 15 #include "net/quic/chromium/quic_chromium_client_session.h" |
16 #include "net/quic/core/quic_client_session_base.h" | 16 #include "net/quic/core/quic_client_session_base.h" |
17 #include "net/quic/core/quic_utils.h" | 17 #include "net/quic/core/quic_utils.h" |
18 #include "net/quic/core/spdy_utils.h" | 18 #include "net/quic/core/spdy_utils.h" |
| 19 #include "net/quic/platform/api/quic_ptr_util.h" |
19 #include "net/quic/test_tools/crypto_test_utils.h" | 20 #include "net/quic/test_tools/crypto_test_utils.h" |
20 #include "net/quic/test_tools/quic_spdy_session_peer.h" | 21 #include "net/quic/test_tools/quic_spdy_session_peer.h" |
21 #include "net/quic/test_tools/quic_test_utils.h" | 22 #include "net/quic/test_tools/quic_test_utils.h" |
22 #include "net/test/gtest_util.h" | 23 #include "net/test/gtest_util.h" |
| 24 #include "net/tools/quic/quic_spdy_client_stream.h" |
23 #include "testing/gmock/include/gmock/gmock.h" | 25 #include "testing/gmock/include/gmock/gmock.h" |
24 #include "testing/gmock_mutant.h" | 26 #include "testing/gmock_mutant.h" |
25 | 27 |
26 using testing::AnyNumber; | 28 using testing::AnyNumber; |
27 using testing::CreateFunctor; | 29 using testing::CreateFunctor; |
28 using testing::Invoke; | 30 using testing::Invoke; |
29 using testing::Return; | 31 using testing::Return; |
30 using testing::StrEq; | 32 using testing::StrEq; |
31 using testing::_; | 33 using testing::_; |
32 | 34 |
(...skipping 21 matching lines...) Expand all Loading... |
54 MOCK_METHOD0(OnClose, void()); | 56 MOCK_METHOD0(OnClose, void()); |
55 MOCK_METHOD1(OnError, void(int)); | 57 MOCK_METHOD1(OnError, void(int)); |
56 MOCK_METHOD0(HasSendHeadersComplete, bool()); | 58 MOCK_METHOD0(HasSendHeadersComplete, bool()); |
57 | 59 |
58 SpdyHeaderBlock headers_; | 60 SpdyHeaderBlock headers_; |
59 | 61 |
60 private: | 62 private: |
61 DISALLOW_COPY_AND_ASSIGN(MockDelegate); | 63 DISALLOW_COPY_AND_ASSIGN(MockDelegate); |
62 }; | 64 }; |
63 | 65 |
| 66 class TestQuicClientSessionBaseStream : public QuicSpdyStream { |
| 67 public: |
| 68 TestQuicClientSessionBaseStream(QuicStreamId id, QuicSpdySession* session) |
| 69 : QuicSpdyStream(id, session) {} |
| 70 |
| 71 void OnDataAvailable() override {} |
| 72 }; |
| 73 |
64 class MockQuicClientSessionBase : public QuicClientSessionBase { | 74 class MockQuicClientSessionBase : public QuicClientSessionBase { |
65 public: | 75 public: |
66 explicit MockQuicClientSessionBase(QuicConnection* connection, | 76 explicit MockQuicClientSessionBase(QuicConnection* connection, |
67 QuicClientPushPromiseIndex* index); | 77 QuicClientPushPromiseIndex* index); |
68 ~MockQuicClientSessionBase() override; | 78 ~MockQuicClientSessionBase() override; |
69 | 79 |
70 const QuicCryptoStream* GetCryptoStream() const override { | 80 const QuicCryptoStream* GetCryptoStream() const override { |
71 return crypto_stream_.get(); | 81 return crypto_stream_.get(); |
72 } | 82 } |
73 | 83 |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
123 MOCK_METHOD5( | 133 MOCK_METHOD5( |
124 WriteHeadersMock, | 134 WriteHeadersMock, |
125 size_t(QuicStreamId id, | 135 size_t(QuicStreamId id, |
126 const SpdyHeaderBlock& headers, | 136 const SpdyHeaderBlock& headers, |
127 bool fin, | 137 bool fin, |
128 SpdyPriority priority, | 138 SpdyPriority priority, |
129 const QuicReferenceCountedPointer<QuicAckListenerInterface>& | 139 const QuicReferenceCountedPointer<QuicAckListenerInterface>& |
130 ack_listener)); | 140 ack_listener)); |
131 MOCK_METHOD1(OnHeadersHeadOfLineBlocking, void(QuicTime::Delta delta)); | 141 MOCK_METHOD1(OnHeadersHeadOfLineBlocking, void(QuicTime::Delta delta)); |
132 | 142 |
| 143 std::unique_ptr<QuicStream> CreateStream(QuicStreamId id) { |
| 144 return QuicMakeUnique<TestQuicClientSessionBaseStream>(id, this); |
| 145 } |
| 146 |
133 using QuicSession::ActivateStream; | 147 using QuicSession::ActivateStream; |
134 | 148 |
135 // Returns a QuicConsumedData that indicates all of |data| (and |fin| if set) | 149 // Returns a QuicConsumedData that indicates all of |data| (and |fin| if set) |
136 // has been consumed. | 150 // has been consumed. |
137 static QuicConsumedData ConsumeAllData( | 151 static QuicConsumedData ConsumeAllData( |
138 QuicStreamId id, | 152 QuicStreamId id, |
139 const QuicIOVector& data, | 153 const QuicIOVector& data, |
140 QuicStreamOffset offset, | 154 QuicStreamOffset offset, |
141 bool fin, | 155 bool fin, |
142 QuicAckListenerInterface* ack_listener); | 156 QuicAckListenerInterface* ack_listener); |
(...skipping 466 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
609 stream->SetDelegate(&delegate_); | 623 stream->SetDelegate(&delegate_); |
610 ProcessHeadersFull(headers_); | 624 ProcessHeadersFull(headers_); |
611 | 625 |
612 // Times(2) because OnClose will be called for stream and stream_. | 626 // Times(2) because OnClose will be called for stream and stream_. |
613 EXPECT_CALL(delegate_, OnClose()).Times(2); | 627 EXPECT_CALL(delegate_, OnClose()).Times(2); |
614 } | 628 } |
615 | 629 |
616 } // namespace | 630 } // namespace |
617 } // namespace test | 631 } // namespace test |
618 } // namespace net | 632 } // namespace net |
OLD | NEW |