| Index: net/quic/quic_crypto_client_stream_test.cc
|
| diff --git a/net/quic/quic_crypto_client_stream_test.cc b/net/quic/quic_crypto_client_stream_test.cc
|
| deleted file mode 100644
|
| index 454d93013b7cc5f4352dd576fa29c37f01315edb..0000000000000000000000000000000000000000
|
| --- a/net/quic/quic_crypto_client_stream_test.cc
|
| +++ /dev/null
|
| @@ -1,205 +0,0 @@
|
| -// Copyright (c) 2012 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/quic_crypto_client_stream.h"
|
| -
|
| -#include "base/memory/scoped_ptr.h"
|
| -#include "net/quic/crypto/aes_128_gcm_12_encrypter.h"
|
| -#include "net/quic/crypto/quic_decrypter.h"
|
| -#include "net/quic/crypto/quic_encrypter.h"
|
| -#include "net/quic/quic_flags.h"
|
| -#include "net/quic/quic_protocol.h"
|
| -#include "net/quic/quic_server_id.h"
|
| -#include "net/quic/quic_utils.h"
|
| -#include "net/quic/test_tools/crypto_test_utils.h"
|
| -#include "net/quic/test_tools/quic_test_utils.h"
|
| -#include "net/quic/test_tools/simple_quic_framer.h"
|
| -#include "testing/gmock/include/gmock/gmock.h"
|
| -#include "testing/gtest/include/gtest/gtest.h"
|
| -
|
| -using std::string;
|
| -
|
| -namespace net {
|
| -namespace test {
|
| -namespace {
|
| -
|
| -const char kServerHostname[] = "example.com";
|
| -const uint16 kServerPort = 80;
|
| -
|
| -class QuicCryptoClientStreamTest : public ::testing::Test {
|
| - public:
|
| - QuicCryptoClientStreamTest()
|
| - : connection_(new PacketSavingConnection(/*is_server=*/false)),
|
| - session_(new TestClientSession(connection_, DefaultQuicConfig())),
|
| - server_id_(kServerHostname, kServerPort, false, PRIVACY_MODE_DISABLED),
|
| - stream_(new QuicCryptoClientStream(server_id_,
|
| - session_.get(),
|
| - nullptr,
|
| - &crypto_config_)) {
|
| - session_->SetCryptoStream(stream_.get());
|
| - // Advance the time, because timers do not like uninitialized times.
|
| - connection_->AdvanceTime(QuicTime::Delta::FromSeconds(1));
|
| - }
|
| -
|
| - void CompleteCryptoHandshake() {
|
| - stream_->CryptoConnect();
|
| - CryptoTestUtils::HandshakeWithFakeServer(connection_, stream_.get());
|
| - }
|
| -
|
| - void ConstructHandshakeMessage() {
|
| - CryptoFramer framer;
|
| - message_data_.reset(framer.ConstructHandshakeMessage(message_));
|
| - }
|
| -
|
| - PacketSavingConnection* connection_;
|
| - scoped_ptr<TestClientSession> session_;
|
| - QuicServerId server_id_;
|
| - scoped_ptr<QuicCryptoClientStream> stream_;
|
| - CryptoHandshakeMessage message_;
|
| - scoped_ptr<QuicData> message_data_;
|
| - QuicCryptoClientConfig crypto_config_;
|
| -};
|
| -
|
| -TEST_F(QuicCryptoClientStreamTest, NotInitiallyConected) {
|
| - EXPECT_FALSE(stream_->encryption_established());
|
| - EXPECT_FALSE(stream_->handshake_confirmed());
|
| -}
|
| -
|
| -TEST_F(QuicCryptoClientStreamTest, ConnectedAfterSHLO) {
|
| - CompleteCryptoHandshake();
|
| - EXPECT_TRUE(stream_->encryption_established());
|
| - EXPECT_TRUE(stream_->handshake_confirmed());
|
| -}
|
| -
|
| -TEST_F(QuicCryptoClientStreamTest, MessageAfterHandshake) {
|
| - CompleteCryptoHandshake();
|
| -
|
| - EXPECT_CALL(*connection_, SendConnectionClose(
|
| - QUIC_CRYPTO_MESSAGE_AFTER_HANDSHAKE_COMPLETE));
|
| - message_.set_tag(kCHLO);
|
| - ConstructHandshakeMessage();
|
| - stream_->ProcessRawData(message_data_->data(), message_data_->length());
|
| -}
|
| -
|
| -TEST_F(QuicCryptoClientStreamTest, BadMessageType) {
|
| - stream_->CryptoConnect();
|
| -
|
| - message_.set_tag(kCHLO);
|
| - ConstructHandshakeMessage();
|
| -
|
| - EXPECT_CALL(*connection_, SendConnectionCloseWithDetails(
|
| - QUIC_INVALID_CRYPTO_MESSAGE_TYPE, "Expected REJ"));
|
| - stream_->ProcessRawData(message_data_->data(), message_data_->length());
|
| -}
|
| -
|
| -TEST_F(QuicCryptoClientStreamTest, NegotiatedParameters) {
|
| - CompleteCryptoHandshake();
|
| -
|
| - const QuicConfig* config = session_->config();
|
| - EXPECT_EQ(kMaximumIdleTimeoutSecs,
|
| - config->IdleConnectionStateLifetime().ToSeconds());
|
| - EXPECT_EQ(kDefaultMaxStreamsPerConnection,
|
| - config->MaxStreamsPerConnection());
|
| -
|
| - const QuicCryptoNegotiatedParameters& crypto_params(
|
| - stream_->crypto_negotiated_params());
|
| - EXPECT_EQ(crypto_config_.aead[0], crypto_params.aead);
|
| - EXPECT_EQ(crypto_config_.kexs[0], crypto_params.key_exchange);
|
| -}
|
| -
|
| -TEST_F(QuicCryptoClientStreamTest, InvalidHostname) {
|
| - QuicServerId server_id("invalid", 80, false, PRIVACY_MODE_DISABLED);
|
| - stream_.reset(new QuicCryptoClientStream(server_id, session_.get(), nullptr,
|
| - &crypto_config_));
|
| - session_->SetCryptoStream(stream_.get());
|
| -
|
| - CompleteCryptoHandshake();
|
| - EXPECT_TRUE(stream_->encryption_established());
|
| - EXPECT_TRUE(stream_->handshake_confirmed());
|
| -}
|
| -
|
| -TEST_F(QuicCryptoClientStreamTest, ExpiredServerConfig) {
|
| - // Seed the config with a cached server config.
|
| - CompleteCryptoHandshake();
|
| -
|
| - connection_ = new PacketSavingConnection(/*is_server=*/false);
|
| - session_.reset(new TestClientSession(connection_, DefaultQuicConfig()));
|
| - stream_.reset(new QuicCryptoClientStream(server_id_, session_.get(), nullptr,
|
| - &crypto_config_));
|
| -
|
| - session_->SetCryptoStream(stream_.get());
|
| -
|
| - // Advance time 5 years to ensure that we pass the expiry time of the cached
|
| - // server config.
|
| - connection_->AdvanceTime(
|
| - QuicTime::Delta::FromSeconds(60 * 60 * 24 * 365 * 5));
|
| -
|
| - stream_->CryptoConnect();
|
| - // Check that a client hello was sent.
|
| - ASSERT_EQ(1u, connection_->encrypted_packets_.size());
|
| -}
|
| -
|
| -TEST_F(QuicCryptoClientStreamTest, ServerConfigUpdate) {
|
| - // Test that the crypto client stream can receive server config updates after
|
| - // the connection has been established.
|
| - CompleteCryptoHandshake();
|
| -
|
| - QuicCryptoClientConfig::CachedState* state =
|
| - crypto_config_.LookupOrCreate(server_id_);
|
| -
|
| - // Ensure cached STK is different to what we send in the handshake.
|
| - EXPECT_NE("xstk", state->source_address_token());
|
| -
|
| - // Initialize using {...} syntax to avoid trailing \0 if converting from
|
| - // string.
|
| - unsigned char stk[] = { 'x', 's', 't', 'k' };
|
| -
|
| - // Minimum SCFG that passes config validation checks.
|
| - unsigned 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'
|
| - };
|
| -
|
| - CryptoHandshakeMessage server_config_update;
|
| - server_config_update.set_tag(kSCUP);
|
| - server_config_update.SetValue(kSourceAddressTokenTag, stk);
|
| - server_config_update.SetValue(kSCFG, scfg);
|
| -
|
| - scoped_ptr<QuicData> data(
|
| - CryptoFramer::ConstructHandshakeMessage(server_config_update));
|
| - stream_->ProcessRawData(data->data(), data->length());
|
| -
|
| - // Make sure that the STK and SCFG are cached correctly.
|
| - EXPECT_EQ("xstk", state->source_address_token());
|
| -
|
| - string cached_scfg = state->server_config();
|
| - test::CompareCharArraysWithHexError(
|
| - "scfg", cached_scfg.data(), cached_scfg.length(),
|
| - QuicUtils::AsChars(scfg), arraysize(scfg));
|
| -}
|
| -
|
| -TEST_F(QuicCryptoClientStreamTest, ServerConfigUpdateBeforeHandshake) {
|
| - EXPECT_CALL(*connection_, SendConnectionClose(
|
| - QUIC_CRYPTO_UPDATE_BEFORE_HANDSHAKE_COMPLETE));
|
| - CryptoHandshakeMessage server_config_update;
|
| - server_config_update.set_tag(kSCUP);
|
| - scoped_ptr<QuicData> data(
|
| - CryptoFramer::ConstructHandshakeMessage(server_config_update));
|
| - stream_->ProcessRawData(data->data(), data->length());
|
| -}
|
| -
|
| -} // namespace
|
| -} // namespace test
|
| -} // namespace net
|
|
|