simulated_time_controller.cc | Explore in Territory

/*
 *  Copyright 2019 The WebRTC project authors. All Rights Reserved.
 *
 *  Use of this source code is governed by a BSD-style license
 *  that can be found in the LICENSE file in the root of the source
 *  tree. An additional intellectual property rights grant can be found
 *  in the file PATENTS.  All contributing project authors may
 *  be found in the AUTHORS file in the root of the source tree.
 */
#include "test/time_controller/simulated_time_controller.h"

#include <algorithm>
#include <deque>
#include <list>
#include <memory>
#include <string>
#include <thread>
#include <vector>

#include "absl/strings/string_view.h"
#include "test/time_controller/simulated_task_queue.h"
#include "test/time_controller/simulated_thread.h"

namespace webrtc {
namespace {
// Helper function to remove from a std container by value.
template <class C>
bool RemoveByValue(C* vec, typename C::value_type val) { … }
}  // namespace

namespace sim_time_impl {

SimulatedTimeControllerImpl::SimulatedTimeControllerImpl(Timestamp start_time)
    : … { … }

SimulatedTimeControllerImpl::~SimulatedTimeControllerImpl() = default;

std::unique_ptr<TaskQueueBase, TaskQueueDeleter>
SimulatedTimeControllerImpl::CreateTaskQueue(
    absl::string_view name,
    TaskQueueFactory::Priority priority) const { … }

std::unique_ptr<rtc::Thread> SimulatedTimeControllerImpl::CreateThread(
    const std::string& name,
    std::unique_ptr<rtc::SocketServer> socket_server) { … }

void SimulatedTimeControllerImpl::YieldExecution() { … }

void SimulatedTimeControllerImpl::RunReadyRunners() { … }

Timestamp SimulatedTimeControllerImpl::CurrentTime() const { … }

Timestamp SimulatedTimeControllerImpl::NextRunTime() const { … }

void SimulatedTimeControllerImpl::AdvanceTime(Timestamp target_time) { … }

void SimulatedTimeControllerImpl::Register(SimulatedSequenceRunner* runner) { … }

void SimulatedTimeControllerImpl::Unregister(SimulatedSequenceRunner* runner) { … }

void SimulatedTimeControllerImpl::StartYield(TaskQueueBase* yielding_from) { … }

void SimulatedTimeControllerImpl::StopYield(TaskQueueBase* yielding_from) { … }

}  // namespace sim_time_impl

GlobalSimulatedTimeController::GlobalSimulatedTimeController(
    Timestamp start_time)
    : … { … }

GlobalSimulatedTimeController::~GlobalSimulatedTimeController() = default;

Clock* GlobalSimulatedTimeController::GetClock() { … }

TaskQueueFactory* GlobalSimulatedTimeController::GetTaskQueueFactory() { … }

std::unique_ptr<rtc::Thread> GlobalSimulatedTimeController::CreateThread(
    const std::string& name,
    std::unique_ptr<rtc::SocketServer> socket_server) { … }

rtc::Thread* GlobalSimulatedTimeController::GetMainThread() { … }

void GlobalSimulatedTimeController::AdvanceTime(TimeDelta duration) { … }

void GlobalSimulatedTimeController::SkipForwardBy(TimeDelta duration) { … }

void GlobalSimulatedTimeController::Register(
    sim_time_impl::SimulatedSequenceRunner* runner) { … }

void GlobalSimulatedTimeController::Unregister(
    sim_time_impl::SimulatedSequenceRunner* runner) { … }

}  // namespace webrtc
chromium/third_party/webrtc/test/time_controller/simulated_time_controller.cc
