| 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
|
|
|