Changes in uspace/srv/system/system.c [ad9e225:ca48672] in mainline

File:

• uspace/srv/system/system.c (modified) (14 diffs)

uspace/srv/system/system.c

@@ -1 +1 @@
 /*
- * Copyright (c) 2024 Jiri Svoboda
+ * Copyright (c) 2025 Jiri Svoboda
  * Copyright (c) 2005 Martin Decky
  * All rights reserved.
@@ -35 +35 @@
  */
 
+#include <devman.h>
 #include <fibril.h>
 #include <futil.h>
@@ -48 +49 @@
 #include <str.h>
 #include <loc.h>
+#include <shutdown.h>
 #include <str_error.h>
 #include <config.h>
@@ -84 +86 @@
 
 static void system_srv_conn(ipc_call_t *, void *);
-static errno_t system_srv_shutdown(void *);
+static errno_t system_srv_poweroff(void *);
+static errno_t system_srv_restart(void *);
 
 system_ops_t system_srv_ops = {
-        .shutdown = system_srv_shutdown
+        .poweroff = system_srv_poweroff,
+        .restart = system_srv_restart
 };
 
@@ -324 +328 @@
         size_t nparts;
         bool sv_mounted;
+        futil_t *futil = NULL;
         size_t i;
         errno_t rc;
@@ -376 +381 @@
 
                 /* Copy initial configuration files */
-                rc = futil_rcopy_contents("/cfg", "/w/cfg");
+                rc = futil_create(NULL, NULL, &futil);
                 if (rc != EOK)
                         goto error;
+
+                rc = futil_rcopy_contents(futil, "/cfg", "/w/cfg");
+                if (rc != EOK)
+                        goto error;
+
+                futil_destroy(futil);
+                futil = NULL;
         } else {
                 printf("%s: System volume is configured.\n", NAME);
 
-                /* Wait until system volume is mounted */
+                /* Verify that system volume is mounted */
                 sv_mounted = false;
 
-                while (true) {
-                        rc = vol_get_parts(vol, &part_ids, &nparts);
+                rc = vol_get_parts(vol, &part_ids, &nparts);
+                if (rc != EOK) {
+                        printf("Error getting list of volumes.\n");
+                        goto error;
+                }
+
+                for (i = 0; i < nparts; i++) {
+                        rc = vol_part_info(vol, part_ids[i], &pinfo);
                         if (rc != EOK) {
-                                printf("Error getting list of volumes.\n");
+                                printf("Error getting partition "
+                                    "information.\n");
+                                rc = EIO;
                                 goto error;
                         }
 
-                        for (i = 0; i < nparts; i++) {
-                                rc = vol_part_info(vol, part_ids[i], &pinfo);
-                                if (rc != EOK) {
-                                        printf("Error getting partition "
-                                            "information.\n");
-                                        rc = EIO;
-                                        goto error;
-                                }
-
-                                if (str_cmp(pinfo.cur_mp, "/w") == 0) {
-                                        sv_mounted = true;
-                                        break;
-                                }
+                        if (str_cmp(pinfo.cur_mp, "/w") == 0) {
+                                sv_mounted = true;
+                                break;
                         }
-
-                        if (sv_mounted)
-                                break;
-
-                        free(part_ids);
-                        part_ids = NULL;
-
-                        fibril_sleep(1);
-                        printf("Sleeping(1) for system volume.\n");
-                }
+                }
+
+                if (sv_mounted == false) {
+                        printf("System volume not found.\n");
+                        rc = EIO;
+                        goto error;
+                }
+
+                free(part_ids);
+                part_ids = NULL;
+
         }
 
@@ -426 +437 @@
         if (part_ids != NULL)
                 free(part_ids);
+        if (futil != NULL)
+                futil_destroy(futil);
 
         return rc;
@@ -520 +533 @@
         /* Eject all volumes. */
 
+        log_msg(LOG_DEFAULT, LVL_NOTE, "Ejecting volumes.");
+
         rc = vol_create(&vol);
         if (rc != EOK) {
@@ -534 +549 @@
 
         for (i = 0; i < nparts; i++) {
-                rc = vol_part_eject(vol, part_ids[i]);
+                rc = vol_part_eject(vol, part_ids[i], vef_none);
                 if (rc != EOK) {
                         log_msg(LOG_DEFAULT, LVL_ERROR, "Error ejecting "
@@ -544 +559 @@
         free(part_ids);
         vol_destroy(vol);
+
         return EOK;
 error:
@@ -556 +572 @@
 static errno_t system_srv_init(sys_srv_t *syssrv)
 {
-        port_id_t port;
+        port_id_t port = 0;
         loc_srv_t *srv = NULL;
         service_id_t sid = 0;
@@ -578 +594 @@
         }
 
-        rc = loc_service_register(srv, SYSTEM_DEFAULT, &sid);
+        rc = loc_service_register(srv, SYSTEM_DEFAULT, port, &sid);
         if (rc != EOK) {
                 log_msg(LOG_DEFAULT, LVL_ERROR,
@@ -592 +608 @@
         if (srv != NULL)
                 loc_server_unregister(srv);
-        // XXX destroy port
+        if (port != 0)
+                async_port_destroy(port);
         return rc;
 }
@@ -610 +627 @@
 }
 
-/** System shutdown request.
+/** System poweroff request.
  *
  * @param arg Argument (sys_srv_t *)
  */
-static errno_t system_srv_shutdown(void *arg)
+static errno_t system_srv_poweroff(void *arg)
 {
         sys_srv_t *syssrv = (sys_srv_t *)arg;
         errno_t rc;
 
-        log_msg(LOG_DEFAULT, LVL_NOTE, "system_srv_shutdown");
+        log_msg(LOG_DEFAULT, LVL_NOTE, "system_srv_poweroff");
 
         rc = system_sys_shutdown();
         if (rc != EOK) {
-                log_msg(LOG_DEFAULT, LVL_NOTE, "system_srv_shutdown failed");
+                log_msg(LOG_DEFAULT, LVL_NOTE, "system_srv_poweroff failed");
                 system_srv_shutdown_failed(&syssrv->srv);
         }
 
-        log_msg(LOG_DEFAULT, LVL_NOTE, "system_srv_shutdown complete");
+        log_msg(LOG_DEFAULT, LVL_NOTE, "system_srv_poweroff complete");
+        system_srv_shutdown_complete(&syssrv->srv);
+        return EOK;
+}
+
+/** System restart request.
+ *
+ * @param arg Argument (sys_srv_t *)
+ */
+static errno_t system_srv_restart(void *arg)
+{
+        sys_srv_t *syssrv = (sys_srv_t *)arg;
+        errno_t rc;
+
+        log_msg(LOG_DEFAULT, LVL_NOTE, "system_srv_restart");
+
+        rc = system_sys_shutdown();
+        if (rc != EOK) {
+                log_msg(LOG_DEFAULT, LVL_NOTE, "system_srv_restart failed");
+                system_srv_shutdown_failed(&syssrv->srv);
+        }
+
+        /* Quiesce the device tree. */
+
+        log_msg(LOG_DEFAULT, LVL_NOTE, "Quiescing devices.");
+
+        rc = devman_quiesce_devices("/hw");
+        if (rc != EOK) {
+                log_msg(LOG_DEFAULT, LVL_ERROR,
+                    "Failed to quiesce device tree.");
+                return rc;
+        }
+
+        sys_reboot();
+
+        log_msg(LOG_DEFAULT, LVL_NOTE, "system_srv_restart complete");
         system_srv_shutdown_complete(&syssrv->srv);
         return EOK;