Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(569)

Side by Side Diff: ui/ozone/platform/wayland/wayland_connection.cc

Issue 2147523003: Rename WaylandDisplay to WaylandConnection (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: add argument name Created 4 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "ui/ozone/platform/wayland/wayland_display.h" 5 #include "ui/ozone/platform/wayland/wayland_connection.h"
6 6
7 #include <xdg-shell-unstable-v5-client-protocol.h> 7 #include <xdg-shell-unstable-v5-client-protocol.h>
8 8
9 #include "base/bind.h" 9 #include "base/bind.h"
10 #include "base/logging.h" 10 #include "base/logging.h"
11 #include "base/memory/ptr_util.h" 11 #include "base/memory/ptr_util.h"
12 #include "base/message_loop/message_loop.h" 12 #include "base/message_loop/message_loop.h"
13 #include "ui/ozone/platform/wayland/wayland_window.h" 13 #include "ui/ozone/platform/wayland/wayland_window.h"
14 14
15 static_assert(XDG_SHELL_VERSION_CURRENT == 5, "Unsupported xdg-shell version"); 15 static_assert(XDG_SHELL_VERSION_CURRENT == 5, "Unsupported xdg-shell version");
16 16
17 namespace ui { 17 namespace ui {
18 namespace { 18 namespace {
19 const uint32_t kMaxCompositorVersion = 4; 19 const uint32_t kMaxCompositorVersion = 4;
20 const uint32_t kMaxSeatVersion = 4; 20 const uint32_t kMaxSeatVersion = 4;
21 const uint32_t kMaxShmVersion = 1; 21 const uint32_t kMaxShmVersion = 1;
22 const uint32_t kMaxXdgShellVersion = 1; 22 const uint32_t kMaxXdgShellVersion = 1;
23 } // namespace 23 } // namespace
24 24
25 WaylandDisplay::WaylandDisplay() {} 25 WaylandConnection::WaylandConnection() {}
26 26
27 WaylandDisplay::~WaylandDisplay() {} 27 WaylandConnection::~WaylandConnection() {}
28 28
29 bool WaylandDisplay::Initialize() { 29 bool WaylandConnection::Initialize() {
30 static const wl_registry_listener registry_listener = { 30 static const wl_registry_listener registry_listener = {
31 &WaylandDisplay::Global, &WaylandDisplay::GlobalRemove, 31 &WaylandConnection::Global, &WaylandConnection::GlobalRemove,
32 }; 32 };
33 33
34 display_.reset(wl_display_connect(nullptr)); 34 display_.reset(wl_display_connect(nullptr));
35 if (!display_) { 35 if (!display_) {
36 LOG(ERROR) << "Failed to connect to Wayland display"; 36 LOG(ERROR) << "Failed to connect to Wayland display";
37 return false; 37 return false;
38 } 38 }
39 39
40 registry_.reset(wl_display_get_registry(display_.get())); 40 registry_.reset(wl_display_get_registry(display_.get()));
41 if (!registry_) { 41 if (!registry_) {
(...skipping 17 matching lines...) Expand all
59 return false; 59 return false;
60 } 60 }
61 if (!shell_) { 61 if (!shell_) {
62 LOG(ERROR) << "No xdg_shell object"; 62 LOG(ERROR) << "No xdg_shell object";
63 return false; 63 return false;
64 } 64 }
65 65
66 return true; 66 return true;
67 } 67 }
68 68
69 bool WaylandDisplay::StartProcessingEvents() { 69 bool WaylandConnection::StartProcessingEvents() {
70 if (watching_) 70 if (watching_)
71 return true; 71 return true;
72 72
73 DCHECK(display_); 73 DCHECK(display_);
74 wl_display_flush(display_.get()); 74 wl_display_flush(display_.get());
75 75
76 DCHECK(base::MessageLoopForUI::IsCurrent()); 76 DCHECK(base::MessageLoopForUI::IsCurrent());
77 if (!base::MessageLoopForUI::current()->WatchFileDescriptor( 77 if (!base::MessageLoopForUI::current()->WatchFileDescriptor(
78 wl_display_get_fd(display_.get()), true, 78 wl_display_get_fd(display_.get()), true,
79 base::MessagePumpLibevent::WATCH_READ, &controller_, this)) 79 base::MessagePumpLibevent::WATCH_READ, &controller_, this))
80 return false; 80 return false;
81 81
82 watching_ = true; 82 watching_ = true;
83 return true; 83 return true;
84 } 84 }
85 85
86 void WaylandDisplay::ScheduleFlush() { 86 void WaylandConnection::ScheduleFlush() {
87 if (scheduled_flush_ || !watching_) 87 if (scheduled_flush_ || !watching_)
88 return; 88 return;
89 base::MessageLoopForUI::current()->task_runner()->PostTask( 89 base::MessageLoopForUI::current()->task_runner()->PostTask(
90 FROM_HERE, base::Bind(&WaylandDisplay::Flush, base::Unretained(this))); 90 FROM_HERE, base::Bind(&WaylandConnection::Flush, base::Unretained(this)));
91 scheduled_flush_ = true; 91 scheduled_flush_ = true;
92 } 92 }
93 93
94 WaylandWindow* WaylandDisplay::GetWindow(gfx::AcceleratedWidget widget) { 94 WaylandWindow* WaylandConnection::GetWindow(gfx::AcceleratedWidget widget) {
95 auto it = window_map_.find(widget); 95 auto it = window_map_.find(widget);
96 return it == window_map_.end() ? nullptr : it->second; 96 return it == window_map_.end() ? nullptr : it->second;
97 } 97 }
98 98
99 void WaylandDisplay::AddWindow(gfx::AcceleratedWidget widget, 99 void WaylandConnection::AddWindow(gfx::AcceleratedWidget widget,
100 WaylandWindow* window) { 100 WaylandWindow* window) {
101 window_map_[widget] = window; 101 window_map_[widget] = window;
102 } 102 }
103 103
104 void WaylandDisplay::RemoveWindow(gfx::AcceleratedWidget widget) { 104 void WaylandConnection::RemoveWindow(gfx::AcceleratedWidget widget) {
105 window_map_.erase(widget); 105 window_map_.erase(widget);
106 } 106 }
107 107
108 void WaylandDisplay::OnDispatcherListChanged() { 108 void WaylandConnection::OnDispatcherListChanged() {
109 StartProcessingEvents(); 109 StartProcessingEvents();
110 } 110 }
111 111
112 void WaylandDisplay::Flush() { 112 void WaylandConnection::Flush() {
113 wl_display_flush(display_.get()); 113 wl_display_flush(display_.get());
114 scheduled_flush_ = false; 114 scheduled_flush_ = false;
115 } 115 }
116 116
117 void WaylandDisplay::DispatchUiEvent(Event* event) { 117 void WaylandConnection::DispatchUiEvent(Event* event) {
118 PlatformEventSource::DispatchEvent(event); 118 PlatformEventSource::DispatchEvent(event);
119 } 119 }
120 120
121 void WaylandDisplay::OnFileCanReadWithoutBlocking(int fd) { 121 void WaylandConnection::OnFileCanReadWithoutBlocking(int fd) {
122 wl_display_dispatch(display_.get()); 122 wl_display_dispatch(display_.get());
123 for (const auto& window : window_map_) 123 for (const auto& window : window_map_)
124 window.second->ApplyPendingBounds(); 124 window.second->ApplyPendingBounds();
125 } 125 }
126 126
127 void WaylandDisplay::OnFileCanWriteWithoutBlocking(int fd) {} 127 void WaylandConnection::OnFileCanWriteWithoutBlocking(int fd) {}
128 128
129 // static 129 // static
130 void WaylandDisplay::Global(void* data, 130 void WaylandConnection::Global(void* data,
131 wl_registry* registry, 131 wl_registry* registry,
132 uint32_t name, 132 uint32_t name,
133 const char* interface, 133 const char* interface,
134 uint32_t version) { 134 uint32_t version) {
135 static const wl_seat_listener seat_listener = { 135 static const wl_seat_listener seat_listener = {
136 &WaylandDisplay::Capabilities, &WaylandDisplay::Name, 136 &WaylandConnection::Capabilities, &WaylandConnection::Name,
137 }; 137 };
138 static const xdg_shell_listener shell_listener = { 138 static const xdg_shell_listener shell_listener = {
139 &WaylandDisplay::Ping, 139 &WaylandConnection::Ping,
140 }; 140 };
141 141
142 WaylandDisplay* display = static_cast<WaylandDisplay*>(data); 142 WaylandConnection* connection = static_cast<WaylandConnection*>(data);
143 if (!display->compositor_ && strcmp(interface, "wl_compositor") == 0) { 143 if (!connection->compositor_ && strcmp(interface, "wl_compositor") == 0) {
144 display->compositor_ = wl::Bind<wl_compositor>( 144 connection->compositor_ = wl::Bind<wl_compositor>(
145 registry, name, std::min(version, kMaxCompositorVersion)); 145 registry, name, std::min(version, kMaxCompositorVersion));
146 if (!display->compositor_) 146 if (!connection->compositor_)
147 LOG(ERROR) << "Failed to bind to wl_compositor global"; 147 LOG(ERROR) << "Failed to bind to wl_compositor global";
148 } else if (!display->shm_ && strcmp(interface, "wl_shm") == 0) { 148 } else if (!connection->shm_ && strcmp(interface, "wl_shm") == 0) {
149 display->shm_ = 149 connection->shm_ =
150 wl::Bind<wl_shm>(registry, name, std::min(version, kMaxShmVersion)); 150 wl::Bind<wl_shm>(registry, name, std::min(version, kMaxShmVersion));
151 if (!display->shm_) 151 if (!connection->shm_)
152 LOG(ERROR) << "Failed to bind to wl_shm global"; 152 LOG(ERROR) << "Failed to bind to wl_shm global";
153 } else if (!display->seat_ && strcmp(interface, "wl_seat") == 0) { 153 } else if (!connection->seat_ && strcmp(interface, "wl_seat") == 0) {
154 display->seat_ = 154 connection->seat_ =
155 wl::Bind<wl_seat>(registry, name, std::min(version, kMaxSeatVersion)); 155 wl::Bind<wl_seat>(registry, name, std::min(version, kMaxSeatVersion));
156 if (!display->seat_) { 156 if (!connection->seat_) {
157 LOG(ERROR) << "Failed to bind to wl_seat global"; 157 LOG(ERROR) << "Failed to bind to wl_seat global";
158 return; 158 return;
159 } 159 }
160 wl_seat_add_listener(display->seat_.get(), &seat_listener, display); 160 wl_seat_add_listener(connection->seat_.get(), &seat_listener, connection);
161 } else if (!display->shell_ && strcmp(interface, "xdg_shell") == 0) { 161 } else if (!connection->shell_ && strcmp(interface, "xdg_shell") == 0) {
162 display->shell_ = wl::Bind<xdg_shell>( 162 connection->shell_ = wl::Bind<xdg_shell>(
163 registry, name, std::min(version, kMaxXdgShellVersion)); 163 registry, name, std::min(version, kMaxXdgShellVersion));
164 if (!display->shell_) { 164 if (!connection->shell_) {
165 LOG(ERROR) << "Failed to bind to xdg_shell global"; 165 LOG(ERROR) << "Failed to bind to xdg_shell global";
166 return; 166 return;
167 } 167 }
168 xdg_shell_add_listener(display->shell_.get(), &shell_listener, display); 168 xdg_shell_add_listener(connection->shell_.get(), &shell_listener,
169 xdg_shell_use_unstable_version(display->shell_.get(), 169 connection);
170 xdg_shell_use_unstable_version(connection->shell_.get(),
170 XDG_SHELL_VERSION_CURRENT); 171 XDG_SHELL_VERSION_CURRENT);
171 } 172 }
172 173
173 display->ScheduleFlush(); 174 connection->ScheduleFlush();
174 } 175 }
175 176
176 // static 177 // static
177 void WaylandDisplay::GlobalRemove(void* data, 178 void WaylandConnection::GlobalRemove(void* data,
178 wl_registry* registry, 179 wl_registry* registry,
179 uint32_t name) { 180 uint32_t name) {
180 NOTIMPLEMENTED(); 181 NOTIMPLEMENTED();
181 } 182 }
182 183
183 // static 184 // static
184 void WaylandDisplay::Capabilities(void* data, 185 void WaylandConnection::Capabilities(void* data,
185 wl_seat* seat, 186 wl_seat* seat,
186 uint32_t capabilities) { 187 uint32_t capabilities) {
187 WaylandDisplay* display = static_cast<WaylandDisplay*>(data); 188 WaylandConnection* connection = static_cast<WaylandConnection*>(data);
188 if (capabilities & WL_SEAT_CAPABILITY_POINTER) { 189 if (capabilities & WL_SEAT_CAPABILITY_POINTER) {
189 if (!display->pointer_) { 190 if (!connection->pointer_) {
190 wl_pointer* pointer = wl_seat_get_pointer(display->seat_.get()); 191 wl_pointer* pointer = wl_seat_get_pointer(connection->seat_.get());
191 if (!pointer) { 192 if (!pointer) {
192 LOG(ERROR) << "Failed to get wl_pointer from seat"; 193 LOG(ERROR) << "Failed to get wl_pointer from seat";
193 return; 194 return;
194 } 195 }
195 display->pointer_ = base::WrapUnique(new WaylandPointer( 196 connection->pointer_ = base::WrapUnique(new WaylandPointer(
196 pointer, base::Bind(&WaylandDisplay::DispatchUiEvent, 197 pointer, base::Bind(&WaylandConnection::DispatchUiEvent,
197 base::Unretained(display)))); 198 base::Unretained(connection))));
198 } 199 }
199 } else if (display->pointer_) { 200 } else if (connection->pointer_) {
200 display->pointer_.reset(); 201 connection->pointer_.reset();
201 } 202 }
202 display->ScheduleFlush(); 203 connection->ScheduleFlush();
203 } 204 }
204 205
205 // static 206 // static
206 void WaylandDisplay::Name(void* data, wl_seat* seat, const char* name) {} 207 void WaylandConnection::Name(void* data, wl_seat* seat, const char* name) {}
207 208
208 // static 209 // static
209 void WaylandDisplay::Ping(void* data, xdg_shell* shell, uint32_t serial) { 210 void WaylandConnection::Ping(void* data, xdg_shell* shell, uint32_t serial) {
210 WaylandDisplay* display = static_cast<WaylandDisplay*>(data); 211 WaylandConnection* connection = static_cast<WaylandConnection*>(data);
211 xdg_shell_pong(shell, serial); 212 xdg_shell_pong(shell, serial);
212 display->ScheduleFlush(); 213 connection->ScheduleFlush();
213 } 214 }
214 215
215 } // namespace ui 216 } // namespace ui
OLDNEW
« no previous file with comments | « ui/ozone/platform/wayland/wayland_connection.h ('k') | ui/ozone/platform/wayland/wayland_connection_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698