tracker-store: Port tracker-main to Vala

1 files changed, 373 insertions, 0 deletions

diff --git a/src/tracker-store/tracker-main.vala b/src/tracker-store/tracker-main.vala
new file mode 100644
index 000000000..a7d459475
--- /dev/null
+++ b/src/tracker-store/tracker-main.vala
@@ -0,0 +1,373 @@
+/*
+ * Copyright (C) 2006, Jamie McCracken <jamiemcc@gnome.org>
+ * Copyright (C) 2008, Nokia <ivan.frade@nokia.com>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public
+ * License along with this library; if not, write to the
+ * Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+ * Boston, MA  02110-1301, USA.
+ */
+
+class Tracker.Main {
+	[CCode (cname = "PACKAGE_VERSION")]
+	extern const string PACKAGE_VERSION;
+
+	const string LICENSE = "This program is free software and comes without any warranty.
+It is licensed under version 2 or later of the General Public
+License which can be viewed at:
+  http://www.gnu.org/licenses/gpl.txt
+";
+
+	const int SELECT_CACHE_SIZE = 100;
+	const int UPDATE_CACHE_SIZE = 100;
+
+	static MainLoop main_loop;
+	static string log_filename;
+
+	static bool shutdown;
+
+	/* Private command line parameters */
+	static bool version;
+	static int verbosity;
+	static bool force_reindex;
+	static bool readonly_mode;
+
+	const OptionEntry entries[] = {
+		/* Daemon options */
+		{ "version", 'V', 0, OptionArg.NONE, ref version, N_("Displays version information"), null },
+		{ "verbosity", 'v', 0, OptionArg.INT, ref verbosity, N_("Logging, 0 = errors only, 1 = minimal, 2 = detailed and 3 = debug (default = 0)"), null },
+
+		/* Indexer options */
+		{ "force-reindex", 'r', 0, OptionArg.NONE, ref force_reindex, N_("Force a re-index of all content"), null },
+		{ "readonly-mode", 'n', 0, OptionArg.NONE, ref readonly_mode, N_("Only allow read based actions on the database"), null },
+		{ null }
+	};
+
+	static void sanity_check_option_values (Tracker.Config config) {
+		message ("General options:");
+		message ("  Verbosity  ............................  %d", config.verbosity);
+
+		message ("Store options:");
+		message ("  Readonly mode  ........................  %s", readonly_mode ? "yes" : "no");
+	}
+
+	static void do_shutdown () {
+		if (main_loop != null) {
+			main_loop.quit ();
+		}
+
+		shutdown = true;
+	}
+
+	static bool shutdown_timeout_cb () {
+		critical ("Could not exit in a timely fashion - terminating...");
+		Process.exit (1);
+	}
+
+	static bool in_loop = false;
+
+	static void signal_handler (int signo) {
+		/* Die if we get re-entrant signals handler calls */
+		if (in_loop) {
+			Process.exit (1);
+		}
+
+		switch (signo) {
+		case Posix.SIGTERM:
+		case Posix.SIGINT:
+			in_loop = true;
+			do_shutdown ();
+
+			if (strsignal (signo) != null) {
+				print ("\n");
+				print ("Received signal:%d->'%s'", signo, strsignal (signo));
+			}
+			break;
+		default:
+			if (strsignal (signo) != null) {
+				print ("\n");
+				print ("Received signal:%d->'%s'", signo, strsignal (signo));
+			}
+			break;
+		}
+	}
+
+	static void initialize_signal_handler () {
+		var empty_mask = Posix.sigset_t ();
+		Posix.sigemptyset (empty_mask);
+
+		var act = Posix.sigaction_t ();
+		act.sa_handler = signal_handler;
+		act.sa_mask = empty_mask;
+		act.sa_flags = 0;
+
+		Posix.sigaction (Posix.SIGTERM, act, null);
+		Posix.sigaction (Posix.SIGINT, act, null);
+		Posix.sigaction (Posix.SIGHUP, act, null);
+	}
+
+	static void initialize_priority () {
+		/* Set disk IO priority and scheduling */
+		Tracker.ioprio_init ();
+
+		/* NOTE: We only set the nice() value when crawling, for all
+		 * other times we don't have a nice() value. Check the
+		 * tracker-status code to see where this is done.
+		 */
+	}
+
+	[CCode (array_length = false, array_null_terminated = true)]
+	static string[] get_notifiable_classes () {
+		string[] classes_to_signal = null;
+
+		try {
+			var result_set = Tracker.Data.query_sparql ("SELECT ?class WHERE { ?class tracker:notify true }");
+
+			if (result_set != null) {
+				classes_to_signal = Tracker.dbus_query_result_to_strv (result_set, 0);
+			}
+		} catch (Error e) {
+			critical ("Unable to retrieve tracker:notify classes: %s", e.message);
+		}
+
+		return classes_to_signal;
+	}
+
+	[CCode (array_length = false, array_null_terminated = true)]
+	static string[] get_writeback_predicates () {
+		string[] predicates_to_signal = null;
+
+		try {
+			var result_set = Tracker.Data.query_sparql ("SELECT ?predicate WHERE { ?predicate tracker:writeback true }");
+
+			if (result_set != null) {
+				predicates_to_signal = Tracker.dbus_query_result_to_strv (result_set, 0);
+			}
+		} catch (Error e) {
+			critical ("Unable to retrieve tracker:writeback properties: %s", e.message);
+		}
+
+		return predicates_to_signal;
+	}
+
+	static void config_verbosity_changed_cb (Object object, ParamSpec? spec) {
+		int verbosity = ((Tracker.Config) object).verbosity;
+
+		message ("Log verbosity is set to %d, %s D-Bus client lookup",
+		         verbosity,
+		         verbosity > 0 ? "enabling" : "disabling");
+
+		Tracker.DBusRequest.enable_client_lookup (verbosity > 0);
+	}
+
+	static int main (string[] args) {
+		Intl.setlocale (LocaleCategory.ALL, "");
+
+		Intl.bindtextdomain (GETTEXT_PACKAGE, LOCALEDIR);
+		Intl.bind_textdomain_codeset (GETTEXT_PACKAGE, "UTF-8");
+		Intl.textdomain (GETTEXT_PACKAGE);
+
+		/* Set timezone info */
+		tzset ();
+
+		verbosity = -1;
+
+		try {
+			/* Translators: this messagge will apper immediately after the
+			 * usage string - Usage: COMMAND <THIS_MESSAGE>
+			 */
+			var context = new OptionContext (_("- start the tracker daemon"));
+			context.add_main_entries (entries, null);
+			context.parse (ref args);
+		} catch (Error e) {
+			printerr ("Invalid arguments, %s\n", e.message);
+			return 1;
+		}
+
+		if (version) {
+			/* Print information */
+			print ("\nTracker " + PACKAGE_VERSION + "\n\n" + LICENSE + "\n");
+			return 0;
+		}
+
+		print ("Initializing tracker-store...\n");
+
+		initialize_signal_handler ();
+
+		/* Check XDG spec locations XDG_DATA_HOME _MUST_ be writable. */
+		if (!Tracker.env_check_xdg_dirs ()) {
+			return 1;
+		}
+
+		/* This makes sure we don't steal all the system's resources */
+		initialize_priority ();
+
+		/* Initialize major subsystems */
+		var config = new Tracker.Config ();
+		var db_config = new Tracker.DBConfig ();
+
+		ulong config_verbosity_id = config.notify["verbosity"].connect (config_verbosity_changed_cb);
+
+		/* Daemon command line arguments */
+		if (verbosity > -1) {
+			config.verbosity = verbosity;
+		} else {
+			/* Make sure we enable/disable the dbus client lookup */
+			config_verbosity_changed_cb (config, null);
+		}
+
+		if (!Tracker.DBus.init ()) {
+			return 1;
+		}
+
+		/* Initialize other subsystems */
+		Tracker.Log.init (config.verbosity, out log_filename);
+		print ("Starting log:\n  File:'%s'\n", log_filename);
+
+		sanity_check_option_values (config);
+
+		DBManagerFlags flags = DBManagerFlags.REMOVE_CACHE;
+
+		if (force_reindex) {
+			/* TODO port backup support
+			   backup_user_metadata (config, language); */
+
+			flags |= DBManagerFlags.FORCE_REINDEX;
+		}
+
+		var notifier = Tracker.DBus.register_notifier ();
+		var busy_callback = notifier.get_callback ();
+
+		Tracker.Store.init ();
+
+		/* Make Tracker available for introspection */
+		if (!Tracker.DBus.register_objects ()) {
+			return 1;
+		}
+
+		if (!Tracker.DBus.register_names ()) {
+			return 1;
+		}
+
+		int chunk_size_mb = db_config.journal_chunk_size;
+		size_t chunk_size = (size_t) ((size_t) chunk_size_mb * (size_t) 1024 * (size_t) 1024);
+		string rotate_to = db_config.journal_rotate_destination;
+
+		if (rotate_to == "") {
+			rotate_to = null;
+		}
+
+		bool do_rotating = (chunk_size_mb != -1);
+
+		Tracker.DBJournal.set_rotating (do_rotating, chunk_size, rotate_to);
+
+		int select_cache_size, update_cache_size;
+		string cache_size_s;
+
+		cache_size_s = Environment.get_variable ("TRACKER_STORE_SELECT_CACHE_SIZE");
+		if (cache_size_s != null && cache_size_s != "") {
+			select_cache_size = cache_size_s.to_int ();
+		} else {
+			select_cache_size = SELECT_CACHE_SIZE;
+		}
+
+		cache_size_s = Environment.get_variable ("TRACKER_STORE_UPDATE_CACHE_SIZE");
+		if (cache_size_s != null && cache_size_s != "") {
+			update_cache_size = cache_size_s.to_int ();
+		} else {
+			update_cache_size = UPDATE_CACHE_SIZE;
+		}
+
+		bool is_first_time_index;
+
+		if (!Tracker.Data.Manager.init (flags,
+			                        null,
+			                        out is_first_time_index,
+			                        true,
+			                        select_cache_size,
+			                        update_cache_size,
+			                        busy_callback,
+			                        "Initializing")) {
+
+			return 1;
+		}
+
+
+		db_config = null;
+		notifier = null;
+
+		if (!shutdown) {
+			/* Setup subscription to get notified of locale changes */
+			Tracker.locale_change_initialize_subscription ();
+
+			Tracker.DBus.register_prepare_class_signal ();
+
+			Tracker.Events.init (get_notifiable_classes);
+			Tracker.Writeback.init (get_writeback_predicates);
+			Tracker.Store.resume ();
+
+			message ("Waiting for D-Bus requests...");
+		}
+
+		/* Set our status as running, if this is FALSE, threads stop
+		 * doing what they do and shutdown.
+		 */
+		if (!shutdown) {
+			main_loop = new MainLoop ();
+			main_loop.run ();
+		}
+
+		/*
+		 * Shutdown the daemon
+		 */
+		message ("Shutdown started");
+
+		Tracker.Store.shutdown ();
+
+		Timeout.add (5000, shutdown_timeout_cb, Priority.LOW);
+
+		message ("Cleaning up");
+
+		/* Shutdown major subsystems */
+		Tracker.Writeback.shutdown ();
+		Tracker.Events.shutdown ();
+
+		Tracker.locale_change_shutdown_subscription ();
+
+		Tracker.DBus.shutdown ();
+		Tracker.Data.Manager.shutdown ();
+		Tracker.Log.shutdown ();
+
+		config.disconnect (config_verbosity_id);
+		config = null;
+
+		/* This will free rotate_to up in the journal code */
+		Tracker.DBJournal.set_rotating ((chunk_size_mb != -1), chunk_size, null);
+
+		print ("\nOK\n\n");
+
+		log_filename = null;
+
+		main_loop = null;
+
+		return 0;
+	}
+
+	[CCode (cname = "GETTEXT_PACKAGE")]
+	extern const string GETTEXT_PACKAGE;
+	[CCode (cname = "LOCALEDIR")]
+	extern const string LOCALEDIR;
+
+	[CCode (cname = "tzset", cheader_filename = "time.h")]
+	extern static void tzset ();
+}