| Index: mojo/embedder/platform_channel_pair_posix_unittest.cc
|
| diff --git a/mojo/embedder/platform_channel_pair_posix_unittest.cc b/mojo/embedder/platform_channel_pair_posix_unittest.cc
|
| index 8f57c5cb35bbdde8ce03c1368522a42c907c11a3..97f5deb0d6a65fcec2c7fafaa272b97a574f3377 100644
|
| --- a/mojo/embedder/platform_channel_pair_posix_unittest.cc
|
| +++ b/mojo/embedder/platform_channel_pair_posix_unittest.cc
|
| @@ -13,7 +13,7 @@
|
| #include <sys/uio.h>
|
| #include <unistd.h>
|
|
|
| -#include <vector>
|
| +#include <deque>
|
|
|
| #include "base/file_util.h"
|
| #include "base/files/file_path.h"
|
| @@ -22,6 +22,8 @@
|
| #include "base/macros.h"
|
| #include "mojo/common/test/test_utils.h"
|
| #include "mojo/embedder/platform_channel_utils_posix.h"
|
| +#include "mojo/embedder/platform_handle.h"
|
| +#include "mojo/embedder/platform_handle_vector.h"
|
| #include "mojo/embedder/scoped_platform_handle.h"
|
| #include "testing/gtest/include/gtest/gtest.h"
|
|
|
| @@ -117,12 +119,12 @@ TEST_F(PlatformChannelPairPosixTest, SendReceiveData) {
|
| WaitReadable(client_handle.get());
|
|
|
| char buf[10000] = {};
|
| - ScopedPlatformHandleVectorPtr received_handles;
|
| + std::deque<PlatformHandle> received_handles;
|
| ssize_t result = PlatformChannelRecvmsg(client_handle.get(), buf,
|
| sizeof(buf), &received_handles);
|
| EXPECT_EQ(static_cast<ssize_t>(send_string.size()), result);
|
| EXPECT_EQ(send_string, std::string(buf, static_cast<size_t>(result)));
|
| - EXPECT_FALSE(received_handles);
|
| + EXPECT_TRUE(received_handles.empty());
|
| }
|
| }
|
|
|
| @@ -152,17 +154,17 @@ TEST_F(PlatformChannelPairPosixTest, SendReceiveFDs) {
|
| WaitReadable(client_handle.get());
|
|
|
| char buf[100] = { 'a' };
|
| - ScopedPlatformHandleVectorPtr received_handles;
|
| + std::deque<PlatformHandle> received_handles;
|
| EXPECT_EQ(1, PlatformChannelRecvmsg(client_handle.get(), buf, sizeof(buf),
|
| &received_handles));
|
| EXPECT_EQ('\0', buf[0]);
|
| - ASSERT_TRUE(received_handles);
|
| - EXPECT_EQ(i, received_handles->size());
|
| + ASSERT_FALSE(received_handles.empty());
|
| + EXPECT_EQ(i, received_handles.size());
|
|
|
| - for (size_t j = 0; j < received_handles->size(); j++) {
|
| + for (size_t j = 0; !received_handles.empty(); j++) {
|
| base::ScopedFILE fp(test::FILEFromPlatformHandle(
|
| - ScopedPlatformHandle((*received_handles)[j]), "rb"));
|
| - (*received_handles)[j] = PlatformHandle();
|
| + ScopedPlatformHandle(received_handles.front()), "rb"));
|
| + received_handles.pop_front();
|
| ASSERT_TRUE(fp);
|
| rewind(fp.get());
|
| char read_buf[100];
|
| @@ -198,23 +200,22 @@ TEST_F(PlatformChannelPairPosixTest, AppendReceivedFDs) {
|
|
|
| WaitReadable(client_handle.get());
|
|
|
| - // Start with an invalid handle in the vector.
|
| - ScopedPlatformHandleVectorPtr handles(new PlatformHandleVector());
|
| - handles->push_back(PlatformHandle());
|
| + // Start with an invalid handle in the deque.
|
| + std::deque<PlatformHandle> received_handles;
|
| + received_handles.push_back(PlatformHandle());
|
|
|
| char buf[100] = { 'a' };
|
| EXPECT_EQ(1, PlatformChannelRecvmsg(client_handle.get(), buf, sizeof(buf),
|
| - &handles));
|
| + &received_handles));
|
| EXPECT_EQ('\0', buf[0]);
|
| - ASSERT_TRUE(handles);
|
| - ASSERT_EQ(2u, handles->size());
|
| - EXPECT_FALSE((*handles)[0].is_valid());
|
| - EXPECT_TRUE((*handles)[1].is_valid());
|
| + ASSERT_EQ(2u, received_handles.size());
|
| + EXPECT_FALSE(received_handles[0].is_valid());
|
| + EXPECT_TRUE(received_handles[1].is_valid());
|
|
|
| {
|
| base::ScopedFILE fp(test::FILEFromPlatformHandle(
|
| - ScopedPlatformHandle((*handles)[1]), "rb"));
|
| - (*handles)[1] = PlatformHandle();
|
| + ScopedPlatformHandle(received_handles[1]), "rb"));
|
| + received_handles[1] = PlatformHandle();
|
| ASSERT_TRUE(fp);
|
| rewind(fp.get());
|
| char read_buf[100];
|
|
|