summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAleksander Morgado <aleksander@lanedo.com>2011-03-17 17:00:32 +0100
committerMartyn Russell <martyn@lanedo.com>2011-04-20 15:45:54 +0100
commit24bf2a2b851f79761fe61b4b0e07c355bf47e2bc (patch)
tree588c15253bb0fd03f81fef46d60ce3ae65aa0bad
parentec4cc47b328e12826599edcbb5e732e0dbb09115 (diff)
downloadtracker-24bf2a2b851f79761fe61b4b0e07c355bf47e2bc.tar.gz
libtracker-miner: Put together sparql buffer reset code
-rw-r--r--src/libtracker-miner/tracker-miner-fs-processing-pool.c10
1 files changed, 4 insertions, 6 deletions
diff --git a/src/libtracker-miner/tracker-miner-fs-processing-pool.c b/src/libtracker-miner/tracker-miner-fs-processing-pool.c
index 35f255d6d..5e176a39f 100644
--- a/src/libtracker-miner/tracker-miner-fs-processing-pool.c
+++ b/src/libtracker-miner/tracker-miner-fs-processing-pool.c
@@ -985,18 +985,16 @@ tracker_processing_pool_buffer_flush (TrackerProcessingPool *pool,
update_data->error_map = error_map;
update_data->sparql_array = sparql_array;
- /* Reset buffer in the pool */
+ /* Reset buffer and current parent in the pool */
pool->sparql_buffer = NULL;
pool->sparql_buffer_start_time = 0;
-
- /* Flush or queue... */
- processing_pool_update_array_flush (pool, update_data, reason);
-
- /* Clear current parent */
if (pool->sparql_buffer_current_parent) {
g_object_unref (pool->sparql_buffer_current_parent);
pool->sparql_buffer_current_parent = NULL;
}
+
+ /* Flush or queue... */
+ processing_pool_update_array_flush (pool, update_data, reason);
}
gboolean