[tracker/gdbus-store: 8/8] tracker-store: Port tracker-main to Vala
- From: Jürg Billeter <juergbi src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [tracker/gdbus-store: 8/8] tracker-store: Port tracker-main to Vala
- Date: Wed, 12 Jan 2011 12:02:03 +0000 (UTC)
commit 0e2bcba612fa5856efee90c24b5d29452bffa615
Author: Jürg Billeter <j bitron ch>
Date: Wed Jan 12 12:32:15 2011 +0100
tracker-store: Port tracker-main to Vala
configure.ac | 2 +-
src/tracker-store/.gitignore | 1 +
src/tracker-store/Makefile.am | 2 +-
src/tracker-store/tracker-main.c | 517 -----------------------------------
src/tracker-store/tracker-main.vala | 371 +++++++++++++++++++++++++
5 files changed, 374 insertions(+), 519 deletions(-)
---
diff --git a/configure.ac b/configure.ac
index 1abcfa4..c184a79 100644
--- a/configure.ac
+++ b/configure.ac
@@ -46,7 +46,7 @@ AC_INIT([tracker],
[tracker],
[http://www.tracker-project.org])
-AC_CONFIG_SRCDIR([src/tracker-store/tracker-main.c])
+AC_CONFIG_SRCDIR([src/tracker-store/tracker-main.vala])
AC_CONFIG_MACRO_DIR([m4])
AC_CONFIG_HEADERS([config.h])
diff --git a/src/tracker-store/.gitignore b/src/tracker-store/.gitignore
index b57c9e6..af38b38 100644
--- a/src/tracker-store/.gitignore
+++ b/src/tracker-store/.gitignore
@@ -1,6 +1,7 @@
tracker-store
tracker-backup.c
tracker-dbus.c
+tracker-main.c
tracker-resources.c
tracker-statistics.c
tracker-status.c
diff --git a/src/tracker-store/Makefile.am b/src/tracker-store/Makefile.am
index d7e2552..27d3355 100644
--- a/src/tracker-store/Makefile.am
+++ b/src/tracker-store/Makefile.am
@@ -23,7 +23,7 @@ tracker_store_SOURCES = \
tracker-dbus.vala \
tracker-events.c \
tracker-locale-change.c \
- tracker-main.c \
+ tracker-main.vala \
tracker-resources.vala \
tracker-statistics.vala \
tracker-status.vala \
diff --git a/src/tracker-store/tracker-main.vala b/src/tracker-store/tracker-main.vala
new file mode 100644
index 0000000..2f9b448
--- /dev/null
+++ b/src/tracker-store/tracker-main.vala
@@ -0,0 +1,371 @@
+/*
+ * 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 = -1;
+ 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 ();
+
+ 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 ();
+}
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]