// SPDX-License-Identifier: GPL-2.0
 
+#include <linux/reboot.h>
 #include <kunit/test.h>
 #include <linux/glob.h>
 #include <linux/moduleparam.h>
 MODULE_PARM_DESC(filter_glob,
                "Filter which KUnit test suites run at boot-time, e.g. list*");
 
+static char *kunit_shutdown;
+core_param(kunit_shutdown, kunit_shutdown, charp, 0644);
+
 static struct kunit_suite * const *
 kunit_filter_subsuite(struct kunit_suite * const * const subsuite)
 {
        return filtered;
 }
 
+static void kunit_handle_shutdown(void)
+{
+       if (!kunit_shutdown)
+               return;
+
+       if (!strcmp(kunit_shutdown, "poweroff"))
+               kernel_power_off();
+       else if (!strcmp(kunit_shutdown, "halt"))
+               kernel_halt();
+       else if (!strcmp(kunit_shutdown, "reboot"))
+               kernel_restart(NULL);
+
+}
+
 static void kunit_print_tap_header(struct suite_set *suite_set)
 {
        struct kunit_suite * const * const *suites, * const *subsuite;
                kfree(suite_set.start);
        }
 
+       kunit_handle_shutdown();
+
        return 0;
 }
 
 
        def run_kernel(self, args=None, build_dir='', filter_glob='', timeout=None) -> Iterator[str]:
                if not args:
                        args = []
-               args.extend(['mem=1G', 'console=tty'])
+               args.extend(['mem=1G', 'console=tty', 'kunit_shutdown=halt'])
                if filter_glob:
                        args.append('kunit.filter_glob='+filter_glob)
                self._ops.linux_bin(args, timeout, build_dir)
 
 
 kunit_start_re = re.compile(r'TAP version [0-9]+$')
 kunit_end_re = re.compile('(List of all partitions:|'
-                         'Kernel panic - not syncing: VFS:)')
+                         'Kernel panic - not syncing: VFS:|reboot: System halted)')
 
 def isolate_kunit_output(kernel_output) -> Iterator[str]:
        started = False