summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCarlos Garnacho <carlosg@gnome.org>2017-11-25 13:57:06 +0100
committerSam Thursfield <sam@afuera.me.uk>2018-07-16 21:12:04 +0200
commitf6e49b1fef154f4eb53d865b5d3747ef653785bb (patch)
treed595b53600a3b776a2c9fc3518b1eebf4da514e4
parent64ebded35ce994ccf67e4673e2efa938ab349644 (diff)
downloadtracker-f6e49b1fef154f4eb53d865b5d3747ef653785bb.tar.gz
tracker-store: Refactor writeback signal emission into separate function
Purely cosmetic.
-rw-r--r--src/tracker-store/tracker-resources.vala45
1 files changed, 24 insertions, 21 deletions
diff --git a/src/tracker-store/tracker-resources.vala b/src/tracker-store/tracker-resources.vala
index 2dbd1c00b..c6a76e749 100644
--- a/src/tracker-store/tracker-resources.vala
+++ b/src/tracker-store/tracker-resources.vala
@@ -223,6 +223,29 @@ public class Tracker.Resources : Object {
graph_updated (cl.uri, deletes, inserts);
}
+ void emit_writeback (HashTable<int, Array<int>> events) {
+ var builder = new VariantBuilder ((VariantType) "a{iai}");
+ var wb_iter = HashTableIter<int, GLib.Array<int>> (events);
+
+ int subject_id;
+ unowned Array<int> types;
+ while (wb_iter.next (out subject_id, out types)) {
+ builder.open ((VariantType) "{iai}");
+
+ builder.add ("i", subject_id);
+
+ builder.open ((VariantType) "ai");
+ for (int i = 0; i < types.length; i++) {
+ builder.add ("i", types.index (i));
+ }
+ builder.close ();
+
+ builder.close ();
+ }
+
+ writeback (builder.end ());
+ }
+
bool on_emit_signals () {
var events = Tracker.Events.get_pending ();
@@ -240,27 +263,7 @@ public class Tracker.Resources : Object {
var writebacks = Tracker.Writeback.get_ready ();
if (writebacks != null) {
- var builder = new VariantBuilder ((VariantType) "a{iai}");
-
- var wb_iter = HashTableIter<int, GLib.Array<int>> (writebacks);
-
- int subject_id;
- unowned Array<int> types;
- while (wb_iter.next (out subject_id, out types)) {
- builder.open ((VariantType) "{iai}");
-
- builder.add ("i", subject_id);
-
- builder.open ((VariantType) "ai");
- for (int i = 0; i < types.length; i++) {
- builder.add ("i", types.index (i));
- }
- builder.close ();
-
- builder.close ();
- }
-
- writeback (builder.end ());
+ emit_writeback (writebacks);
}
signal_timeout = 0;