Index: net/quic/test_tools/quic_stream_factory_peer.cc |
diff --git a/net/quic/test_tools/quic_stream_factory_peer.cc b/net/quic/test_tools/quic_stream_factory_peer.cc |
deleted file mode 100644 |
index efd35980db4402f200ff176f307993a7a5065bf6..0000000000000000000000000000000000000000 |
--- a/net/quic/test_tools/quic_stream_factory_peer.cc |
+++ /dev/null |
@@ -1,207 +0,0 @@ |
-// Copyright 2015 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "net/quic/test_tools/quic_stream_factory_peer.h" |
- |
-#include <string> |
-#include <vector> |
- |
-#include "net/cert/x509_certificate.h" |
-#include "net/quic/chromium/quic_chromium_client_session.h" |
-#include "net/quic/chromium/quic_http_stream.h" |
-#include "net/quic/chromium/quic_stream_factory.h" |
-#include "net/quic/core/crypto/quic_crypto_client_config.h" |
-#include "net/quic/platform/impl/quic_chromium_clock.h" |
-#include "net/test/cert_test_util.h" |
-#include "net/test/test_data_directory.h" |
- |
-using std::string; |
- |
-namespace net { |
-namespace test { |
- |
-const QuicConfig* QuicStreamFactoryPeer::GetConfig(QuicStreamFactory* factory) { |
- return &factory->config_; |
-} |
- |
-QuicCryptoClientConfig* QuicStreamFactoryPeer::GetCryptoConfig( |
- QuicStreamFactory* factory) { |
- return &factory->crypto_config_; |
-} |
- |
-bool QuicStreamFactoryPeer::HasActiveSession(QuicStreamFactory* factory, |
- const QuicServerId& server_id) { |
- return factory->HasActiveSession(server_id); |
-} |
- |
-bool QuicStreamFactoryPeer::HasActiveJob(QuicStreamFactory* factory, |
- const QuicServerId& server_id) { |
- return factory->HasActiveJob(server_id); |
-} |
- |
-bool QuicStreamFactoryPeer::HasActiveCertVerifierJob( |
- QuicStreamFactory* factory, |
- const QuicServerId& server_id) { |
- return factory->HasActiveCertVerifierJob(server_id); |
-} |
- |
-QuicChromiumClientSession* QuicStreamFactoryPeer::GetActiveSession( |
- QuicStreamFactory* factory, |
- const QuicServerId& server_id) { |
- DCHECK(factory->HasActiveSession(server_id)); |
- return factory->active_sessions_[server_id]; |
-} |
- |
-std::unique_ptr<QuicHttpStream> QuicStreamFactoryPeer::CreateFromSession( |
- QuicStreamFactory* factory, |
- QuicChromiumClientSession* session) { |
- return factory->CreateFromSession(session); |
-} |
- |
-bool QuicStreamFactoryPeer::IsLiveSession(QuicStreamFactory* factory, |
- QuicChromiumClientSession* session) { |
- for (QuicStreamFactory::SessionIdMap::iterator it = |
- factory->all_sessions_.begin(); |
- it != factory->all_sessions_.end(); ++it) { |
- if (it->first == session) |
- return true; |
- } |
- return false; |
-} |
- |
-void QuicStreamFactoryPeer::SetTaskRunner(QuicStreamFactory* factory, |
- base::TaskRunner* task_runner) { |
- factory->task_runner_ = task_runner; |
-} |
- |
-QuicTime::Delta QuicStreamFactoryPeer::GetPingTimeout( |
- QuicStreamFactory* factory) { |
- return factory->ping_timeout_; |
-} |
- |
-bool QuicStreamFactoryPeer::IsQuicDisabled(QuicStreamFactory* factory) { |
- return factory->IsQuicDisabled(); |
-} |
- |
-bool QuicStreamFactoryPeer::GetDelayTcpRace(QuicStreamFactory* factory) { |
- return factory->delay_tcp_race_; |
-} |
- |
-void QuicStreamFactoryPeer::SetDelayTcpRace(QuicStreamFactory* factory, |
- bool delay_tcp_race) { |
- factory->delay_tcp_race_ = delay_tcp_race; |
-} |
- |
-bool QuicStreamFactoryPeer::GetRaceCertVerification( |
- QuicStreamFactory* factory) { |
- return factory->race_cert_verification_; |
-} |
- |
-void QuicStreamFactoryPeer::SetRaceCertVerification( |
- QuicStreamFactory* factory, |
- bool race_cert_verification) { |
- factory->race_cert_verification_ = race_cert_verification; |
-} |
- |
-QuicAsyncStatus QuicStreamFactoryPeer::StartCertVerifyJob( |
- QuicStreamFactory* factory, |
- const QuicServerId& server_id, |
- int cert_verify_flags, |
- const NetLogWithSource& net_log) { |
- return factory->StartCertVerifyJob(server_id, cert_verify_flags, net_log); |
-} |
- |
-void QuicStreamFactoryPeer::SetYieldAfterPackets(QuicStreamFactory* factory, |
- int yield_after_packets) { |
- factory->yield_after_packets_ = yield_after_packets; |
-} |
- |
-void QuicStreamFactoryPeer::SetYieldAfterDuration( |
- QuicStreamFactory* factory, |
- QuicTime::Delta yield_after_duration) { |
- factory->yield_after_duration_ = yield_after_duration; |
-} |
- |
-size_t QuicStreamFactoryPeer::GetNumberOfActiveJobs( |
- QuicStreamFactory* factory, |
- const QuicServerId& server_id) { |
- auto it = factory->active_jobs_.find(server_id); |
- if (it == factory->active_jobs_.end()) |
- return 0; |
- return it->second.size(); |
-} |
- |
-void QuicStreamFactoryPeer::MaybeInitialize(QuicStreamFactory* factory) { |
- factory->MaybeInitialize(); |
-} |
- |
-bool QuicStreamFactoryPeer::HasInitializedData(QuicStreamFactory* factory) { |
- return factory->has_initialized_data_; |
-} |
- |
-bool QuicStreamFactoryPeer::SupportsQuicAtStartUp(QuicStreamFactory* factory, |
- HostPortPair host_port_pair) { |
- return base::ContainsKey(factory->quic_supported_servers_at_startup_, |
- host_port_pair); |
-} |
- |
-bool QuicStreamFactoryPeer::CryptoConfigCacheIsEmpty( |
- QuicStreamFactory* factory, |
- const QuicServerId& quic_server_id) { |
- return factory->CryptoConfigCacheIsEmpty(quic_server_id); |
-} |
- |
-void QuicStreamFactoryPeer::CacheDummyServerConfig( |
- QuicStreamFactory* factory, |
- const QuicServerId& quic_server_id) { |
- // Minimum SCFG that passes config validation checks. |
- const char scfg[] = {// SCFG |
- 0x53, 0x43, 0x46, 0x47, |
- // num entries |
- 0x01, 0x00, |
- // padding |
- 0x00, 0x00, |
- // EXPY |
- 0x45, 0x58, 0x50, 0x59, |
- // EXPY end offset |
- 0x08, 0x00, 0x00, 0x00, |
- // Value |
- '1', '2', '3', '4', '5', '6', '7', '8'}; |
- |
- string server_config(reinterpret_cast<const char*>(&scfg), sizeof(scfg)); |
- string source_address_token("test_source_address_token"); |
- string signature("test_signature"); |
- |
- std::vector<string> certs; |
- // Load a certificate that is valid for *.example.org |
- scoped_refptr<X509Certificate> cert( |
- ImportCertFromFile(GetTestCertsDirectory(), "wildcard.pem")); |
- DCHECK(cert); |
- std::string der_bytes; |
- bool success = |
- X509Certificate::GetDEREncoded(cert->os_cert_handle(), &der_bytes); |
- DCHECK(success); |
- certs.push_back(der_bytes); |
- |
- QuicCryptoClientConfig* crypto_config = &factory->crypto_config_; |
- QuicCryptoClientConfig::CachedState* cached = |
- crypto_config->LookupOrCreate(quic_server_id); |
- QuicChromiumClock clock; |
- cached->Initialize(server_config, source_address_token, certs, "", "", |
- signature, clock.WallNow(), QuicWallTime::Zero()); |
- DCHECK(!cached->certs().empty()); |
-} |
- |
-QuicClientPushPromiseIndex* QuicStreamFactoryPeer::GetPushPromiseIndex( |
- QuicStreamFactory* factory) { |
- return &factory->push_promise_index_; |
-} |
- |
-int QuicStreamFactoryPeer::GetNumPushStreamsCreated( |
- QuicStreamFactory* factory) { |
- return factory->num_push_streams_created_; |
-} |
- |
-} // namespace test |
-} // namespace net |