| Index: blimp/net/blimp_message_multiplexer_unittest.cc
|
| diff --git a/blimp/net/blimp_message_multiplexer_unittest.cc b/blimp/net/blimp_message_multiplexer_unittest.cc
|
| deleted file mode 100644
|
| index 9dd600fddcab5f37e00db75be5a4e4fb13dd7eaa..0000000000000000000000000000000000000000
|
| --- a/blimp/net/blimp_message_multiplexer_unittest.cc
|
| +++ /dev/null
|
| @@ -1,114 +0,0 @@
|
| -// Copyright 2015 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 "blimp/common/proto/blimp_message.pb.h"
|
| -#include "blimp/common/proto/input.pb.h"
|
| -#include "blimp/common/proto/navigation.pb.h"
|
| -#include "blimp/net/blimp_message_multiplexer.h"
|
| -#include "blimp/net/test_common.h"
|
| -#include "net/base/net_errors.h"
|
| -#include "net/base/test_completion_callback.h"
|
| -#include "testing/gmock/include/gmock/gmock.h"
|
| -#include "testing/gtest/include/gtest/gtest.h"
|
| -
|
| -using testing::_;
|
| -using testing::DoAll;
|
| -using testing::Ref;
|
| -using testing::SaveArg;
|
| -
|
| -namespace blimp {
|
| -namespace {
|
| -
|
| -class BlimpMessageMultiplexerTest : public testing::Test {
|
| - public:
|
| - BlimpMessageMultiplexerTest()
|
| - : multiplexer_(&mock_output_processor_),
|
| - input_message_(new BlimpMessage),
|
| - navigation_message_(new BlimpMessage),
|
| - input_processor_(multiplexer_.CreateSender(BlimpMessage::kInput)),
|
| - navigation_processor_(
|
| - multiplexer_.CreateSender(BlimpMessage::kNavigation)) {}
|
| -
|
| - void SetUp() override {
|
| - EXPECT_CALL(mock_output_processor_, MockableProcessMessage(_, _))
|
| - .WillRepeatedly(
|
| - DoAll(SaveArg<0>(&captured_message_), SaveArg<1>(&captured_cb_)));
|
| -
|
| - input_message_->mutable_input()->set_type(
|
| - InputMessage::Type_GestureScrollBegin);
|
| - navigation_message_->mutable_navigation()->set_type(
|
| - NavigationMessage::LOAD_URL);
|
| - }
|
| -
|
| - protected:
|
| - MockBlimpMessageProcessor mock_output_processor_;
|
| - BlimpMessageMultiplexer multiplexer_;
|
| - std::unique_ptr<BlimpMessage> input_message_;
|
| - std::unique_ptr<BlimpMessage> navigation_message_;
|
| - BlimpMessage captured_message_;
|
| - net::CompletionCallback captured_cb_;
|
| - std::unique_ptr<BlimpMessageProcessor> input_processor_;
|
| - std::unique_ptr<BlimpMessageProcessor> navigation_processor_;
|
| -};
|
| -
|
| -// Verify that each sender propagates its types and copies the message payload
|
| -// correctly.
|
| -TEST_F(BlimpMessageMultiplexerTest, TypeSetByMux) {
|
| - net::TestCompletionCallback cb_1;
|
| - input_processor_->ProcessMessage(std::move(input_message_), cb_1.callback());
|
| - EXPECT_EQ(BlimpMessage::kInput, captured_message_.feature_case());
|
| - EXPECT_EQ(InputMessage::Type_GestureScrollBegin,
|
| - captured_message_.input().type());
|
| - captured_cb_.Run(net::OK);
|
| - EXPECT_EQ(net::OK, cb_1.WaitForResult());
|
| -
|
| - net::TestCompletionCallback cb_2;
|
| - navigation_processor_->ProcessMessage(std::move(navigation_message_),
|
| - cb_2.callback());
|
| - EXPECT_EQ(BlimpMessage::kNavigation, captured_message_.feature_case());
|
| - EXPECT_EQ(NavigationMessage::LOAD_URL, captured_message_.navigation().type());
|
| - captured_cb_.Run(net::ERR_FAILED);
|
| - EXPECT_EQ(net::ERR_FAILED, cb_2.WaitForResult());
|
| -}
|
| -
|
| -// Verify that the multiplexer allows the caller to supply a message type.
|
| -TEST_F(BlimpMessageMultiplexerTest, TypeSetByCaller) {
|
| - input_message_->mutable_input();
|
| -
|
| - net::TestCompletionCallback cb_1;
|
| - input_processor_->ProcessMessage(std::move(input_message_), cb_1.callback());
|
| - EXPECT_EQ(BlimpMessage::kInput, captured_message_.feature_case());
|
| - EXPECT_EQ(InputMessage::Type_GestureScrollBegin,
|
| - captured_message_.input().type());
|
| - captured_cb_.Run(net::OK);
|
| - EXPECT_EQ(net::OK, cb_1.WaitForResult());
|
| -}
|
| -
|
| -// Verify that senders for a given type can be torn down and recreated.
|
| -TEST_F(BlimpMessageMultiplexerTest, SenderTransience) {
|
| - net::TestCompletionCallback cb_3;
|
| - input_processor_ = multiplexer_.CreateSender(BlimpMessage::kInput);
|
| - input_processor_->ProcessMessage(std::move(input_message_), cb_3.callback());
|
| - EXPECT_EQ(BlimpMessage::kInput, captured_message_.feature_case());
|
| - EXPECT_EQ(InputMessage::Type_GestureScrollBegin,
|
| - captured_message_.input().type());
|
| - captured_cb_.Run(net::OK);
|
| - EXPECT_EQ(net::OK, cb_3.WaitForResult());
|
| -}
|
| -
|
| -// Verify that there is no limit on the number of senders for a given type.
|
| -TEST_F(BlimpMessageMultiplexerTest, SenderMultiplicity) {
|
| - net::TestCompletionCallback cb_4;
|
| - std::unique_ptr<BlimpMessageProcessor> input_processor_2 =
|
| - multiplexer_.CreateSender(BlimpMessage::kInput);
|
| - input_processor_2->ProcessMessage(std::move(input_message_), cb_4.callback());
|
| - EXPECT_EQ(BlimpMessage::kInput, captured_message_.feature_case());
|
| - EXPECT_EQ(InputMessage::Type_GestureScrollBegin,
|
| - captured_message_.input().type());
|
| - captured_cb_.Run(net::ERR_INVALID_ARGUMENT);
|
| - EXPECT_EQ(net::ERR_INVALID_ARGUMENT, cb_4.WaitForResult());
|
| -}
|
| -
|
| -} // namespace
|
| -} // namespace blimp
|
|
|