chromium/third_party/blink/renderer/platform/scheduler/test/fuzzer/thread_pool_manager.cc

#include "third_party/blink/renderer/platform/scheduler/test/fuzzer/thread_pool_manager.h"

#include <algorithm>

#include "base/functional/bind.h"
#include "third_party/blink/renderer/platform/scheduler/test/fuzzer/sequence_manager_fuzzer_processor.h"
#include "third_party/blink/renderer/platform/scheduler/test/fuzzer/simple_thread_impl.h"
#include "third_party/blink/renderer/platform/scheduler/test/fuzzer/thread_manager.h"

namespace base {
namespace sequence_manager {

ThreadPoolManager::ThreadPoolManager(SequenceManagerFuzzerProcessor* processor)
    : … { … }

ThreadPoolManager::~ThreadPoolManager() = default;

void ThreadPoolManager::CreateThread(
    const google::protobuf::RepeatedPtrField<
        SequenceManagerTestDescription::Action>& initial_thread_actions,
    base::TimeTicks time) { … }

void ThreadPoolManager::StartThread(
    const google::protobuf::RepeatedPtrField<
        SequenceManagerTestDescription::Action>& initial_thread_actions,
    ThreadManager* thread_manager) { … }

void ThreadPoolManager::AdvanceClockSynchronouslyByPendingTaskDelay(
    ThreadManager* thread_manager) { … }

void ThreadPoolManager::AdvanceClockSynchronouslyToTime(
    ThreadManager* thread_manager,
    base::TimeTicks time) { … }

void ThreadPoolManager::ThreadReadyToComputeTime() { … }

void ThreadPoolManager::AdvanceThreadClock(ThreadManager* thread_manager) { … }

void ThreadPoolManager::StartInitialThreads() { … }

void ThreadPoolManager::WaitForAllThreads() { … }

void ThreadPoolManager::ThreadDone() { … }

SequenceManagerFuzzerProcessor* ThreadPoolManager::processor() const { … }

ThreadManager* ThreadPoolManager::GetThreadManagerFor(uint64_t thread_id) { … }

Vector<ThreadManager*> ThreadPoolManager::GetAllThreadManagers() { … }

}  // namespace sequence_manager
}  // namespace base