Index: remoting/host/setup/native_messaging_reader_unittest.cc |
diff --git a/remoting/host/setup/native_messaging_reader_unittest.cc b/remoting/host/setup/native_messaging_reader_unittest.cc |
deleted file mode 100644 |
index c78b4c2bd24e4f241ee45299ce0bc9f250a70c6f..0000000000000000000000000000000000000000 |
--- a/remoting/host/setup/native_messaging_reader_unittest.cc |
+++ /dev/null |
@@ -1,163 +0,0 @@ |
-// Copyright 2013 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 "remoting/host/setup/native_messaging_reader.h" |
- |
-#include "base/basictypes.h" |
-#include "base/bind.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "base/message_loop/message_loop.h" |
-#include "base/platform_file.h" |
-#include "base/run_loop.h" |
-#include "base/values.h" |
-#include "remoting/host/setup/test_util.h" |
-#include "testing/gtest/include/gtest/gtest.h" |
- |
-namespace remoting { |
- |
-class NativeMessagingReaderTest : public testing::Test { |
- public: |
- NativeMessagingReaderTest(); |
- virtual ~NativeMessagingReaderTest(); |
- |
- virtual void SetUp() OVERRIDE; |
- virtual void TearDown() OVERRIDE; |
- |
- // Starts the reader and runs the MessageLoop to completion. |
- void Run(); |
- |
- // MessageCallback passed to the Reader. Stores |message| so it can be |
- // verified by tests. |
- void OnMessage(scoped_ptr<base::Value> message); |
- |
- // Writes a message (header+body) to the write-end of the pipe. |
- void WriteMessage(std::string message); |
- |
- // Writes some data to the write-end of the pipe. |
- void WriteData(const char* data, int length); |
- |
- protected: |
- scoped_ptr<NativeMessagingReader> reader_; |
- base::PlatformFile read_handle_; |
- base::PlatformFile write_handle_; |
- scoped_ptr<base::Value> message_; |
- |
- private: |
- // MessageLoop declared here, since the NativeMessageReader ctor requires a |
- // MessageLoop to have been created. |
- base::MessageLoop message_loop_; |
- base::RunLoop run_loop_; |
-}; |
- |
-NativeMessagingReaderTest::NativeMessagingReaderTest() |
- : message_loop_(base::MessageLoop::TYPE_IO) { |
-} |
- |
-NativeMessagingReaderTest::~NativeMessagingReaderTest() {} |
- |
-void NativeMessagingReaderTest::SetUp() { |
- ASSERT_TRUE(MakePipe(&read_handle_, &write_handle_)); |
- reader_.reset(new NativeMessagingReader(read_handle_)); |
-} |
- |
-void NativeMessagingReaderTest::TearDown() { |
- // |read_handle_| is owned by NativeMessagingReader's FileStream, so don't |
- // try to close it here. Also, |write_handle_| gets closed by Run(). |
-} |
- |
-void NativeMessagingReaderTest::Run() { |
- // Close the write-end, so the reader doesn't block waiting for more data. |
- base::ClosePlatformFile(write_handle_); |
- |
- // base::Unretained is safe since no further tasks can run after |
- // RunLoop::Run() returns. |
- reader_->Start( |
- base::Bind(&NativeMessagingReaderTest::OnMessage, base::Unretained(this)), |
- run_loop_.QuitClosure()); |
- run_loop_.Run(); |
-} |
- |
-void NativeMessagingReaderTest::OnMessage(scoped_ptr<base::Value> message) { |
- message_ = message.Pass(); |
-} |
- |
-void NativeMessagingReaderTest::WriteMessage(std::string message) { |
- uint32 length = message.length(); |
- WriteData(reinterpret_cast<char*>(&length), 4); |
- WriteData(message.data(), length); |
-} |
- |
-void NativeMessagingReaderTest::WriteData(const char* data, int length) { |
- int written = base::WritePlatformFileAtCurrentPos(write_handle_, data, |
- length); |
- ASSERT_EQ(length, written); |
-} |
- |
-TEST_F(NativeMessagingReaderTest, GoodMessage) { |
- WriteMessage("{\"foo\": 42}"); |
- Run(); |
- EXPECT_TRUE(message_); |
- base::DictionaryValue* message_dict; |
- EXPECT_TRUE(message_->GetAsDictionary(&message_dict)); |
- int result; |
- EXPECT_TRUE(message_dict->GetInteger("foo", &result)); |
- EXPECT_EQ(42, result); |
-} |
- |
-TEST_F(NativeMessagingReaderTest, InvalidLength) { |
- uint32 length = 0xffffffff; |
- WriteData(reinterpret_cast<char*>(&length), 4); |
- Run(); |
- EXPECT_FALSE(message_); |
-} |
- |
-TEST_F(NativeMessagingReaderTest, EmptyFile) { |
- Run(); |
- EXPECT_FALSE(message_); |
-} |
- |
-TEST_F(NativeMessagingReaderTest, ShortHeader) { |
- // Write only 3 bytes - the message length header is supposed to be 4 bytes. |
- WriteData("xxx", 3); |
- Run(); |
- EXPECT_FALSE(message_); |
-} |
- |
-TEST_F(NativeMessagingReaderTest, EmptyBody) { |
- uint32 length = 1; |
- WriteData(reinterpret_cast<char*>(&length), 4); |
- Run(); |
- EXPECT_FALSE(message_); |
-} |
- |
-TEST_F(NativeMessagingReaderTest, ShortBody) { |
- uint32 length = 2; |
- WriteData(reinterpret_cast<char*>(&length), 4); |
- |
- // Only write 1 byte, where the header indicates there should be 2 bytes. |
- WriteData("x", 1); |
- Run(); |
- EXPECT_FALSE(message_); |
-} |
- |
-TEST_F(NativeMessagingReaderTest, InvalidJSON) { |
- std::string text = "{"; |
- WriteMessage(text); |
- Run(); |
- EXPECT_FALSE(message_); |
-} |
- |
-TEST_F(NativeMessagingReaderTest, SecondMessage) { |
- WriteMessage("{}"); |
- WriteMessage("{\"foo\": 42}"); |
- Run(); |
- EXPECT_TRUE(message_); |
- base::DictionaryValue* message_dict; |
- EXPECT_TRUE(message_->GetAsDictionary(&message_dict)); |
- int result; |
- EXPECT_TRUE(message_dict->GetInteger("foo", &result)); |
- EXPECT_EQ(42, result); |
-} |
- |
-} // namespace remoting |