diff options
author | Carlos Garnacho <carlos@lanedo.com> | 2011-12-07 15:22:09 +0100 |
---|---|---|
committer | Carlos Garnacho <carlos@lanedo.com> | 2011-12-07 15:22:09 +0100 |
commit | ec4c2391d376a06ceab3dea9ecaafebec47887bb (patch) | |
tree | 31cba703222523d6420865ff5c8f8e953d58df5f | |
parent | 96cef6269c3e943e9229015203cf13c582b84024 (diff) | |
download | tracker-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.vala | 6 | ||||
-rw-r--r-- | src/tracker-store/tracker-steroids.vala | 6 |
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); |