From a98d9364cb5395aca5adc9fa4db219df7545ab98 Mon Sep 17 00:00:00 2001 From: Marco Pesenti Gritti Date: Fri, 23 May 2003 21:06:13 +0000 Subject: Implement generic way to save/load db and make it low disk safe. 2003-05-23 Marco Pesenti Gritti * embed/ephy-favicon-cache.c: (ephy_favicon_cache_load), (ephy_favicon_cache_save), (ephy_favicon_cache_init), (ephy_favicon_cache_finalize): * embed/ephy-history.c: (ephy_history_load), (ephy_history_save), (ephy_history_init): * lib/ephy-node-db.c: (ephy_node_db_set_version), (ephy_node_db_get_property), (ephy_node_db_set_property), (ephy_node_db_class_init), (ephy_node_db_init), (ephy_node_db_finalize), (ephy_node_db_new), (_ephy_node_db_remove_id), (ephy_node_db_load_from_xml), (ephy_node_db_save_to_xml): * lib/ephy-node-db.h: * lib/ephy-node.c: (ephy_node_to_xml): * lib/ephy-node.h: * lib/ephy-state.c: (ephy_states_load), (ephy_states_save), (ensure_states): * src/bookmarks/ephy-bookmarks.c: (ephy_bookmarks_load), (ephy_bookmarks_save), (ephy_bookmarks_init), (ephy_bookmarks_finalize): Implement generic way to save/load db and make it low disk safe. --- lib/ephy-node-db.c | 152 ++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 file changed, 150 insertions(+), 2 deletions(-) (limited to 'lib/ephy-node-db.c') diff --git a/lib/ephy-node-db.c b/lib/ephy-node-db.c index 86913d93c..bb10759ec 100644 --- a/lib/ephy-node-db.c +++ b/lib/ephy-node-db.c @@ -19,6 +19,9 @@ */ #include "ephy-node-db.h" +#include "ephy-debug.h" + +#include static void ephy_node_db_class_init (EphyNodeDbClass *klass); static void ephy_node_db_init (EphyNodeDb *node); @@ -30,12 +33,14 @@ static void ephy_node_db_finalize (GObject *object); enum { PROP_0, - PROP_NAME + PROP_NAME, + PROP_VERSION }; struct EphyNodeDbPrivate { char *name; + char *version; GMutex *id_factory_lock; long id_factory; @@ -74,6 +79,12 @@ ephy_node_db_get_type (void) return ephy_node_db_type; } +static void +ephy_node_db_set_version (EphyNodeDb *db, const char *version) +{ + db->priv->version = g_strdup (version); +} + static void ephy_node_db_set_name (EphyNodeDb *db, const char *name) { @@ -102,6 +113,9 @@ ephy_node_db_get_property (GObject *object, case PROP_NAME: g_value_set_string (value, db->priv->name); break; + case PROP_VERSION: + g_value_set_string (value, db->priv->version); + break; } } @@ -121,6 +135,9 @@ ephy_node_db_set_property (GObject *object, case PROP_NAME: ephy_node_db_set_name (db, g_value_get_string (value)); break; + case PROP_VERSION: + ephy_node_db_set_version (db, g_value_get_string (value)); + break; } } @@ -142,6 +159,14 @@ ephy_node_db_class_init (EphyNodeDbClass *klass) "Name", NULL, G_PARAM_READWRITE)); + g_object_class_install_property (object_class, + PROP_VERSION, + g_param_spec_string ("version", + "Version", + "Version", + NULL, + G_PARAM_READWRITE)); + } static void @@ -150,6 +175,7 @@ ephy_node_db_init (EphyNodeDb *db) db->priv = g_new0 (EphyNodeDbPrivate, 1); db->priv->name = NULL; + db->priv->version = NULL; /* id to node */ db->priv->id_to_node = g_ptr_array_new (); @@ -186,6 +212,7 @@ ephy_node_db_finalize (GObject *object) g_mutex_free (db->priv->id_factory_lock); g_free (db->priv->name); + g_free (db->priv->version); g_free (db->priv); @@ -203,12 +230,13 @@ ephy_node_db_get_by_name (const char *name) } EphyNodeDb * -ephy_node_db_new (const char *name) +ephy_node_db_new (const char *name, const char *version) { EphyNodeDb *db; db = EPHY_NODE_DB (g_object_new (EPHY_TYPE_NODE_DB, "name", name, + "version", version, NULL)); g_return_val_if_fail (db->priv != NULL, NULL); @@ -295,3 +323,123 @@ _ephy_node_db_remove_id (EphyNodeDb *db, g_static_rw_lock_writer_unlock (db->priv->id_to_node_lock); } + +gboolean +ephy_node_db_load_from_xml (EphyNodeDb *db, const char *xml_file) +{ + xmlDocPtr doc; + xmlNodePtr root, child; + + if (g_file_test (xml_file, G_FILE_TEST_EXISTS) == FALSE) + { + return FALSE; + } + + doc = xmlParseFile (xml_file); + g_return_val_if_fail (doc != NULL, FALSE); + + root = xmlDocGetRootElement (doc); + + for (child = root->children; child != NULL; child = child->next) + { + EphyNode *node; + + node = ephy_node_new_from_xml (db, child); + } + + xmlFreeDoc (doc); + + return TRUE; +} + +gboolean +ephy_node_db_save_to_xml (EphyNodeDb *db, const char *xml_file) +{ + xmlDocPtr doc; + xmlNodePtr root; + GPtrArray *children; + int i; + char *tmp_file; + char *old_file; + gboolean old_exist; + gboolean retval = TRUE; + + LOG ("Build the xml file %s", xml_file) + + tmp_file = g_strconcat (xml_file, ".tmp", NULL); + old_file = g_strconcat (xml_file, ".old", NULL); + + /* save nodes to xml */ + xmlIndentTreeOutput = TRUE; + doc = xmlNewDoc ("1.0"); + + root = xmlNewDocNode (doc, NULL, "ephy_node_db", NULL); + xmlDocSetRootElement (doc, root); + + xmlSetProp (root, "name", db->priv->name); + xmlSetProp (root, "version", db->priv->version); + + g_static_rw_lock_reader_lock (db->priv->id_to_node_lock); + + children = db->priv->id_to_node; + + for (i = RESERVED_IDS; i < children->len; i++) + { + EphyNode *kid; + + kid = g_ptr_array_index (children, i); + + if (kid) + { + ephy_node_to_xml (kid, root); + } + } + + g_static_rw_lock_reader_unlock (db->priv->id_to_node_lock); + + LOG ("Save it") + + if (!xmlSaveFormatFile (tmp_file, doc, 1)) + { + g_warning ("Failed to write XML data to %s", tmp_file); + goto failed; + } + + old_exist = g_file_test (xml_file, G_FILE_TEST_EXISTS); + + if (old_exist) + { + if (rename (xml_file, old_file) < 0) + { + g_warning ("Failed to rename %s to %s", xml_file, old_file); + retval = FALSE; + goto failed; + } + } + + if (rename (tmp_file, xml_file) < 0) + { + g_warning ("Failed to rename %s to %s", tmp_file, xml_file); + + if (rename (old_file, xml_file) < 0) + { + g_warning ("Failed to restore %s from %s", xml_file, tmp_file); + } + retval = FALSE; + goto failed; + } + + if (old_exist) + { + if (unlink (old_file) < 0) + { + g_warning ("Failed to delete old file %s", old_file); + } + } + + failed: + g_free (old_file); + g_free (tmp_file); + + return retval; +} -- cgit v1.2.3