1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
// Copyright (c) 2010 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 "chrome/gpu/gpu_thread.h"
#include <string>
#include <vector>
#include "app/gfx/gl/gl_context.h"
#include "base/command_line.h"
#include "build/build_config.h"
#include "chrome/common/child_process.h"
#include "chrome/common/child_process_logging.h"
#include "chrome/common/gpu_info.h"
#include "chrome/common/gpu_messages.h"
#include "chrome/gpu/gpu_info_collector.h"
#include "ipc/ipc_channel_handle.h"
#if defined(TOOLKIT_USES_GTK)
#include <gtk/gtk.h>
#include "app/x11_util.h"
#include "gfx/gtk_util.h"
#endif
GpuThread::GpuThread() {
#if defined(OS_LINUX)
{
// The X11 port of the command buffer code assumes it can access the X
// display via the macro GDK_DISPLAY(), which implies that Gtk has been
// initialized. This code was taken from PluginThread. TODO(kbr):
// rethink whether initializing Gtk is really necessary or whether we
// should just send a raw display connection down to the GPUProcessor.
g_thread_init(NULL);
gfx::GtkInitFromCommandLine(*CommandLine::ForCurrentProcess());
x11_util::SetDefaultX11ErrorHandlers();
}
#endif
}
GpuThread::~GpuThread() {
}
void GpuThread::RemoveChannel(int renderer_id) {
gpu_channels_.erase(renderer_id);
}
void GpuThread::OnControlMessageReceived(const IPC::Message& msg) {
bool msg_is_ok = true;
IPC_BEGIN_MESSAGE_MAP_EX(GpuThread, msg, msg_is_ok)
IPC_MESSAGE_HANDLER(GpuMsg_EstablishChannel,
OnEstablishChannel)
IPC_MESSAGE_HANDLER(GpuMsg_Synchronize,
OnSynchronize)
IPC_MESSAGE_HANDLER(GpuMsg_CollectGraphicsInfo,
OnCollectGraphicsInfo)
IPC_MESSAGE_HANDLER(GpuMsg_Crash,
OnCrash)
IPC_MESSAGE_HANDLER(GpuMsg_Hang,
OnHang)
IPC_END_MESSAGE_MAP_EX()
}
void GpuThread::OnEstablishChannel(int renderer_id) {
scoped_refptr<GpuChannel> channel;
IPC::ChannelHandle channel_handle;
GPUInfo gpu_info;
// Fail to establish a channel if some implementation of GL cannot be
// initialized.
if (gfx::GLContext::InitializeOneOff()) {
if (!gpu_info_collector::CollectGraphicsInfo(&gpu_info))
LOG(WARNING) << "Could not collect GPU info.";
child_process_logging::SetGpuInfo(gpu_info);
GpuChannelMap::const_iterator iter = gpu_channels_.find(renderer_id);
if (iter == gpu_channels_.end())
channel = new GpuChannel(renderer_id);
else
channel = iter->second;
DCHECK(channel != NULL);
if (channel->Init())
gpu_channels_[renderer_id] = channel;
else
channel = NULL;
if (channel.get()) {
channel_handle.name = channel->GetChannelName();
#if defined(OS_POSIX)
// On POSIX, pass the renderer-side FD. Also mark it as auto-close so
// that it gets closed after it has been sent.
int renderer_fd = channel->DisownRendererFd();
channel_handle.socket = base::FileDescriptor(renderer_fd, true);
#endif
}
}
Send(new GpuHostMsg_ChannelEstablished(channel_handle, gpu_info));
}
void GpuThread::OnSynchronize() {
Send(new GpuHostMsg_SynchronizeReply());
}
void GpuThread::OnCollectGraphicsInfo() {
// Fail to establish a channel if some implementation of GL cannot be
// initialized.
GPUInfo gpu_info;
if (gfx::GLContext::InitializeOneOff()) {
gpu_info_collector::CollectGraphicsInfo(&gpu_info);
}
Send(new GpuHostMsg_GraphicsInfoCollected(gpu_info));
}
void GpuThread::OnCrash() {
// Good bye, cruel world.
volatile int* it_s_the_end_of_the_world_as_we_know_it = NULL;
*it_s_the_end_of_the_world_as_we_know_it = 0xdead;
}
void GpuThread::OnHang() {
for (;;)
PlatformThread::Sleep(1000);
}
|
