chromium/net/third_party/quiche/src/quiche/quic/test_tools/server_thread.cc

// Copyright 2013 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 "quiche/quic/test_tools/server_thread.h"

#include <memory>
#include <utility>

#include "quiche/quic/core/quic_default_clock.h"
#include "quiche/quic/core/quic_dispatcher.h"
#include "quiche/quic/test_tools/crypto_test_utils.h"
#include "quiche/quic/test_tools/quic_dispatcher_peer.h"
#include "quiche/quic/test_tools/quic_server_peer.h"
#include "quiche/common/platform/api/quiche_mutex.h"
#include "quiche/common/quiche_callbacks.h"

namespace quic {
namespace test {

ServerThread::ServerThread(std::unique_ptr<QuicServer> server,
                           const QuicSocketAddress& address)
    : … { … }

ServerThread::~ServerThread() = default;

void ServerThread::Initialize() { … }

void ServerThread::Run() { … }

int ServerThread::GetPort() { … }

void ServerThread::Schedule(quiche::SingleUseCallback<void()> action) { … }

void ServerThread::ScheduleAndWaitForCompletion(
    quiche::SingleUseCallback<void()> action) { … }

void ServerThread::WaitForCryptoHandshakeConfirmed() { … }

bool ServerThread::WaitUntil(
    quiche::UnretainedCallback<bool()> termination_predicate,
    QuicTime::Delta timeout) { … }

void ServerThread::Pause() { … }

void ServerThread::Resume() { … }

void ServerThread::Quit() { … }

void ServerThread::MaybeNotifyOfHandshakeConfirmation() { … }

void ServerThread::ExecuteScheduledActions() { … }

}  // namespace test
}  // namespace quic