diff --git a/src/mconnect/battery.vala b/src/mconnect/battery.vala index f8f7448..70a9e34 100644 --- a/src/mconnect/battery.vala +++ b/src/mconnect/battery.vala @@ -36,14 +36,19 @@ class BatteryHandler : Object, PacketHandlerInterface { public void use_device(Device dev) { debug("use device %s for battery status updates", dev.to_string()); - dev.message.connect((d, pkt) => { - if (pkt.pkt_type == BATTERY) { - this.message(pkt); - } - }); + dev.message.connect(this.message); } - public void message(Packet pkt) { + public void release_device(Device dev) { + debug("release device %s", dev.to_string()); + dev.message.disconnect(this.message); + } + + public void message(Device dev, Packet pkt) { + if (pkt.pkt_type != BATTERY) { + return; + } + debug("got battery packet"); int64 level = pkt.body.get_int_member("currentCharge"); diff --git a/src/mconnect/mousepad.vala b/src/mconnect/mousepad.vala index 4160185..5c7ae07 100644 --- a/src/mconnect/mousepad.vala +++ b/src/mconnect/mousepad.vala @@ -46,15 +46,20 @@ class MousepadHandler : Object, PacketHandlerInterface { } public void use_device(Device dev) { - debug("use device %s for battery status updates", dev.to_string()); - dev.message.connect((d, pkt) => { - if (pkt.pkt_type == MOUSEPAD) { - this.message(pkt); - } - }); + debug("use device %s for mouse/keyboard input", dev.to_string()); + dev.message.connect(this.message); } - public void message(Packet pkt) { + public void release_device(Device dev) { + debug("release device %s ", dev.to_string()); + dev.message.disconnect(this.message); + } + + private void message(Device dev, Packet pkt) { + if (pkt.pkt_type != MOUSEPAD) { + return; + } + debug("got mousepad packet"); if (_display == null) { diff --git a/src/mconnect/notification.vala b/src/mconnect/notification.vala index 8876465..db08f78 100644 --- a/src/mconnect/notification.vala +++ b/src/mconnect/notification.vala @@ -38,14 +38,17 @@ class NotificationHandler : Object, PacketHandlerInterface { } public void use_device(Device dev) { - dev.message.connect((d, pkt) => { - if (pkt.pkt_type == NOTIFICATION) { - this.message(pkt); - } - }); + dev.message.connect(this.message); + } + + public void release_device(Device dev) { + dev.message.disconnect(this.message); } - public void message(Packet pkt) { + public void message(Device dev, Packet pkt) { + if (pkt.pkt_type != NOTIFICATION) { + return; + } debug("got notification packet"); // get application ID diff --git a/src/mconnect/packethandlerinterface.vala b/src/mconnect/packethandlerinterface.vala index 1688d14..e814e50 100644 --- a/src/mconnect/packethandlerinterface.vala +++ b/src/mconnect/packethandlerinterface.vala @@ -24,4 +24,6 @@ interface PacketHandlerInterface : Object { public abstract void use_device(Device dev); + public abstract void release_device(Device dev); + } \ No newline at end of file diff --git a/src/mconnect/packethandlers.vala b/src/mconnect/packethandlers.vala index 3d81f0c..c40b28c 100644 --- a/src/mconnect/packethandlers.vala +++ b/src/mconnect/packethandlers.vala @@ -69,4 +69,10 @@ class PacketHandlers : Object { h.use_device(dev); }); } + + public void release_device(Device dev) { + _handlers.foreach((h) => { + h.release_device(dev); + }); + } } \ No newline at end of file diff --git a/src/mconnect/telephony.vala b/src/mconnect/telephony.vala index 407349f..9f2a9c1 100644 --- a/src/mconnect/telephony.vala +++ b/src/mconnect/telephony.vala @@ -36,14 +36,18 @@ class TelephonyHandler : Object, PacketHandlerInterface { } public void use_device(Device dev) { - dev.message.connect((d, pkt) => { - if (pkt.pkt_type == TELEPHONY) { - this.message(pkt); - } - }); + dev.message.connect(this.message); + } + + public void release_device(Device dev) { + dev.message.disconnect(this.message); } - public void message(Packet pkt) { + public void message(Device dev, Packet pkt) { + if (pkt.pkt_type != TELEPHONY) { + return; + } + debug("got telephony packet"); if (pkt.body.has_member("phoneNumber") == false ||