X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Flibsystemd-terminal%2Fidev-evdev.c;h=25ac849b8d588028bbbf7f1ce509f69c4b3d422b;hb=6022343476982439dfc2e06bf54db78a0c8c6bff;hp=241743c3fdc7fafb0c9c5b2eabbd2acd88cabb16;hpb=667b60341f404d8f18aa0909e34d39e7d6baa56b;p=elogind.git diff --git a/src/libsystemd-terminal/idev-evdev.c b/src/libsystemd-terminal/idev-evdev.c index 241743c3f..25ac849b8 100644 --- a/src/libsystemd-terminal/idev-evdev.c +++ b/src/libsystemd-terminal/idev-evdev.c @@ -49,6 +49,7 @@ struct idev_evdev { bool unsync : 1; /* not in-sync with kernel */ bool resync : 1; /* re-syncing with kernel */ + bool running : 1; }; struct unmanaged_evdev { @@ -268,6 +269,12 @@ static void idev_evdev_enable(idev_evdev *evdev) { assert(evdev->fd_src); assert(evdev->idle_src); + if (evdev->running) + return; + if (evdev->fd < 0 || evdev->element.n_open < 1 || !evdev->element.enabled) + return; + + evdev->running = true; sd_event_source_set_enabled(evdev->fd_src, SD_EVENT_ON); sd_event_source_set_enabled(evdev->idle_src, SD_EVENT_ONESHOT); } @@ -277,6 +284,10 @@ static void idev_evdev_disable(idev_evdev *evdev) { assert(evdev->fd_src); assert(evdev->idle_src); + if (!evdev->running) + return; + + evdev->running = false; sd_event_source_set_enabled(evdev->fd_src, SD_EVENT_OFF); sd_event_source_set_enabled(evdev->idle_src, SD_EVENT_OFF); } @@ -288,9 +299,7 @@ static int idev_evdev_resume(idev_evdev *evdev, int dev_fd) { if (fd < 0 || evdev->fd == fd) { fd = -1; - if (evdev->fd >= 0 && e->n_open > 0 && e->enabled) - idev_evdev_enable(evdev); - + idev_evdev_enable(evdev); return 0; } @@ -314,11 +323,7 @@ static int idev_evdev_resume(idev_evdev *evdev, int dev_fd) { return -EACCES; evdev->element.readable = true; - evdev->element.writable = true; - if (flags == O_RDONLY) - evdev->element.writable = false; - else if (flags == O_WRONLY) - evdev->element.readable = false; + evdev->element.writable = !(flags & O_RDONLY); /* * TODO: We *MUST* re-sync the device so we get a delta of the changed @@ -355,15 +360,14 @@ static int idev_evdev_resume(idev_evdev *evdev, int dev_fd) { return r; } - if (e->n_open < 1 || !e->enabled) { - sd_event_source_set_enabled(evdev->fd_src, SD_EVENT_OFF); - sd_event_source_set_enabled(evdev->idle_src, SD_EVENT_OFF); - } + sd_event_source_set_enabled(evdev->fd_src, SD_EVENT_OFF); + sd_event_source_set_enabled(evdev->idle_src, SD_EVENT_OFF); evdev->unsync = true; evdev->fd = fd; - fd = -1; + + idev_evdev_enable(evdev); return 0; } @@ -375,12 +379,11 @@ static void idev_evdev_pause(idev_evdev *evdev, bool release) { log_debug("idev-evdev: %s/%s: pause", e->session->name, e->name); + idev_evdev_disable(evdev); if (release) { evdev->idle_src = sd_event_source_unref(evdev->idle_src); evdev->fd_src = sd_event_source_unref(evdev->fd_src); evdev->fd = safe_close(evdev->fd); - } else { - idev_evdev_disable(evdev); } } @@ -858,7 +861,6 @@ static int managed_evdev_new(idev_element **out, idev_session *s, struct udev_de int r; assert_return(s, -EINVAL); - assert_return(s->context->sysbus, -EINVAL); assert_return(s->managed, -EINVAL); assert_return(s->context->sysbus, -EINVAL); assert_return(ud, -EINVAL);