Chromium Code Reviews| Index: blimp/engine/renderer/scheduler.h |
| diff --git a/blimp/engine/renderer/scheduler.h b/blimp/engine/renderer/scheduler.h |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..b437b577d07c9f46dda6b4719a095266e2b9576b |
| --- /dev/null |
| +++ b/blimp/engine/renderer/scheduler.h |
| @@ -0,0 +1,86 @@ |
| +// Copyright 2016 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 BLIMP_ENGINE_RENDERER_SCHEDULER_H_ |
| +#define BLIMP_ENGINE_RENDERER_SCHEDULER_H_ |
| + |
| +#include "base/macros.h" |
| +#include "base/memory/weak_ptr.h" |
| +#include "base/timer/timer.h" |
| + |
| +namespace blimp { |
| +namespace engine { |
| + |
| +class SchedulerClient { |
| + public: |
| + virtual ~SchedulerClient() {} |
| + |
| + // Used to notify the SchedulerClient to synchronously start the requested |
| + // frame. |
|
Wez
2016/10/19 22:01:34
Sorry, meant to comment last time; it's not clear
Khushal
2016/10/20 01:29:33
I wanted to write synchronously because the assump
|
| + virtual void StartFrameUpdate() = 0; |
| +}; |
| + |
| +// Responsible for scheduling frame updates sent to the client. |
| +// The Scheduler uses the state of frames sent to the client and the |
| +// acknowledgements for these frames from the client to make decisions regarding |
| +// when a frame should be produced on the engine. |
| +// The user provides the SchedulerClient to be notified of when a frame update |
|
Wez
2016/10/19 22:01:34
nit: s/user/caller s/the/a
Khushal
2016/10/20 01:29:33
Done.
Khushal
2016/10/20 01:29:33
Done.
|
| +// should be produced. The SchedulerClient must outlive this class. |
| +class Scheduler { |
|
Wez
2016/10/19 22:01:34
nit: Scheduler seems awfully generic for something
Khushal
2016/10/20 01:29:33
I renamed it to FrameScheduler. I think FrameSched
|
| + public: |
| + Scheduler(scoped_refptr<base::SingleThreadTaskRunner> task_runner, |
| + SchedulerClient* client); |
| + virtual ~Scheduler(); |
| + |
| + // Called when the |client| wants to start a frame update on the engine. |
| + void SetNeedsFrameUpdate(); |
| + |
| + // Called when a frame update is sent to the client. |
| + void DidSendFrameUpdateToClient(); |
| + |
| + // Called when an Ack is received for a frame sent to the client. |
| + void DidReceiveFrameUpdateAck(); |
| + |
| + base::TimeTicks next_frame_time() const { return next_frame_time_; } |
| + |
| + protected: |
| + // protected for testing. |
| + Scheduler(base::TimeDelta frame_delay, |
| + scoped_refptr<base::SingleThreadTaskRunner> task_runner, |
| + SchedulerClient* client); |
| + |
| + private: |
| + void ScheduleMainFrameIfNecessary(); |
| + |
| + // Returns true if a main frame update can be started. The Scheduler can not |
| + // produce new frames either if there is no request for main frames pending |
| + // or we are waiting for an ack for a frame previously sent to the client. |
| + bool CanProduceMainFrames() const; |
| + |
| + void StartMainFrame(); |
| + |
| + // Set to true if the |client_| has requested us to schedule frames. |
| + bool needs_frame_update_ = false; |
| + |
| + // Set to true if a frame update was sent to the client and the ack is |
| + // pending. |
| + bool frame_ack_pending_ = false; |
| + |
| + // The time at which the next main frame update can be run. |
| + base::TimeTicks next_frame_time_; |
| + |
| + // The delay to use between consecutive frames. |
| + base::TimeDelta frame_delay_; |
| + |
| + base::OneShotTimer frame_tick_timer_; |
| + |
| + SchedulerClient* client_; |
| + |
| + DISALLOW_COPY_AND_ASSIGN(Scheduler); |
| +}; |
| + |
| +} // namespace engine |
| +} // namespace blimp |
| + |
| +#endif // BLIMP_ENGINE_RENDERER_SCHEDULER_H_ |