[tracker] libtracker-miner: Fix buffer control in TrackerMinerFS



commit d1120150a8faaeb0f3eb03792e439b96521a1006
Author: Carlos Garnacho <carlos lanedo com>
Date:   Wed Nov 23 18:09:49 2011 +0100

    libtracker-miner: Fix buffer control in TrackerMinerFS
    
    Add an explicit check on item_queue_handlers_cb() to check the
    sparql buffer status, so it doesn't have an opportunity to clog
    it any further.

 src/libtracker-miner/tracker-miner-fs.c |    9 +++++++--
 1 files changed, 7 insertions(+), 2 deletions(-)
---
diff --git a/src/libtracker-miner/tracker-miner-fs.c b/src/libtracker-miner/tracker-miner-fs.c
index 104db35..f4cc9d4 100644
--- a/src/libtracker-miner/tracker-miner-fs.c
+++ b/src/libtracker-miner/tracker-miner-fs.c
@@ -2878,7 +2878,7 @@ item_queue_get_progress (TrackerMinerFS *fs,
 static gboolean
 item_queue_handlers_cb (gpointer user_data)
 {
-	TrackerMinerFS *fs;
+	TrackerMinerFS *fs = user_data;
 	GFile *file = NULL;
 	GFile *source_file = NULL;
 	GFile *parent;
@@ -2888,7 +2888,12 @@ item_queue_handlers_cb (gpointer user_data)
 	gboolean keep_processing = TRUE;
 	gint priority = 0;
 
-	fs = user_data;
+	if (tracker_task_pool_limit_reached (TRACKER_TASK_POOL (fs->priv->sparql_buffer))) {
+		/* Task pool is full, give it a break */
+		fs->priv->item_queues_handler_id = 0;
+		return FALSE;
+	}
+
 	queue = item_queue_get_next_file (fs, &file, &source_file, &priority);
 
 	if (queue == QUEUE_WAIT) {



[Date Prev][Date Next]   [Thread Prev][Thread Next]   [Thread Index] [Date Index] [Author Index]