summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCarlos Garnacho <carlos@lanedo.com>2011-12-07 15:22:09 +0100
committerCarlos Garnacho <carlos@lanedo.com>2011-12-07 15:22:09 +0100
commitec4c2391d376a06ceab3dea9ecaafebec47887bb (patch)
tree31cba703222523d6420865ff5c8f8e953d58df5f
parent96cef6269c3e943e9229015203cf13c582b84024 (diff)
downloadtracker-ec4c2391d376a06ceab3dea9ecaafebec47887bb.tar.gz
tracker-store: Finalize the TrackerDBusRequests on blank updates
This was likely to leave stuck resources for already disconnected clients in the tracker-store side.
-rw-r--r--src/tracker-store/tracker-resources.vala6
-rw-r--r--src/tracker-store/tracker-steroids.vala6
2 files changed, 10 insertions, 2 deletions
diff --git a/src/tracker-store/tracker-resources.vala b/src/tracker-store/tracker-resources.vala
index cd7b6eb97..c5d3a82ec 100644
--- a/src/tracker-store/tracker-resources.vala
+++ b/src/tracker-store/tracker-resources.vala
@@ -148,7 +148,11 @@ public class Tracker.Resources : Object {
var request = DBusRequest.begin (sender, "Resources.SparqlUpdateBlank");
request.debug ("query: %s", update);
try {
- return yield Tracker.Store.sparql_update_blank (update, Tracker.Store.Priority.HIGH, sender);
+ var variant = yield Tracker.Store.sparql_update_blank (update, Tracker.Store.Priority.HIGH, sender);
+
+ request.end ();
+
+ return variant;
} catch (DBInterfaceError.NO_SPACE ie) {
throw new Sparql.Error.NO_SPACE (ie.message);
} catch (Error e) {
diff --git a/src/tracker-store/tracker-steroids.vala b/src/tracker-store/tracker-steroids.vala
index 124d63463..7b80989bf 100644
--- a/src/tracker-store/tracker-steroids.vala
+++ b/src/tracker-store/tracker-steroids.vala
@@ -120,7 +120,11 @@ public class Tracker.Steroids : Object {
return null;
} else {
- return yield Tracker.Store.sparql_update_blank ((string) query, priority, sender);
+ var variant = yield Tracker.Store.sparql_update_blank ((string) query, priority, sender);
+
+ request.end ();
+
+ return variant;
}
} catch (DBInterfaceError.NO_SPACE ie) {
throw new Sparql.Error.NO_SPACE (ie.message);