| Index: mojo/shell/domain_socket/unix_domain_client_socket_posix_unittest.cc
|
| diff --git a/mojo/shell/domain_socket/unix_domain_client_socket_posix_unittest.cc b/mojo/shell/domain_socket/unix_domain_client_socket_posix_unittest.cc
|
| deleted file mode 100644
|
| index ae9fb437722de908e559c7139369c9fcf2470295..0000000000000000000000000000000000000000
|
| --- a/mojo/shell/domain_socket/unix_domain_client_socket_posix_unittest.cc
|
| +++ /dev/null
|
| @@ -1,151 +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 "mojo/shell/domain_socket/unix_domain_client_socket_posix.h"
|
| -
|
| -#include <unistd.h>
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/files/file_path.h"
|
| -#include "base/files/scoped_temp_dir.h"
|
| -#include "base/memory/scoped_ptr.h"
|
| -#include "base/message_loop/message_loop.h"
|
| -#include "base/posix/eintr_wrapper.h"
|
| -#include "mojo/shell/domain_socket/net_errors.h"
|
| -#include "mojo/shell/domain_socket/socket_libevent.h"
|
| -#include "mojo/shell/domain_socket/test_completion_callback.h"
|
| -#include "mojo/shell/domain_socket/unix_domain_server_socket_posix.h"
|
| -#include "testing/gtest/include/gtest/gtest.h"
|
| -
|
| -namespace mojo {
|
| -namespace shell {
|
| -namespace {
|
| -
|
| -const char kSocketFilename[] = "socket_for_testing";
|
| -
|
| -bool UserCanConnectCallback(
|
| - bool allow_user,
|
| - const UnixDomainServerSocket::Credentials& credentials) {
|
| - // Here peers are running in same process.
|
| - EXPECT_EQ(getpid(), credentials.process_id);
|
| - EXPECT_EQ(getuid(), credentials.user_id);
|
| - EXPECT_EQ(getgid(), credentials.group_id);
|
| - return allow_user;
|
| -}
|
| -
|
| -UnixDomainServerSocket::AuthCallback CreateAuthCallback(bool allow_user) {
|
| - return base::Bind(&UserCanConnectCallback, allow_user);
|
| -}
|
| -
|
| -// Connects socket synchronously.
|
| -int ConnectSynchronously(UnixDomainClientSocket* socket) {
|
| - TestCompletionCallback connect_callback;
|
| - int rv = socket->Connect(connect_callback.callback());
|
| - if (rv == net::ERR_IO_PENDING)
|
| - rv = connect_callback.WaitForResult();
|
| - return rv;
|
| -}
|
| -} // namespace
|
| -
|
| -class UnixDomainClientSocketTest : public testing::Test {
|
| - protected:
|
| - UnixDomainClientSocketTest() {
|
| - EXPECT_TRUE(temp_dir_.CreateUniqueTempDir());
|
| - socket_path_ = temp_dir_.path().Append(kSocketFilename).value();
|
| - }
|
| -
|
| - base::ScopedTempDir temp_dir_;
|
| - std::string socket_path_;
|
| - base::MessageLoopForIO loop_;
|
| -};
|
| -
|
| -TEST_F(UnixDomainClientSocketTest, ConnectWithSocketDescriptor) {
|
| - const bool kUseAbstractNamespace = false;
|
| -
|
| - UnixDomainServerSocket server_socket(CreateAuthCallback(true),
|
| - kUseAbstractNamespace);
|
| - EXPECT_EQ(net::OK, server_socket.ListenWithPath(socket_path_, 1));
|
| -
|
| - SocketDescriptor accepted_socket_fd = kInvalidSocket;
|
| - TestCompletionCallback accept_callback;
|
| - EXPECT_EQ(
|
| - net::ERR_IO_PENDING,
|
| - server_socket.Accept(&accepted_socket_fd, accept_callback.callback()));
|
| - EXPECT_EQ(kInvalidSocket, accepted_socket_fd);
|
| -
|
| - UnixDomainClientSocket client_socket(socket_path_, kUseAbstractNamespace);
|
| - EXPECT_FALSE(client_socket.IsConnected());
|
| -
|
| - EXPECT_EQ(net::OK, ConnectSynchronously(&client_socket));
|
| - EXPECT_TRUE(client_socket.IsConnected());
|
| - // Server has not yet been notified of the connection.
|
| - EXPECT_EQ(kInvalidSocket, accepted_socket_fd);
|
| -
|
| - EXPECT_EQ(net::OK, accept_callback.WaitForResult());
|
| - EXPECT_NE(kInvalidSocket, accepted_socket_fd);
|
| -
|
| - SocketDescriptor client_socket_fd = client_socket.ReleaseConnectedSocket();
|
| - EXPECT_NE(kInvalidSocket, client_socket_fd);
|
| -
|
| - // Now, re-wrap client_socket_fd in a UnixDomainClientSocket and check that
|
| - // it hasn't gotten accidentally closed.
|
| - SockaddrStorage addr;
|
| - ASSERT_TRUE(UnixDomainClientSocket::FillAddress(socket_path_, false, &addr));
|
| - scoped_ptr<SocketLibevent> adopter(new SocketLibevent);
|
| - adopter->AdoptConnectedSocket(client_socket_fd, addr);
|
| - UnixDomainClientSocket rewrapped_socket(adopter.Pass());
|
| - EXPECT_TRUE(rewrapped_socket.IsConnected());
|
| -
|
| - EXPECT_EQ(0, IGNORE_EINTR(close(accepted_socket_fd)));
|
| -}
|
| -
|
| -TEST_F(UnixDomainClientSocketTest, ConnectWithAbstractNamespace) {
|
| - const bool kUseAbstractNamespace = true;
|
| -
|
| - UnixDomainClientSocket client_socket(socket_path_, kUseAbstractNamespace);
|
| - EXPECT_FALSE(client_socket.IsConnected());
|
| -
|
| - UnixDomainServerSocket server_socket(CreateAuthCallback(true),
|
| - kUseAbstractNamespace);
|
| - EXPECT_EQ(net::OK, server_socket.ListenWithPath(socket_path_, 1));
|
| -
|
| - SocketDescriptor accepted_socket_fd = kInvalidSocket;
|
| - TestCompletionCallback accept_callback;
|
| - EXPECT_EQ(
|
| - net::ERR_IO_PENDING,
|
| - server_socket.Accept(&accepted_socket_fd, accept_callback.callback()));
|
| - EXPECT_EQ(kInvalidSocket, accepted_socket_fd);
|
| -
|
| - EXPECT_EQ(net::OK, ConnectSynchronously(&client_socket));
|
| - EXPECT_TRUE(client_socket.IsConnected());
|
| - // Server has not yet been notified of the connection.
|
| - EXPECT_EQ(kInvalidSocket, accepted_socket_fd);
|
| -
|
| - EXPECT_EQ(net::OK, accept_callback.WaitForResult());
|
| - EXPECT_NE(kInvalidSocket, accepted_socket_fd);
|
| -
|
| - EXPECT_EQ(0, IGNORE_EINTR(close(accepted_socket_fd)));
|
| -}
|
| -
|
| -TEST_F(UnixDomainClientSocketTest, ConnectToNonExistentSocket) {
|
| - const bool kUseAbstractNamespace = false;
|
| -
|
| - UnixDomainClientSocket client_socket(socket_path_, kUseAbstractNamespace);
|
| - EXPECT_FALSE(client_socket.IsConnected());
|
| - EXPECT_EQ(net::ERR_FILE_NOT_FOUND, ConnectSynchronously(&client_socket));
|
| -}
|
| -
|
| -TEST_F(UnixDomainClientSocketTest,
|
| - ConnectToNonExistentSocketWithAbstractNamespace) {
|
| - const bool kUseAbstractNamespace = true;
|
| -
|
| - UnixDomainClientSocket client_socket(socket_path_, kUseAbstractNamespace);
|
| - EXPECT_FALSE(client_socket.IsConnected());
|
| -
|
| - TestCompletionCallback connect_callback;
|
| - EXPECT_EQ(net::ERR_CONNECTION_REFUSED, ConnectSynchronously(&client_socket));
|
| -}
|
| -
|
| -} // namespace shell
|
| -} // namespace mojo
|
|
|