| 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
|
|
|