Index: content/renderer/gpu/frame_swap_message_queue_unittest.cc |
diff --git a/content/renderer/gpu/frame_swap_message_queue_unittest.cc b/content/renderer/gpu/frame_swap_message_queue_unittest.cc |
deleted file mode 100644 |
index dc802c0e33c7748c278b6caf80d5969b2c3273e8..0000000000000000000000000000000000000000 |
--- a/content/renderer/gpu/frame_swap_message_queue_unittest.cc |
+++ /dev/null |
@@ -1,289 +0,0 @@ |
-// Copyright 2014 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. |
- |
-#include "content/renderer/gpu/frame_swap_message_queue.h" |
-#include "ipc/ipc_message.h" |
-#include "testing/gtest/include/gtest/gtest.h" |
- |
-namespace content { |
- |
-class FrameSwapMessageQueueTest : public testing::Test { |
- public: |
- FrameSwapMessageQueueTest() |
- : first_message_(41, 1, IPC::Message::PRIORITY_NORMAL), |
- second_message_(42, 2, IPC::Message::PRIORITY_NORMAL), |
- third_message_(43, 3, IPC::Message::PRIORITY_NORMAL), |
- queue_(new FrameSwapMessageQueue()) {} |
- |
- protected: |
- void QueueNextSwapMessage(scoped_ptr<IPC::Message> msg) { |
- queue_->QueueMessageForFrame( |
- MESSAGE_DELIVERY_POLICY_WITH_NEXT_SWAP, 0, msg.Pass(), NULL); |
- } |
- |
- void QueueNextSwapMessage(scoped_ptr<IPC::Message> msg, bool* first) { |
- queue_->QueueMessageForFrame( |
- MESSAGE_DELIVERY_POLICY_WITH_NEXT_SWAP, 0, msg.Pass(), first); |
- } |
- |
- void QueueVisualStateMessage(int source_frame_number, |
- scoped_ptr<IPC::Message> msg) { |
- queue_->QueueMessageForFrame(MESSAGE_DELIVERY_POLICY_WITH_VISUAL_STATE, |
- source_frame_number, |
- msg.Pass(), |
- NULL); |
- } |
- |
- void QueueVisualStateMessage(int source_frame_number, |
- scoped_ptr<IPC::Message> msg, |
- bool* first) { |
- queue_->QueueMessageForFrame(MESSAGE_DELIVERY_POLICY_WITH_VISUAL_STATE, |
- source_frame_number, |
- msg.Pass(), |
- first); |
- } |
- |
- void DrainMessages(int source_frame_number, |
- ScopedVector<IPC::Message>* messages) { |
- messages->clear(); |
- queue_->DidSwap(source_frame_number); |
- scoped_ptr<FrameSwapMessageQueue::SendMessageScope> send_message_scope = |
- queue_->AcquireSendMessageScope(); |
- queue_->DrainMessages(messages); |
- } |
- |
- bool HasMessageForId(const ScopedVector<IPC::Message>& messages, |
- int routing_id) { |
- for (ScopedVector<IPC::Message>::const_iterator i = messages.begin(); |
- i != messages.end(); |
- ++i) { |
- if ((*i)->routing_id() == routing_id) |
- return true; |
- } |
- return false; |
- } |
- |
- scoped_ptr<IPC::Message> CloneMessage(const IPC::Message& other) { |
- return make_scoped_ptr(new IPC::Message(other)).Pass(); |
- } |
- |
- void TestDidNotSwap(cc::SwapPromise::DidNotSwapReason reason); |
- |
- IPC::Message first_message_; |
- IPC::Message second_message_; |
- IPC::Message third_message_; |
- scoped_refptr<FrameSwapMessageQueue> queue_; |
-}; |
- |
-TEST_F(FrameSwapMessageQueueTest, TestEmptyQueueDrain) { |
- ScopedVector<IPC::Message> messages; |
- |
- DrainMessages(0, &messages); |
- ASSERT_TRUE(messages.empty()); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, TestEmpty) { |
- ScopedVector<IPC::Message> messages; |
- ASSERT_TRUE(queue_->Empty()); |
- QueueNextSwapMessage(CloneMessage(first_message_)); |
- ASSERT_FALSE(queue_->Empty()); |
- DrainMessages(0, &messages); |
- ASSERT_TRUE(queue_->Empty()); |
- QueueVisualStateMessage(1, CloneMessage(first_message_)); |
- ASSERT_FALSE(queue_->Empty()); |
- queue_->DidSwap(1); |
- ASSERT_FALSE(queue_->Empty()); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, TestQueueMessageFirst) { |
- ScopedVector<IPC::Message> messages; |
- bool visual_state_first = false; |
- bool next_swap_first = false; |
- |
- // Queuing the first time should result in true. |
- QueueVisualStateMessage(1, CloneMessage(first_message_), &visual_state_first); |
- ASSERT_TRUE(visual_state_first); |
- // Queuing the second time should result in true. |
- QueueVisualStateMessage( |
- 1, CloneMessage(second_message_), &visual_state_first); |
- ASSERT_FALSE(visual_state_first); |
- // Queuing for a different frame should result in true. |
- QueueVisualStateMessage(2, CloneMessage(first_message_), &visual_state_first); |
- ASSERT_TRUE(visual_state_first); |
- |
- // Queuing for a different policy should result in true. |
- QueueNextSwapMessage(CloneMessage(first_message_), &next_swap_first); |
- ASSERT_TRUE(next_swap_first); |
- // Second time for the same policy is still false. |
- QueueNextSwapMessage(CloneMessage(first_message_), &next_swap_first); |
- ASSERT_FALSE(next_swap_first); |
- |
- DrainMessages(4, &messages); |
- // Queuing after all messages are drained is a true again. |
- QueueVisualStateMessage(4, CloneMessage(first_message_), &visual_state_first); |
- ASSERT_TRUE(visual_state_first); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, TestNextSwapMessageSentWithNextFrame) { |
- ScopedVector<IPC::Message> messages; |
- |
- DrainMessages(1, &messages); |
- QueueNextSwapMessage(CloneMessage(first_message_)); |
- DrainMessages(2, &messages); |
- ASSERT_EQ(1u, messages.size()); |
- ASSERT_EQ(first_message_.routing_id(), messages.front()->routing_id()); |
- messages.clear(); |
- |
- DrainMessages(2, &messages); |
- ASSERT_TRUE(messages.empty()); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, TestNextSwapMessageSentWithCurrentFrame) { |
- ScopedVector<IPC::Message> messages; |
- |
- DrainMessages(1, &messages); |
- QueueNextSwapMessage(CloneMessage(first_message_)); |
- DrainMessages(1, &messages); |
- ASSERT_EQ(1u, messages.size()); |
- ASSERT_EQ(first_message_.routing_id(), messages.front()->routing_id()); |
- messages.clear(); |
- |
- DrainMessages(1, &messages); |
- ASSERT_TRUE(messages.empty()); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, |
- TestDrainsVisualStateMessagesForCorrespondingFrames) { |
- ScopedVector<IPC::Message> messages; |
- |
- QueueVisualStateMessage(1, CloneMessage(first_message_)); |
- QueueVisualStateMessage(2, CloneMessage(second_message_)); |
- QueueVisualStateMessage(3, CloneMessage(third_message_)); |
- DrainMessages(0, &messages); |
- ASSERT_TRUE(messages.empty()); |
- |
- DrainMessages(2, &messages); |
- ASSERT_EQ(2u, messages.size()); |
- ASSERT_TRUE(HasMessageForId(messages, first_message_.routing_id())); |
- ASSERT_TRUE(HasMessageForId(messages, second_message_.routing_id())); |
- messages.clear(); |
- |
- DrainMessages(2, &messages); |
- ASSERT_TRUE(messages.empty()); |
- |
- DrainMessages(5, &messages); |
- ASSERT_EQ(1u, messages.size()); |
- ASSERT_EQ(third_message_.routing_id(), messages.front()->routing_id()); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, |
- TestQueueNextSwapMessagePreservesFifoOrdering) { |
- ScopedVector<IPC::Message> messages; |
- |
- QueueNextSwapMessage(CloneMessage(first_message_)); |
- QueueNextSwapMessage(CloneMessage(second_message_)); |
- DrainMessages(1, &messages); |
- ASSERT_EQ(2u, messages.size()); |
- ASSERT_EQ(first_message_.routing_id(), messages[0]->routing_id()); |
- ASSERT_EQ(second_message_.routing_id(), messages[1]->routing_id()); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, |
- TestQueueVisualStateMessagePreservesFifoOrdering) { |
- ScopedVector<IPC::Message> messages; |
- |
- QueueVisualStateMessage(1, CloneMessage(first_message_)); |
- QueueVisualStateMessage(1, CloneMessage(second_message_)); |
- DrainMessages(1, &messages); |
- ASSERT_EQ(2u, messages.size()); |
- ASSERT_EQ(first_message_.routing_id(), messages[0]->routing_id()); |
- ASSERT_EQ(second_message_.routing_id(), messages[1]->routing_id()); |
-} |
- |
-void FrameSwapMessageQueueTest::TestDidNotSwap( |
- cc::SwapPromise::DidNotSwapReason reason) { |
- ScopedVector<IPC::Message> messages; |
- |
- QueueNextSwapMessage(CloneMessage(first_message_)); |
- QueueVisualStateMessage(2, CloneMessage(second_message_)); |
- QueueVisualStateMessage(3, CloneMessage(third_message_)); |
- |
- queue_->DidNotSwap(2, cc::SwapPromise::COMMIT_NO_UPDATE, &messages); |
- ASSERT_EQ(2u, messages.size()); |
- ASSERT_TRUE(HasMessageForId(messages, first_message_.routing_id())); |
- ASSERT_TRUE(HasMessageForId(messages, second_message_.routing_id())); |
- messages.clear(); |
- |
- queue_->DidNotSwap(3, cc::SwapPromise::COMMIT_NO_UPDATE, &messages); |
- ASSERT_EQ(1u, messages.size()); |
- ASSERT_TRUE(HasMessageForId(messages, third_message_.routing_id())); |
- messages.clear(); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, TestDidNotSwapNoUpdate) { |
- TestDidNotSwap(cc::SwapPromise::COMMIT_NO_UPDATE); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, TestDidNotSwapSwapFails) { |
- TestDidNotSwap(cc::SwapPromise::SWAP_FAILS); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, TestDidNotSwapCommitFails) { |
- ScopedVector<IPC::Message> messages; |
- |
- QueueNextSwapMessage(CloneMessage(first_message_)); |
- QueueVisualStateMessage(2, CloneMessage(second_message_)); |
- QueueVisualStateMessage(3, CloneMessage(third_message_)); |
- |
- queue_->DidNotSwap(2, cc::SwapPromise::COMMIT_FAILS, &messages); |
- ASSERT_EQ(0u, messages.size()); |
- messages.clear(); |
- |
- queue_->DidNotSwap(3, cc::SwapPromise::COMMIT_FAILS, &messages); |
- ASSERT_EQ(0u, messages.size()); |
- messages.clear(); |
- |
- DrainMessages(1, &messages); |
- ASSERT_EQ(1u, messages.size()); |
- ASSERT_TRUE(HasMessageForId(messages, first_message_.routing_id())); |
-} |
- |
-class NotifiesDeletionMessage : public IPC::Message { |
- public: |
- NotifiesDeletionMessage(bool* deleted, const IPC::Message& other) |
- : IPC::Message(other), deleted_(deleted) {} |
- ~NotifiesDeletionMessage() override { *deleted_ = true; } |
- |
- private: |
- bool* deleted_; |
-}; |
- |
-TEST_F(FrameSwapMessageQueueTest, TestDeletesNextSwapMessage) { |
- bool message_deleted = false; |
- QueueNextSwapMessage(make_scoped_ptr( |
- new NotifiesDeletionMessage(&message_deleted, first_message_))); |
- queue_ = NULL; |
- ASSERT_TRUE(message_deleted); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, TestDeletesVisualStateMessage) { |
- bool message_deleted = false; |
- QueueVisualStateMessage(1, |
- make_scoped_ptr(new NotifiesDeletionMessage( |
- &message_deleted, first_message_))); |
- queue_ = NULL; |
- ASSERT_TRUE(message_deleted); |
-} |
- |
-TEST_F(FrameSwapMessageQueueTest, TestDeletesQueuedVisualStateMessage) { |
- bool message_deleted = false; |
- QueueVisualStateMessage(1, |
- make_scoped_ptr(new NotifiesDeletionMessage( |
- &message_deleted, first_message_))); |
- queue_->DidSwap(1); |
- queue_ = NULL; |
- ASSERT_TRUE(message_deleted); |
-} |
- |
-} // namespace content |