OLD | NEW |
---|---|
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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 CONTENT_COMMON_INPUT_WEB_INPUT_EVENT_QUEUE_H_ | 5 #ifndef CONTENT_COMMON_INPUT_WEB_INPUT_EVENT_QUEUE_H_ |
mustaq
2017/03/24 15:31:18
Should we move this source file to content/rendere
dtapuska
2017/03/24 20:16:31
Hmm; ya I could clean this up.
| |
6 #define CONTENT_COMMON_INPUT_WEB_INPUT_EVENT_QUEUE_H_ | 6 #define CONTENT_COMMON_INPUT_WEB_INPUT_EVENT_QUEUE_H_ |
7 | 7 |
8 #include <deque> | 8 #include <deque> |
9 #include <memory> | 9 #include <memory> |
10 | 10 |
11 namespace content { | 11 namespace content { |
12 | 12 |
13 // WebInputEventQueue is a coalescing queue. It will examine | 13 // WebInputEventQueue is a coalescing queue. It will examine |
14 // the current events in the queue and will attempt to coalesce with | 14 // the current events in the queue and will attempt to coalesce with |
15 // the last event of the same class type. | 15 // the last event of the same class type. |
16 template <typename T> | 16 template <typename T> |
17 class WebInputEventQueue { | 17 class WebInputEventQueue { |
18 public: | 18 public: |
19 WebInputEventQueue() {} | 19 WebInputEventQueue() {} |
20 | 20 |
21 // Adds an event to the queue. The event may be coalesced with previously | 21 // Adds an event to the queue. The event may be coalesced with previously |
22 // queued events. | 22 // queued events. |
23 void Queue(std::unique_ptr<T> event) { | 23 void Queue(std::unique_ptr<T> event) { |
24 for (auto last_event_iter = queue_.rbegin(); | 24 for (auto last_event_iter = queue_.rbegin(); |
25 last_event_iter != queue_.rend(); ++last_event_iter) { | 25 last_event_iter != queue_.rend(); ++last_event_iter) { |
26 if (!(*last_event_iter)->event().isSameEventClass(event->event())) { | 26 if (!(*last_event_iter)->IsSameEventClass(*event.get())) { |
27 continue; | 27 continue; |
28 } | 28 } |
29 | 29 |
30 if ((*last_event_iter)->CanCoalesceWith(*event.get())) { | 30 if ((*last_event_iter)->CanCoalesceWith(*event.get())) { |
31 (*last_event_iter)->CoalesceWith(*event.get()); | 31 (*last_event_iter)->CoalesceWith(*event.get()); |
32 return; | 32 return; |
33 } | 33 } |
34 break; | 34 break; |
35 } | 35 } |
36 queue_.emplace_back(std::move(event)); | 36 queue_.emplace_back(std::move(event)); |
37 } | 37 } |
38 | 38 |
39 const std::unique_ptr<T>& front() const { return queue_.front(); } | 39 const std::unique_ptr<T>& front() const { return queue_.front(); } |
40 const std::unique_ptr<T>& at(size_t pos) const { return queue_.at(pos); } | 40 const std::unique_ptr<T>& at(size_t pos) const { return queue_.at(pos); } |
41 | 41 |
42 std::unique_ptr<T> Pop() { | 42 std::unique_ptr<T> Pop() { |
mustaq
2017/03/24 15:31:18
Nit: make it |pop()| to be consistent?
dtapuska
2017/03/24 20:16:31
Not done because I've made this no longer a templa
| |
43 std::unique_ptr<T> result; | 43 std::unique_ptr<T> result; |
44 if (!queue_.empty()) { | 44 if (!queue_.empty()) { |
45 result.reset(queue_.front().release()); | 45 result.reset(queue_.front().release()); |
46 queue_.pop_front(); | 46 queue_.pop_front(); |
47 } | 47 } |
48 return result; | 48 return result; |
49 } | 49 } |
50 | 50 |
51 void emplace_front(std::unique_ptr<T> event) { | |
52 queue_.emplace_front(std::move(event)); | |
53 } | |
54 void swap(std::deque<std::unique_ptr<T>>* queue) { queue_.swap(*queue); } | |
55 | |
51 bool empty() const { return queue_.empty(); } | 56 bool empty() const { return queue_.empty(); } |
52 | 57 |
53 size_t size() const { return queue_.size(); } | 58 size_t size() const { return queue_.size(); } |
54 | 59 |
55 private: | 60 private: |
56 typedef std::deque<std::unique_ptr<T>> EventQueue; | 61 typedef std::deque<std::unique_ptr<T>> EventQueue; |
57 EventQueue queue_; | 62 EventQueue queue_; |
58 | 63 |
59 DISALLOW_COPY_AND_ASSIGN(WebInputEventQueue); | 64 DISALLOW_COPY_AND_ASSIGN(WebInputEventQueue); |
60 }; | 65 }; |
61 | 66 |
62 } // namespace content | 67 } // namespace content |
63 | 68 |
64 #endif // CONTENT_COMMON_INPUT_WEB_INPUT_EVENT_QUEUE_H_ | 69 #endif // CONTENT_COMMON_INPUT_WEB_INPUT_EVENT_QUEUE_H_ |
OLD | NEW |