blob: c1347fcb6be3838f57512b1b524ee9bcbdf9c388 [file] [log] [blame]
// 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 "ui/ozone/public/ozone_gpu_test_helper.h"
#include "base/threading/thread.h"
#include "base/threading/thread_task_runner_handle.h"
#include "ipc/ipc_listener.h"
#include "ipc/ipc_message.h"
#include "ipc/ipc_sender.h"
#include "ipc/message_filter.h"
#include "ui/ozone/public/gpu_platform_support_host.h"
#include "ui/ozone/public/ozone_platform.h"
namespace ui {
namespace {
const int kGpuProcessHostId = 1;
void DispatchToGpuPlatformSupportHostTask(IPC::Message* msg) {
ui::OzonePlatform::GetInstance()
->GetGpuPlatformSupportHost()
->OnMessageReceived(*msg);
delete msg;
}
void DispatchToGpuPlatformSupportTaskOnIO(IPC::Message* msg) {
IPC::MessageFilter* filter =
ui::OzonePlatform::GetInstance()->GetGpuMessageFilter();
if (filter)
filter->OnMessageReceived(*msg);
delete msg;
}
} // namespace
class FakeGpuProcess : public IPC::Channel {
public:
FakeGpuProcess(
const scoped_refptr<base::SingleThreadTaskRunner>& ui_task_runner)
: ui_task_runner_(ui_task_runner) {}
~FakeGpuProcess() override {}
void InitOnIO() {
IPC::MessageFilter* filter =
ui::OzonePlatform::GetInstance()->GetGpuMessageFilter();
if (filter)
filter->OnFilterAdded(this);
}
// IPC::Channel implementation:
bool Send(IPC::Message* msg) override {
ui_task_runner_->PostTask(
FROM_HERE, base::Bind(&DispatchToGpuPlatformSupportHostTask, msg));
return true;
}
bool Connect() override {
NOTREACHED();
return false;
}
void Close() override { NOTREACHED(); }
base::ProcessId GetPeerPID() const override {
NOTREACHED();
return base::kNullProcessId;
}
base::ProcessId GetSelfPID() const override {
NOTREACHED();
return base::kNullProcessId;
}
#if defined(OS_POSIX) && !defined(OS_NACL_SFI)
int GetClientFileDescriptor() const override {
NOTREACHED();
return 0;
}
base::ScopedFD TakeClientFileDescriptor() override {
NOTREACHED();
return base::ScopedFD();
}
#endif
private:
scoped_refptr<base::SingleThreadTaskRunner> ui_task_runner_;
};
class FakeGpuProcessHost {
public:
FakeGpuProcessHost(
const scoped_refptr<base::SingleThreadTaskRunner>& gpu_task_runner,
const scoped_refptr<base::SingleThreadTaskRunner>& gpu_io_task_runner)
: gpu_task_runner_(gpu_task_runner),
gpu_io_task_runner_(gpu_io_task_runner) {}
~FakeGpuProcessHost() {}
void Init() {
base::Callback<void(IPC::Message*)> sender =
base::Bind(&DispatchToGpuPlatformSupportTaskOnIO);
ui::OzonePlatform::GetInstance()
->GetGpuPlatformSupportHost()
->OnChannelEstablished(kGpuProcessHostId, gpu_io_task_runner_, sender);
}
private:
scoped_refptr<base::SingleThreadTaskRunner> gpu_task_runner_;
scoped_refptr<base::SingleThreadTaskRunner> gpu_io_task_runner_;
};
OzoneGpuTestHelper::OzoneGpuTestHelper() {
}
OzoneGpuTestHelper::~OzoneGpuTestHelper() {
}
bool OzoneGpuTestHelper::Initialize(
const scoped_refptr<base::SingleThreadTaskRunner>& ui_task_runner,
const scoped_refptr<base::SingleThreadTaskRunner>& gpu_task_runner) {
io_helper_thread_.reset(new base::Thread("IOHelperThread"));
if (!io_helper_thread_->StartWithOptions(
base::Thread::Options(base::MessageLoop::TYPE_IO, 0)))
return false;
fake_gpu_process_.reset(new FakeGpuProcess(ui_task_runner));
io_helper_thread_->task_runner()->PostTask(
FROM_HERE, base::Bind(&FakeGpuProcess::InitOnIO,
base::Unretained(fake_gpu_process_.get())));
fake_gpu_process_host_.reset(new FakeGpuProcessHost(
gpu_task_runner, io_helper_thread_->task_runner()));
fake_gpu_process_host_->Init();
return true;
}
} // namespace ui