diff options
Diffstat (limited to 'tst/nhm-systemd-test.c')
| -rw-r--r-- | tst/nhm-systemd-test.c | 882 |
1 files changed, 882 insertions, 0 deletions
diff --git a/tst/nhm-systemd-test.c b/tst/nhm-systemd-test.c new file mode 100644 index 0000000..1486eb3 --- /dev/null +++ b/tst/nhm-systemd-test.c @@ -0,0 +1,882 @@ +/* NHM - NodeHealthMonitor + * + * Copyright (C) 2013 Continental Automotive Systems, Inc. + * + * 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/. + * + * Author: Jean-Pierre Bogler <Jean-Pierre.Bogler@continental-corporation.com> + */ + +/** + * SECTION:nhm-unit-test + * @title: NodeHealthMonitor (NHM) unit test + * @short_description: Unit test for an automatic check of the NHM systemd + * observation. + * + * The unit test will stimulate the NHM systemd observation and check for the + * expected reactions. + */ + + +/******************************************************************************* +* +* Header includes +* +*******************************************************************************/ + +/* System header files */ +#include <stdio.h> /* NULL */ +#include <glib-2.0/glib.h> /* use gtypes */ + +/* Include the stubbed main file of the NHM. Its functions will be tested! */ +#include "nhm-systemd-test.h" + + +/******************************************************************************* +* +* Local variables and constants +* +*******************************************************************************/ + +/* Variables to check callback on unit state change */ +static gboolean nhm_systemd_test_app_state_changed_cb_called = FALSE; +static gchar *nhm_systemd_test_app_state_changed_cb_name = NULL; +static NhmAppStatus_e nhm_systemd_test_app_state_changed_cb_status = NhmAppStatus_Ok; + + +/******************************************************************************* +* +* Prototypes for file local functions (see implementation for description) +* +*******************************************************************************/ + + +/******************************************************************************* +* +* Local (static) functions +* +*******************************************************************************/ + +/** + * nhm_systemd_test_app_state_changed_cb: + * @name: Name of the application, whose state changed + * @status: New status of the application. + * + * The function is not a test case, but a callback that will be used during + * the tests. + */ +static void +nhm_systemd_test_app_state_changed_cb(const gchar *name, + NhmAppStatus_e status) +{ + /* Remember that callback was called and store passed parameters */ + nhm_systemd_test_app_state_changed_cb_called = TRUE; + nhm_systemd_test_app_state_changed_cb_name = (gchar*) name; + nhm_systemd_test_app_state_changed_cb_status = status; +} + + +/** + * nhm_test_systemd_connect: + * @Return: 0, if test succeeded. Otherwise -1. + * + * Test nhm_systemd_connect() function. + */ +static gint +nhm_test_systemd_connect(void) +{ + gint retval = 0; + NhmSystemdAppStatusCb callback = NULL; + GdbusConnectionCallSyncStubCalls g_dbus_connection_call_sync_stub_calls[3]; + GVariantBuilder *builder; + + /* Check 1: Callback nok. */ + callback = NULL; + retval = (nhm_systemd_connect(callback) == FALSE) ? 0 : -1; + + /* Check 2: Callback ok. Bus conn. nok. */ + if(retval == 0) + { + callback = &nhm_systemd_test_app_state_changed_cb; + g_bus_get_sync_set_error = TRUE; + + retval = (nhm_systemd_connect(callback) == FALSE) ? 0 : -1; + } + + /* Check 3: Callback ok. Bus conn. ok. Subscribe nok. */ + if(retval == 0) + { + callback = &nhm_systemd_test_app_state_changed_cb; + g_bus_get_sync_set_error = FALSE; + + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Subscribe"; + g_dbus_connection_call_sync_stub_calls[0].rval = NULL; + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + retval = (nhm_systemd_connect(callback) == FALSE) ? 0 : -1; + } + + /* Check 4: Callback ok. Bus conn. ok. Subscribe ok. ListUnits nok */ + if(retval == 0) + { + callback = &nhm_systemd_test_app_state_changed_cb; + + g_bus_get_sync_set_error = FALSE; + + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Subscribe"; + g_dbus_connection_call_sync_stub_calls[0].rval = g_variant_new("()"); + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + g_dbus_connection_call_sync_stub_control.count = 2; + g_dbus_connection_call_sync_stub_calls[1].method = "ListUnits"; + g_dbus_connection_call_sync_stub_calls[1].rval = NULL; + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + g_dbus_connection_call_sync_stub_control.count = 3; + g_dbus_connection_call_sync_stub_calls[2].method = "Unsubscribe"; + g_dbus_connection_call_sync_stub_calls[2].rval = NULL; + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + retval = (nhm_systemd_connect(callback) == FALSE) ? 0 : -1; + } + + /* Check 5: Callback ok. Bus conn. ok. Subscribe ok. ListUnits ok */ + if(retval == 0) + { + /* Callback ok */ + callback = &nhm_systemd_test_app_state_changed_cb; + + /* Bus conn. ok */ + g_bus_get_sync_set_error = FALSE; + + /* Subscribe ok */ + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Subscribe"; + g_dbus_connection_call_sync_stub_calls[0].rval = g_variant_new("()"); + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + /* ListUnits ok */ + g_dbus_connection_call_sync_stub_control.count = 2; + g_dbus_connection_call_sync_stub_calls[1].method = "ListUnits"; + + builder = g_variant_builder_new (G_VARIANT_TYPE("a(ssssssouso)")); + g_variant_builder_add (builder, "(ssssssouso)", "1", "2", "3", "4", "5", "6", "/a/b/c", 100, "7", "/a/b/c"); + g_variant_builder_add (builder, "(ssssssouso)", "1.service", "2", "3", "4", "5", "6", "/a/b/c", 100, "7", "/a/b/c"); + g_dbus_connection_call_sync_stub_calls[1].rval = g_variant_new("(a(ssssssouso))", builder); + g_variant_builder_unref (builder); + + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + /* Call */ + retval = (nhm_systemd_connect(callback) == TRUE) ? 0 : -1; + + /* Free created unit object. Destroy bus conn. */ + g_slist_free_full(nhm_systemd_observed_units, &nhm_systemd_free_unit); + g_object_unref(nhm_systemd_conn); + } + + return retval; +} + + +/** + * nhm_test_systemd_disconnect: + * @Return: 0, if test succeeded. Otherwise -1. + * + * Test nhm_systemd_disconnect() function. + */ +static gint +nhm_test_systemd_disconnect(void) +{ + NhmSystemdUnit *unit = NULL; + GdbusConnectionCallSyncStubCalls g_dbus_connection_call_sync_stub_calls[1]; + + /* Check 1: Sub nok. No UnitAdd sig. No UnitRem sig. No obs. units. No systemd conn. */ + nhm_systemd_events_subscribed = FALSE; + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Unsubscribe"; + g_dbus_connection_call_sync_stub_calls[0].rval = NULL; + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + nhm_systemd_unit_add_sig_id = 0; + nhm_systemd_unit_rem_sig_id = 0; + nhm_systemd_observed_units = NULL; + nhm_systemd_conn = NULL; + + nhm_systemd_disconnect(); + + /* Check 2: Sub ok. Unsub. nok. No UnitAdd sig. No UnitRem sig. No obs. units. No systemd conn. */ + nhm_systemd_events_subscribed = TRUE; + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Unsubscribe"; + g_dbus_connection_call_sync_stub_calls[0].rval = NULL; + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + nhm_systemd_unit_add_sig_id = 0; + nhm_systemd_unit_rem_sig_id = 0; + nhm_systemd_observed_units = NULL; + nhm_systemd_conn = NULL; + + nhm_systemd_disconnect(); + + /* Check 3: Unsub. ok. UnitAdd sig. UnitRem sig. Obs. units. Systemd conn. */ + nhm_systemd_events_subscribed = TRUE; + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Unsubscribe"; + g_dbus_connection_call_sync_stub_calls[0].rval = g_variant_new("()"); + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + nhm_systemd_unit_add_sig_id = 1; + nhm_systemd_unit_rem_sig_id = 1; + + unit = g_new(NhmSystemdUnit, 1); + unit->active_state = NHM_ACTIVE_STATE_UNKNOWN; + unit->name = g_strdup("Unit"); + unit->path = g_strdup("/a/unit/to/destroy"); + unit->sig_sub_id = 0; + nhm_systemd_observed_units = g_slist_append(nhm_systemd_observed_units, unit); + + nhm_systemd_conn = g_object_new(G_TYPE_DBUS_CONNECTION, NULL); + + nhm_systemd_disconnect(); + + return 0; +} + + +/** + * nhm_systemd_test_active_state_string_to_enum: + * @Return: 0, if test succeeded. Otherwise -1. + * + * Test nhm_systemd_active_state_string_to_enum() function. + */ +static gint +nhm_systemd_test_active_state_string_to_enum(void) +{ + gint retval = 0; + + /* Check 1: active -> NHM_ACTIVE_STATE_ACTIVE */ + retval = ( nhm_systemd_active_state_string_to_enum("active") + == NHM_ACTIVE_STATE_ACTIVE) ? 0 : -1; + + /* Check 2: inactive -> NHM_ACTIVE_STATE_INACTIVE */ + if(retval == 0) + { + retval = (nhm_systemd_active_state_string_to_enum("inactive") + == NHM_ACTIVE_STATE_INACTIVE) ? 0 : -1; + } + + /* Check 3: activating -> NHM_ACTIVE_STATE_ACTIVATING */ + if(retval == 0) + { + retval = (nhm_systemd_active_state_string_to_enum("activating") + == NHM_ACTIVE_STATE_ACTIVATING) ? 0 : -1; + } + + /* Check 4: deactivating -> NHM_ACTIVE_STATE_DEACTIVATING */ + if(retval == 0) + { + retval = (nhm_systemd_active_state_string_to_enum("deactivating") + == NHM_ACTIVE_STATE_DEACTIVATING) ? 0 : -1; + } + + /* Check 5: failed -> NHM_ACTIVE_STATE_FAILED */ + if(retval == 0) + { + retval = (nhm_systemd_active_state_string_to_enum("failed") + == NHM_ACTIVE_STATE_FAILED) ? 0 : -1; + } + + /* Check 6: reloading -> NHM_ACTIVE_STATE_RELOADING */ + if(retval == 0) + { + retval = (nhm_systemd_active_state_string_to_enum("reloading") + == NHM_ACTIVE_STATE_RELOADING) ? 0 : -1; + } + + /* Check 6: ? -> NHM_ACTIVE_STATE_UNKNOWN */ + if(retval == 0) + { + retval = (nhm_systemd_active_state_string_to_enum("") + == NHM_ACTIVE_STATE_UNKNOWN) ? 0 : -1; + } + + return retval; +} + + +/** + * nhm_systemd_test_subscribe_properties_changed: + * @Return: 0, if test succeeded. Otherwise -1. + * + * Test nhm_systemd_subscribe_properties_changed() function. + */ +static gint +nhm_systemd_test_subscribe_properties_changed(void) +{ + NhmSystemdUnit unit; + + /* Check 1: Do a subscription */ + return (nhm_systemd_subscribe_properties_changed(&unit) == 0) ? 0 : -1; +} + + +/** + * nhm_systemd_test_find_unit_by_name: + * @Return: 0, if test succeeded. Otherwise -1. + * + * Test nhm_systemd_find_unit_by_name() function. + */ +static gint +nhm_systemd_test_find_unit_by_name(void) +{ + gint retval = 0; + NhmSystemdUnit u1; + NhmSystemdUnit u2; + + /* Check 1: Valid compare */ + u1.name = "Unit1"; + u2.name = "Unit1"; + retval = (nhm_systemd_find_unit_by_name(&u1, &u2) == 0) ? 0 : -1; + + /* Check 2: Invalid compare I */ + if(retval == 0) + { + u1.name = "Unit1"; + u2.name = "Unit2"; + retval = (nhm_systemd_find_unit_by_name(&u1, &u2) == -1) ? 0 : -1; + } + + /* Check 3: Invalid compare II */ + if(retval == 0) + { + u1.name = "Unit2"; + u2.name = "Unit1"; + retval = (nhm_systemd_find_unit_by_name(&u1, &u2) == 1) ? 0 : -1; + } + + return retval; +} + + +/** + * nhm_systemd_test_free_unit: + * @Return: 0, if test succeeded. Otherwise -1. + * + * Test nhm_systemd_free_unit() function. + */ +static gint +nhm_systemd_test_free_unit(void) +{ + NhmSystemdUnit *unit = g_new(NhmSystemdUnit, 1); + + /* Check 1: Free normal unit object */ + unit->active_state = NHM_ACTIVE_STATE_UNKNOWN; + unit->name = g_strdup("Unit"); + unit->path = g_strdup("/path/to/unit"); + unit->sig_sub_id = 0; + + nhm_systemd_free_unit(unit); + + return 0; +} + + +/** + * nhm_systemd_test_unit_active_state_changed: + * @Return: 0, if test succeeded. Otherwise -1. + * + * Test nhm_systemd_unit_active_state_changed() function. + */ +static gint +nhm_systemd_test_unit_active_state_changed(void) +{ + gint retval = 0; + NhmSystemdUnit unit = {"Unit", "Path", NHM_ACTIVE_STATE_UNKNOWN, 0}; + + /* Check 1: Change NHM_ACTIVE_STATE_UNKNOWN -> NHM_ACTIVE_STATE_UNKNOWN */ + nhm_systemd_app_status_cb = &nhm_systemd_test_app_state_changed_cb; + nhm_systemd_test_app_state_changed_cb_called = FALSE; + nhm_systemd_test_app_state_changed_cb_name = NULL; + nhm_systemd_test_app_state_changed_cb_status = NhmAppStatus_Ok; + + nhm_systemd_unit_active_state_changed(&unit, NHM_ACTIVE_STATE_UNKNOWN); + + /* Check that no callback occured */ + retval = (nhm_systemd_test_app_state_changed_cb_called == FALSE) ? 0 : -1; + + /* Check 2: Change NHM_ACTIVE_STATE_UNKNOWN -> NHM_ACTIVE_STATE_ACTIVE */ + if(retval == 0) + { + nhm_systemd_app_status_cb = &nhm_systemd_test_app_state_changed_cb; + nhm_systemd_test_app_state_changed_cb_called = FALSE; + nhm_systemd_test_app_state_changed_cb_name = NULL; + nhm_systemd_test_app_state_changed_cb_status = NhmAppStatus_Failed; + + nhm_systemd_unit_active_state_changed(&unit, NHM_ACTIVE_STATE_ACTIVE); + + /* Assert that callback occurred */ + retval = ( (nhm_systemd_test_app_state_changed_cb_called == TRUE) + && (g_strcmp0(nhm_systemd_test_app_state_changed_cb_name, unit.name) == 0) + && (nhm_systemd_test_app_state_changed_cb_status == NhmAppStatus_Ok)) + ? 0 : -1; + } + + /* Check 2: Change NHM_ACTIVE_STATE_UNKNOWN -> NHM_ACTIVE_STATE_ACTIVE */ + if(retval == 0) + { + nhm_systemd_app_status_cb = &nhm_systemd_test_app_state_changed_cb; + nhm_systemd_test_app_state_changed_cb_called = FALSE; + nhm_systemd_test_app_state_changed_cb_name = NULL; + nhm_systemd_test_app_state_changed_cb_status = NhmAppStatus_Ok; + + nhm_systemd_unit_active_state_changed(&unit, NHM_ACTIVE_STATE_FAILED); + + /* Assert that callback occurred */ + retval = ( (nhm_systemd_test_app_state_changed_cb_called == TRUE) + && (g_strcmp0(nhm_systemd_test_app_state_changed_cb_name, unit.name) == 0) + && (nhm_systemd_test_app_state_changed_cb_status == NhmAppStatus_Failed)) + ? 0 : -1; + } + + return retval; +} + + +/** + * nhm_systemd_test_unit_get_active_state: + * @Return: 0, if test succeeded. Otherwise -1. + * + * Test nhm_systemd_unit_get_active_state() function. + */ +static gint +nhm_systemd_test_unit_get_active_state(void) +{ + gint retval = 0; + GVariant *unit_state_variant = NULL; + NhmSystemdUnit unit = {"Name", "Path", NHM_ACTIVE_STATE_ACTIVE, 0}; + GdbusConnectionCallSyncStubCalls g_dbus_connection_call_sync_stub_calls[1]; + + /* Check 1: D-Bus error getting ActiveState property */ + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Get"; + g_dbus_connection_call_sync_stub_calls[0].rval = NULL; + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + retval = (nhm_systemd_unit_get_active_state(&unit) == NHM_ACTIVE_STATE_UNKNOWN) + ? 0 : -1; + + /* Check 2: Retrieve D-Bus property value successful */ + if(retval == 0) + { + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Get"; + + unit_state_variant = g_variant_new_string("active"); + unit_state_variant = g_variant_new_variant(unit_state_variant); + unit_state_variant = g_variant_new_tuple(&unit_state_variant, 1); + g_dbus_connection_call_sync_stub_calls[0].rval = unit_state_variant; + + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + retval = (nhm_systemd_unit_get_active_state(&unit) == NHM_ACTIVE_STATE_ACTIVE) + ? 0 : -1; + } + + return retval; +} + + +/** + * nhm_systemd_test_unit_added: + * @Return: 0, if test succeeded. Otherwise -1. + * + * Test nhm_systemd_unit_added() function. + */ +static gint +nhm_systemd_test_unit_added(void) +{ + gint retval = 0; + GVariant *param = NULL; + GVariant *unit_state_variant = NULL; + NhmSystemdUnit *unit = NULL; + GdbusConnectionCallSyncStubCalls g_dbus_connection_call_sync_stub_calls[1]; + + /* Check 1: Wrong parameter format */ + nhm_systemd_observed_units = NULL; + param = g_variant_new("(uss)", 10, "Wrong", "Unit"); + + nhm_systemd_unit_added(NULL, + NULL, + NULL, + NULL, + NULL, + param, + NULL); + + retval = (nhm_systemd_observed_units == NULL) ? 0 : -1; + + /* Check 2: New unit added, but no service */ + if(retval == 0) + { + nhm_systemd_observed_units = NULL; + param = g_variant_new("(so)", "Unit", "/Path/to/Unit"); + + /* Function will retrieve unit's active state */ + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Get"; + + unit_state_variant = g_variant_new_string("active"); + unit_state_variant = g_variant_new_variant(unit_state_variant); + unit_state_variant = g_variant_new_tuple(&unit_state_variant, 1); + g_dbus_connection_call_sync_stub_calls[0].rval = unit_state_variant; + + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + nhm_systemd_unit_added(NULL, + NULL, + NULL, + NULL, + NULL, + param, + NULL); + g_variant_unref(param); + /* Check that unit was not added */ + retval = (nhm_systemd_observed_units == NULL) ? 0 : -1; + } + + /* Check 3: Add new service */ + if(retval == 0) + { + nhm_systemd_observed_units = NULL; + param = g_variant_new("(so)", "Unit.service", "/Path/to/Unit"); + + /* Function will retrieve unit's active state */ + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Get"; + + unit_state_variant = g_variant_new_string("active"); + unit_state_variant = g_variant_new_variant(unit_state_variant); + unit_state_variant = g_variant_new_tuple(&unit_state_variant, 1); + g_dbus_connection_call_sync_stub_calls[0].rval = unit_state_variant; + + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + nhm_systemd_unit_added(NULL, + NULL, + NULL, + NULL, + NULL, + param, + NULL); + + g_variant_unref(param); + /* Check that unit was not added */ + unit = (NhmSystemdUnit*) nhm_systemd_observed_units->data; + retval = ( (g_strcmp0(unit->name, "Unit.service") == 0) + && (g_strcmp0(unit->path, "/Path/to/Unit") == 0) + && (unit->active_state == NHM_ACTIVE_STATE_ACTIVE) + && (unit->sig_sub_id == 0)) ? 0 : -1; + + g_slist_free_full(nhm_systemd_observed_units, &nhm_systemd_free_unit); + } + + /* Check 4: Add same service */ + if(retval == 0) + { + param = g_variant_new("(so)", "Unit.service", "/Path/to/Unit"); + + /* Add unit to the list */ + nhm_systemd_observed_units = NULL; + unit = g_new(NhmSystemdUnit, 1); + unit->name = g_strdup("Unit.service"); + unit->path = g_strdup("/Path/to/Unit"); + unit->active_state = NHM_ACTIVE_STATE_UNKNOWN; + unit->sig_sub_id = 0; + nhm_systemd_observed_units = g_slist_append(nhm_systemd_observed_units, unit); + + nhm_systemd_unit_added(NULL, + NULL, + NULL, + NULL, + NULL, + param, + NULL); + + g_variant_unref(param); + retval = (g_slist_length(nhm_systemd_observed_units) == 1) ? 0 : -1; + + g_slist_free_full(nhm_systemd_observed_units, &nhm_systemd_free_unit); + } + + return retval; +} + + +/** + * nhm_systemd_test_unit_removed: + * @Return: 0, if test succeeded. Otherwise -1. + * + * Test nhm_systemd_unit_removed() function. + */ +static gint +nhm_systemd_test_unit_removed(void) +{ + gint retval = 0; + GVariant *param = NULL; + NhmSystemdUnit *unit; + + /* Preparation: Build up a list with an observed unit */ + nhm_systemd_observed_units = NULL; + unit = g_new(NhmSystemdUnit, 1); + unit->name = g_strdup("Unit.service"); + unit->path = g_strdup("/Path/to/Unit"); + unit->active_state = NHM_ACTIVE_STATE_UNKNOWN; + unit->sig_sub_id = 0; + nhm_systemd_observed_units = g_slist_append(nhm_systemd_observed_units, unit); + + /* Reuse unit variable to point on first list element */ + unit = (NhmSystemdUnit*) (nhm_systemd_observed_units->data); + + + /* Check 1: Invalid parameter format */ + param = g_variant_new("(uss)", 10, "Unit", "/Path/to/Unit"); + + nhm_systemd_unit_removed(NULL, + NULL, + NULL, + NULL, + NULL, + param, + NULL); + g_variant_unref(param); + /* Assert unit still on the list */ + retval = ( (g_strcmp0(unit->name, "Unit.service") == 0) + && (g_strcmp0(unit->path, "/Path/to/Unit") == 0) + && (unit->active_state == NHM_ACTIVE_STATE_UNKNOWN) + && (unit->sig_sub_id == 0)) ? 0 : -1; + + /* Check 2: No service removed */ + if(retval == 0) + { + param = g_variant_new("(so)", "Unit1", "/Path/to/Unit"); + + nhm_systemd_unit_removed(NULL, + NULL, + NULL, + NULL, + NULL, + param, + NULL); + g_variant_unref(param); + /* Assert unit still on the list */ + retval = ( (g_strcmp0(unit->name, "Unit.service") == 0) + && (g_strcmp0(unit->path, "/Path/to/Unit") == 0) + && (unit->active_state == NHM_ACTIVE_STATE_UNKNOWN) + && (unit->sig_sub_id == 0)) ? 0 : -1; + } + + /* Check 3: Unknown unit removed */ + if(retval == 0) + { + param = g_variant_new("(so)", "Unit1.service", "/Path/to/Unit"); + + nhm_systemd_unit_removed(NULL, + NULL, + NULL, + NULL, + NULL, + param, + NULL); + g_variant_unref(param); + /* Assert unit still on the list */ + retval = ( (g_strcmp0(unit->name, "Unit.service") == 0) + && (g_strcmp0(unit->path, "/Path/to/Unit") == 0) + && (unit->active_state == NHM_ACTIVE_STATE_UNKNOWN) + && (unit->sig_sub_id == 0)) ? 0 : -1; + } + + /* Check 4: Unit removed */ + if(retval == 0) + { + param = g_variant_new("(so)", "Unit.service", "/Path/to/Unit"); + + nhm_systemd_unit_removed(NULL, + NULL, + NULL, + NULL, + NULL, + param, + NULL); + g_variant_unref(param); + retval = (nhm_systemd_observed_units == NULL) ? 0 : -1; + } + + return retval; +} + + +/** + * nhm_systemd_test_unit_properties_changed: + * @Return: 0, if test succeeded. Otherwise -1. + * + * Test nhm_systemd_unit_properties_changed() function. + */ +static gint +nhm_systemd_test_unit_properties_changed(void) +{ + gint retval = 0; + GVariant *param = NULL; + GVariant *unit_state_variant = NULL; + gchar *inv_prop[2] = {"state", NULL}; + NhmSystemdUnit unit; + GdbusConnectionCallSyncStubCalls g_dbus_connection_call_sync_stub_calls[1]; + + /* Check 1: Parameter format nok. */ + param = g_variant_new("(s)", "Test"); + nhm_systemd_app_status_cb = &nhm_systemd_test_app_state_changed_cb; + nhm_systemd_test_app_state_changed_cb_called = FALSE; + + nhm_systemd_unit_properties_changed(NULL, + NULL, + NULL, + NULL, + NULL, + param, + NULL); + g_variant_unref(param); + retval = (nhm_systemd_test_app_state_changed_cb_called == FALSE) ? 0 : -1; + + /* Check 2: Parameter format ok. ActiveState unchanged. */ + if(retval == 0) + { + inv_prop[0] = "Invalid"; + param = g_variant_new("(sa{sv}^as)", "Test", NULL, inv_prop); + + nhm_systemd_app_status_cb = &nhm_systemd_test_app_state_changed_cb; + nhm_systemd_test_app_state_changed_cb_called = FALSE; + + nhm_systemd_unit_properties_changed(NULL, + NULL, + NULL, + NULL, + NULL, + param, + NULL); + g_variant_unref(param); + retval = (nhm_systemd_test_app_state_changed_cb_called == FALSE) ? 0 : -1; + } + + /* Check 3: Parameter format ok. Same ActiveState. */ + if(retval == 0) + { + inv_prop[0] = "ActiveState"; + param = g_variant_new("(sa{sv}^as)", "Test", NULL, inv_prop); + + unit.name = "Unit"; + unit.path = "Path"; + unit.active_state = NHM_ACTIVE_STATE_ACTIVE; + unit.sig_sub_id = 0; + + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Get"; + unit_state_variant = g_variant_new_string("active"); + unit_state_variant = g_variant_new_variant(unit_state_variant); + unit_state_variant = g_variant_new_tuple(&unit_state_variant, 1); + g_dbus_connection_call_sync_stub_calls[0].rval = unit_state_variant; + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + nhm_systemd_app_status_cb = &nhm_systemd_test_app_state_changed_cb; + nhm_systemd_test_app_state_changed_cb_called = FALSE; + + nhm_systemd_unit_properties_changed(NULL, + NULL, + NULL, + NULL, + NULL, + param, + &unit); + g_variant_unref(param); + retval = (nhm_systemd_test_app_state_changed_cb_called == FALSE) ? 0 : -1; + } + + /* Check 4: Parameter format ok. ActiveState changed. */ + if(retval == 0) + { + inv_prop[0] = "ActiveState"; + param = g_variant_new("(sa{sv}^as)", "Test", NULL, inv_prop); + + unit.name = "Unit"; + unit.path = "Path"; + unit.active_state = NHM_ACTIVE_STATE_FAILED; + unit.sig_sub_id = 0; + g_dbus_connection_call_sync_stub_control.count = 1; + g_dbus_connection_call_sync_stub_calls[0].method = "Get"; + unit_state_variant = g_variant_new_string("active"); + unit_state_variant = g_variant_new_variant(unit_state_variant); + unit_state_variant = g_variant_new_tuple(&unit_state_variant, 1); + g_dbus_connection_call_sync_stub_calls[0].rval = unit_state_variant; + g_dbus_connection_call_sync_stub_control.calls = g_dbus_connection_call_sync_stub_calls; + + nhm_systemd_test_app_state_changed_cb_called = FALSE; + nhm_systemd_app_status_cb = &nhm_systemd_test_app_state_changed_cb; + nhm_systemd_unit_properties_changed(NULL, + NULL, + NULL, + NULL, + NULL, + param, + &unit); + g_variant_unref(param); + retval = (nhm_systemd_test_app_state_changed_cb_called == TRUE) ? 0 : -1; + } + + return retval; +} + + +/******************************************************************************* +* +* Interfaces. Exported functions. +* +*******************************************************************************/ + +/** + * main: + * + * Main function of the unit test. + * + * Return value: 0 if all tests succeeded. Otherwise -1. + */ +int +main(void) +{ + int retval = 0; + + g_type_init(); + + /* Test interfaces */ + retval = nhm_test_systemd_connect(); + retval = (retval == 0) ? nhm_test_systemd_disconnect() : -1; + + /* Test static functions */ + retval = (retval == 0) ? nhm_systemd_test_active_state_string_to_enum() : -1; + + /* Test helper functions */ + retval = (retval == 0) ? nhm_systemd_test_subscribe_properties_changed() : -1; + retval = (retval == 0) ? nhm_systemd_test_find_unit_by_name() : -1; + retval = (retval == 0) ? nhm_systemd_test_free_unit() : -1; + + /* Test unit state change chain */ + retval = (retval == 0) ? nhm_systemd_test_unit_active_state_changed() : -1; + retval = (retval == 0) ? nhm_systemd_test_unit_get_active_state() : -1; + retval = (retval == 0) ? nhm_systemd_test_unit_added() : -1; + retval = (retval == 0) ? nhm_systemd_test_unit_removed() : -1; + retval = (retval == 0) ? nhm_systemd_test_unit_properties_changed() : -1; + + return retval; +} |