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

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

Issue 2908243002: Remove QuicChromiumClientStream::Delegate in favor of async methods. (Closed)
Patch Set: Async errors Created 3 years, 6 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
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 <algorithm> 5 #include <algorithm>
6 #include <memory> 6 #include <memory>
7 #include <ostream> 7 #include <ostream>
8 #include <string> 8 #include <string>
9 #include <utility> 9 #include <utility>
10 #include <vector> 10 #include <vector>
(...skipping 1184 matching lines...) Expand 10 before | Expand all | Expand 10 after
1195 MockQuicData mock_quic_data; 1195 MockQuicData mock_quic_data;
1196 QuicStreamOffset request_header_offset = 0; 1196 QuicStreamOffset request_header_offset = 0;
1197 mock_quic_data.AddWrite( 1197 mock_quic_data.AddWrite(
1198 ConstructInitialSettingsPacket(1, &request_header_offset)); 1198 ConstructInitialSettingsPacket(1, &request_header_offset));
1199 mock_quic_data.AddWrite(ConstructClientRequestHeadersPacket( 1199 mock_quic_data.AddWrite(ConstructClientRequestHeadersPacket(
1200 2, GetNthClientInitiatedStreamId(0), true, true, 1200 2, GetNthClientInitiatedStreamId(0), true, true,
1201 GetRequestHeaders("GET", "https", "/"), &request_header_offset)); 1201 GetRequestHeaders("GET", "https", "/"), &request_header_offset));
1202 mock_quic_data.AddRead(ConstructServerResponseHeadersPacket( 1202 mock_quic_data.AddRead(ConstructServerResponseHeadersPacket(
1203 1, GetNthClientInitiatedStreamId(0), false, true, 1203 1, GetNthClientInitiatedStreamId(0), false, true,
1204 GetResponseHeaders("421"), nullptr)); 1204 GetResponseHeaders("421"), nullptr));
1205 mock_quic_data.AddWrite(ConstructClientAckAndRstPacket(
1206 3, GetNthClientInitiatedStreamId(0), QUIC_STREAM_CANCELLED, 1, 1, 1));
1207 mock_quic_data.AddRead(ASYNC, OK); 1205 mock_quic_data.AddRead(ASYNC, OK);
1208 mock_quic_data.AddSocketDataToFactory(&socket_factory_); 1206 mock_quic_data.AddSocketDataToFactory(&socket_factory_);
1209 1207
1210 // Second try: The main job uses TCP, and there is no alternate job. Once the 1208 // Second try: The main job uses TCP, and there is no alternate job. Once the
1211 // Connect() is unblocked, |http_data| will leave the socket pool, binding to 1209 // Connect() is unblocked, |http_data| will leave the socket pool, binding to
1212 // the main job of the second request. It then succeeds over HTTP/1.1. 1210 // the main job of the second request. It then succeeds over HTTP/1.1.
1213 // Note that if there was an alternative QUIC Job created for the second try, 1211 // Note that if there was an alternative QUIC Job created for the second try,
1214 // that would read these data, and would fail with ERR_QUIC_PROTOCOL_ERROR. 1212 // that would read these data, and would fail with ERR_QUIC_PROTOCOL_ERROR.
1215 // Therefore this test ensures that no alternative Job is created on retry. 1213 // Therefore this test ensures that no alternative Job is created on retry.
1216 MockWrite writes[] = {MockWrite(ASYNC, 0, "GET / HTTP/1.1\r\n"), 1214 MockWrite writes[] = {MockWrite(ASYNC, 0, "GET / HTTP/1.1\r\n"),
(...skipping 3579 matching lines...) Expand 10 before | Expand all | Expand 10 after
4796 4794
4797 request_.url = GURL("https://mail.example.org/pushed.jpg"); 4795 request_.url = GURL("https://mail.example.org/pushed.jpg");
4798 ChunkedUploadDataStream upload_data(0); 4796 ChunkedUploadDataStream upload_data(0);
4799 upload_data.AppendData("1", 1, true); 4797 upload_data.AppendData("1", 1, true);
4800 request_.upload_data_stream = &upload_data; 4798 request_.upload_data_stream = &upload_data;
4801 SendRequestAndExpectQuicResponse("and hello!"); 4799 SendRequestAndExpectQuicResponse("and hello!");
4802 } 4800 }
4803 4801
4804 } // namespace test 4802 } // namespace test
4805 } // namespace net 4803 } // namespace net
OLDNEW
« net/quic/chromium/quic_http_stream_test.cc ('K') | « net/quic/chromium/quic_http_stream_test.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698