| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 // TODO(vtl): The POSIX-specific bits have been factored out. Apply this test to | 5 // TODO(vtl): The POSIX-specific bits have been factored out. Apply this test to |
| 6 // non-POSIX once we have a non-POSIX implementation. | 6 // non-POSIX once we have a non-POSIX implementation. |
| 7 | 7 |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 #include <string.h> | 9 #include <string.h> |
| 10 | 10 |
| (...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 69 io_thread_task_runner()->PostTask( | 69 io_thread_task_runner()->PostTask( |
| 70 FROM_HERE, | 70 FROM_HERE, |
| 71 base::Bind(&RemoteMessagePipeTest::BootstrapMessagePipeOnIOThread, | 71 base::Bind(&RemoteMessagePipeTest::BootstrapMessagePipeOnIOThread, |
| 72 base::Unretained(this), channel_index, mp)); | 72 base::Unretained(this), channel_index, mp)); |
| 73 } | 73 } |
| 74 | 74 |
| 75 private: | 75 private: |
| 76 void SetUpOnIOThread() { | 76 void SetUpOnIOThread() { |
| 77 CHECK_EQ(base::MessageLoop::current(), io_thread_message_loop()); | 77 CHECK_EQ(base::MessageLoop::current(), io_thread_message_loop()); |
| 78 | 78 |
| 79 PlatformChannelPair channel_pair; | 79 embedder::PlatformChannelPair channel_pair; |
| 80 platform_handles_[0] = channel_pair.PassServerHandle(); | 80 platform_handles_[0] = channel_pair.PassServerHandle(); |
| 81 platform_handles_[1] = channel_pair.PassClientHandle(); | 81 platform_handles_[1] = channel_pair.PassClientHandle(); |
| 82 } | 82 } |
| 83 | 83 |
| 84 void CreateAndInitChannel(unsigned channel_index) { | 84 void CreateAndInitChannel(unsigned channel_index) { |
| 85 CHECK_EQ(base::MessageLoop::current(), io_thread_message_loop()); | 85 CHECK_EQ(base::MessageLoop::current(), io_thread_message_loop()); |
| 86 CHECK(channel_index == 0 || channel_index == 1); | 86 CHECK(channel_index == 0 || channel_index == 1); |
| 87 CHECK(!channels_[channel_index].get()); | 87 CHECK(!channels_[channel_index].get()); |
| 88 | 88 |
| 89 channels_[channel_index] = new Channel(); | 89 channels_[channel_index] = new Channel(); |
| (...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 128 if (channels_[0].get()) { | 128 if (channels_[0].get()) { |
| 129 channels_[0]->Shutdown(); | 129 channels_[0]->Shutdown(); |
| 130 channels_[0] = NULL; | 130 channels_[0] = NULL; |
| 131 } | 131 } |
| 132 if (channels_[1].get()) { | 132 if (channels_[1].get()) { |
| 133 channels_[1]->Shutdown(); | 133 channels_[1]->Shutdown(); |
| 134 channels_[1] = NULL; | 134 channels_[1] = NULL; |
| 135 } | 135 } |
| 136 } | 136 } |
| 137 | 137 |
| 138 ScopedPlatformHandle platform_handles_[2]; | 138 embedder::ScopedPlatformHandle platform_handles_[2]; |
| 139 scoped_refptr<Channel> channels_[2]; | 139 scoped_refptr<Channel> channels_[2]; |
| 140 | 140 |
| 141 DISALLOW_COPY_AND_ASSIGN(RemoteMessagePipeTest); | 141 DISALLOW_COPY_AND_ASSIGN(RemoteMessagePipeTest); |
| 142 }; | 142 }; |
| 143 | 143 |
| 144 TEST_F(RemoteMessagePipeTest, Basic) { | 144 TEST_F(RemoteMessagePipeTest, Basic) { |
| 145 const char hello[] = "hello"; | 145 const char hello[] = "hello"; |
| 146 const char world[] = "world!!!1!!!1!"; | 146 const char world[] = "world!!!1!!!1!"; |
| 147 char buffer[100] = { 0 }; | 147 char buffer[100] = { 0 }; |
| 148 uint32_t buffer_size = static_cast<uint32_t>(sizeof(buffer)); | 148 uint32_t buffer_size = static_cast<uint32_t>(sizeof(buffer)); |
| (...skipping 251 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 400 MOJO_READ_MESSAGE_FLAG_NONE)); | 400 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 401 EXPECT_EQ(sizeof(hello), static_cast<size_t>(buffer_size)); | 401 EXPECT_EQ(sizeof(hello), static_cast<size_t>(buffer_size)); |
| 402 EXPECT_EQ(0, strcmp(buffer, hello)); | 402 EXPECT_EQ(0, strcmp(buffer, hello)); |
| 403 | 403 |
| 404 // And MP 1, port 1. | 404 // And MP 1, port 1. |
| 405 mp_1->Close(1); | 405 mp_1->Close(1); |
| 406 } | 406 } |
| 407 } // namespace | 407 } // namespace |
| 408 } // namespace system | 408 } // namespace system |
| 409 } // namespace mojo | 409 } // namespace mojo |
| OLD | NEW |