diff options
author | Scott Anderson <ascent12@hotmail.com> | 2017-08-26 14:02:04 +1200 |
---|---|---|
committer | Scott Anderson <ascent12@hotmail.com> | 2017-08-26 14:02:04 +1200 |
commit | fb93628bda0cb7750628e227213a1ddc2ae34be9 (patch) | |
tree | fbf3e2aa08594ad6f30dfdc51089a5309ad1a597 /backend | |
parent | 46823152ea5e2d0f888fa25ba6b4b1896e4e89b9 (diff) |
Merge wlr_udev into wlr_session
Diffstat (limited to 'backend')
-rw-r--r-- | backend/backend.c | 19 | ||||
-rw-r--r-- | backend/drm/backend.c | 9 | ||||
-rw-r--r-- | backend/libinput/backend.c | 8 | ||||
-rw-r--r-- | backend/meson.build | 1 | ||||
-rw-r--r-- | backend/multi/backend.c | 6 | ||||
-rw-r--r-- | backend/session/direct.c | 2 | ||||
-rw-r--r-- | backend/session/logind.c | 2 | ||||
-rw-r--r-- | backend/session/session.c | 273 | ||||
-rw-r--r-- | backend/udev.c | 252 |
9 files changed, 276 insertions, 296 deletions
diff --git a/backend/backend.c b/backend/backend.c index 9a3fd036..88b9dfbc 100644 --- a/backend/backend.c +++ b/backend/backend.c @@ -12,7 +12,6 @@ #include <wlr/backend/wayland.h> #include <wlr/backend/multi.h> #include <wlr/util/log.h> -#include "backend/udev.h" void wlr_backend_init(struct wlr_backend *backend, const struct wlr_backend_impl *impl) { @@ -91,29 +90,23 @@ struct wlr_backend *wlr_backend_autocreate(struct wl_display *display) { return NULL; } - struct wlr_udev *udev = wlr_udev_create(display); - if (!udev) { - wlr_log(L_ERROR, "Failed to start udev"); - goto error_session; - } - - int gpu = wlr_udev_find_gpu(udev, session); + int gpu = wlr_session_find_gpu(session); if (gpu == -1) { wlr_log(L_ERROR, "Failed to open DRM device"); - goto error_udev; + goto error_session; } - backend = wlr_multi_backend_create(session, udev); + backend = wlr_multi_backend_create(session); if (!backend) { goto error_gpu; } - struct wlr_backend *libinput = wlr_libinput_backend_create(display, session, udev); + struct wlr_backend *libinput = wlr_libinput_backend_create(display, session); if (!libinput) { goto error_multi; } - struct wlr_backend *drm = wlr_drm_backend_create(display, session, udev, gpu); + struct wlr_backend *drm = wlr_drm_backend_create(display, session, gpu); if (!drm) { goto error_libinput; } @@ -128,8 +121,6 @@ error_multi: wlr_backend_destroy(backend); error_gpu: wlr_session_close_file(session, gpu); -error_udev: - wlr_udev_destroy(udev); error_session: wlr_session_destroy(session); return NULL; diff --git a/backend/drm/backend.c b/backend/drm/backend.c index a84130ee..68e73268 100644 --- a/backend/drm/backend.c +++ b/backend/drm/backend.c @@ -13,7 +13,6 @@ #include <wlr/util/list.h> #include <wlr/util/log.h> #include <wlr/egl.h> -#include "backend/udev.h" #include "backend/drm.h" static bool wlr_drm_backend_start(struct wlr_backend *_backend) { @@ -32,7 +31,6 @@ static void wlr_drm_backend_destroy(struct wlr_backend *_backend) { wlr_output_destroy(&output->output); } - wlr_udev_signal_remove(backend->udev, &backend->drm_invalidated); wlr_drm_renderer_free(&backend->renderer); wlr_drm_resources_free(backend); wlr_session_close_file(backend->session, backend->fd); @@ -84,8 +82,6 @@ static void session_signal(struct wl_listener *listener, void *data) { static void drm_invalidated(struct wl_listener *listener, void *data) { struct wlr_drm_backend *backend = wl_container_of(listener, backend, drm_invalidated); - struct wlr_udev *udev = data; - (void)udev; char *name = drmGetDeviceNameFromFd2(backend->fd); wlr_log(L_DEBUG, "%s invalidated", name); @@ -95,7 +91,7 @@ static void drm_invalidated(struct wl_listener *listener, void *data) { } struct wlr_backend *wlr_drm_backend_create(struct wl_display *display, - struct wlr_session *session, struct wlr_udev *udev, int gpu_fd) { + struct wlr_session *session, int gpu_fd) { assert(display && session && gpu_fd >= 0); char *name = drmGetDeviceNameFromFd2(gpu_fd); @@ -112,7 +108,6 @@ struct wlr_backend *wlr_drm_backend_create(struct wl_display *display, wlr_backend_init(&backend->backend, &backend_impl); backend->session = session; - backend->udev = udev; backend->outputs = list_create(); if (!backend->outputs) { wlr_log(L_ERROR, "Failed to allocate list"); @@ -128,7 +123,7 @@ struct wlr_backend *wlr_drm_backend_create(struct wl_display *display, backend->dev = st.st_rdev; backend->drm_invalidated.notify = drm_invalidated; - wlr_udev_signal_add(udev, backend->dev, &backend->drm_invalidated); + wlr_session_signal_add(session, gpu_fd, &backend->drm_invalidated); backend->display = display; struct wl_event_loop *event_loop = wl_display_get_event_loop(display); diff --git a/backend/libinput/backend.c b/backend/libinput/backend.c index 5dd93f47..3d3c90ce 100644 --- a/backend/libinput/backend.c +++ b/backend/libinput/backend.c @@ -4,7 +4,6 @@ #include <wlr/backend/session.h> #include <wlr/backend/interface.h> #include <wlr/util/log.h> -#include "backend/udev.h" #include "backend/libinput.h" static int wlr_libinput_open_restricted(const char *path, @@ -47,7 +46,7 @@ static bool wlr_libinput_backend_start(struct wlr_backend *_backend) { struct wlr_libinput_backend *backend = (struct wlr_libinput_backend *)_backend; wlr_log(L_DEBUG, "Initializing libinput"); backend->libinput_context = libinput_udev_create_context(&libinput_impl, backend, - backend->udev->udev); + backend->session->udev); if (!backend->libinput_context) { wlr_log(L_ERROR, "Failed to create libinput context"); return false; @@ -139,8 +138,8 @@ static void session_signal(struct wl_listener *listener, void *data) { } struct wlr_backend *wlr_libinput_backend_create(struct wl_display *display, - struct wlr_session *session, struct wlr_udev *udev) { - assert(display && session && udev); + struct wlr_session *session) { + assert(display && session); struct wlr_libinput_backend *backend = calloc(1, sizeof(struct wlr_libinput_backend)); if (!backend) { @@ -155,7 +154,6 @@ struct wlr_backend *wlr_libinput_backend_create(struct wl_display *display, } backend->session = session; - backend->udev = udev; backend->display = display; backend->session_signal.notify = session_signal; diff --git a/backend/meson.build b/backend/meson.build index 6a6a5f9f..fcff55b6 100644 --- a/backend/meson.build +++ b/backend/meson.build @@ -1,6 +1,5 @@ backend_files = files( 'backend.c', - 'udev.c', 'session/direct-ipc.c', 'session/direct.c', 'session/session.c', diff --git a/backend/multi/backend.c b/backend/multi/backend.c index 9bb596e5..5f745c40 100644 --- a/backend/multi/backend.c +++ b/backend/multi/backend.c @@ -2,7 +2,6 @@ #include <stdbool.h> #include <stdlib.h> #include <wlr/backend/interface.h> -#include <wlr/backend/udev.h> #include <wlr/backend/session.h> #include <wlr/util/log.h> #include "backend/multi.h" @@ -37,7 +36,6 @@ static void multi_backend_destroy(struct wlr_backend *_backend) { } list_free(backend->backends); wlr_session_destroy(backend->session); - wlr_udev_destroy(backend->udev); free(backend); } @@ -59,8 +57,7 @@ struct wlr_backend_impl backend_impl = { .get_egl = multi_backend_get_egl }; -struct wlr_backend *wlr_multi_backend_create(struct wlr_session *session, - struct wlr_udev *udev) { +struct wlr_backend *wlr_multi_backend_create(struct wlr_session *session) { struct wlr_multi_backend *backend = calloc(1, sizeof(struct wlr_multi_backend)); if (!backend) { @@ -78,7 +75,6 @@ struct wlr_backend *wlr_multi_backend_create(struct wlr_session *session, wlr_backend_init(&backend->backend, &backend_impl); backend->session = session; - backend->udev = udev; return &backend->backend; } diff --git a/backend/session/direct.c b/backend/session/direct.c index 0a08bfd6..4eff10e1 100644 --- a/backend/session/direct.c +++ b/backend/session/direct.c @@ -223,8 +223,6 @@ static struct wlr_session *direct_session_create(struct wl_display *disp) { snprintf(session->base.seat, sizeof(session->base.seat), "%s", seat); session->base.drm_fd = -1; session->base.impl = &session_direct; - session->base.active = true; - wl_signal_init(&session->base.session_signal); return &session->base; error_ipc: diff --git a/backend/session/logind.c b/backend/session/logind.c index 6b93ff67..c5465936 100644 --- a/backend/session/logind.c +++ b/backend/session/logind.c @@ -376,8 +376,6 @@ static struct wlr_session *logind_session_create(struct wl_display *disp) { session->base.drm_fd = -1; session->base.impl = &session_logind; - session->base.active = true; - wl_signal_init(&session->base.session_signal); return &session->base; error_bus: diff --git a/backend/session/session.c b/backend/session/session.c index 24a1f538..26b9aa92 100644 --- a/backend/session/session.c +++ b/backend/session/session.c @@ -1,9 +1,25 @@ +#include <assert.h> #include <stddef.h> #include <stdarg.h> +#include <stdlib.h> +#include <sys/stat.h> +#include <sys/types.h> +#include <libudev.h> +#include <wayland-server.h> +#include <xf86drm.h> +#include <xf86drmMode.h> #include <wlr/backend/session.h> #include <wlr/backend/session/interface.h> #include <wlr/util/log.h> +struct device { + int fd; + dev_t dev; + struct wl_signal signal; + + struct wl_list link; +}; + extern const struct session_impl session_logind; extern const struct session_impl session_direct; @@ -15,17 +31,88 @@ static const struct session_impl *impls[] = { NULL, }; +static int udev_event(int fd, uint32_t mask, void *data) { + struct wlr_session *session = data; + + struct udev_device *udev_dev = udev_monitor_receive_device(session->mon); + if (!udev_dev) { + return 1; + } + + const char *action = udev_device_get_action(udev_dev); + + wlr_log(L_DEBUG, "udev event for %s (%s)", + udev_device_get_sysname(udev_dev), action); + + if (!action || strcmp(action, "change") != 0) { + goto out; + } + + dev_t devnum = udev_device_get_devnum(udev_dev); + struct device *dev; + + wl_list_for_each(dev, &session->devices, link) { + if (dev->dev == devnum) { + wl_signal_emit(&dev->signal, session); + break; + } + } + +out: + udev_device_unref(udev_dev); + return 1; +} + struct wlr_session *wlr_session_create(struct wl_display *disp) { + struct wlr_session *session = NULL; const struct session_impl **iter; - for (iter = impls; *iter; ++iter) { - struct wlr_session *session = (*iter)->create(disp); - if (session) { - return session; - } + for (iter = impls; !session && *iter; ++iter) { + session = (*iter)->create(disp); + } + + if (!session) { + wlr_log(L_ERROR, "Failed to load session backend"); + return NULL; + } + + session->active = true; + wl_signal_init(&session->session_signal); + wl_list_init(&session->devices); + + session->udev = udev_new(); + if (!session->udev) { + wlr_log_errno(L_ERROR, "Failed to create udev context"); + goto error_session; } - wlr_log(L_ERROR, "Failed to load session backend"); + session->mon = udev_monitor_new_from_netlink(session->udev, "udev"); + if (!session->mon) { + wlr_log_errno(L_ERROR, "Failed to create udev monitor"); + goto error_udev; + } + + udev_monitor_filter_add_match_subsystem_devtype(session->mon, "drm", NULL); + udev_monitor_enable_receiving(session->mon); + + struct wl_event_loop *event_loop = wl_display_get_event_loop(disp); + int fd = udev_monitor_get_fd(session->mon); + + session->udev_event = wl_event_loop_add_fd(event_loop, fd, + WL_EVENT_READABLE, udev_event, session); + if (!session->udev_event) { + wlr_log_errno(L_ERROR, "Failed to create udev event source"); + goto error_mon; + } + + return session; + +error_mon: + udev_monitor_unref(session->mon); +error_udev: + udev_unref(session->udev); +error_session: + wlr_session_destroy(session); return NULL; } @@ -34,15 +121,69 @@ void wlr_session_destroy(struct wlr_session *session) { return; } + wl_event_source_remove(session->udev_event); + udev_monitor_unref(session->mon); + udev_unref(session->udev); + session->impl->destroy(session); -}; +} int wlr_session_open_file(struct wlr_session *session, const char *path) { - return session->impl->open(session, path); + int fd = session->impl->open(session, path); + if (fd < 0) { + return fd; + } + + struct device *dev = malloc(sizeof(*dev)); + if (!dev) { + wlr_log_errno(L_ERROR, "Allocation failed"); + goto error; + } + + struct stat st; + if (fstat(fd, &st) < 0) { + wlr_log_errno(L_ERROR, "Stat failed"); + goto error; + } + + dev->fd = fd; + dev->dev = st.st_rdev; + wl_signal_init(&dev->signal); + wl_list_insert(&session->devices, &dev->link); + + return fd; + +error: + free(dev); + return fd; +} + +static struct device *find_device(struct wlr_session *session, int fd) { + struct device *dev; + + wl_list_for_each(dev, &session->devices, link) { + if (dev->fd == fd) { + return dev; + } + } + + wlr_log(L_ERROR, "Tried to use fd %d not opened by session", fd); + assert(0); } void wlr_session_close_file(struct wlr_session *session, int fd) { + struct device *dev = find_device(session, fd); + session->impl->close(session, fd); + wl_list_remove(&dev->link); + free(dev); +} + +void wlr_session_signal_add(struct wlr_session *session, int fd, + struct wl_listener *listener) { + struct device *dev = find_device(session, fd); + + wl_signal_add(&dev->signal, listener); } bool wlr_session_change_vt(struct wlr_session *session, unsigned vt) { @@ -52,3 +193,119 @@ bool wlr_session_change_vt(struct wlr_session *session, unsigned vt) { return session->impl->change_vt(session, vt); } + +/* Tests if 'path' is KMS compatible by trying to open it. + * It leaves the open device in *fd_out it it succeeds. + */ +static bool device_is_kms(struct wlr_session *restrict session, + const char *restrict path, int *restrict fd_out) { + + int fd; + + if (!path) { + return false; + } + + fd = wlr_session_open_file(session, path); + if (fd < 0) { + return false; + } + + drmModeRes *res = drmModeGetResources(fd); + if (!res) { + goto out_fd; + } + + if (res->count_crtcs <= 0 || res->count_connectors <= 0 || + res->count_encoders <= 0) { + + goto out_res; + } + + if (*fd_out >= 0) { + wlr_session_close_file(session, *fd_out); + } + + *fd_out = fd; + + drmModeFreeResources(res); + return true; + +out_res: + drmModeFreeResources(res); +out_fd: + wlr_session_close_file(session, fd); + return false; +} + +/* Tries to find the primary GPU by checking for the "boot_vga" attribute. + * If it's not found, it returns the first valid GPU it finds. + */ +int wlr_session_find_gpu(struct wlr_session *session) { + struct udev_enumerate *en = udev_enumerate_new(session->udev); + if (!en) { + wlr_log(L_ERROR, "Failed to create udev enumeration"); + return -1; + } + + udev_enumerate_add_match_subsystem(en, "drm"); + udev_enumerate_add_match_sysname(en, "card[0-9]*"); + udev_enumerate_scan_devices(en); + + struct udev_list_entry *entry; + int fd = -1; + + udev_list_entry_foreach(entry, udev_enumerate_get_list_entry(en)) { + bool is_boot_vga = false; + + const char *path = udev_list_entry_get_name(entry); + struct udev_device *dev = udev_device_new_from_syspath(session->udev, path); + if (!dev) { + continue; + } + + /* + const char *seat = udev_device_get_property_value(dev, "ID_SEAT"); + if (!seat) + seat = "seat0"; + if (strcmp(session->seat, seat) != 0) { + udev_device_unref(dev); + continue; + } + */ + + // This is owned by 'dev', so we don't need to free it + struct udev_device *pci = + udev_device_get_parent_with_subsystem_devtype(dev, "pci", NULL); + + if (pci) { + const char *id = udev_device_get_sysattr_value(pci, "boot_vga"); + if (id && strcmp(id, "1") == 0) { + is_boot_vga = true; + } + } + + // We already have a valid GPU + if (!is_boot_vga && fd >= 0) { + udev_device_unref(dev); + continue; + } + + path = udev_device_get_devnode(dev); + if (!device_is_kms(session, path, &fd)) { + udev_device_unref(dev); + continue; + } + + udev_device_unref(dev); + + // We've found the primary GPU + if (is_boot_vga) { + break; + } + } + + udev_enumerate_unref(en); + + return fd; +} diff --git a/backend/udev.c b/backend/udev.c deleted file mode 100644 index a2492172..00000000 --- a/backend/udev.c +++ /dev/null @@ -1,252 +0,0 @@ -#define _POSIX_C_SOURCE 200809L -#include <libudev.h> -#include <stdbool.h> -#include <stdlib.h> -#include <string.h> -#include <stdint.h> -#include <errno.h> -#include <xf86drm.h> -#include <xf86drmMode.h> -#include <wayland-server.h> -#include <wlr/backend/session.h> -#include <wlr/util/log.h> -#include "backend/udev.h" - -/* Tests if 'path' is KMS compatible by trying to open it. - * It leaves the open device in *fd_out it it succeeds. - */ -static bool device_is_kms(struct wlr_session *restrict session, - const char *restrict path, int *restrict fd_out) { - - int fd; - - if (!path) { - return false; - } - - fd = wlr_session_open_file(session, path); - if (fd < 0) { - return false; - } - - drmModeRes *res = drmModeGetResources(fd); - if (!res) { - goto out_fd; - } - - if (res->count_crtcs <= 0 || res->count_connectors <= 0 || - res->count_encoders <= 0) { - - goto out_res; - } - - if (*fd_out >= 0) { - wlr_session_close_file(session, *fd_out); - } - - *fd_out = fd; - - drmModeFreeResources(res); - return true; - -out_res: - drmModeFreeResources(res); -out_fd: - wlr_session_close_file(session, fd); - return false; -} - -/* Tries to find the primary GPU by checking for the "boot_vga" attribute. - * If it's not found, it returns the first valid GPU it finds. - */ -int wlr_udev_find_gpu(struct wlr_udev *udev, struct wlr_session *session) { - struct udev_enumerate *en = udev_enumerate_new(udev->udev); - if (!en) { - wlr_log(L_ERROR, "Failed to create udev enumeration"); - return -1; - } - - udev_enumerate_add_match_subsystem(en, "drm"); - udev_enumerate_add_match_sysname(en, "card[0-9]*"); - udev_enumerate_scan_devices(en); - - struct udev_list_entry *entry; - int fd = -1; - - udev_list_entry_foreach(entry, udev_enumerate_get_list_entry(en)) { - bool is_boot_vga = false; - - const char *path = udev_list_entry_get_name(entry); - struct udev_device *dev = udev_device_new_from_syspath(udev->udev, path); - if (!dev) { - continue; - } - - /* - const char *seat = udev_device_get_property_value(dev, "ID_SEAT"); - if (!seat) - seat = "seat0"; - if (strcmp(session->seat, seat) != 0) { - udev_device_unref(dev); - continue; - } - */ - - // This is owned by 'dev', so we don't need to free it - struct udev_device *pci = - udev_device_get_parent_with_subsystem_devtype(dev, "pci", NULL); - - if (pci) { - const char *id = udev_device_get_sysattr_value(pci, "boot_vga"); - if (id && strcmp(id, "1") == 0) { - is_boot_vga = true; - } - } - - // We already have a valid GPU - if (!is_boot_vga && fd >= 0) { - udev_device_unref(dev); - continue; - } - - path = udev_device_get_devnode(dev); - if (!device_is_kms(session, path, &fd)) { - udev_device_unref(dev); - continue; - } - - udev_device_unref(dev); - - // We've found the primary GPU - if (is_boot_vga) { - break; - } - } - - udev_enumerate_unref(en); - - return fd; -} - -static int udev_event(int fd, uint32_t mask, void *data) { - struct wlr_udev *udev = data; - - struct udev_device *dev = udev_monitor_receive_device(udev->mon); - if (!dev) { - return 1; - } - - const char *action = udev_device_get_action(dev); - - wlr_log(L_DEBUG, "udev event for %s (%s)", - udev_device_get_sysname(dev), action); - - if (!action || strcmp(action, "change") != 0) { - goto out; - } - - dev_t devnum = udev_device_get_devnum(dev); - struct wlr_udev_dev *signal; - - wl_list_for_each(signal, &udev->devices, link) { - if (signal->dev == devnum) { - wl_signal_emit(&signal->invalidate, udev); - break; - } - } - -out: - udev_device_unref(dev); - return 1; -} - -struct wlr_udev *wlr_udev_create(struct wl_display *display) { - struct wlr_udev *udev = calloc(sizeof(struct wlr_udev), 1); - if (!udev) { - return NULL; - } - udev->udev = udev_new(); - if (!udev->udev) { - wlr_log(L_ERROR, "Failed to create udev context"); - goto error; - } - - udev->mon = udev_monitor_new_from_netlink(udev->udev, "udev"); - if (!udev->mon) { - wlr_log(L_ERROR, "Failed to create udev monitor"); - goto error_udev; - } - - udev_monitor_filter_add_match_subsystem_devtype(udev->mon, "drm", NULL); - udev_monitor_enable_receiving(udev->mon); - - struct wl_event_loop *event_loop = wl_display_get_event_loop(display); - int fd = udev_monitor_get_fd(udev->mon); - - udev->event = wl_event_loop_add_fd(event_loop, fd, WL_EVENT_READABLE, - udev_event, udev); - if (!udev->event) { - wlr_log(L_ERROR, "Failed to create udev event source"); - goto error_mon; - } - - wl_list_init(&udev->devices); - - wlr_log(L_DEBUG, "Successfully initialized udev"); - return udev; - -error_mon: - udev_monitor_unref(udev->mon); -error_udev: - udev_unref(udev->udev); -error: - free(udev); - return NULL; -} - -void wlr_udev_destroy(struct wlr_udev *udev) { - if (!udev) { - return; - } - - struct wlr_udev_dev *dev, *tmp; - wl_list_for_each_safe(dev, tmp, &udev->devices, link) { - free(dev); - } - - wl_event_source_remove(udev->event); - udev_monitor_unref(udev->mon); - udev_unref(udev->udev); - free(udev); -} - -bool wlr_udev_signal_add(struct wlr_udev *udev, dev_t dev, struct wl_listener *listener) { - struct wlr_udev_dev *device = malloc(sizeof(*device)); - if (!device) { - wlr_log(L_ERROR, "Allocation failed: %s", strerror(errno)); - return false; - } - - device->dev = dev; - wl_signal_init(&device->invalidate); - wl_signal_add(&device->invalidate, listener); - wl_list_insert(&udev->devices, &device->link); - - return true; -} - -void wlr_udev_signal_remove(struct wlr_udev *udev, struct wl_listener *listener) { - if (!udev || !listener) { - return; - } - - struct wlr_udev_dev *dev, *tmp; - wl_list_for_each_safe(dev, tmp, &udev->devices, link) { - // The signal should only have a single listener - if (wl_signal_get(&dev->invalidate, listener->notify) != NULL) { - wl_list_remove(&dev->link); - free(dev); - return; - } - } -} |