Implement TargetStartupMonitor class

This class listens to systemd's JobRemoved signal, and should respond if
it recognises one of the following units finishing:
- focussed.target
- unfocussed.target
- lazy.target

With the currently-used version of systemd, the unit name is not given.
At the current state of the project, the Node State Manager is not
available to communicate with.

4 files changed, 247 insertions, 0 deletions

diff --git a/boot-manager/Makefile.am b/boot-manager/Makefile.am
index fefaa6a..4722350 100644
--- a/boot-manager/Makefile.am
+++ b/boot-manager/Makefile.am
@@ -26,6 +26,8 @@ boot_manager_SOURCES =							\
 	boot-manager-service.h						\
 	luc-starter.c							\
 	luc-starter.h							\
+	target-startup-monitor.c					\
+	target-startup-monitor.h					\
 	main.c								\
 	$(boot_manager_built_sources)
 
diff --git a/boot-manager/main.c b/boot-manager/main.c
index b0611b8..3291664 100644
--- a/boot-manager/main.c
+++ b/boot-manager/main.c
@@ -23,6 +23,7 @@
 #include <boot-manager/boot-manager-application.h>
 #include <boot-manager/boot-manager-service.h>
 #include <boot-manager/systemd-manager-dbus.h>
+#include <boot-manager/target-startup-monitor.h>
 
 
 
@@ -35,6 +36,7 @@ main (int    argc,
       char **argv)
 {
   BootManagerApplication *application;
+  TargetStartupMonitor   *target_startup_monitor;
   BootManagerService     *service;
   GDBusConnection        *connection;
   SystemdManager         *systemd_manager;
@@ -126,12 +128,16 @@ main (int    argc,
       return EXIT_FAILURE;
     }
 
+  /* start up the target startup monitor */
+  target_startup_monitor = target_startup_monitor_new (systemd_manager);
+
   /* create and run the main application */
   application = boot_manager_application_new (service, luc_handler);
   exit_status = g_application_run (G_APPLICATION (application), 0, NULL);
   g_object_unref (application);
 
   /* release allocated objects */
+  g_object_unref (target_startup_monitor);
   g_object_unref (systemd_manager);
   g_object_unref (service);
   g_object_unref (connection);
diff --git a/boot-manager/target-startup-monitor.c b/boot-manager/target-startup-monitor.c
new file mode 100644
index 0000000..e188152
--- /dev/null
+++ b/boot-manager/target-startup-monitor.c
@@ -0,0 +1,207 @@
+/* vi:set et ai sw=2 sts=2 ts=2: */
+/* -
+ * Copyright (c) 2012 GENIVI.
+ *
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
+
+#include <glib-object.h>
+#include <gio/gio.h>
+
+#include <boot-manager/boot-manager-dbus.h>
+#include <boot-manager/target-startup-monitor.h>
+
+
+
+/* property identifier */
+enum
+{
+  PROP_0,
+  PROP_SYSTEMD_MANAGER,
+};
+
+
+
+static void target_startup_monitor_finalize     (GObject              *object);
+static void target_startup_monitor_constructed  (GObject              *object);
+static void target_startup_monitor_get_property (GObject              *object,
+                                                 guint                 prop_id,
+                                                 GValue               *value,
+                                                 GParamSpec           *pspec);
+static void target_startup_monitor_set_property (GObject              *object,
+                                                 guint                 prop_id,
+                                                 const GValue         *value,
+                                                 GParamSpec           *pspec);
+static void target_startup_monitor_job_removed  (SystemdManager       *manager,
+                                                 guint                 id,
+                                                 const gchar          *job_name,
+                                                 const gchar          *result,
+                                                 TargetStartupMonitor *monitor);
+
+
+
+struct _TargetStartupMonitorClass
+{
+  GObjectClass __parent__;
+};
+
+struct _TargetStartupMonitor
+{
+  GObject         __parent__;
+
+  SystemdManager *systemd_manager;
+
+  /* map of targets to their NSM states */
+  GHashTable     *watched_targets;
+};
+
+
+
+G_DEFINE_TYPE (TargetStartupMonitor, target_startup_monitor, G_TYPE_OBJECT);
+
+
+
+static void
+target_startup_monitor_class_init (TargetStartupMonitorClass *klass)
+{
+  GObjectClass *gobject_class;
+
+  gobject_class = G_OBJECT_CLASS (klass);
+  gobject_class->finalize = target_startup_monitor_finalize;
+  gobject_class->constructed = target_startup_monitor_constructed;
+  gobject_class->get_property = target_startup_monitor_get_property;
+  gobject_class->set_property = target_startup_monitor_set_property;
+
+  g_object_class_install_property (gobject_class,
+                                   PROP_SYSTEMD_MANAGER,
+                                   g_param_spec_object ("systemd-manager",
+                                                        "systemd-manager",
+                                                        "systemd-manager",
+                                                        TYPE_SYSTEMD_MANAGER,
+                                                        G_PARAM_READWRITE |
+                                                        G_PARAM_CONSTRUCT_ONLY |
+                                                        G_PARAM_STATIC_STRINGS));
+}
+
+
+
+static void
+target_startup_monitor_init (TargetStartupMonitor *monitor)
+{
+  /* create the table of targets and their NSM states */
+  monitor->watched_targets = g_hash_table_new (g_str_hash, g_str_equal);
+  g_hash_table_insert (monitor->watched_targets, "focussed.target", "LUC_RUNNING");
+  g_hash_table_insert (monitor->watched_targets, "unfocussed.target", "FULLY_RUNNING");
+  g_hash_table_insert (monitor->watched_targets, "lazy.target", "FULLY_OPERATIONAL");
+}
+
+
+
+static void
+target_startup_monitor_constructed (GObject *object)
+{
+  TargetStartupMonitor *monitor = TARGET_STARTUP_MONITOR (object);
+
+  /* connect to systemd's "JobRemoved" signal so that we are notified
+   * whenever a job is finished */
+  g_signal_connect (monitor->systemd_manager, "job-removed",
+                    G_CALLBACK (target_startup_monitor_job_removed), monitor);
+}
+
+
+
+static void
+target_startup_monitor_finalize (GObject *object)
+{
+  TargetStartupMonitor *monitor = TARGET_STARTUP_MONITOR (object);
+
+  /* release the watched_targets table */
+  g_hash_table_destroy (monitor->watched_targets);
+
+  /* release the systemd manager */
+  g_signal_handlers_disconnect_matched (monitor->systemd_manager,
+                                        G_SIGNAL_MATCH_DATA,
+                                        0, 0, NULL, NULL, monitor);
+  g_object_unref (monitor->systemd_manager);
+
+  (*G_OBJECT_CLASS (target_startup_monitor_parent_class)->finalize) (object);
+}
+
+
+
+static void
+target_startup_monitor_get_property (GObject    *object,
+                                     guint       prop_id,
+                                     GValue     *value,
+                                     GParamSpec *pspec)
+{
+  TargetStartupMonitor *monitor = TARGET_STARTUP_MONITOR (object);
+
+  switch (prop_id)
+    {
+      case PROP_SYSTEMD_MANAGER:
+        g_value_set_object (value, monitor->systemd_manager);
+        break;
+      default:
+        G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+        break;
+    }
+}
+
+
+
+static void
+target_startup_monitor_set_property (GObject      *object,
+                                     guint         prop_id,
+                                     const GValue *value,
+                                     GParamSpec   *pspec)
+{
+  TargetStartupMonitor *monitor = TARGET_STARTUP_MONITOR (object);
+
+  switch (prop_id)
+    {
+      case PROP_SYSTEMD_MANAGER:
+        monitor->systemd_manager = g_value_dup_object (value);
+        break;
+      default:
+        G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+        break;
+    }
+}
+
+
+
+static void
+target_startup_monitor_job_removed (SystemdManager       *manager,
+                                    guint                 id,
+                                    const gchar          *job_name,
+                                    const gchar          *result,
+                                    TargetStartupMonitor *monitor)
+{
+  g_return_if_fail (IS_SYSTEMD_MANAGER (manager));
+  g_return_if_fail (job_name != NULL && *job_name != '\0');
+  g_return_if_fail (result != NULL && *result != '\0');
+  g_return_if_fail (IS_TARGET_STARTUP_MONITOR (monitor));
+
+  /* TODO: The current version of systemd does not return the unit's name.
+   * later versions will, so finishing this handler is postponed until we
+   * have a newer version of systemd */
+}
+
+
+
+TargetStartupMonitor *
+target_startup_monitor_new (SystemdManager *systemd_manager)
+{
+  g_return_val_if_fail (IS_SYSTEMD_MANAGER (systemd_manager), NULL);
+
+  return g_object_new (TYPE_TARGET_STARTUP_MONITOR,
+                       "systemd-manager", systemd_manager,
+                       NULL);
+}
diff --git a/boot-manager/target-startup-monitor.h b/boot-manager/target-startup-monitor.h
new file mode 100644
index 0000000..b4054e8
--- /dev/null
+++ b/boot-manager/target-startup-monitor.h
@@ -0,0 +1,32 @@
+/* vi:set et ai sw=2 sts=2 ts=2: */
+/* -
+ * Copyright (c) 2012 GENIVI.
+ *
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/.
+ */
+
+#ifndef __TARGET_STARTUP_MONITOR_H__
+#define __TARGET_STARTUP_MONITOR_H__
+
+#include <boot-manager/systemd-manager-dbus.h>
+
+G_BEGIN_DECLS
+
+#define TYPE_TARGET_STARTUP_MONITOR            (target_startup_monitor_get_type ())
+#define TARGET_STARTUP_MONITOR(obj)            (G_TYPE_CHECK_INSTANCE_CAST ((obj), TYPE_TARGET_STARTUP_MONITOR, TargetStartupMonitor))
+#define TARGET_STARTUP_MONITOR_CLASS(klass)    (G_TYPE_CHECK_CLASS_CAST ((klass), TYPE_TARGET_STARTUP_MONITOR, TargetStartupMonitorClass))
+#define IS_TARGET_STARTUP_MONITOR(obj)         (G_TYPE_CHECK_INSTANCE_TYPE ((obj), TYPE_TARGET_STARTUP_MONITOR))
+#define IS_TARGET_STARTUP_MONITOR_CLASS(klass) (G_TYPE_CHECK_CLASS_TYPE ((klass), TYPE_TARGET_STARTUP_MONITOR))
+#define TARGET_STARTUP_MONITOR_GET_CLASS(obj)  (G_TYPE_INSTANCE_GET_CLASS ((obj), TYPE_TARGET_STARTUP_MONITOR, TargetStartupMonitorClass))
+
+typedef struct _TargetStartupMonitor      TargetStartupMonitor;
+typedef struct _TargetStartupMonitorClass TargetStartupMonitorClass;
+
+GType                 target_startup_monitor_get_type (void) G_GNUC_CONST;
+TargetStartupMonitor *target_startup_monitor_new      (SystemdManager *systemd_manager) G_GNUC_MALLOC G_GNUC_WARN_UNUSED_RESULT;
+
+G_END_DECLS
+
+#endif /* !__TARGET_STARTUP_MONITOR_H__ */