#include <stddef.h>
#include <stdio.h>
#include <memory>
#include <sstream>
#include <string>
#include "base/functional/bind.h"
#include "base/location.h"
#include "base/memory/raw_ptr.h"
#include "base/run_loop.h"
#include "base/sync_socket.h"
#include "base/task/single_thread_task_runner.h"
#include "base/threading/thread.h"
#include "build/build_config.h"
#include "ipc/ipc_test_base.h"
#include "testing/gtest/include/gtest/gtest.h"
#if BUILDFLAG(IS_POSIX) || BUILDFLAG(IS_FUCHSIA)
#include "base/file_descriptor_posix.h"
#endif
#define IPC_MESSAGE_IMPL
#include "ipc/ipc_message_macros.h"
#include "ipc/ipc_message_start.h"
#define IPC_MESSAGE_START TestMsgStart
#if BUILDFLAG(IS_WIN)
IPC_MESSAGE_CONTROL1(MsgClassSetHandle, base::SyncSocket::Handle)
#elif BUILDFLAG(IS_POSIX) || BUILDFLAG(IS_FUCHSIA)
IPC_MESSAGE_CONTROL1(MsgClassSetHandle, base::FileDescriptor)
#endif
IPC_MESSAGE_CONTROL1(MsgClassResponse, std::string)
IPC_MESSAGE_CONTROL0(MsgClassShutdown)
namespace {
const char kHelloString[] = "Hello, SyncSocket Client";
const size_t kHelloStringLength = std::size(kHelloString);
class SyncSocketServerListener : public IPC::Listener {
public:
SyncSocketServerListener() : chan_(nullptr) {}
SyncSocketServerListener(const SyncSocketServerListener&) = delete;
SyncSocketServerListener& operator=(const SyncSocketServerListener&) = delete;
void Init(IPC::Channel* chan) {
chan_ = chan;
}
bool OnMessageReceived(const IPC::Message& msg) override {
if (msg.routing_id() == MSG_ROUTING_CONTROL) {
IPC_BEGIN_MESSAGE_MAP(SyncSocketServerListener, msg)
IPC_MESSAGE_HANDLER(MsgClassSetHandle, OnMsgClassSetHandle)
IPC_MESSAGE_HANDLER(MsgClassShutdown, OnMsgClassShutdown)
IPC_END_MESSAGE_MAP()
}
return true;
}
private:
#if BUILDFLAG(IS_WIN)
void OnMsgClassSetHandle(const base::SyncSocket::Handle handle) {
SetHandle(handle);
}
#elif BUILDFLAG(IS_POSIX) || BUILDFLAG(IS_FUCHSIA)
void OnMsgClassSetHandle(const base::FileDescriptor& fd_struct) {
SetHandle(fd_struct.fd);
}
#else
# error "What platform?"
#endif
void SetHandle(base::SyncSocket::Handle handle) {
base::SyncSocket sync_socket(handle);
EXPECT_EQ(sync_socket.Send(kHelloString, kHelloStringLength),
kHelloStringLength);
IPC::Message* msg = new MsgClassResponse(kHelloString);
EXPECT_TRUE(chan_->Send(msg));
}
void OnMsgClassShutdown() { base::RunLoop::QuitCurrentWhenIdleDeprecated(); }
raw_ptr<IPC::Channel> chan_;
};
DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT(SyncSocketServerClient) {
SyncSocketServerListener listener;
Connect(&listener);
listener.Init(channel());
base::RunLoop().Run();
Close();
}
class SyncSocketClientListener : public IPC::Listener {
public:
SyncSocketClientListener() = default;
SyncSocketClientListener(const SyncSocketClientListener&) = delete;
SyncSocketClientListener& operator=(const SyncSocketClientListener&) = delete;
void Init(base::SyncSocket* socket, IPC::Channel* chan) {
socket_ = socket;
chan_ = chan;
}
bool OnMessageReceived(const IPC::Message& msg) override {
if (msg.routing_id() == MSG_ROUTING_CONTROL) {
IPC_BEGIN_MESSAGE_MAP(SyncSocketClientListener, msg)
IPC_MESSAGE_HANDLER(MsgClassResponse, OnMsgClassResponse)
IPC_END_MESSAGE_MAP()
}
return true;
}
private:
void OnMsgClassResponse(const std::string& str) {
EXPECT_EQ(kHelloStringLength, socket_->Peek());
char buf[kHelloStringLength];
socket_->Receive(static_cast<void*>(buf), kHelloStringLength);
EXPECT_EQ(strcmp(str.c_str(), buf), 0);
EXPECT_EQ(0U, socket_->Peek());
IPC::Message* msg = new MsgClassShutdown();
EXPECT_TRUE(chan_->Send(msg));
base::RunLoop::QuitCurrentWhenIdleDeprecated();
}
raw_ptr<base::SyncSocket> socket_;
raw_ptr<IPC::Channel> chan_;
};
using SyncSocketTest = IPCChannelMojoTestBase;
TEST_F(SyncSocketTest, SanityTest) {
Init("SyncSocketServerClient");
SyncSocketClientListener listener;
CreateChannel(&listener);
base::SyncSocket pair[2];
base::SyncSocket::CreatePair(&pair[0], &pair[1]);
EXPECT_EQ(0U, pair[0].Peek());
EXPECT_EQ(0U, pair[1].Peek());
base::SyncSocket::Handle target_handle;
ASSERT_TRUE(ConnectChannel());
listener.Init(&pair[0], channel());
#if BUILDFLAG(IS_WIN)
BOOL retval = DuplicateHandle(GetCurrentProcess(), pair[1].handle(),
client_process().Handle(), &target_handle,
0, FALSE, DUPLICATE_SAME_ACCESS);
EXPECT_TRUE(retval);
IPC::Message* msg = new MsgClassSetHandle(target_handle);
#else
target_handle = pair[1].handle();
base::FileDescriptor filedesc(target_handle, false);
IPC::Message* msg = new MsgClassSetHandle(filedesc);
#endif
EXPECT_TRUE(sender()->Send(msg));
base::RunLoop().Run();
pair[0].Close();
pair[1].Close();
EXPECT_TRUE(WaitForClientShutdown());
DestroyChannel();
}
static void BlockingRead(base::SyncSocket* socket, char* buf,
size_t length, size_t* received) {
DCHECK_NE(buf, nullptr);
socket->Send(kHelloString, kHelloStringLength);
*received = socket->Receive(buf, length);
}
TEST_F(SyncSocketTest, DisconnectTest) {
base::CancelableSyncSocket pair[2];
ASSERT_TRUE(base::CancelableSyncSocket::CreatePair(&pair[0], &pair[1]));
base::Thread worker("BlockingThread");
worker.Start();
char buf[0xff];
size_t received = 1U;
worker.task_runner()->PostTask(
FROM_HERE, base::BindOnce(&BlockingRead, &pair[0], &buf[0],
std::size(buf), &received));
char hello[kHelloStringLength] = {0};
pair[1].Receive(&hello[0], sizeof(hello));
EXPECT_EQ(0, strcmp(hello, kHelloString));
base::PlatformThread::YieldCurrentThread();
pair[0].Shutdown();
worker.Stop();
EXPECT_EQ(0U, received);
}
TEST_F(SyncSocketTest, BlockingReceiveTest) {
base::CancelableSyncSocket pair[2];
ASSERT_TRUE(base::CancelableSyncSocket::CreatePair(&pair[0], &pair[1]));
base::Thread worker("BlockingThread");
worker.Start();
char buf[kHelloStringLength] = {0};
size_t received = 1U;
worker.task_runner()->PostTask(
FROM_HERE, base::BindOnce(&BlockingRead, &pair[0], &buf[0],
kHelloStringLength, &received));
char hello[kHelloStringLength] = {0};
pair[1].Receive(&hello[0], sizeof(hello));
EXPECT_EQ(0, strcmp(hello, kHelloString));
base::PlatformThread::YieldCurrentThread();
pair[1].Send(kHelloString, kHelloStringLength);
worker.Stop();
EXPECT_TRUE(strcmp(buf, kHelloString) == 0);
EXPECT_EQ(kHelloStringLength, received);
}
TEST_F(SyncSocketTest, NonBlockingWriteTest) {
base::CancelableSyncSocket pair[2];
ASSERT_TRUE(base::CancelableSyncSocket::CreatePair(&pair[0], &pair[1]));
while (pair[0].Send(kHelloString, kHelloStringLength) != 0) {}
size_t bytes_in_buffer = pair[1].Peek();
EXPECT_NE(bytes_in_buffer, 0U);
EXPECT_EQ(0U, pair[0].Send(kHelloString, kHelloStringLength));
EXPECT_EQ(bytes_in_buffer, pair[1].Peek());
char hello[kHelloStringLength] = {0};
pair[1].Receive(&hello[0], sizeof(hello));
EXPECT_EQ(kHelloStringLength, pair[0].Send(kHelloString, kHelloStringLength));
}
}