Changeset d1d355f in mainline for uspace/lib/device/src/hr.c

Timestamp:

2025-05-06T21:30:30Z (5 weeks ago)

Author:

Miroslav Cimerman <mc@…>

Children:

c2f0160

Parents:

40f56a4

Message:

hr: refactor hrctl and some hr IPC methods

File:

• uspace/lib/device/src/hr.c (modified) (4 diffs)

uspace/lib/device/src/hr.c

@@ -109 +109 @@
         async_exchange_end(exch);
         async_wait_for(req, &retval);
-        if (retval != EOK)
-                return retval;
-
-        return EOK;
+        return retval;
 }
 
@@ -269 +266 @@
 }
 
-errno_t hr_stop(const char *devname, long extent)
+errno_t hr_stop(const char *devname)
 {
         hr_t *hr;
@@ -289 +286 @@
                 goto error;
         }
-        rc = async_req_2_0(exch, HR_STOP, svc_id, extent);
+
+        rc = async_req_1_0(exch, HR_STOP, svc_id);
         async_exchange_end(exch);
 error:
@@ -296 +294 @@
 }
 
-errno_t hr_add_hotspare(service_id_t vol_svc_id, service_id_t hs_svc_id)
+errno_t hr_stop_all(void)
 {
         hr_t *hr;
-        errno_t rc;
-        async_exch_t *exch;
+        async_exch_t *exch;
+        errno_t rc;
+
+        rc = hr_sess_init(&hr);
+        if (rc != EOK)
+                return rc;
+
+        exch = async_exchange_begin(hr->sess);
+        if (exch == NULL) {
+                rc = EINVAL;
+                goto error;
+        }
+
+        rc = async_req_0_0(exch, HR_STOP_ALL);
+        async_exchange_end(exch);
+error:
+        hr_sess_destroy(hr);
+        return rc;
+}
+
+errno_t hr_fail_extent(const char *volume_name, unsigned long extent)
+{
+        hr_t *hr;
+        errno_t rc;
+        async_exch_t *exch;
+        service_id_t vol_svc_id;
+
+        rc = loc_service_get_id(volume_name, &vol_svc_id, 0);
+        if (rc != EOK)
+                return rc;
+
+        rc = hr_sess_init(&hr);
+        if (rc != EOK)
+                return rc;
+
+        exch = async_exchange_begin(hr->sess);
+        if (exch == NULL) {
+                rc = EINVAL;
+                goto error;
+        }
+
+        rc = async_req_2_0(exch, HR_FAIL_EXTENT, vol_svc_id, extent);
+        async_exchange_end(exch);
+error:
+        hr_sess_destroy(hr);
+        return rc;
+}
+
+errno_t hr_add_hotspare(const char *volume_name, const char *hotspare)
+{
+        hr_t *hr;
+        errno_t rc;
+        async_exch_t *exch;
+        service_id_t vol_svc_id, hs_svc_id;
+
+        rc = loc_service_get_id(volume_name, &vol_svc_id, 0);
+        if (rc != EOK)
+                return rc;
+
+        rc = loc_service_get_id(hotspare, &hs_svc_id, 0);
+        if (rc != EOK)
+                return rc;
 
         rc = hr_sess_init(&hr);