Changeset 978130a in mainline for uspace/srv/bd/hr/raid4.c

Timestamp:

2024-10-28T16:03:24Z (15 months ago)

Author:

Miroslav Cimerman <mc@…>

Children:

4dd650a

Parents:

76cd345

Message:

hr: optimize RAID 0, 4, 5 to write whole strip

File:

• uspace/srv/bd/hr/raid4.c (modified) (7 diffs)

uspace/srv/bd/hr/raid4.c

@@ -43 +43 @@
 #include <ipc/services.h>
 #include <loc.h>
+#include <mem.h>
 #include <task.h>
 #include <stdio.h>
@@ -85 +86 @@
 
 static errno_t write_parity(hr_volume_t *vol, uint64_t extent, uint64_t block,
-    const void *data)
-{
-        errno_t rc;
-        size_t i;
+    const void *data, size_t cnt)
+{
+        errno_t rc;
+        size_t i, j;
         void *xorbuf;
         void *buf;
 
-        xorbuf = calloc(1, vol->bsize);
+        xorbuf = malloc(vol->bsize);
         if (xorbuf == NULL)
                 return ENOMEM;
@@ -102 +103 @@
         }
 
-        for (i = 1; i < vol->dev_no; i++) {
-                if (i == extent) {
-                        xor(xorbuf, data, vol->bsize);
-                } else {
-                        rc = block_read_direct(vol->extents[i].svc_id, block, 1,
-                            buf);
-                        if (rc != EOK)
-                                goto end;
-                        xor(xorbuf, buf, vol->bsize);
+        for (j = 0; j < cnt; j++) {
+                memset(xorbuf, 0, vol->bsize);
+                for (i = 1; i < vol->dev_no; i++) {
+                        if (i == extent) {
+                                xor(xorbuf, data, vol->bsize);
+                        } else {
+                                rc = block_read_direct(vol->extents[i].svc_id,
+                                    block, 1, buf);
+                                if (rc != EOK)
+                                        goto end;
+                                xor(xorbuf, buf, vol->bsize);
+                        }
                 }
-        }
-
-        rc = block_write_direct(vol->extents[0].svc_id, block, 1, xorbuf);
-
+                rc = block_write_direct(vol->extents[0].svc_id, block, 1,
+                    xorbuf);
+                if (rc != EOK)
+                        goto end;
+                data = (void *) ((uintptr_t) data + vol->bsize);
+                block++;
+        }
 end:
         free(xorbuf);
@@ -122 +129 @@
 }
 
-static void raid4_geometry(uint64_t x, hr_volume_t *vol, size_t *extent,
-    uint64_t *phys_block)
-{
-        uint64_t N = vol->dev_no; /* extents */
-        uint64_t L = vol->strip_size / vol->bsize; /* size of strip in blocks */
-
-        uint64_t i = ((x / L) % (N - 1)) + 1; /* extent */
-        uint64_t j = (x / L) / (N - 1); /* stripe */
-        uint64_t k = x % L; /* strip offset */
-
-        *extent = i;
-        *phys_block = j * L + k;
-}
-
 static errno_t hr_raid4_bd_open(bd_srvs_t *bds, bd_srv_t *bd)
 {
@@ -154 +147 @@
         errno_t rc;
         uint64_t phys_block;
-        size_t extent, left;
+        size_t left;
 
         if (type == HR_BD_READ || type == HR_BD_WRITE)
@@ -164 +157 @@
                 return rc;
 
+        uint64_t strip_size = vol->strip_size / vol->bsize; /* in blocks */
+        uint64_t stripe = (ba / strip_size); /* stripe number */
+        uint64_t extent = (stripe % (vol->dev_no - 1)) + 1;
+        uint64_t ext_stripe = stripe / (vol->dev_no - 1); /* stripe level */
+        uint64_t strip_off = ba % strip_size; /* strip offset */
+
         fibril_mutex_lock(&vol->lock);
 
         left = cnt;
         while (left != 0) {
-                raid4_geometry(ba, vol, &extent, &phys_block);
+                phys_block = ext_stripe * strip_size + strip_off;
+                cnt = min(left, strip_size - strip_off);
                 hr_add_ba_offset(vol, &phys_block);
                 switch (type) {
                 case HR_BD_SYNC:
                         rc = block_sync_cache(vol->extents[extent].svc_id,
-                            phys_block, 1);
+                            phys_block, cnt);
                         break;
                 case HR_BD_READ:
                         rc = block_read_direct(vol->extents[extent].svc_id,
-                            phys_block, 1, data_read);
-                        data_read = data_read + vol->bsize;
+                            phys_block, cnt, data_read);
+                        data_read = (void *) ((uintptr_t) data_read +
+                            (vol->bsize * cnt));
                         break;
                 case HR_BD_WRITE:
                         rc = block_write_direct(vol->extents[extent].svc_id,
-                            phys_block, 1, data_write);
+                            phys_block, cnt, data_write);
                         if (rc != EOK)
                                 goto error;
-                        rc = write_parity(vol, extent, phys_block, data_write);
+                        rc = write_parity(vol, extent, phys_block, data_write,
+                            cnt);
                         if (rc != EOK)
                                 goto error;
-                        data_write = data_write + vol->bsize;
+                        data_write = (void *) ((uintptr_t) data_write +
+                            (vol->bsize * cnt));
                         break;
                 default:
@@ -197 +200 @@
                         goto error;
 
-                left--;
-                ba++;
+                left -= cnt;
+                strip_off = 0;
+                extent++;
+                if (extent >= vol->dev_no) {
+                        ext_stripe++;
+                        extent = 1;
+                }
         }