[tracker/journal: 21/22] libtracker-data: Transaction logic in journal-replay



commit 75d05b0f9684ef0822b9117a9ee9926cdfa550ac
Author: Philip Van Hoof <philip codeminded be>
Date:   Wed Mar 17 12:46:12 2010 +0100

    libtracker-data: Transaction logic in journal-replay

 src/libtracker-data/tracker-data-update.c |    9 ++++++---
 1 files changed, 6 insertions(+), 3 deletions(-)
---
diff --git a/src/libtracker-data/tracker-data-update.c b/src/libtracker-data/tracker-data-update.c
index 0893e42..7d81473 100644
--- a/src/libtracker-data/tracker-data-update.c
+++ b/src/libtracker-data/tracker-data-update.c
@@ -2406,6 +2406,8 @@ tracker_data_replay_journal (GHashTable *classes,
 	static TrackerProperty *rdf_type = NULL;
 	gint last_operation_type = 0;
 
+	tracker_data_begin_replay_transaction (0);
+
 	if (!rdf_type) {
 		rdf_type = tracker_ontologies_get_property_by_uri (RDF_PREFIX "type");
 	}
@@ -2453,9 +2455,7 @@ tracker_data_replay_journal (GHashTable *classes,
 			}
 
 		} else if (type == TRACKER_DB_JOURNAL_START_TRANSACTION) {
-			tracker_data_begin_replay_transaction (tracker_db_journal_reader_get_time ());
-		} else if (type == TRACKER_DB_JOURNAL_END_TRANSACTION) {
-			tracker_data_commit_transaction ();
+			resource_time = tracker_db_journal_reader_get_time ();
 		} else if (type == TRACKER_DB_JOURNAL_INSERT_STATEMENT) {
 			GError *new_error = NULL;
 			TrackerProperty *property;
@@ -2639,4 +2639,7 @@ tracker_data_replay_journal (GHashTable *classes,
 	} else {
 		tracker_db_journal_reader_shutdown ();
 	}
+
+	tracker_data_commit_transaction ();
+
 }



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