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

Timestamp:

2025-03-29T14:04:37Z (4 months ago)

Author:

Miroslav Cimerman <mc@…>

Children:

746e636

Parents:

1a28518

Message:

hr: refactor manual assembly

File:

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

uspace/lib/device/src/hr.c

@@ -1 +1 @@
 /*
- * Copyright (c) 2024 Miroslav Cimerman
+ * Copyright (c) 2025 Miroslav Cimerman
  * All rights reserved.
  *
@@ -88 +88 @@
 }
 
-errno_t hr_create(hr_t *hr, hr_config_t *hr_config, bool assemble)
+errno_t hr_create(hr_t *hr, hr_config_t *hr_config)
 {
         errno_t rc, retval;
@@ -98 +98 @@
                 return EINVAL;
 
-        req = async_send_0(exch, assemble ? HR_ASSEMBLE : HR_CREATE, NULL);
+        req = async_send_0(exch, HR_CREATE, NULL);
 
         rc = async_data_write_start(exch, hr_config, sizeof(hr_config_t));
@@ -113 +113 @@
 
         return EOK;
+}
+
+errno_t hr_assemble(hr_t *hr, hr_config_t *hr_config, size_t *rassembled_cnt)
+{
+        errno_t rc;
+        async_exch_t *exch;
+        aid_t req;
+        size_t assembled_cnt;
+
+        exch = async_exchange_begin(hr->sess);
+        if (exch == NULL)
+                return EINVAL;
+
+        req = async_send_0(exch, HR_ASSEMBLE, NULL);
+
+        rc = async_data_write_start(exch, hr_config, sizeof(hr_config_t));
+        if (rc != EOK) {
+                async_exchange_end(exch);
+                async_forget(req);
+                return rc;
+        }
+
+        rc = async_data_read_start(exch, &assembled_cnt, sizeof(size_t));
+        if (rc != EOK) {
+                async_exchange_end(exch);
+                async_forget(req);
+                return rc;
+        }
+
+        async_exchange_end(exch);
+        async_wait_for(req, &rc);
+
+        if (rassembled_cnt != NULL)
+                *rassembled_cnt = assembled_cnt;
+
+        return rc;
 }