Merge lp:~raof/mir/wayland-input-fixes into lp:mir

[Chris Halse Rogers]

Wayland: Fix lifetimes of wrapper objects.

This prevents client disconnects/reconnects from crashing the server, which is good.

[Mir CI Bot (mir-ci-bot)]

FAILED: Continuous integration, rev:4276
https://mir-jenkins.ubuntu.com/job/mir-ci/3685/
Executed test runs:
    FAILURE: https://mir-jenkins.ubuntu.com/job/build-mir/5052/console
    SUCCESS: https://mir-jenkins.ubuntu.com/job/build-0-fetch/5288
    SUCCESS: https://mir-jenkins.ubuntu.com/job/build-1-sourcepkg/release=artful/5276
    SUCCESS: https://mir-jenkins.ubuntu.com/job/build-1-sourcepkg/release=xenial/5276
    SUCCESS: https://mir-jenkins.ubuntu.com/job/build-1-sourcepkg/release=zesty/5276
    ABORTED: https://mir-jenkins.ubuntu.com/job/build-2-binpkg-mir/arch=amd64,compiler=clang,platform=mesa,release=artful/5096/console
    ABORTED: https://mir-jenkins.ubuntu.com/job/build-2-binpkg-mir/arch=amd64,compiler=clang,platform=mesa,release=zesty/5096/console
    ABORTED: https://mir-jenkins.ubuntu.com/job/build-2-binpkg-mir/arch=cross-armhf,compiler=gcc,platform=mesa,release=artful/5096/console
    FAILURE: https://mir-jenkins.ubuntu.com/job/build-2-binpkg-mir/arch=i386,compiler=gcc,platform=mesa,release=xenial/5096/console

Click here to trigger a rebuild:
https://mir-jenkins.ubuntu.com/job/mir-ci/3685/rebuild

review: Needs Fixing (continuous-integration)

=== modified file 'debian/control'
--- debian/control	2017-09-13 04:15:28 +0000
+++ debian/control	2017-09-25 18:25:28 +0000
@@ -47,6 +47,7 @@
                capnproto,
                libepoxy-dev,
                python3-pil:native,
+               linux-libc-dev,
 Standards-Version: 3.9.4
 Homepage: https://launchpad.net/mir
 # If you aren't a member of ~mir-team but need to upload packaging changes,
 
=== added file 'include/client/mir/client/event.h'
--- include/client/mir/client/event.h	1970-01-01 00:00:00 +0000
+++ include/client/mir/client/event.h	2017-09-25 18:25:28 +0000
@@ -0,0 +1,54 @@
+/*
+ * Copyright © 2017 Canonical Ltd.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License version 2 or 3 as
+ * published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ * Authored by: Christopher James Halse Rogers <[e-mail]>
+ */
+
+#ifndef MIR_CLIENT_EVENT_H_
+#define MIR_CLIENT_EVENT_H_
+
+#include "mir_toolkit/events/event.h"
+
+#include <memory>
+
+namespace mir
+{
+namespace client
+{
+/// Handle class for MirEvent - provides automatic reference counting.
+class Event
+{
+public:
+    Event() = default;
+    explicit Event(MirEvent const* event) : self{mir_event_ref(event), deleter}
+    {
+    }
+
+    operator MirEvent const*() const { return self.get(); }
+
+    void reset() { self.reset(); }
+
+private:
+    static void deleter(MirEvent const* event) { mir_event_unref(event); }
+    std::shared_ptr<MirEvent const> self;
+};
+
+// Provide a deleted overload to avoid double release "accidents".
+void mir_event_unref(Event const& event) = delete;
+}
+}
+
+#endif //MIR_CLIENT_EVENT_H_
+
 
=== modified file 'src/client/CMakeLists.txt'
--- src/client/CMakeLists.txt	2017-08-29 14:23:50 +0000
+++ src/client/CMakeLists.txt	2017-09-25 18:25:28 +0000
@@ -118,6 +118,7 @@
   ${CMAKE_SOURCE_DIR}/include/client/mir/client/connection.h
   ${CMAKE_SOURCE_DIR}/include/client/mir/client/display_config.h
   ${CMAKE_SOURCE_DIR}/include/client/mir/client/window.h
+  ${CMAKE_SOURCE_DIR}/include/client/mir/client/event.h
 )
 
 # Ensure protobuf C++ headers have been produced before
 
=== modified file 'src/protocol/wrapper_generator.cpp'
--- src/protocol/wrapper_generator.cpp	2017-09-07 00:32:52 +0000
+++ src/protocol/wrapper_generator.cpp	2017-09-25 18:25:28 +0000
@@ -373,6 +373,16 @@
 
         if (!methods.empty())
         {
+            if (!is_global)
+            {
+                emit_indented_lines(out, "    ", {
+                    {"static void resource_destroyed_thunk(wl_resource* us)"},
+                    {"{"},
+                    {"    delete static_cast<", generated_name, "*>(wl_resource_get_user_data(us));"},
+                    {"}"}
+                });
+            }
+
             emit_indented_lines(out, "    ", {
                 { "static struct ", wl_name, "_interface const vtable;" }
             });
@@ -427,7 +437,7 @@
         if (has_vtable)
         {
             emit_indented_lines(out, indent + "    ",
-                {{ "wl_resource_set_implementation(resource, &vtable, this, nullptr);" }});
+                {{ "wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);" }});
         }
         emit_indented_lines(out, indent, {
             { "}" }
 
=== modified file 'src/server/frontend/wayland/core_generated_interfaces.h'
--- src/server/frontend/wayland/core_generated_interfaces.h	2017-09-07 00:33:43 +0000
+++ src/server/frontend/wayland/core_generated_interfaces.h	2017-09-25 18:25:28 +0000
@@ -108,7 +108,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~ShmPool() = default;
 
@@ -138,6 +138,10 @@
         me->resize(size);
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<ShmPool*>(wl_resource_get_user_data(us));
+    }
     static struct wl_shm_pool_interface const vtable;
 };
 
@@ -207,7 +211,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~Buffer() = default;
 
@@ -223,6 +227,10 @@
         me->destroy();
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<Buffer*>(wl_resource_get_user_data(us));
+    }
     static struct wl_buffer_interface const vtable;
 };
 
@@ -243,7 +251,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~DataOffer() = default;
 
@@ -293,6 +301,10 @@
         me->set_actions(dnd_actions, preferred_action);
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<DataOffer*>(wl_resource_get_user_data(us));
+    }
     static struct wl_data_offer_interface const vtable;
 };
 
@@ -317,7 +329,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~DataSource() = default;
 
@@ -347,6 +359,10 @@
         me->set_actions(dnd_actions);
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<DataSource*>(wl_resource_get_user_data(us));
+    }
     static struct wl_data_source_interface const vtable;
 };
 
@@ -369,7 +385,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~DataDevice() = default;
 
@@ -414,6 +430,10 @@
         me->release();
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<DataDevice*>(wl_resource_get_user_data(us));
+    }
     static struct wl_data_device_interface const vtable;
 };
 
@@ -536,7 +556,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~ShellSurface() = default;
 
@@ -625,6 +645,10 @@
         me->set_class(class_);
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<ShellSurface*>(wl_resource_get_user_data(us));
+    }
     static struct wl_shell_surface_interface const vtable;
 };
 
@@ -654,7 +678,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~Surface() = default;
 
@@ -748,6 +772,10 @@
         me->damage_buffer(x, y, width, height);
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<Surface*>(wl_resource_get_user_data(us));
+    }
     static struct wl_surface_interface const vtable;
 };
 
@@ -847,7 +875,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~Pointer() = default;
 
@@ -875,6 +903,10 @@
         me->release();
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<Pointer*>(wl_resource_get_user_data(us));
+    }
     static struct wl_pointer_interface const vtable;
 };
 
@@ -896,7 +928,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~Keyboard() = default;
 
@@ -912,6 +944,10 @@
         me->release();
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<Keyboard*>(wl_resource_get_user_data(us));
+    }
     static struct wl_keyboard_interface const vtable;
 };
 
@@ -932,7 +968,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~Touch() = default;
 
@@ -948,6 +984,10 @@
         me->release();
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<Touch*>(wl_resource_get_user_data(us));
+    }
     static struct wl_touch_interface const vtable;
 };
 
@@ -1014,7 +1054,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~Region() = default;
 
@@ -1044,6 +1084,10 @@
         me->subtract(x, y, width, height);
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<Region*>(wl_resource_get_user_data(us));
+    }
     static struct wl_region_interface const vtable;
 };
 
@@ -1120,7 +1164,7 @@
             wl_resource_post_no_memory(parent);
             BOOST_THROW_EXCEPTION((std::bad_alloc{}));
         }
-        wl_resource_set_implementation(resource, &vtable, this, nullptr);
+        wl_resource_set_implementation(resource, &vtable, this, &resource_destroyed_thunk);
     }
     virtual ~Subsurface() = default;
 
@@ -1171,6 +1215,10 @@
         me->set_desync();
     }
 
+    static void resource_destroyed_thunk(wl_resource* us)
+    {
+        delete static_cast<Subsurface*>(wl_resource_get_user_data(us));
+    }
     static struct wl_subsurface_interface const vtable;
 };
 
 
=== modified file 'src/server/frontend/wayland/wayland_connector.cpp'
--- src/server/frontend/wayland/wayland_connector.cpp	2017-09-22 15:49:10 +0000
+++ src/server/frontend/wayland/wayland_connector.cpp	2017-09-25 18:25:28 +0000
@@ -41,6 +41,8 @@
 
 #include "mir/executor.h"
 
+#include "mir/client/event.h"
+
 #include <system_error>
 #include <sys/eventfd.h>
 #include <wayland-server-core.h>
@@ -51,6 +53,7 @@
 #include <functional>
 #include <type_traits>
 
+#include <linux/input.h>
 #include <algorithm>
 #include <iostream>
 #include <mir/log.h>
@@ -69,6 +72,7 @@
 namespace mc = mir::compositor;
 namespace ms = mir::scene;
 namespace geom = mir::geometry;
+namespace mcl = mir::client;
 
 namespace mir
 {
@@ -559,7 +563,7 @@
 
 void WlSurface::destroy()
 {
-    delete this;
+    wl_resource_destroy(resource);
 }
 
 void WlSurface::attach(std::experimental::optional<wl_resource*> const& buffer, int32_t x, int32_t y)
@@ -741,6 +745,19 @@
 class WlPointer;
 class WlTouch;
 
+template<typename Callable>
+auto run_unless(std::shared_ptr<bool> const& condition, Callable&& callable)
+{
+    return
+        [callable = std::move(callable), condition]()
+        {
+            if (*condition)
+                return;
+
+            callable();
+        };
+}
+
 class WlKeyboard : public wayland::Keyboard
 {
 public:
@@ -748,16 +765,29 @@
         wl_client* client,
         wl_resource* parent,
         uint32_t id,
+        std::function<void(WlKeyboard*)> const& on_destroy,
         std::shared_ptr<mir::Executor> const& executor)
         : Keyboard(client, parent, id),
-          executor{executor}
-    {
+          executor{executor},
+          on_destroy{on_destroy},
+          destroyed{std::make_shared<bool>(false)}
+    {
+    }
+
+    ~WlKeyboard()
+    {
+        on_destroy(this);
+        *destroyed = true;
     }
 
     void handle_event(MirInputEvent const* event, wl_resource* /*target*/)
     {
-        executor->spawn(
-            [ev = mir_event_ref(mir_input_event_get_event(event)), this] ()
+        executor->spawn(run_unless(
+            destroyed,
+            [
+                ev = mcl::Event{mir_event_ref(mir_input_event_get_event(event))},
+                this
+            ] ()
             {
                 int const serial = wl_display_next_serial(wl_client_get_display(client));
                 auto event = mir_event_get_input_event(ev);
@@ -782,18 +812,22 @@
                     default:
                         break;
                 }
-                mir_event_unref(ev);
-            });
+            }));
     }
 
     void handle_event(MirWindowEvent const* event, wl_resource* target)
     {
         if (mir_window_event_get_attribute(event) == mir_window_attrib_focus)
         {
-            executor->spawn(
-               [resource = resource, serial = wl_display_next_serial(wl_client_get_display(client)),
-                target = target, focussed = mir_window_event_get_attribute_value(event)]()
+            executor->spawn(run_unless(
+                destroyed,
+                [
+                    target = target,
+                    focussed = mir_window_event_get_attribute_value(event),
+                    this
+                ]()
                 {
+                    auto const serial = wl_display_next_serial(wl_client_get_display(client));
                     if (focussed)
                     {
                         wl_array key_state;
@@ -805,18 +839,21 @@
                     {
                         wl_keyboard_send_leave(resource, serial, target);
                     }
-                });
+                }));
         }
     }
 
 private:
     std::shared_ptr<mir::Executor> const executor;
+    std::function<void(WlKeyboard*)> on_destroy;
+    std::shared_ptr<bool> const destroyed;
 
     void release() override;
 };
 
 void WlKeyboard::release()
 {
+    wl_resource_destroy(resource);
 }
 
 class WlPointer : public wayland::Pointer
@@ -827,17 +864,27 @@
         wl_client* client,
         wl_resource* parent,
         uint32_t id,
+        std::function<void(WlPointer*)> const& on_destroy,
         std::shared_ptr<mir::Executor> const& executor)
         : Pointer(client, parent, id),
           display{wl_client_get_display(client)},
-          executor{executor}
-    {
+          executor{executor},
+          on_destroy{on_destroy},
+          destroyed{std::make_shared<bool>(false)}
+    {
+    }
+
+    ~WlPointer()
+    {
+        on_destroy(this);
+        *destroyed = true;
     }
 
     void handle_event(MirInputEvent const* event, wl_resource* target)
     {
-        executor->spawn(
-            [ev = mir_event_ref(mir_input_event_get_event(event)), target, this]()
+        executor->spawn(run_unless(
+            destroyed,
+            [ev = mcl::Event{mir_input_event_get_event(event)}, target, this]()
             {
                 auto const serial = wl_display_next_serial(display);
                 auto const event = mir_event_get_input_event(ev);
@@ -851,25 +898,27 @@
                         auto const current_set  = mir_pointer_event_buttons(pointer_event);
                         auto const current_time = mir_input_event_get_event_time(event) / 1000;
 
-                        auto button = 272;  // No, I have *no* idea why GTK expects 272 to be the primary button.
-                        // NB button is incremented in the loop and the order mir_pointer_button_XXX matters
-                        for (auto mir_button :
-                            {mir_pointer_button_primary,    // 272
-                             mir_pointer_button_tertiary,   // 273
-                             mir_pointer_button_secondary,  // 274
-                             mir_pointer_button_back,       // 275
-                             mir_pointer_button_forward})   // 276
+                        std::unordered_map<MirPointerButton, int> const button_mappings = {
+                            {mir_pointer_button_primary, BTN_LEFT},
+                            {mir_pointer_button_secondary, BTN_RIGHT},
+                            {mir_pointer_button_tertiary, BTN_MIDDLE},
+                            {mir_pointer_button_back, BTN_BACK},
+                            {mir_pointer_button_forward, BTN_FORWARD},
+                            {mir_pointer_button_side, BTN_SIDE},
+                            {mir_pointer_button_task, BTN_TASK},
+                            {mir_pointer_button_extra, BTN_EXTRA}
+                        };
+
+                        for (auto mapping : button_mappings)
                         {
-                            if (mir_button & (current_set ^ last_set))
+                            if (mapping.first & (current_set ^ last_set))
                             {
-                                auto const action = (mir_button & current_set) ?
+                                auto const action = (mapping.first & current_set) ?
                                                     WL_POINTER_BUTTON_STATE_PRESSED :
                                                     WL_POINTER_BUTTON_STATE_RELEASED;
 
-                                wl_pointer_send_button(resource, serial, current_time, button, action);
+                                wl_pointer_send_button(resource, serial, current_time, mapping.second, action);
                             }
-
-                            ++button;
                         }
 
                         last_set = current_set;
@@ -934,7 +983,7 @@
                     case mir_pointer_actions:
                         break;
                 }
-            });
+            }));
     }
 
     // Pointer interface
@@ -942,6 +991,9 @@
     wl_display* const display;
     std::shared_ptr<mir::Executor> const executor;
 
+    std::function<void(WlPointer*)> on_destroy;
+    std::shared_ptr<bool> const destroyed;
+
     MirPointerButtons last_set{0};
     float last_x, last_y, last_vscroll, last_hscroll;
 
@@ -959,7 +1011,7 @@
 
 void WlPointer::release()
 {
-    delete this;
+    wl_resource_destroy(resource);
 }
 
 class WlTouch : public wayland::Touch
@@ -969,9 +1021,18 @@
         wl_client* client,
         wl_resource* parent,
         uint32_t id,
-        std::shared_ptr<mir::Executor> const& /*executor*/)
-        : Touch(client, parent, id)
-    {
+        std::function<void(WlTouch*)> const& on_destroy,
+        std::shared_ptr<mir::Executor> const& executor)
+        : Touch(client, parent, id),
+          executor{executor},
+          on_destroy{on_destroy}
+    {
+    }
+
+    ~WlTouch()
+    {
+        on_destroy(this);
+        *destroyed = true;
     }
 
     void handle_event(MirInputEvent const* /*event*/, wl_resource* /*target*/)
@@ -980,11 +1041,16 @@
 
     // Touch interface
 private:
+    std::shared_ptr<mir::Executor> const executor;
+    std::function<void(WlTouch*)> on_destroy;
+    std::shared_ptr<bool> const destroyed;
+
     void release() override;
 };
 
 void WlTouch::release()
 {
+    wl_resource_destroy(resource);
 }
 
 template<class InputInterface>
@@ -997,25 +1063,27 @@
     InputCtx(InputCtx const&) = delete;
     InputCtx& operator=(InputCtx const&) = delete;
 
-    void register_listener(std::shared_ptr<InputInterface> const& listener)
+    void register_listener(InputInterface* listener)
     {
+        std::lock_guard<std::mutex> lock{mutex};
         listeners.push_back(listener);
     }
 
     void unregister_listener(InputInterface const* listener)
     {
-        std::remove_if(
-            listeners.begin(),
-            listeners.end(),
-            [listener](auto candidate)
-            {
-                return candidate.get() == listener;
-            });
+        std::lock_guard<std::mutex> lock{mutex};
+        listeners.erase(
+            std::remove(
+                listeners.begin(),
+                listeners.end(),
+                listener),
+            listeners.end());
     }
 
     void handle_event(MirInputEvent const* event, wl_resource* target) const
     {
-        for (auto& listener : listeners)
+        std::lock_guard<std::mutex> lock{mutex};
+        for (auto listener : listeners)
         {
             listener->handle_event(event, target);
         }
@@ -1023,6 +1091,7 @@
 
     void handle_event(MirWindowEvent const* event, wl_resource* target) const
     {
+        std::lock_guard<std::mutex> lock{mutex};
         for (auto& listener : listeners)
         {
             listener->handle_event(event, target);
@@ -1030,7 +1099,8 @@
     }
 
 private:
-    std::vector<std::shared_ptr<InputInterface>> listeners;
+    std::mutex mutable mutex;
+    std::vector<InputInterface*> listeners;
 };
 
 class WlSeat
@@ -1100,32 +1170,49 @@
     static void get_pointer(wl_client* client, wl_resource* resource, uint32_t id)
     {
         auto me = reinterpret_cast<WlSeat*>(wl_resource_get_user_data(resource));
-        me->pointer[client].register_listener(
-            std::make_shared<WlPointer>(
+        auto& input_ctx = me->pointer[client];
+        input_ctx.register_listener(
+            new WlPointer{
                 client,
                 resource,
                 id,
-                me->executor));
+                [&input_ctx](WlPointer* listener)
+                {
+                    input_ctx.unregister_listener(listener);
+                },
+                me->executor});
     }
     static void get_keyboard(wl_client* client, wl_resource* resource, uint32_t id)
     {
         auto me = reinterpret_cast<WlSeat*>(wl_resource_get_user_data(resource));
-        me->keyboard[client].register_listener(
-            std::make_shared<WlKeyboard>(
+        auto& input_ctx = me->keyboard[client];
+
+        input_ctx.register_listener(
+            new WlKeyboard{
                 client,
                 resource,
                 id,
-                me->executor));
+                [&input_ctx](WlKeyboard* listener)
+                {
+                    input_ctx.unregister_listener(listener);
+                },
+                me->executor});
     }
     static void get_touch(wl_client* client, wl_resource* resource, uint32_t id)
     {
         auto me = reinterpret_cast<WlSeat*>(wl_resource_get_user_data(resource));
-        me->touch[client].register_listener(
-            std::make_shared<WlTouch>(
+        auto& input_ctx = me->touch[client];
+
+        input_ctx.register_listener(
+            new WlTouch{
                 client,
                 resource,
                 id,
-                me->executor));
+                [&input_ctx](WlTouch* listener)
+                {
+                    input_ctx.unregister_listener(listener);
+                },
+                me->executor});
     }
     static void release(struct wl_client* /*client*/, struct wl_resource* /*resource*/) {}