[tracker/urho-sync] No need to do an extra fsync of commit causes one already



commit a61dbf091354411c093674105039e1546e7a3151
Author: Philip Van Hoof <philip codeminded be>
Date:   Fri Aug 21 11:19:23 2009 +0200

    No need to do an extra fsync of commit causes one already

 src/tracker-store/tracker-store.c |   13 +++++++------
 1 files changed, 7 insertions(+), 6 deletions(-)
---
diff --git a/src/tracker-store/tracker-store.c b/src/tracker-store/tracker-store.c
index 98f876b..e99c815 100644
--- a/src/tracker-store/tracker-store.c
+++ b/src/tracker-store/tracker-store.c
@@ -39,7 +39,6 @@
 #include "tracker-store.h"
 
 #define TRACKER_STORE_TRANSACTION_MAX			4000		/* At commit is journal fsynced too */
-#define TRACKER_STORE_JOURNAL_MAX_BEFORE_FLUSH		2000		/* Amount of queries before fsync */
 #define TRACKER_STORE_JOURNAL_TIMEOUT_BEFORE_BACKUP	(60 * 60 * 2)	/* Two hours before backup */
 
 typedef struct {
@@ -172,11 +171,6 @@ log_to_journal (TrackerStorePrivate *private, const gchar *query)
 {
 	tracker_db_journal_log (query);
 	private->journal_log_count++;
-
-	if (private->journal_log_count >= TRACKER_STORE_JOURNAL_MAX_BEFORE_FLUSH) {
-		tracker_store_flush_journal ();
-		private->journal_log_count = 0;
-	}
 }
 
 static gboolean
@@ -311,9 +305,16 @@ sync_idle_destroy (gpointer user_data)
 void 
 tracker_store_flush_journal (void)
 {
+	TrackerStorePrivate *private;
+
+	private = g_static_private_get (&private_key);
+	g_return_if_fail (private != NULL);
+
 	tracker_db_journal_fsync ();
+	private->journal_log_count = 0;
 }
 
+
 void
 tracker_store_play_journal (void)
 {



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