OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_ENQUEUE_ORDER_H_ | 5 #ifndef THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_ENQUEUE_ORDER_H_ |
6 #define THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_ENQUEUE_ORDER_H_ | 6 #define THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_ENQUEUE_ORDER_H_ |
7 | 7 |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 | 9 |
10 #include "base/synchronization/lock.h" | 10 #include "base/synchronization/lock.h" |
| 11 #include "public/platform/WebCommon.h" |
11 | 12 |
12 namespace blink { | 13 namespace blink { |
13 namespace scheduler { | 14 namespace scheduler { |
14 namespace internal { | 15 namespace internal { |
15 | 16 |
16 using EnqueueOrder = uint64_t; | 17 using SequenceNumber = uint64_t; |
17 | 18 |
18 // TODO(scheduler-dev): Remove explicit casts when c++17 comes. | 19 // The enqueue order is used to uniquely order tasks. The primary ordering key |
19 enum class EnqueueOrderValues : EnqueueOrder { | 20 // is the desired run time of a task, followed by the sequence number. Note the |
20 // Invalid EnqueueOrder. | 21 // scheduler assumes sequence numbers will not overflow. |
| 22 struct BLINK_PLATFORM_EXPORT EnqueueOrder { |
| 23 base::TimeTicks delayed_run_time; |
| 24 SequenceNumber sequence_num; |
| 25 |
| 26 EnqueueOrder(); |
| 27 EnqueueOrder(base::TimeTicks delayed_run_time, SequenceNumber sequence_num); |
| 28 |
| 29 bool is_null() const { return delayed_run_time.is_null() && !sequence_num; } |
| 30 |
| 31 bool operator==(const EnqueueOrder& other) const; |
| 32 bool operator<=(const EnqueueOrder& other) const; |
| 33 bool operator<(const EnqueueOrder& other) const; |
| 34 }; |
| 35 |
| 36 std::ostream& operator<<(std::ostream&, const EnqueueOrder&); |
| 37 |
| 38 enum class EnqueueOrderSequenceNumberValues { |
| 39 // Invalid sequence number. |
21 NONE = 0, | 40 NONE = 0, |
22 | 41 |
23 // Earliest possible EnqueueOrder, to be used for fence blocking. | 42 // Earliest possible sequence number, to be used for fence blocking. |
24 BLOCKING_FENCE = 1, | 43 BLOCKING_FENCE = 1, |
25 FIRST = 2, | 44 FIRST = 2, |
26 }; | 45 }; |
27 | 46 |
28 // A 64bit integer used to provide ordering of tasks. NOTE The scheduler assumes | |
29 // these values will not overflow. | |
30 class EnqueueOrderGenerator { | 47 class EnqueueOrderGenerator { |
31 public: | 48 public: |
32 EnqueueOrderGenerator(); | 49 EnqueueOrderGenerator(); |
33 ~EnqueueOrderGenerator(); | 50 ~EnqueueOrderGenerator(); |
34 | 51 |
35 // Returns a monotonically increasing integer, starting from one. Can be | 52 // Returns a monotonically increasing enqueue order, starting from one. Can be |
36 // called from any thread. | 53 // called from any thread. |
37 EnqueueOrder GenerateNext(); | 54 EnqueueOrder GenerateNext(base::TimeTicks delayed_run_time); |
38 | |
39 static bool IsValidEnqueueOrder(EnqueueOrder enqueue_order) { | |
40 return enqueue_order != 0ull; | |
41 } | |
42 | 55 |
43 private: | 56 private: |
44 base::Lock lock_; | 57 base::Lock lock_; |
45 EnqueueOrder enqueue_order_; | 58 SequenceNumber sequence_num_; |
46 }; | 59 }; |
47 | 60 |
48 } // namespace internal | 61 } // namespace internal |
49 } // namespace scheduler | 62 } // namespace scheduler |
50 } // namespace blink | 63 } // namespace blink |
51 | 64 |
52 #endif // THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_ENQUEUE_ORDER_H_ | 65 #endif // THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_BASE_ENQUEUE_ORDER_H_ |
OLD | NEW |