OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 #include "content/renderer/gpu/queue_message_swap_promise.h" | 5 #include "content/renderer/gpu/queue_message_swap_promise.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 | 8 |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
11 #include "base/macros.h" | 11 #include "base/macros.h" |
| 12 #include "base/memory/ptr_util.h" |
12 #include "base/memory/scoped_vector.h" | 13 #include "base/memory/scoped_vector.h" |
13 #include "cc/output/swap_promise.h" | 14 #include "cc/output/swap_promise.h" |
14 #include "content/renderer/gpu/frame_swap_message_queue.h" | 15 #include "content/renderer/gpu/frame_swap_message_queue.h" |
15 #include "content/renderer/gpu/render_widget_compositor.h" | 16 #include "content/renderer/gpu/render_widget_compositor.h" |
16 #include "content/renderer/render_widget.h" | 17 #include "content/renderer/render_widget.h" |
17 #include "content/test/mock_render_process.h" | 18 #include "content/test/mock_render_process.h" |
18 #include "ipc/ipc_message.h" | 19 #include "ipc/ipc_message.h" |
19 #include "ipc/ipc_sync_message_filter.h" | 20 #include "ipc/ipc_sync_message_filter.h" |
20 #include "ipc/ipc_test_sink.h" | 21 #include "ipc/ipc_test_sink.h" |
21 #include "testing/gtest/include/gtest/gtest.h" | 22 #include "testing/gtest/include/gtest/gtest.h" |
22 | 23 |
23 namespace content { | 24 namespace content { |
24 | 25 |
25 class TestRenderWidget : public RenderWidget { | 26 class TestRenderWidget : public RenderWidget { |
26 public: | 27 public: |
27 using RenderWidget::QueueMessageImpl; | 28 using RenderWidget::QueueMessageImpl; |
28 | 29 |
29 private: | 30 private: |
30 ~TestRenderWidget() override {} | 31 ~TestRenderWidget() override {} |
31 | 32 |
32 DISALLOW_COPY_AND_ASSIGN(TestRenderWidget); | 33 DISALLOW_COPY_AND_ASSIGN(TestRenderWidget); |
33 }; | 34 }; |
34 | 35 |
35 class TestSyncMessageFilter : public IPC::SyncMessageFilter { | 36 class TestSyncMessageFilter : public IPC::SyncMessageFilter { |
36 public: | 37 public: |
37 TestSyncMessageFilter() : IPC::SyncMessageFilter(NULL, false) {} | 38 TestSyncMessageFilter() : IPC::SyncMessageFilter(NULL, false) {} |
38 | 39 |
39 bool Send(IPC::Message* message) override { | 40 bool Send(IPC::Message* message) override { |
40 messages_.push_back(make_scoped_ptr(message)); | 41 messages_.push_back(base::WrapUnique(message)); |
41 return true; | 42 return true; |
42 } | 43 } |
43 | 44 |
44 std::vector<scoped_ptr<IPC::Message>>& messages() { return messages_; } | 45 std::vector<std::unique_ptr<IPC::Message>>& messages() { return messages_; } |
45 | 46 |
46 private: | 47 private: |
47 ~TestSyncMessageFilter() override {} | 48 ~TestSyncMessageFilter() override {} |
48 | 49 |
49 std::vector<scoped_ptr<IPC::Message>> messages_; | 50 std::vector<std::unique_ptr<IPC::Message>> messages_; |
50 | 51 |
51 DISALLOW_COPY_AND_ASSIGN(TestSyncMessageFilter); | 52 DISALLOW_COPY_AND_ASSIGN(TestSyncMessageFilter); |
52 }; | 53 }; |
53 | 54 |
54 struct QueueMessageData { | 55 struct QueueMessageData { |
55 MessageDeliveryPolicy policy; | 56 MessageDeliveryPolicy policy; |
56 int source_frame_number; | 57 int source_frame_number; |
57 }; | 58 }; |
58 | 59 |
59 class QueueMessageSwapPromiseTest : public testing::Test { | 60 class QueueMessageSwapPromiseTest : public testing::Test { |
60 public: | 61 public: |
61 QueueMessageSwapPromiseTest() | 62 QueueMessageSwapPromiseTest() |
62 : frame_swap_message_queue_(new FrameSwapMessageQueue()), | 63 : frame_swap_message_queue_(new FrameSwapMessageQueue()), |
63 sync_message_filter_(new TestSyncMessageFilter()) {} | 64 sync_message_filter_(new TestSyncMessageFilter()) {} |
64 | 65 |
65 ~QueueMessageSwapPromiseTest() override {} | 66 ~QueueMessageSwapPromiseTest() override {} |
66 | 67 |
67 scoped_ptr<cc::SwapPromise> QueueMessageImpl(IPC::Message* msg, | 68 std::unique_ptr<cc::SwapPromise> QueueMessageImpl( |
68 MessageDeliveryPolicy policy, | 69 IPC::Message* msg, |
69 int source_frame_number) { | 70 MessageDeliveryPolicy policy, |
| 71 int source_frame_number) { |
70 return TestRenderWidget::QueueMessageImpl( | 72 return TestRenderWidget::QueueMessageImpl( |
71 msg, policy, frame_swap_message_queue_.get(), sync_message_filter_, | 73 msg, policy, frame_swap_message_queue_.get(), sync_message_filter_, |
72 source_frame_number); | 74 source_frame_number); |
73 } | 75 } |
74 | 76 |
75 const std::vector<scoped_ptr<IPC::Message>>& DirectSendMessages() { | 77 const std::vector<std::unique_ptr<IPC::Message>>& DirectSendMessages() { |
76 return sync_message_filter_->messages(); | 78 return sync_message_filter_->messages(); |
77 } | 79 } |
78 | 80 |
79 std::vector<scoped_ptr<IPC::Message>>& NextSwapMessages() { | 81 std::vector<std::unique_ptr<IPC::Message>>& NextSwapMessages() { |
80 next_swap_messages_.clear(); | 82 next_swap_messages_.clear(); |
81 scoped_ptr<FrameSwapMessageQueue::SendMessageScope> send_message_scope = | 83 std::unique_ptr<FrameSwapMessageQueue::SendMessageScope> |
82 frame_swap_message_queue_->AcquireSendMessageScope(); | 84 send_message_scope = |
| 85 frame_swap_message_queue_->AcquireSendMessageScope(); |
83 frame_swap_message_queue_->DrainMessages(&next_swap_messages_); | 86 frame_swap_message_queue_->DrainMessages(&next_swap_messages_); |
84 return next_swap_messages_; | 87 return next_swap_messages_; |
85 } | 88 } |
86 | 89 |
87 bool ContainsMessage(const std::vector<scoped_ptr<IPC::Message>>& messages, | 90 bool ContainsMessage( |
88 const IPC::Message& message) { | 91 const std::vector<std::unique_ptr<IPC::Message>>& messages, |
| 92 const IPC::Message& message) { |
89 if (messages.empty()) | 93 if (messages.empty()) |
90 return false; | 94 return false; |
91 for (const auto& msg : messages) { | 95 for (const auto& msg : messages) { |
92 if (msg->type() == message.type()) | 96 if (msg->type() == message.type()) |
93 return true; | 97 return true; |
94 } | 98 } |
95 return false; | 99 return false; |
96 } | 100 } |
97 | 101 |
98 bool NextSwapHasMessage(const IPC::Message& message) { | 102 bool NextSwapHasMessage(const IPC::Message& message) { |
(...skipping 26 matching lines...) Expand all Loading... |
125 void VisualStateSwapPromiseDidNotSwap( | 129 void VisualStateSwapPromiseDidNotSwap( |
126 cc::SwapPromise::DidNotSwapReason reason); | 130 cc::SwapPromise::DidNotSwapReason reason); |
127 | 131 |
128 base::MessageLoop message_loop_; | 132 base::MessageLoop message_loop_; |
129 scoped_refptr<FrameSwapMessageQueue> frame_swap_message_queue_; | 133 scoped_refptr<FrameSwapMessageQueue> frame_swap_message_queue_; |
130 scoped_refptr<TestSyncMessageFilter> sync_message_filter_; | 134 scoped_refptr<TestSyncMessageFilter> sync_message_filter_; |
131 std::vector<IPC::Message> messages_; | 135 std::vector<IPC::Message> messages_; |
132 ScopedVector<cc::SwapPromise> promises_; | 136 ScopedVector<cc::SwapPromise> promises_; |
133 | 137 |
134 private: | 138 private: |
135 std::vector<scoped_ptr<IPC::Message>> next_swap_messages_; | 139 std::vector<std::unique_ptr<IPC::Message>> next_swap_messages_; |
136 | 140 |
137 DISALLOW_COPY_AND_ASSIGN(QueueMessageSwapPromiseTest); | 141 DISALLOW_COPY_AND_ASSIGN(QueueMessageSwapPromiseTest); |
138 }; | 142 }; |
139 | 143 |
140 TEST_F(QueueMessageSwapPromiseTest, NextSwapPolicySchedulesMessageForNextSwap) { | 144 TEST_F(QueueMessageSwapPromiseTest, NextSwapPolicySchedulesMessageForNextSwap) { |
141 QueueMessageData data[] = { | 145 QueueMessageData data[] = { |
142 /* { policy, source_frame_number } */ | 146 /* { policy, source_frame_number } */ |
143 {MESSAGE_DELIVERY_POLICY_WITH_NEXT_SWAP, 1}, | 147 {MESSAGE_DELIVERY_POLICY_WITH_NEXT_SWAP, 1}, |
144 }; | 148 }; |
145 QueueMessages(data, arraysize(data)); | 149 QueueMessages(data, arraysize(data)); |
(...skipping 99 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
245 /* { policy, source_frame_number } */ | 249 /* { policy, source_frame_number } */ |
246 {MESSAGE_DELIVERY_POLICY_WITH_VISUAL_STATE, 1}, | 250 {MESSAGE_DELIVERY_POLICY_WITH_VISUAL_STATE, 1}, |
247 {MESSAGE_DELIVERY_POLICY_WITH_VISUAL_STATE, 1}, | 251 {MESSAGE_DELIVERY_POLICY_WITH_VISUAL_STATE, 1}, |
248 {MESSAGE_DELIVERY_POLICY_WITH_VISUAL_STATE, 2}, | 252 {MESSAGE_DELIVERY_POLICY_WITH_VISUAL_STATE, 2}, |
249 }; | 253 }; |
250 QueueMessages(data, arraysize(data)); | 254 QueueMessages(data, arraysize(data)); |
251 | 255 |
252 promises_[0]->DidActivate(); | 256 promises_[0]->DidActivate(); |
253 promises_[0]->DidSwap(NULL); | 257 promises_[0]->DidSwap(NULL); |
254 ASSERT_FALSE(promises_[1]); | 258 ASSERT_FALSE(promises_[1]); |
255 std::vector<scoped_ptr<IPC::Message>> messages; | 259 std::vector<std::unique_ptr<IPC::Message>> messages; |
256 messages.swap(NextSwapMessages()); | 260 messages.swap(NextSwapMessages()); |
257 EXPECT_EQ(2u, messages.size()); | 261 EXPECT_EQ(2u, messages.size()); |
258 EXPECT_TRUE(ContainsMessage(messages, messages_[0])); | 262 EXPECT_TRUE(ContainsMessage(messages, messages_[0])); |
259 EXPECT_TRUE(ContainsMessage(messages, messages_[1])); | 263 EXPECT_TRUE(ContainsMessage(messages, messages_[1])); |
260 EXPECT_FALSE(ContainsMessage(messages, messages_[2])); | 264 EXPECT_FALSE(ContainsMessage(messages, messages_[2])); |
261 | 265 |
262 promises_[2]->DidActivate(); | 266 promises_[2]->DidActivate(); |
263 promises_[2]->DidNotSwap(cc::SwapPromise::SWAP_FAILS); | 267 promises_[2]->DidNotSwap(cc::SwapPromise::SWAP_FAILS); |
264 messages.swap(NextSwapMessages()); | 268 messages.swap(NextSwapMessages()); |
265 EXPECT_EQ(1u, messages.size()); | 269 EXPECT_EQ(1u, messages.size()); |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
313 TEST_F(QueueMessageSwapPromiseTest, VisualStateSwapPromiseDidNotSwapSwapFails) { | 317 TEST_F(QueueMessageSwapPromiseTest, VisualStateSwapPromiseDidNotSwapSwapFails) { |
314 VisualStateSwapPromiseDidNotSwap(cc::SwapPromise::SWAP_FAILS); | 318 VisualStateSwapPromiseDidNotSwap(cc::SwapPromise::SWAP_FAILS); |
315 } | 319 } |
316 | 320 |
317 TEST_F(QueueMessageSwapPromiseTest, | 321 TEST_F(QueueMessageSwapPromiseTest, |
318 VisualStateSwapPromiseDidNotSwapActivationFails) { | 322 VisualStateSwapPromiseDidNotSwapActivationFails) { |
319 VisualStateSwapPromiseDidNotSwap(cc::SwapPromise::ACTIVATION_FAILS); | 323 VisualStateSwapPromiseDidNotSwap(cc::SwapPromise::ACTIVATION_FAILS); |
320 } | 324 } |
321 | 325 |
322 } // namespace content | 326 } // namespace content |
OLD | NEW |