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

Side by Side Diff: net/quic/chromium/quic_chromium_client_stream_test.cc

Issue 2589983002: Create a QUIC wrapper around scoped_refptr. (Closed)
Patch Set: rm = nullptr Created 4 years 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
OLDNEW
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"
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after
72 QuicCryptoStream* GetCryptoStream() override { return crypto_stream_.get(); } 72 QuicCryptoStream* GetCryptoStream() override { return crypto_stream_.get(); }
73 73
74 // From QuicSession. 74 // From QuicSession.
75 MOCK_METHOD3(OnConnectionClosed, 75 MOCK_METHOD3(OnConnectionClosed,
76 void(QuicErrorCode error, 76 void(QuicErrorCode error,
77 const std::string& error_details, 77 const std::string& error_details,
78 ConnectionCloseSource source)); 78 ConnectionCloseSource source));
79 MOCK_METHOD1(CreateIncomingDynamicStream, QuicSpdyStream*(QuicStreamId id)); 79 MOCK_METHOD1(CreateIncomingDynamicStream, QuicSpdyStream*(QuicStreamId id));
80 MOCK_METHOD1(CreateOutgoingDynamicStream, 80 MOCK_METHOD1(CreateOutgoingDynamicStream,
81 QuicChromiumClientStream*(SpdyPriority priority)); 81 QuicChromiumClientStream*(SpdyPriority priority));
82 MOCK_METHOD6(WritevData, 82 MOCK_METHOD6(
83 QuicConsumedData(QuicStream* stream, 83 WritevData,
84 QuicStreamId id, 84 QuicConsumedData(QuicStream* stream,
85 QuicIOVector data, 85 QuicStreamId id,
86 QuicStreamOffset offset, 86 QuicIOVector data,
87 bool fin, 87 QuicStreamOffset offset,
88 scoped_refptr<QuicAckListenerInterface>)); 88 bool fin,
89 QuicReferenceCountedPointer<QuicAckListenerInterface>));
89 MOCK_METHOD3(SendRstStream, 90 MOCK_METHOD3(SendRstStream,
90 void(QuicStreamId stream_id, 91 void(QuicStreamId stream_id,
91 QuicRstStreamErrorCode error, 92 QuicRstStreamErrorCode error,
92 QuicStreamOffset bytes_written)); 93 QuicStreamOffset bytes_written));
93 94
94 MOCK_METHOD2(OnStreamHeaders, 95 MOCK_METHOD2(OnStreamHeaders,
95 void(QuicStreamId stream_id, base::StringPiece headers_data)); 96 void(QuicStreamId stream_id, base::StringPiece headers_data));
96 MOCK_METHOD2(OnStreamHeadersPriority, 97 MOCK_METHOD2(OnStreamHeadersPriority,
97 void(QuicStreamId stream_id, SpdyPriority priority)); 98 void(QuicStreamId stream_id, SpdyPriority priority));
98 MOCK_METHOD3(OnStreamHeadersComplete, 99 MOCK_METHOD3(OnStreamHeadersComplete,
99 void(QuicStreamId stream_id, bool fin, size_t frame_len)); 100 void(QuicStreamId stream_id, bool fin, size_t frame_len));
100 MOCK_METHOD2(OnPromiseHeaders, 101 MOCK_METHOD2(OnPromiseHeaders,
101 void(QuicStreamId stream_id, StringPiece headers_data)); 102 void(QuicStreamId stream_id, StringPiece headers_data));
102 MOCK_METHOD3(OnPromiseHeadersComplete, 103 MOCK_METHOD3(OnPromiseHeadersComplete,
103 void(QuicStreamId stream_id, 104 void(QuicStreamId stream_id,
104 QuicStreamId promised_stream_id, 105 QuicStreamId promised_stream_id,
105 size_t frame_len)); 106 size_t frame_len));
106 MOCK_METHOD0(IsCryptoHandshakeConfirmed, bool()); 107 MOCK_METHOD0(IsCryptoHandshakeConfirmed, bool());
107 // Methods taking non-copyable types like SpdyHeaderBlock by value cannot be 108 // Methods taking non-copyable types like SpdyHeaderBlock by value cannot be
108 // mocked directly. 109 // mocked directly.
109 size_t WriteHeaders( 110 size_t WriteHeaders(QuicStreamId id,
110 QuicStreamId id, 111 SpdyHeaderBlock headers,
111 SpdyHeaderBlock headers, 112 bool fin,
112 bool fin, 113 SpdyPriority priority,
113 SpdyPriority priority, 114 QuicReferenceCountedPointer<QuicAckListenerInterface>
114 scoped_refptr<QuicAckListenerInterface> ack_notifier_delegate) override { 115 ack_notifier_delegate) override {
115 return WriteHeadersMock(id, headers, fin, priority, 116 return WriteHeadersMock(id, headers, fin, priority,
116 std::move(ack_notifier_delegate)); 117 std::move(ack_notifier_delegate));
117 } 118 }
118 MOCK_METHOD5(WriteHeadersMock, 119 MOCK_METHOD5(
119 size_t(QuicStreamId id, 120 WriteHeadersMock,
120 const SpdyHeaderBlock& headers, 121 size_t(QuicStreamId id,
121 bool fin, 122 const SpdyHeaderBlock& headers,
122 SpdyPriority priority, 123 bool fin,
123 const scoped_refptr<QuicAckListenerInterface>& 124 SpdyPriority priority,
124 ack_notifier_delegate)); 125 const QuicReferenceCountedPointer<QuicAckListenerInterface>&
126 ack_notifier_delegate));
125 MOCK_METHOD1(OnHeadersHeadOfLineBlocking, void(QuicTime::Delta delta)); 127 MOCK_METHOD1(OnHeadersHeadOfLineBlocking, void(QuicTime::Delta delta));
126 128
127 using QuicSession::ActivateStream; 129 using QuicSession::ActivateStream;
128 130
129 // Returns a QuicConsumedData that indicates all of |data| (and |fin| if set) 131 // Returns a QuicConsumedData that indicates all of |data| (and |fin| if set)
130 // has been consumed. 132 // has been consumed.
131 static QuicConsumedData ConsumeAllData( 133 static QuicConsumedData ConsumeAllData(
132 QuicStreamId id, 134 QuicStreamId id,
133 const QuicIOVector& data, 135 const QuicIOVector& data,
134 QuicStreamOffset offset, 136 QuicStreamOffset offset,
(...skipping 457 matching lines...) Expand 10 before | Expand all | Expand 10 after
592 stream->SetDelegate(&delegate_); 594 stream->SetDelegate(&delegate_);
593 ProcessHeadersFull(headers_); 595 ProcessHeadersFull(headers_);
594 596
595 // Times(2) because OnClose will be called for stream and stream_. 597 // Times(2) because OnClose will be called for stream and stream_.
596 EXPECT_CALL(delegate_, OnClose()).Times(2); 598 EXPECT_CALL(delegate_, OnClose()).Times(2);
597 } 599 }
598 600
599 } // namespace 601 } // namespace
600 } // namespace test 602 } // namespace test
601 } // namespace net 603 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/chromium/quic_chromium_client_stream.cc ('k') | net/quic/core/crypto/crypto_handshake.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698