Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(880)

Unified Diff: third_party/WebKit/Source/platform/scheduler/base/queueing_time_estimator.h

Issue 2273703002: Force events to be non blocking if main thread is unresponsive. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Address nits. Created 4 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: third_party/WebKit/Source/platform/scheduler/base/queueing_time_estimator.h
diff --git a/third_party/WebKit/Source/platform/scheduler/base/queueing_time_estimator.h b/third_party/WebKit/Source/platform/scheduler/base/queueing_time_estimator.h
index b94f121ae0d1775eeef0d35277f3c6d4ba22a848..f10f23199d4b15974e56950205761444a82461e8 100644
--- a/third_party/WebKit/Source/platform/scheduler/base/queueing_time_estimator.h
+++ b/third_party/WebKit/Source/platform/scheduler/base/queueing_time_estimator.h
@@ -27,20 +27,36 @@ class BLINK_PLATFORM_EXPORT QueueingTimeEstimator {
DISALLOW_COPY_AND_ASSIGN(Client);
};
+ class State {
+ public:
+ base::TimeDelta current_expected_queueing_time;
+ base::TimeDelta window_duration;
+ base::TimeTicks window_start_time;
+ base::TimeTicks current_task_start_time;
+ void OnTopLevelTaskStarted(base::TimeTicks task_start_time);
+ void OnTopLevelTaskCompleted(Client* client, base::TimeTicks task_end_time);
+
+ private:
+ bool TimePastWindowEnd(base::TimeTicks task_end_time);
+ };
+
QueueingTimeEstimator(Client* client, base::TimeDelta window_duration);
+ explicit QueueingTimeEstimator(const State& state);
+
+ void OnTopLevelTaskStarted(base::TimeTicks task_start_time);
+ void OnTopLevelTaskCompleted(base::TimeTicks task_end_time);
- void OnToplevelTaskCompleted(base::TimeTicks task_start_time,
- base::TimeTicks task_end_time);
+ // Returns all state except for the current |client_|.
+ const State& state() const { return state_; }
+
+ base::TimeDelta EstimateQueueingTimeIncludingCurrentTask(
+ base::TimeTicks now) const;
private:
- bool TimePastWindowEnd(base::TimeTicks task_end_time);
Client* client_; // NOT OWNED.
+ State state_;
- base::TimeDelta current_expected_queueing_time_;
- base::TimeDelta window_duration_;
- base::TimeTicks window_start_time_;
-
- DISALLOW_COPY_AND_ASSIGN(QueueingTimeEstimator);
+ DISALLOW_ASSIGN(QueueingTimeEstimator);
};
} // namespace scheduler

Powered by Google App Engine
This is Rietveld 408576698