Changeset b55f62a in mainline for uspace/lib/sysman/src/ctl.c

Timestamp:

2019-08-07T09:29:33Z (6 years ago)

Author:

Matthieu Riolo <matthieu.riolo@…>

Children:

918ac9b

Parents:

2df7d824

git-author:

Michal Koutný <xm.koutny+hos@…> (2015-11-02 00:50:02)

git-committer:

Matthieu Riolo <matthieu.riolo@…> (2019-08-07 09:29:33)

Message:

sysman: Create control utility sysctl

• can list units and their states (starts to feel like systemctl
• helluva boilerplate to get some IPC between sysctl and sysman :-/

Conflicts:

boot/Makefile.common
uspace/Makefile

File:

• uspace/lib/sysman/src/ctl.c (modified) (2 diffs)

uspace/lib/sysman/src/ctl.c

@@ -29 +29 @@
 #include <async.h>
 #include <errno.h>
+#include <stdlib.h>
 #include <str.h>
 #include <sysman/ctl.h>
@@ -57 +58 @@
         return rc;
 }
+
+static int sysman_get_units_once(sysarg_t *buf, size_t buf_size,
+    size_t *act_size)
+{
+        async_exch_t *exch = sysman_exchange_begin(SYSMAN_PORT_CTL);
+
+        ipc_call_t answer;
+        aid_t req = async_send_0(exch, SYSMAN_CTL_GET_UNITS, &answer);
+        int rc = async_data_read_start(exch, buf, buf_size);
+
+        sysman_exchange_end(exch);
+
+        if (rc != EOK) {
+                async_forget(req);
+                return rc;
+        }
+
+        sysarg_t retval;
+        async_wait_for(req, &retval);
+
+        if (retval != EOK) {
+                return retval;
+        }
+
+        *act_size = IPC_GET_ARG1(answer);
+        return EOK;
+}
+
+int sysman_get_units(unit_handle_t **units_ptr, size_t *cnt_ptr)
+{
+        *units_ptr = NULL;
+        *cnt_ptr = 0;
+
+        unit_handle_t *units = NULL;
+        size_t alloc_size = 0;
+        size_t act_size = 0;
+
+        while (true) {
+                int rc = sysman_get_units_once(units, alloc_size, &act_size);
+                if (rc != EOK) {
+                        return rc;
+                }
+
+                if (act_size <= alloc_size) {
+                        break;
+                }
+
+                alloc_size = act_size;
+                units = realloc(units, alloc_size);
+                if (units == NULL) {
+                        return ENOMEM;
+                }
+        }
+
+        *units_ptr = units;
+        *cnt_ptr = act_size / sizeof(unit_handle_t);
+        return EOK;
+}
+
+int sysman_unit_get_name(unit_handle_t handle, char *buf, size_t buf_size)
+{
+        async_exch_t *exch = sysman_exchange_begin(SYSMAN_PORT_CTL);
+
+        ipc_call_t answer;
+        aid_t req = async_send_1(exch, SYSMAN_CTL_UNIT_GET_NAME, handle, &answer);
+        int rc = async_data_read_start(exch, buf, buf_size);
+
+        sysman_exchange_end(exch);
+
+        if (rc != EOK) {
+                async_forget(req);
+                return rc;
+        }
+
+        sysarg_t retval;
+        async_wait_for(req, &retval);
+
+        if (retval != EOK) {
+                return retval;
+        }
+
+        return EOK;
+}
+
+int sysman_unit_get_state(unit_handle_t handle, unit_state_t *state)
+{
+        async_exch_t *exch = sysman_exchange_begin(SYSMAN_PORT_CTL);
+        int rc = async_req_1_1(exch, SYSMAN_CTL_UNIT_GET_STATE, handle, state);
+        sysman_exchange_end(exch);
+
+        return rc;
+}