From 9626523420e390dc826e56946ec6307ba3c4e2f1 Mon Sep 17 00:00:00 2001 From: Max Kellermann Date: Mon, 4 Jun 2018 21:41:51 +0200 Subject: [PATCH] neighbor/udisks: move code to class UDisks2::ParseObjects(ReadMessageIter) --- src/lib/dbus/UDisks2.cxx | 15 +++++++++++++++ src/lib/dbus/UDisks2.hxx | 9 +++++++++ src/neighbor/plugins/UdisksNeighborPlugin.cxx | 9 +++------ 3 files changed, 27 insertions(+), 6 deletions(-) diff --git a/src/lib/dbus/UDisks2.cxx b/src/lib/dbus/UDisks2.cxx index 1cb231951..3c3f0c5c4 100644 --- a/src/lib/dbus/UDisks2.cxx +++ b/src/lib/dbus/UDisks2.cxx @@ -19,6 +19,7 @@ #include "UDisks2.hxx" #include "ReadIter.hxx" +#include "ObjectManager.hxx" #include "util/StringAPI.hxx" #include "Compiler.h" @@ -98,4 +99,18 @@ ParseObject(Object &o, ODBus::ReadMessageIter &&i) noexcept }); } +void +ParseObjects(ODBus::ReadMessageIter &&i, + std::function callback) +{ + using namespace ODBus; + + ForEachInterface(std::move(i), [&callback](const char *path, auto &&j){ + Object o(path); + ParseObject(o, std::move(j)); + if (o.IsValid()) + callback(std::move(o)); + }); +} + } // namespace UDisks2 diff --git a/src/lib/dbus/UDisks2.hxx b/src/lib/dbus/UDisks2.hxx index 23d7fe599..b0a068fd1 100644 --- a/src/lib/dbus/UDisks2.hxx +++ b/src/lib/dbus/UDisks2.hxx @@ -21,6 +21,7 @@ #define UDISKS2_HXX #include +#include #define UDISKS2_PATH "/org/freedesktop/UDisks2" #define UDISKS2_INTERFACE "org.freedesktop.UDisks2" @@ -57,6 +58,14 @@ struct Object { void ParseObject(Object &o, ODBus::ReadMessageIter &&i) noexcept; +/** + * Parse objects from an array/dictionary and invoke the callback for + * each. + */ +void +ParseObjects(ODBus::ReadMessageIter &&i, + std::function callback); + } // namespace UDisks2 #endif diff --git a/src/neighbor/plugins/UdisksNeighborPlugin.cxx b/src/neighbor/plugins/UdisksNeighborPlugin.cxx index 43e7fb056..dc809062d 100644 --- a/src/neighbor/plugins/UdisksNeighborPlugin.cxx +++ b/src/neighbor/plugins/UdisksNeighborPlugin.cxx @@ -231,12 +231,9 @@ UdisksNeighborExplorer::OnListNotify(ODBus::Message reply) noexcept return; } - ForEachInterface(i.Recurse(), [this](const char *path, auto &&j){ - UDisks2::Object o(path); - UDisks2::ParseObject(o, std::move(j)); - if (o.IsValid()) - Insert(std::move(o)); - }); + ParseObjects(i.Recurse(), + std::bind(&UdisksNeighborExplorer::Insert, + this, std::placeholders::_1)); } inline DBusHandlerResult