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/test_tools/quic_test_utils.h" | 5 #include "net/quic/test_tools/quic_test_utils.h" |
6 | 6 |
7 #include <memory> | 7 #include <memory> |
8 | 8 |
9 #include "base/memory/ptr_util.h" | 9 #include "base/memory/ptr_util.h" |
10 #include "base/sha1.h" | 10 #include "base/sha1.h" |
(...skipping 425 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
436 return new QuicCryptoServerStream(crypto_config, compressed_certs_cache, | 436 return new QuicCryptoServerStream(crypto_config, compressed_certs_cache, |
437 FLAGS_enable_quic_stateless_reject_support, | 437 FLAGS_enable_quic_stateless_reject_support, |
438 this, &helper_); | 438 this, &helper_); |
439 } | 439 } |
440 | 440 |
441 QuicCryptoServerStream* TestQuicSpdyServerSession::GetCryptoStream() { | 441 QuicCryptoServerStream* TestQuicSpdyServerSession::GetCryptoStream() { |
442 return static_cast<QuicCryptoServerStream*>( | 442 return static_cast<QuicCryptoServerStream*>( |
443 QuicServerSessionBase::GetCryptoStream()); | 443 QuicServerSessionBase::GetCryptoStream()); |
444 } | 444 } |
445 | 445 |
| 446 TestPushPromiseDelegate::TestPushPromiseDelegate(bool match) |
| 447 : match_(match), rendezvous_fired_(false), rendezvous_stream_(nullptr) {} |
| 448 |
| 449 bool TestPushPromiseDelegate::CheckVary( |
| 450 const SpdyHeaderBlock& client_request, |
| 451 const SpdyHeaderBlock& promise_request, |
| 452 const SpdyHeaderBlock& promise_response) { |
| 453 DVLOG(1) << "match " << match_; |
| 454 return match_; |
| 455 } |
| 456 |
| 457 void TestPushPromiseDelegate::OnRendezvousResult(QuicSpdyStream* stream) { |
| 458 rendezvous_fired_ = true; |
| 459 rendezvous_stream_ = stream; |
| 460 } |
| 461 |
446 TestQuicSpdyClientSession::TestQuicSpdyClientSession( | 462 TestQuicSpdyClientSession::TestQuicSpdyClientSession( |
447 QuicConnection* connection, | 463 QuicConnection* connection, |
448 const QuicConfig& config, | 464 const QuicConfig& config, |
449 const QuicServerId& server_id, | 465 const QuicServerId& server_id, |
450 QuicCryptoClientConfig* crypto_config) | 466 QuicCryptoClientConfig* crypto_config) |
451 : QuicClientSessionBase(connection, &push_promise_index_, config) { | 467 : QuicClientSessionBase(connection, &push_promise_index_, config) { |
452 crypto_stream_.reset(new QuicCryptoClientStream( | 468 crypto_stream_.reset(new QuicCryptoClientStream( |
453 server_id, this, CryptoTestUtils::ProofVerifyContextForTesting(), | 469 server_id, this, CryptoTestUtils::ProofVerifyContextForTesting(), |
454 crypto_config, this)); | 470 crypto_config, this)); |
455 Initialize(); | 471 Initialize(); |
(...skipping 470 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
926 // strike register worries that we've just overflowed a uint32_t time. | 942 // strike register worries that we've just overflowed a uint32_t time. |
927 (*server_connection)->AdvanceTime(connection_start_time); | 943 (*server_connection)->AdvanceTime(connection_start_time); |
928 } | 944 } |
929 | 945 |
930 QuicStreamId QuicClientDataStreamId(int i) { | 946 QuicStreamId QuicClientDataStreamId(int i) { |
931 return kClientDataStreamId1 + 2 * i; | 947 return kClientDataStreamId1 + 2 * i; |
932 } | 948 } |
933 | 949 |
934 } // namespace test | 950 } // namespace test |
935 } // namespace net | 951 } // namespace net |
OLD | NEW |