#include <wayland-cursor.h>
#include <xkbcommon/xkbcommon.h>
#include "eloop.h"
-#include "log.h"
#include "shl_array.h"
#include "shl_dlist.h"
#include "shl_hook.h"
+#include "shl_log.h"
#include "shl_misc.h"
#include "tsm_vte.h"
#include "wlt_main.h"
struct wl_global_listener *dp_listener;
struct shl_hook *listeners;
unsigned int state;
+ struct wl_registry *w_registry;
struct shl_dlist window_list;
bool buffer_attached;
bool skip_damage;
bool need_resize;
- bool need_redraw;
bool need_frame;
bool idle_pending;
unsigned int new_width;
wl_surface_attach(disp->w_cursor_surface, buffer, 0, 0);
wl_surface_damage(disp->w_cursor_surface, 0, 0,
image->width, image->height);
+ wl_surface_commit(disp->w_cursor_surface);
}
-static int dp_mask_update(uint32_t mask, void *data)
+static void dp_dispatch(struct wlt_display *disp, bool nonblock)
{
- struct wlt_display *disp = data;
int ret;
- int mode;
- if (!disp->dp_fd)
- return 0;
+ errno = 0;
+ if (nonblock)
+ ret = wl_display_dispatch_pending(disp->dp);
+ else
+ ret = wl_display_dispatch(disp->dp);
- mode = 0;
- if (mask & WL_DISPLAY_READABLE)
- mode |= EV_READABLE;
- if (mask & WL_DISPLAY_WRITABLE)
- mode |= EV_WRITEABLE;
+ if (ret == -1) {
+ log_error("error during wayland dispatch (%d): %m", errno);
+ return;
+ } else if (errno == EAGAIN) {
+ ret = ev_fd_update(disp->dp_fd, EV_READABLE | EV_WRITEABLE);
+ if (ret)
+ log_warning("cannot update wayland-fd event-polling modes (%d)",
+ ret);
+ } else {
+ ret = ev_fd_update(disp->dp_fd, EV_READABLE);
+ if (ret)
+ log_warning("cannot update wayland-fd event-polling modes (%d)",
+ ret);
+ }
+}
- ret = ev_fd_update(disp->dp_fd, mode);
- if (ret)
- log_warning("cannot update wayland-fd event-polling modes (%d)",
- ret);
+static void dp_pre_event(struct ev_eloop *eloop, void *unused, void *data)
+{
+ struct wlt_display *disp = data;
- return 0;
+ dp_dispatch(disp, true);
}
static void dp_event(struct ev_fd *fd, int mask, void *data)
{
struct wlt_display *disp = data;
- int mode;
if (mask & (EV_HUP | EV_ERR)) {
log_warning("HUP/ERR on wayland socket");
return;
}
- mode = 0;
if (mask & EV_READABLE)
- mode |= WL_DISPLAY_READABLE;
- if (mask & EV_WRITEABLE)
- mode |= WL_DISPLAY_WRITABLE;
-
- if (mode)
- wl_display_iterate(disp->dp, mode);
+ dp_dispatch(disp, false);
+ else
+ dp_dispatch(disp, true);
}
static void pointer_enter(void *data, struct wl_pointer *w_pointer,
return;
}
- disp->xkb_keymap = xkb_map_new_from_string(disp->xkb_ctx, map,
- XKB_KEYMAP_FORMAT_TEXT_V1,
- 0);
+ disp->xkb_keymap = xkb_keymap_new_from_string(disp->xkb_ctx, map,
+ XKB_KEYMAP_FORMAT_TEXT_V1,
+ 0);
munmap(map, size);
close(fd);
disp->xkb_state = xkb_state_new(disp->xkb_keymap);
if (!disp->xkb_state) {
log_error("cannot create XKB state object");
- xkb_map_unref(disp->xkb_keymap);
+ xkb_keymap_unref(disp->xkb_keymap);
disp->xkb_keymap = NULL;
return;
}
return;
mask = shl_get_xkb_mods(disp->xkb_state);
- num_syms = xkb_key_get_syms(disp->xkb_state, code, &syms);
+ num_syms = xkb_state_key_get_syms(disp->xkb_state, code, &syms);
ascii = shl_get_ascii(disp->xkb_state, code, syms, num_syms);
sym = XKB_KEY_NoSymbol;
if (num_syms == 1)
}
}
- if (state == WL_KEYBOARD_KEY_STATE_RELEASED &&
- sym == disp->repeat_sym) {
+ if (state == WL_KEYBOARD_KEY_STATE_RELEASED) {
ev_timer_update(disp->repeat_timer, NULL);
} else if (state == WL_KEYBOARD_KEY_STATE_PRESSED) {
disp->repeat_sym = sym;
.capabilities = seat_capabilities,
};
-static void dp_global(struct wl_display *dp, uint32_t id, const char *iface,
- uint32_t version, void *data)
+static void dp_global(void *data, struct wl_registry *registry, uint32_t id,
+ const char *iface, uint32_t version)
{
struct wlt_display *disp = data;
log_error("global wl_compositor advertised twice");
return;
}
- disp->w_comp = wl_display_bind(disp->dp,
- id,
- &wl_compositor_interface);
+ disp->w_comp = wl_registry_bind(disp->w_registry,
+ id,
+ &wl_compositor_interface,
+ 1);
if (!disp->w_comp) {
log_error("cannot bind wl_compositor object");
return;
log_error("global wl_seat advertised twice");
return;
}
- disp->w_seat = wl_display_bind(disp->dp,
- id,
- &wl_seat_interface);
+ disp->w_seat = wl_registry_bind(disp->w_registry,
+ id,
+ &wl_seat_interface,
+ 1);
if (!disp->w_seat) {
log_error("cannot bind wl_seat object");
return;
log_error("global wl_shell advertised twice");
return;
}
- disp->w_shell = wl_display_bind(disp->dp,
- id,
- &wl_shell_interface);
+ disp->w_shell = wl_registry_bind(disp->w_registry,
+ id,
+ &wl_shell_interface,
+ 1);
if (!disp->w_shell) {
log_error("cannot bind wl_shell object");
return;
log_error("global wl_shm advertised twice");
return;
}
- disp->w_shm = wl_display_bind(disp->dp,
- id,
- &wl_shm_interface);
+ disp->w_shm = wl_registry_bind(disp->w_registry,
+ id,
+ &wl_shm_interface,
+ 1);
if (!disp->w_shm) {
log_error("cannot bind wl_shm object");
return;
log_error("global wl_data_device_manager advertised twice");
return;
}
- disp->w_manager = wl_display_bind(disp->dp, id,
- &wl_data_device_manager_interface);
+ disp->w_manager = wl_registry_bind(disp->w_registry,
+ id,
+ &wl_data_device_manager_interface,
+ 1);
if (!disp->w_manager) {
log_error("cannot bind wl_data_device_manager_object");
return;
check_ready(disp);
}
+static const struct wl_registry_listener registry_listener = {
+ .global = dp_global,
+ /* TODO: handle .global_remove */
+};
+
int wlt_display_new(struct wlt_display **out,
struct ev_eloop *eloop)
{
struct wlt_display *disp;
- int ret;
+ int ret, fd;
if (!out || !eloop)
return -EINVAL;
goto err_listener;
}
+ fd = wl_display_get_fd(disp->dp);
+ if (fd < 0) {
+ log_error("cannot retrieve wayland FD");
+ ret = -EFAULT;
+ goto err_dp;
+ }
+
+ /* TODO: nonblocking wl_display doesn't work, yet. fix that upstream */
+ /*
+ int set;
+ set = fcntl(fd, F_GETFL);
+ if (set < 0) {
+ log_error("cannot retrieve file flags for wayland FD (%d): %m",
+ errno);
+ ret = -EFAULT;
+ goto err_dp;
+ }
+
+ set |= O_NONBLOCK;
+ ret = fcntl(fd, F_SETFL, set);
+ if (ret) {
+ log_error("cannot set file flags for wayland FD (%d): %m",
+ errno);
+ ret = -EFAULT;
+ goto err_dp;
+ }*/
+
ret = ev_eloop_new_fd(eloop,
&disp->dp_fd,
- wl_display_get_fd(disp->dp,
- dp_mask_update,
- disp),
+ fd,
EV_READABLE,
dp_event,
disp);
goto err_dp;
}
+ ret = ev_eloop_register_pre_cb(eloop, dp_pre_event, disp);
+ if (ret) {
+ log_error("cannot register pre-cb (%d)", ret);
+ goto err_dp_fd;
+ }
+
ret = ev_eloop_new_timer(eloop, &disp->repeat_timer, NULL,
repeat_event, disp);
if (ret) {
log_error("cannot create repeat-timer");
- goto err_dp_fd;
+ goto err_pre_cb;
}
- disp->dp_listener = wl_display_add_global_listener(disp->dp,
- dp_global,
- disp);
- if (!disp->dp_listener) {
- log_error("cannot add wayland global listener (%d)", errno);
+ disp->w_registry = wl_display_get_registry(disp->dp);
+ if (!disp->w_registry) {
+ log_error("cannot get wayland registry object");
goto err_timer;
}
+ wl_registry_add_listener(disp->w_registry, ®istry_listener, disp);
+
disp->xkb_ctx = xkb_context_new(0);
if (!disp->xkb_ctx) {
log_error("cannot create XKB context");
err_timer:
ev_eloop_rm_timer(disp->repeat_timer);
+err_pre_cb:
+ ev_eloop_unregister_pre_cb(disp->eloop, dp_pre_event, disp);
err_dp_fd:
ev_eloop_rm_fd(disp->dp_fd);
err_dp:
return;
unload_cursors(disp);
- wl_display_remove_global_listener(disp->dp, disp->dp_listener);
wl_display_flush(disp->dp);
wl_display_disconnect(disp->dp);
ev_eloop_rm_timer(disp->repeat_timer);
+ ev_eloop_unregister_pre_cb(disp->eloop, dp_pre_event, disp);
ev_eloop_rm_fd(disp->dp_fd);
xkb_context_unref(disp->xkb_ctx);
shl_hook_free(disp->listeners);
if (!disp)
return -EINVAL;
- return shl_hook_add_cast(disp->listeners, cb, data);
+ return shl_hook_add_cast(disp->listeners, cb, data, false);
}
void wlt_display_unregister_cb(struct wlt_display *disp,
wl_surface_damage(wnd->w_surface, 0, 0, wnd->buffer.width,
wnd->buffer.height);
+ wl_surface_commit(wnd->w_surface);
}
static int resize_window(struct wlt_window *wnd, unsigned int width,
- unsigned int height, bool force_redraw)
+ unsigned int height)
{
struct shl_dlist *iter;
struct wlt_widget *widget;
if (width == wnd->buffer.width &&
height == wnd->buffer.height) {
- if (force_redraw)
- wlt_window_do_redraw(wnd, width, height);
+ wlt_window_do_redraw(wnd, width, height);
return 0;
}
static void do_frame(struct wlt_window *wnd)
{
- bool force;
-
- wnd->idle_pending = false;
- ev_eloop_unregister_idle_cb(wnd->disp->eloop, idle_frame, wnd);
+ ev_eloop_unregister_idle_cb(wnd->disp->eloop, idle_frame, wnd,
+ EV_NORMAL);
if (wnd->need_resize) {
- force = wnd->need_redraw;
wnd->need_frame = true;
wnd->need_resize = false;
- wnd->need_redraw = false;
- resize_window(wnd, wnd->new_width, wnd->new_height, force);
- }
-
- if (wnd->need_redraw) {
+ wnd->w_frame = wl_surface_frame(wnd->w_surface);
+ wl_callback_add_listener(wnd->w_frame,
+ &frame_callback_listener, wnd);
+ resize_window(wnd, wnd->new_width, wnd->new_height);
+ } else {
wnd->need_frame = true;
- wnd->need_redraw = false;
- wlt_window_do_redraw(wnd, wnd->buffer.width,
- wnd->buffer.height);
- }
-
- if (wnd->need_frame) {
wnd->w_frame = wl_surface_frame(wnd->w_surface);
wl_callback_add_listener(wnd->w_frame,
&frame_callback_listener, wnd);
+ wlt_window_do_redraw(wnd, wnd->buffer.width,
+ wnd->buffer.height);
}
}
+static void schedule_frame(struct wlt_window *wnd);
+
static void frame_callback(void *data, struct wl_callback *w_callback,
uint32_t time)
{
wl_callback_destroy(w_callback);
wnd->w_frame = NULL;
- wnd->need_frame = false;
- do_frame(wnd);
+ wnd->idle_pending = false;
+ if (wnd->need_frame)
+ schedule_frame(wnd);
}
static void idle_frame(struct ev_eloop *eloop, void *unused, void *data)
{
int ret;
- if (!wnd || wnd->w_frame)
+ if (!wnd)
return;
- if (wnd->need_frame || wnd->idle_pending)
+ wnd->need_frame = true;
+
+ if (wnd->idle_pending)
return;
- ret = ev_eloop_register_idle_cb(wnd->disp->eloop, idle_frame, wnd);
+ ret = ev_eloop_register_idle_cb(wnd->disp->eloop, idle_frame, wnd,
+ EV_NORMAL);
if (ret)
log_error("cannot schedule idle callback: %d", ret);
else
{
struct wlt_window *wnd = data;
- ev_eloop_unregister_idle_cb(eloop, close_window, wnd);
+ ev_eloop_unregister_idle_cb(eloop, close_window, wnd, EV_NORMAL);
wnd->close_pending = false;
if (wnd->close_cb)
&shell_surface_listener, wnd);
wl_shell_surface_set_toplevel(wnd->w_shell_surface);
- ret = resize_window(wnd, width, height, true);
+ ret = resize_window(wnd, width, height);
if (ret)
goto err_shell_surface;
if (wnd->close_pending)
ev_eloop_unregister_idle_cb(wnd->disp->eloop, close_window,
- wnd);
+ wnd, EV_NORMAL);
if (wnd->idle_pending)
- ev_eloop_unregister_idle_cb(wnd->disp->eloop, idle_frame, wnd);
+ ev_eloop_unregister_idle_cb(wnd->disp->eloop, idle_frame, wnd,
+ EV_NORMAL);
shl_dlist_unlink(&wnd->list);
if (wnd->w_frame)
wl_callback_destroy(wnd->w_frame);
if (!wnd)
return;
- wnd->need_redraw = true;
schedule_frame(wnd);
}
wl_surface_damage(wnd->w_surface, damage->x, damage->y,
damage->width, damage->height);
+ wl_surface_commit(wnd->w_surface);
}
void wlt_window_get_buffer(struct wlt_window *wnd,
return;
wnd->close_pending = true;
- ev_eloop_register_idle_cb(wnd->disp->eloop, close_window, wnd);
+ ev_eloop_register_idle_cb(wnd->disp->eloop, close_window, wnd,
+ EV_NORMAL);
}
void wlt_window_toggle_maximize(struct wlt_window *wnd)
wnd->maximized = !wnd->maximized;
}
+bool wlt_window_is_maximized(struct wlt_window *wnd)
+{
+ return wnd && wnd->maximized;
+}
+
void wlt_window_toggle_fullscreen(struct wlt_window *wnd)
{
if (!wnd)
wnd->fullscreen = !wnd->fullscreen;
}
+bool wlt_window_is_fullscreen(struct wlt_window *wnd)
+{
+ return wnd && wnd->fullscreen;
+}
+
struct ev_eloop *wlt_window_get_eloop(struct wlt_window *wnd)
{
if (!wnd)
projects / platform / upstream / kmscon.git / blobdiff