| 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 <stddef.h> | 5 #include <stddef.h> |
| 6 #include <string> | 6 #include <string> |
| 7 #include <sys/epoll.h> | 7 #include <sys/epoll.h> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
| (...skipping 203 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 214 server_config_.SetInitialSessionFlowControlWindowToSend( | 214 server_config_.SetInitialSessionFlowControlWindowToSend( |
| 215 3 * kInitialSessionFlowControlWindowForTest); | 215 3 * kInitialSessionFlowControlWindowForTest); |
| 216 | 216 |
| 217 QuicInMemoryCachePeer::ResetForTests(); | 217 QuicInMemoryCachePeer::ResetForTests(); |
| 218 AddToCache("GET", "https://www.google.com/foo", | 218 AddToCache("GET", "https://www.google.com/foo", |
| 219 "HTTP/1.1", "200", "OK", kFooResponseBody); | 219 "HTTP/1.1", "200", "OK", kFooResponseBody); |
| 220 AddToCache("GET", "https://www.google.com/bar", | 220 AddToCache("GET", "https://www.google.com/bar", |
| 221 "HTTP/1.1", "200", "OK", kBarResponseBody); | 221 "HTTP/1.1", "200", "OK", kBarResponseBody); |
| 222 } | 222 } |
| 223 | 223 |
| 224 virtual ~EndToEndTest() { | 224 ~EndToEndTest() override { |
| 225 // TODO(rtenneti): port RecycleUnusedPort if needed. | 225 // TODO(rtenneti): port RecycleUnusedPort if needed. |
| 226 // RecycleUnusedPort(server_address_.port()); | 226 // RecycleUnusedPort(server_address_.port()); |
| 227 QuicInMemoryCachePeer::ResetForTests(); | 227 QuicInMemoryCachePeer::ResetForTests(); |
| 228 } | 228 } |
| 229 | 229 |
| 230 QuicTestClient* CreateQuicClient(QuicPacketWriterWrapper* writer) { | 230 QuicTestClient* CreateQuicClient(QuicPacketWriterWrapper* writer) { |
| 231 QuicTestClient* client = new QuicTestClient( | 231 QuicTestClient* client = new QuicTestClient( |
| 232 server_address_, | 232 server_address_, |
| 233 server_hostname_, | 233 server_hostname_, |
| 234 false, // not secure | 234 false, // not secure |
| (...skipping 1111 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1346 QuicSession* session = dispatcher->session_map().begin()->second; | 1346 QuicSession* session = dispatcher->session_map().begin()->second; |
| 1347 EXPECT_EQ(0u, QuicSessionPeer::GetLocallyClosedStreamsHighestOffset( | 1347 EXPECT_EQ(0u, QuicSessionPeer::GetLocallyClosedStreamsHighestOffset( |
| 1348 session).size()); | 1348 session).size()); |
| 1349 server_thread_->Resume(); | 1349 server_thread_->Resume(); |
| 1350 } | 1350 } |
| 1351 | 1351 |
| 1352 } // namespace | 1352 } // namespace |
| 1353 } // namespace test | 1353 } // namespace test |
| 1354 } // namespace tools | 1354 } // namespace tools |
| 1355 } // namespace net | 1355 } // namespace net |
| OLD | NEW |