// Copyright 2018 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.

#ifndef PLATFORM_TEST_FAKE_CLOCK_H_
#define PLATFORM_TEST_FAKE_CLOCK_H_

#include <atomic>
#include <thread>
#include <vector>

#include "platform/api/time.h"

namespace openscreen {

class FakeTaskRunner;

class FakeClock {
 public:
  explicit FakeClock(Clock::time_point start_time);
  ~FakeClock();

  // Moves the clock forward, simulating execution by running tasks in all
  // FakeTaskRunners. The clock advances in one or more jumps, to ensure delayed
  // tasks see the correct "now time" when they are executed.
  void Advance(Clock::duration delta);

  static Clock::time_point now() noexcept;

 protected:
  friend class FakeTaskRunner;

  void SubscribeToTimeChanges(FakeTaskRunner* task_runner);
  void UnsubscribeFromTimeChanges(FakeTaskRunner* task_runner);

 private:
  // Used for ensuring this FakeClock's lifecycle and mutations occur on the
  // same thread.
  const std::thread::id control_thread_id_;

  std::vector<FakeTaskRunner*> task_runners_;

  // This variable is atomic because some tests (e.g., TaskRunnerImplTest) will
  // call now() on a different thread.
  static std::atomic<Clock::time_point> now_;
};

}  // namespace openscreen

#endif  // PLATFORM_TEST_FAKE_CLOCK_H_