Changeset 5b320ac in mainline for uspace/lib/device

Timestamp:

2024-11-22T18:38:49Z (14 months ago)

Author:

Miroslav Cimerman <mc@…>

Children:

d0f0744

Parents:

06f2762

Message:

hr: hotspares + RAID1 rebuild

Location:

uspace/lib/device

Files:

• include/hr.h (modified) (5 diffs)
• include/ipc/hr.h (modified) (1 diff)
• src/hr.c (modified) (4 diffs)

uspace/lib/device/include/hr.h

@@ -43 +43 @@
 /* for now */
 #define HR_MAX_EXTENTS 4
+#define HR_MAX_HOTSPARES HR_MAX_EXTENTS
 
 #define HR_DEVNAME_LEN 32
@@ -57 +58 @@
         HR_VOL_ONLINE,  /* OK, OPTIMAL */
         HR_VOL_FAULTY,
-        HR_VOL_DEGRADED /* also used for partial, but usable mirror */
+        HR_VOL_DEGRADED, /* also used for partial, but usable mirror */
+        HR_VOL_REBUILD
 } hr_vol_status_t;
 
@@ -63 +65 @@
         HR_EXT_ONLINE,  /* OK */
         HR_EXT_MISSING,
-        HR_EXT_FAILED
+        HR_EXT_FAILED,
+        HR_EXT_REBUILD,
+        HR_EXT_HOTSPARE
 } hr_ext_status_t;
 
@@ -84 +88 @@
 typedef struct hr_vol_info {
         hr_extent_t extents[HR_MAX_EXTENTS];
+        hr_extent_t hotspares[HR_MAX_HOTSPARES];
         size_t extent_no;
+        size_t hotspare_no;
         service_id_t svc_id;
         hr_level_t level;
@@ -98 +104 @@
 extern errno_t hr_create(hr_t *, hr_config_t *, bool);
 extern errno_t hr_stop(const char *, long);
+extern errno_t hr_add_hotspare(service_id_t, service_id_t);
 extern errno_t hr_print_status(void);
 

uspace/lib/device/include/ipc/hr.h

@@ -42 +42 @@
         HR_ASSEMBLE,
         HR_STOP,
+        HR_ADD_HOTSPARE,
         HR_STATUS
 } hr_request_t;

uspace/lib/device/src/hr.c

@@ -166 +166 @@
                         printf("          %s    %zu       %s\n", hr_get_ext_status_msg(ext->status), i, devname);
         }
+
+        if (vol_info->hotspare_no == 0)
+                return EOK;
+
+        printf("hotspares: [status] [index] [devname]\n");
+        for (i = 0; i < vol_info->hotspare_no; i++) {
+                ext = &vol_info->hotspares[i];
+                if (ext->status == HR_EXT_MISSING) {
+                        devname = (char *) "MISSING-devname";
+                } else {
+                        rc = loc_service_get_name(ext->svc_id, &devname);
+                        if (rc != EOK)
+                                return rc;
+                }
+                printf("            %s   %zu     %s\n",
+                    hr_get_ext_status_msg(ext->status), i, devname);
+        }
+
         return EOK;
 }
@@ -194 +212 @@
         if (rc != EOK)
                 goto error;
+error:
+        hr_sess_destroy(hr);
+        return rc;
+}
+
+errno_t hr_add_hotspare(service_id_t vol_svc_id, service_id_t hs_svc_id)
+{
+        hr_t *hr;
+        errno_t rc;
+        async_exch_t *exch;
+
+        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_ADD_HOTSPARE, vol_svc_id, hs_svc_id);
+        async_exchange_end(exch);
 error:
         hr_sess_destroy(hr);
@@ -277 +318 @@
         case HR_VOL_DEGRADED:
                 return "DEGRADED";
+        case HR_VOL_REBUILD:
+                return "REBUILD";
         default:
                 return "UNKNOWN";
@@ -291 +334 @@
         case HR_EXT_FAILED:
                 return "FAILED";
+        case HR_EXT_REBUILD:
+                return "REBUILD";
+        case HR_EXT_HOTSPARE:
+                return "HOTSPARE";
         default:
                 return "UNKNOWN";