From 2e8981f0f549d59665ca93dfa5a8a38a7defb7e5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Marco=20Trevisan=20=28Trevi=C3=B1o=29?= Date: Thu, 12 Dec 2019 18:42:46 +0100 Subject: [PATCH 128/181] tests: Add unit tests for fpi-ssm Verify that the state machine actions are done as we expected, being the main tool for drivers, better to check that is done as we expect. --- tests/meson.build | 1 + tests/test-fpi-ssm.c | 1396 ++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 1397 insertions(+) create mode 100644 tests/test-fpi-ssm.c diff --git a/tests/meson.build b/tests/meson.build index d082908..b4022a4 100644 --- a/tests/meson.build +++ b/tests/meson.build @@ -58,6 +58,7 @@ test_utils = static_library('fprint-test-utils', unit_tests = [ 'fpi-device', + 'fpi-ssm', ] if 'virtual_image' in drivers diff --git a/tests/test-fpi-ssm.c b/tests/test-fpi-ssm.c new file mode 100644 index 0000000..a3bd9da --- /dev/null +++ b/tests/test-fpi-ssm.c @@ -0,0 +1,1396 @@ +/* + * FpiSsm Unit tests + * Copyright (C) 2019 Marco Trevisan + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 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 + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser 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 + */ + +#include "fp-device.h" +#define FP_COMPONENT "SSM" + +#include "drivers_api.h" +#include "test-device-fake.h" +#include "fpi-log.h" + +/* Utility functions and shared data */ + +static FpDevice *fake_device = NULL; + +typedef struct +{ + volatile int ref_count; + int handler_state; + GSList *handlers_chain; + gboolean completed; + GError *error; + gboolean ssm_destroyed; + gboolean expected_last_state; +} FpiSsmTestData; + +static FpiSsmTestData * +fpi_ssm_test_data_new (void) +{ + FpiSsmTestData *data = g_new0 (FpiSsmTestData, 1); + + data->ref_count = 1; + data->handler_state = -1; + + return data; +} + +static FpiSsmTestData * +fpi_ssm_test_data_ref (FpiSsmTestData *data) +{ + g_atomic_int_inc (&data->ref_count); + return data; +} + +static void +fpi_ssm_test_data_unref (FpiSsmTestData *data) +{ + if (g_atomic_int_dec_and_test (&data->ref_count)) + { + g_clear_error (&data->error); + g_slist_free (data->handlers_chain); + g_free (data); + } +} +G_DEFINE_AUTOPTR_CLEANUP_FUNC (FpiSsmTestData, fpi_ssm_test_data_unref) + +static void +fpi_ssm_test_data_unref_by_ssm (FpiSsmTestData *data) +{ + data->ssm_destroyed = TRUE; + + fpi_ssm_test_data_unref (data); +} + +enum { + FPI_TEST_SSM_STATE_0, + FPI_TEST_SSM_STATE_1, + FPI_TEST_SSM_STATE_2, + FPI_TEST_SSM_STATE_3, + FPI_TEST_SSM_STATE_NUM +}; + +static void +test_ssm_handler (FpiSsm *ssm, + FpDevice *dev) +{ + FpiSsmTestData *data; + + g_assert (dev == fake_device); + g_assert_true (FP_IS_DEVICE (dev)); + + data = fpi_ssm_get_data (ssm); + data->handler_state = fpi_ssm_get_cur_state (ssm); + data->handlers_chain = g_slist_append (data->handlers_chain, + GINT_TO_POINTER (fpi_ssm_get_cur_state (ssm))); +} + +static void +test_ssm_completed_callback (FpiSsm *ssm, + FpDevice *dev, + GError *error) +{ + FpiSsmTestData *data; + + g_assert (dev == fake_device); + g_assert_true (FP_IS_DEVICE (dev)); + + data = fpi_ssm_get_data (ssm); + data->completed = TRUE; + data->handlers_chain = g_slist_append (data->handlers_chain, + GINT_TO_POINTER (fpi_ssm_get_cur_state (ssm))); + g_clear_error (&data->error); + data->error = error; + + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, data->expected_last_state); +} + +static FpiSsm * +ssm_test_new_full (int nr_states, const char *name) +{ + FpiSsm *ssm; + FpiSsmTestData *data; + + ssm = fpi_ssm_new_full (fake_device, test_ssm_handler, nr_states, name); + data = fpi_ssm_test_data_new (); + data->expected_last_state = nr_states; + fpi_ssm_set_data (ssm, data, (GDestroyNotify) fpi_ssm_test_data_unref_by_ssm); + + return ssm; +} + +static FpiSsm * +ssm_test_new (void) +{ + return ssm_test_new_full (FPI_TEST_SSM_STATE_NUM, "FPI_TEST_SSM"); +} + +static gboolean +test_ssm_cancel_delayed_action_delayed (gpointer data) +{ + FpiSsm *ssm = data; + + fpi_ssm_cancel_delayed_state_change (ssm); + + return G_SOURCE_REMOVE; +} + +static gboolean +test_ssm_cancel_cancellable_delayed (gpointer data) +{ + g_cancellable_cancel (G_CANCELLABLE (data)); + + return G_SOURCE_REMOVE; +} + +/* Tests */ + +static void +test_ssm_new (void) +{ + FpiSsm *ssm; + + ssm = fpi_ssm_new (fake_device, test_ssm_handler, FPI_TEST_SSM_STATE_NUM); + + g_assert_null (fpi_ssm_get_data (ssm)); + g_assert_no_error (fpi_ssm_get_error (ssm)); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + + fpi_ssm_free (ssm); +} + +static void +test_ssm_new_full (void) +{ + FpiSsm *ssm; + + ssm = fpi_ssm_new_full (fake_device, test_ssm_handler, + FPI_TEST_SSM_STATE_NUM, "Test SSM Name"); + + g_assert_null (fpi_ssm_get_data (ssm)); + g_assert_no_error (fpi_ssm_get_error (ssm)); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + + fpi_ssm_free (ssm); +} + +static void +test_ssm_new_no_handler (void) +{ + g_autoptr(FpiSsm) ssm = NULL; + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, + "*BUG:*handler*"); + ssm = fpi_ssm_new (fake_device, NULL, FPI_TEST_SSM_STATE_NUM); + g_test_assert_expected_messages (); +} + +static void +test_ssm_new_wrong_states (void) +{ + g_autoptr(FpiSsm) ssm = NULL; + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, + "*BUG:*nr_states*"); + ssm = fpi_ssm_new (fake_device, test_ssm_handler, -1); + g_test_assert_expected_messages (); +} + +static void +test_ssm_set_data (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + GObject *object = g_object_new (FPI_TYPE_DEVICE_FAKE, NULL); + + g_object_add_weak_pointer (object, (gpointer) & object); + + fpi_ssm_set_data (ssm, object, g_object_unref); + g_assert (fpi_ssm_get_data (ssm) == object); + + fpi_ssm_set_data (ssm, (gpointer) 0xdeadbeef, NULL); + g_assert (fpi_ssm_get_data (ssm) == (gpointer) 0xdeadbeef); + g_assert_null (object); +} + +static void +test_ssm_set_data_cleanup (void) +{ + FpiSsm *ssm = ssm_test_new (); + GObject *object = g_object_new (FPI_TYPE_DEVICE_FAKE, NULL); + + g_object_add_weak_pointer (object, (gpointer) & object); + + fpi_ssm_set_data (ssm, object, g_object_unref); + g_assert (fpi_ssm_get_data (ssm) == object); + + fpi_ssm_free (ssm); + g_assert_null (object); +} + +static void +test_ssm_start (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + g_assert_null (data->handlers_chain); + + fpi_ssm_start (ssm, NULL); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + g_assert_no_error (data->error); + g_assert_false (data->ssm_destroyed); +} + +static void +test_ssm_start_single (void) +{ + g_autoptr(FpiSsmTestData) data = NULL; + FpiSsm *ssm; + + ssm = ssm_test_new_full (1, "FPI_TEST_SSM_SINGLE_STATE"); + data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, 0); + g_assert_cmpint (data->handler_state, ==, 0); + + fpi_ssm_next_state (ssm); + g_assert_cmpint (data->handler_state, ==, 0); + + g_assert_true (data->completed); + g_assert_no_error (data->error); + g_assert_true (data->ssm_destroyed); +} + +static void +test_ssm_next (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsmTestData) data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_next_state (ssm); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_next_not_started (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + fpi_ssm_next_state (ssm); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_next_with_delayed (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + gpointer timeout_tracker = GUINT_TO_POINTER (TRUE); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_next_state_delayed (ssm, 10, NULL); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*timeout*"); + fpi_ssm_next_state (ssm); + g_test_assert_expected_messages (); + + g_timeout_add (100, (GSourceFunc) g_nullify_pointer, &timeout_tracker); + while (timeout_tracker) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_next_complete (void) +{ + FpiSsm *ssm = ssm_test_new (); + + g_autoptr(FpiSsmTestData) data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_next_state (ssm); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + fpi_ssm_next_state (ssm); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 3); + + fpi_ssm_next_state (ssm); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 4); + + fpi_ssm_next_state (ssm); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 5); + + g_assert_true (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_jump_to_state (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_jump_to_state (ssm, FPI_TEST_SSM_STATE_2); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + fpi_ssm_jump_to_state (ssm, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 3); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_jump_to_state_not_started (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + fpi_ssm_jump_to_state (ssm, FPI_TEST_SSM_STATE_2); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_jump_to_state_with_delayed (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + gpointer timeout_tracker = GUINT_TO_POINTER (TRUE); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_jump_to_state_delayed (ssm, FPI_TEST_SSM_STATE_2, 10, NULL); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*timeout*"); + fpi_ssm_jump_to_state (ssm, FPI_TEST_SSM_STATE_2); + g_test_assert_expected_messages (); + + g_timeout_add (100, (GSourceFunc) g_nullify_pointer, &timeout_tracker); + while (timeout_tracker) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_jump_to_state_last (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_jump_to_state (ssm, FPI_TEST_SSM_STATE_3); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_jump_to_state_wrong (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*nr_states*"); + fpi_ssm_jump_to_state (ssm, FPI_TEST_SSM_STATE_NUM + 10); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_NUM + 10); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_NUM + 10); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*state*"); + fpi_ssm_jump_to_state (ssm, FPI_TEST_SSM_STATE_0 - 10); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0 - 10); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0 - 10); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 3); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_mark_completed (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsmTestData) data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + data->expected_last_state = FPI_TEST_SSM_STATE_0; + fpi_ssm_mark_completed (g_steal_pointer (&ssm)); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_true (data->completed); + g_assert_no_error (data->error); + g_assert_true (data->ssm_destroyed); +} + +static void +test_ssm_mark_completed_not_started (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsmTestData) data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + fpi_ssm_mark_completed (g_steal_pointer (&ssm)); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, -1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 0); + g_assert_true (data->ssm_destroyed); +} + +static void +test_ssm_mark_completed_with_delayed (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsmTestData) data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + gpointer timeout_tracker = GUINT_TO_POINTER (TRUE); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + data->expected_last_state = FPI_TEST_SSM_STATE_0; + fpi_ssm_mark_completed_delayed (ssm, 10, NULL); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*timeout*"); + fpi_ssm_mark_completed (g_steal_pointer (&ssm)); + g_test_assert_expected_messages (); + + g_timeout_add (100, (GSourceFunc) g_nullify_pointer, &timeout_tracker); + while (timeout_tracker) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + g_assert_true (data->ssm_destroyed); +} + +static void +test_ssm_mark_failed (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsmTestData) data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + data->expected_last_state = FPI_TEST_SSM_STATE_0; + fpi_ssm_mark_failed (g_steal_pointer (&ssm), + fpi_device_error_new (FP_DEVICE_ERROR_PROTO)); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_true (data->completed); + g_assert_error (data->error, FP_DEVICE_ERROR, FP_DEVICE_ERROR_PROTO); + g_assert_true (data->ssm_destroyed); +} + +static void +test_ssm_mark_failed_not_started (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsmTestData) data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + fpi_ssm_mark_failed (g_steal_pointer (&ssm), + fpi_device_error_new (FP_DEVICE_ERROR_PROTO)); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, -1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 0); + g_assert_true (data->ssm_destroyed); +} + +static void +test_ssm_mark_failed_with_delayed (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsmTestData) data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + gpointer timeout_tracker = GUINT_TO_POINTER (TRUE); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_mark_completed_delayed (ssm, 10, NULL); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*timeout*"); + data->expected_last_state = FPI_TEST_SSM_STATE_0; + fpi_ssm_mark_failed (g_steal_pointer (&ssm), + fpi_device_error_new (FP_DEVICE_ERROR_PROTO)); + g_test_assert_expected_messages (); + + g_timeout_add (100, (GSourceFunc) g_nullify_pointer, &timeout_tracker); + while (timeout_tracker) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_true (data->completed); + g_assert_error (data->error, FP_DEVICE_ERROR, FP_DEVICE_ERROR_PROTO); + g_assert_true (data->ssm_destroyed); +} + +static void +test_ssm_delayed_next (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_next_state_delayed (ssm, 10, NULL); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + while (data->handler_state == FPI_TEST_SSM_STATE_0) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_next_cancel (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + gpointer timeout_tracker = GUINT_TO_POINTER (TRUE); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_next_state_delayed (ssm, 10, NULL); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_idle_add_full (G_PRIORITY_HIGH, test_ssm_cancel_delayed_action_delayed, ssm, NULL); + g_timeout_add (100, (GSourceFunc) g_nullify_pointer, &timeout_tracker); + + while (timeout_tracker) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_next_cancellable (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(GCancellable) cancellable = g_cancellable_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_next_state_delayed (ssm, 10, cancellable); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_idle_add_full (G_PRIORITY_HIGH, test_ssm_cancel_cancellable_delayed, cancellable, NULL); + + while (!g_cancellable_is_cancelled (cancellable)) + g_main_context_iteration (NULL, TRUE); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*timeout*"); + fpi_ssm_cancel_delayed_state_change (ssm); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_next_not_started (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + fpi_ssm_next_state_delayed (ssm, 10, NULL); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, -1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 0); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + while (data->handler_state == -1) + g_main_context_iteration (NULL, TRUE); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_next_complete (void) +{ + FpiSsm *ssm = ssm_test_new (); + + g_autoptr(FpiSsmTestData) data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_next_state_delayed (ssm, 10, NULL); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + while (data->handler_state == FPI_TEST_SSM_STATE_0) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + fpi_ssm_next_state_delayed (ssm, 10, NULL); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + while (data->handler_state == FPI_TEST_SSM_STATE_1) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 3); + + fpi_ssm_next_state_delayed (ssm, 10, NULL); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 3); + + while (data->handler_state == FPI_TEST_SSM_STATE_2) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 4); + + fpi_ssm_next_state_delayed (ssm, 10, NULL); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 4); + + while (!data->completed) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 5); + + g_assert_true (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_jump_to_state (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_jump_to_state_delayed (ssm, FPI_TEST_SSM_STATE_2, 10, NULL); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + while (data->handler_state == FPI_TEST_SSM_STATE_0) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + fpi_ssm_jump_to_state_delayed (ssm, FPI_TEST_SSM_STATE_1, 10, NULL); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + while (data->handler_state == FPI_TEST_SSM_STATE_2) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 3); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_jump_to_state_cancel (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + gpointer timeout_tracker = GUINT_TO_POINTER (TRUE); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_jump_to_state_delayed (ssm, FPI_TEST_SSM_STATE_2, 10, NULL); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_idle_add_full (G_PRIORITY_HIGH, test_ssm_cancel_delayed_action_delayed, ssm, NULL); + g_timeout_add (100, (GSourceFunc) g_nullify_pointer, &timeout_tracker); + + while (timeout_tracker) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_jump_to_state_cancellable (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(GCancellable) cancellable = g_cancellable_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_jump_to_state_delayed (ssm, FPI_TEST_SSM_STATE_2, 10, cancellable); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_idle_add_full (G_PRIORITY_HIGH, test_ssm_cancel_cancellable_delayed, cancellable, NULL); + + while (!g_cancellable_is_cancelled (cancellable)) + g_main_context_iteration (NULL, TRUE); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*timeout*"); + fpi_ssm_cancel_delayed_state_change (ssm); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_jump_to_state_not_started (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + fpi_ssm_jump_to_state_delayed (ssm, FPI_TEST_SSM_STATE_2, 10, NULL); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, -1); + g_assert_null (data->handlers_chain); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + while (data->handler_state == -1) + g_main_context_iteration (NULL, TRUE); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_2); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_jump_to_state_last (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_jump_to_state_delayed (ssm, FPI_TEST_SSM_STATE_3, 10, NULL); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + while (data->handler_state == FPI_TEST_SSM_STATE_0) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_3); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_jump_to_state_wrong (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*nr_states*"); + fpi_ssm_jump_to_state_delayed (ssm, FPI_TEST_SSM_STATE_NUM + 10, 10, NULL); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*nr_states*"); + while (g_slist_length (data->handlers_chain) == 1) + g_main_context_iteration (NULL, TRUE); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_NUM + 10); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_NUM + 10); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*state*"); + fpi_ssm_jump_to_state_delayed (ssm, FPI_TEST_SSM_STATE_0 - 10, 10, NULL); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_NUM + 10); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_NUM + 10); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*state*"); + while (g_slist_length (data->handlers_chain) == 2) + g_main_context_iteration (NULL, TRUE); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0 - 10); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0 - 10); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 3); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_mark_completed (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsmTestData) data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + data->expected_last_state = FPI_TEST_SSM_STATE_0; + fpi_ssm_mark_completed_delayed (g_steal_pointer (&ssm), 10, NULL); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + while (g_slist_length (data->handlers_chain) == 1) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + g_assert_true (data->completed); + g_assert_no_error (data->error); + g_assert_true (data->ssm_destroyed); +} + +static void +test_ssm_delayed_mark_completed_not_started (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsmTestData) data = fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + fpi_ssm_mark_completed_delayed (ssm, 10, NULL); + g_test_assert_expected_messages (); + + g_timeout_add (100, (GSourceFunc) g_nullify_pointer, &ssm); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + while (ssm != NULL) + g_main_context_iteration (NULL, TRUE); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, -1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 0); + g_assert_true (data->ssm_destroyed); +} + +static void +test_ssm_delayed_mark_completed_cancel (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + gpointer timeout_tracker = GUINT_TO_POINTER (TRUE); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_mark_completed_delayed (ssm, 10, NULL); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_idle_add_full (G_PRIORITY_HIGH, test_ssm_cancel_delayed_action_delayed, ssm, NULL); + g_timeout_add (100, (GSourceFunc) g_nullify_pointer, &timeout_tracker); + + while (timeout_tracker) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_assert_false (data->completed); + g_assert_no_error (data->error); + g_assert_false (data->ssm_destroyed); +} + +static void +test_ssm_delayed_mark_completed_cancellable (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(GCancellable) cancellable = g_cancellable_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_mark_completed_delayed (ssm, 10, cancellable); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_idle_add_full (G_PRIORITY_HIGH, test_ssm_cancel_cancellable_delayed, cancellable, NULL); + + while (!g_cancellable_is_cancelled (cancellable)) + g_main_context_iteration (NULL, TRUE); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*timeout*"); + fpi_ssm_cancel_delayed_state_change (ssm); + g_test_assert_expected_messages (); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_assert_false (data->completed); + g_assert_no_error (data->error); +} + +static void +test_ssm_delayed_cancel_error (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*timeout*"); + fpi_ssm_cancel_delayed_state_change (ssm); + g_test_assert_expected_messages (); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*timeout*"); + fpi_ssm_cancel_delayed_state_change (ssm); + g_test_assert_expected_messages (); +} + +static void +test_ssm_subssm_start (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsm) subssm = + ssm_test_new_full (FPI_TEST_SSM_STATE_NUM, "FPI_TEST_SUB_SSM"); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + g_autoptr(FpiSsmTestData) subdata = + fpi_ssm_test_data_ref (fpi_ssm_get_data (subssm)); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_start_subsm (ssm, subssm); + g_assert_cmpint (subdata->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (subssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (subdata->handlers_chain), ==, 1); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_next_state (subssm); + + g_assert_cmpint (subdata->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (subdata->handlers_chain), ==, 2); + g_assert_no_error (subdata->error); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + subdata->expected_last_state = FPI_TEST_SSM_STATE_1; + fpi_ssm_mark_completed (g_steal_pointer (&subssm)); + + g_assert_cmpint (subdata->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (subdata->handlers_chain), ==, 2); + g_assert_true (subdata->ssm_destroyed); + g_assert_no_error (subdata->error); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_false (data->completed); + g_assert_false (data->ssm_destroyed); + g_assert_no_error (data->error); +} + +static void +test_ssm_subssm_mark_failed (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsm) subssm = + ssm_test_new_full (FPI_TEST_SSM_STATE_NUM, "FPI_TEST_SUB_SSM"); + g_autoptr(FpiSsmTestData) data = + fpi_ssm_test_data_ref (fpi_ssm_get_data (ssm)); + g_autoptr(FpiSsmTestData) subdata = + fpi_ssm_test_data_ref (fpi_ssm_get_data (subssm)); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_start_subsm (g_steal_pointer (&ssm), subssm); + g_assert_cmpint (subdata->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (subssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (subdata->handlers_chain), ==, 1); + + data->expected_last_state = FPI_TEST_SSM_STATE_0; + subdata->expected_last_state = FPI_TEST_SSM_STATE_0; + fpi_ssm_mark_failed (g_steal_pointer (&subssm), + fpi_device_error_new (FP_DEVICE_ERROR_BUSY)); + + g_assert_cmpint (subdata->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (subdata->handlers_chain), ==, 1); + g_assert_true (subdata->ssm_destroyed); + g_assert_no_error (subdata->error); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_true (data->completed); + g_assert_true (data->ssm_destroyed); + g_assert_error (data->error, FP_DEVICE_ERROR, FP_DEVICE_ERROR_BUSY); +} + +static void +test_ssm_subssm_start_with_started (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsm) subssm = + ssm_test_new_full (FPI_TEST_SSM_STATE_NUM, "FPI_TEST_SUB_SSM"); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + g_autoptr(FpiSsmTestData) subdata = + fpi_ssm_test_data_ref (fpi_ssm_get_data (subssm)); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_start (subssm, test_ssm_completed_callback); + g_assert_cmpuint (g_slist_length (subdata->handlers_chain), ==, 1); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*completed*"); + fpi_ssm_start_subsm (ssm, subssm); + g_test_assert_expected_messages (); + + g_assert_cmpint (subdata->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (subssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (subdata->handlers_chain), ==, 2); + + subdata->expected_last_state = FPI_TEST_SSM_STATE_0; + fpi_ssm_mark_completed (g_steal_pointer (&subssm)); + + g_assert_cmpint (subdata->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (subdata->handlers_chain), ==, 2); + g_assert_true (subdata->ssm_destroyed); + g_assert_no_error (subdata->error); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_false (data->completed); + g_assert_false (data->ssm_destroyed); + g_assert_no_error (data->error); +} + +static void +test_ssm_subssm_start_with_delayed (void) +{ + g_autoptr(FpiSsm) ssm = ssm_test_new (); + g_autoptr(FpiSsm) subssm = + ssm_test_new_full (FPI_TEST_SSM_STATE_NUM, "FPI_TEST_SUB_SSM"); + FpiSsmTestData *data = fpi_ssm_get_data (ssm); + g_autoptr(FpiSsmTestData) subdata = + fpi_ssm_test_data_ref (fpi_ssm_get_data (subssm)); + gpointer timeout_tracker = GUINT_TO_POINTER (TRUE); + + fpi_ssm_start (ssm, test_ssm_completed_callback); + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 1); + + fpi_ssm_next_state_delayed (ssm, 10, NULL); + + g_test_expect_message (G_LOG_DOMAIN, G_LOG_LEVEL_CRITICAL, "*BUG:*timeout*"); + fpi_ssm_start_subsm (ssm, subssm); + g_test_assert_expected_messages (); + + g_timeout_add (100, (GSourceFunc) g_nullify_pointer, &timeout_tracker); + while (timeout_tracker) + g_main_context_iteration (NULL, TRUE); + + g_assert_cmpint (subdata->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpint (fpi_ssm_get_cur_state (subssm), ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (subdata->handlers_chain), ==, 1); + + subdata->expected_last_state = FPI_TEST_SSM_STATE_0; + fpi_ssm_mark_completed (g_steal_pointer (&subssm)); + + g_assert_cmpint (subdata->handler_state, ==, FPI_TEST_SSM_STATE_0); + g_assert_cmpuint (g_slist_length (subdata->handlers_chain), ==, 1); + g_assert_true (subdata->ssm_destroyed); + g_assert_no_error (subdata->error); + + g_assert_cmpint (data->handler_state, ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpint (fpi_ssm_get_cur_state (ssm), ==, FPI_TEST_SSM_STATE_1); + g_assert_cmpuint (g_slist_length (data->handlers_chain), ==, 2); + + g_assert_false (data->completed); + g_assert_false (data->ssm_destroyed); + g_assert_no_error (data->error); +} + +int +main (int argc, char *argv[]) +{ + g_autoptr(FpDevice) device = NULL; + + g_test_init (&argc, &argv, NULL); + + device = g_object_new (FPI_TYPE_DEVICE_FAKE, NULL); + fake_device = device; + g_object_add_weak_pointer (G_OBJECT (device), (gpointer) & fake_device); + + g_test_add_func ("/ssm/new", test_ssm_new); + g_test_add_func ("/ssm/new/full", test_ssm_new_full); + g_test_add_func ("/ssm/new/no_handler", test_ssm_new_no_handler); + g_test_add_func ("/ssm/new/wrong_states", test_ssm_new_wrong_states); + g_test_add_func ("/ssm/set_data", test_ssm_set_data); + g_test_add_func ("/ssm/set_data/cleanup", test_ssm_set_data_cleanup); + g_test_add_func ("/ssm/start", test_ssm_start); + g_test_add_func ("/ssm/start/single", test_ssm_start_single); + g_test_add_func ("/ssm/next", test_ssm_next); + g_test_add_func ("/ssm/next/complete", test_ssm_next_complete); + g_test_add_func ("/ssm/next/not_started", test_ssm_next_not_started); + g_test_add_func ("/ssm/next/with_delayed", test_ssm_next_with_delayed); + g_test_add_func ("/ssm/jump_to_state", test_ssm_jump_to_state); + g_test_add_func ("/ssm/jump_to_state/not_started", test_ssm_jump_to_state_not_started); + g_test_add_func ("/ssm/jump_to_state/with_delayed", test_ssm_jump_to_state_with_delayed); + g_test_add_func ("/ssm/jump_to_state/last", test_ssm_jump_to_state_last); + g_test_add_func ("/ssm/jump_to_state/wrong", test_ssm_jump_to_state_wrong); + g_test_add_func ("/ssm/mark_completed", test_ssm_mark_completed); + g_test_add_func ("/ssm/mark_completed/not_started", test_ssm_mark_completed_not_started); + g_test_add_func ("/ssm/mark_completed/with_delayed", test_ssm_mark_completed_with_delayed); + g_test_add_func ("/ssm/mark_failed", test_ssm_mark_failed); + g_test_add_func ("/ssm/mark_failed/not_started", test_ssm_mark_failed_not_started); + g_test_add_func ("/ssm/mark_failed/with_delayed", test_ssm_mark_failed_with_delayed); + g_test_add_func ("/ssm/delayed/next", test_ssm_delayed_next); + g_test_add_func ("/ssm/delayed/next/cancel", test_ssm_delayed_next_cancel); + g_test_add_func ("/ssm/delayed/next/cancellable", test_ssm_delayed_next_cancellable); + g_test_add_func ("/ssm/delayed/next/not_started", test_ssm_delayed_next_not_started); + g_test_add_func ("/ssm/delayed/next/complete", test_ssm_delayed_next_complete); + g_test_add_func ("/ssm/delayed/jump_to_state", test_ssm_delayed_jump_to_state); + g_test_add_func ("/ssm/delayed/jump_to_state/cancel", test_ssm_delayed_jump_to_state_cancel); + g_test_add_func ("/ssm/delayed/jump_to_state/cancellable", test_ssm_delayed_jump_to_state_cancellable); + g_test_add_func ("/ssm/delayed/jump_to_state/not_started", test_ssm_delayed_jump_to_state_not_started); + g_test_add_func ("/ssm/delayed/jump_to_state/last", test_ssm_delayed_jump_to_state_last); + g_test_add_func ("/ssm/delayed/jump_to_state/wrong", test_ssm_delayed_jump_to_state_wrong); + g_test_add_func ("/ssm/delayed/mark_completed", test_ssm_delayed_mark_completed); + g_test_add_func ("/ssm/delayed/mark_completed/cancel", test_ssm_delayed_mark_completed_cancel); + g_test_add_func ("/ssm/delayed/mark_completed/cancellable", test_ssm_delayed_mark_completed_cancellable); + g_test_add_func ("/ssm/delayed/mark_completed/not_started", test_ssm_delayed_mark_completed_not_started); + g_test_add_func ("/ssm/delayed/cancel/error", test_ssm_delayed_cancel_error); + g_test_add_func ("/ssm/subssm/start", test_ssm_subssm_start); + g_test_add_func ("/ssm/subssm/start/with_started", test_ssm_subssm_start_with_started); + g_test_add_func ("/ssm/subssm/start/with_delayed", test_ssm_subssm_start_with_delayed); + g_test_add_func ("/ssm/subssm/mark_failed", test_ssm_subssm_mark_failed); + + return g_test_run (); +} -- 2.24.1