WebSVN – HelenOS – Diff – //branches/tracing/uspace/srv/fs/tmpfs/tmpfs_dump.c

  */
 #include "tmpfs.h"
 #include "../../vfs/vfs.h"
 #include <ipc/ipc.h>
+#include <async.h>
 #include <errno.h>
 #include <stdlib.h>
 #include <string.h>
 #include <sys/types.h>
 #include <as.h>
 #include <ipc/services.h>
 #include <ipc/devmap.h>
 #include <sys/mman.h>
 #include <byteorder.h>
-#define BLOCK_SIZE          1024    // FIXME
+#define TMPFS_BLOCK_SIZE    1024
-#define RD_BASE             1024    // FIXME
-#define RD_READ_BLOCK   (RD_BASE + 1)
 struct rdentry {
     uint8_t type;
     uint32_t len;
 } __attribute__((packed));
-static bool
-tmpfs_blockread(int phone, void *buffer, size_t *bufpos, size_t *buflen,
-    size_t *pos, void *dst, size_t size)
-{
-    size_t offset = 0;
-    size_t left = size;
-    while (left > 0) {
-        size_t rd;
-        if (*bufpos + left < *buflen)
-            rd = left;
-        else
-            rd = *buflen - *bufpos;
-        if (rd > 0) {
-            memcpy(dst + offset, buffer + *bufpos, rd);
-            offset += rd;
-            *bufpos += rd;
-            *pos += rd;
-            left -= rd;
-        }
-        if (*bufpos == *buflen) {
-            ipcarg_t retval;
-            int rc = ipc_call_sync_2_1(phone, RD_READ_BLOCK,
-                *pos / BLOCK_SIZE, BLOCK_SIZE,
-                &retval);
-            if ((rc != EOK) || (retval != EOK))
-                return false;
-            *bufpos = 0;
-            *buflen = BLOCK_SIZE;
-        }
-    }
-    return true;
-}
 static bool
-tmpfs_restore_recursion(int phone, void *block, size_t *bufpos, size_t *buflen,
+tmpfs_restore_recursion(int phone, void *block, off_t *bufpos, size_t *buflen,
-    size_t *pos, tmpfs_dentry_t *parent)
+    off_t *pos, tmpfs_dentry_t *parent)
+{
     struct rdentry entry;
     libfs_ops_t *ops = &tmpfs_libfs_ops;
     do {
         char *fname;
         tmpfs_dentry_t *node;
         uint32_t size;
-        if (!tmpfs_blockread(phone, block, bufpos, buflen, pos, &entry,
+        if (!libfs_blockread(phone, block, bufpos, buflen, pos, &entry,
-            sizeof(entry)))
+            sizeof(entry), TMPFS_BLOCK_SIZE))
             return false;
         entry.len = uint32_t_le2host(entry.len);
         switch (entry.type) {
-        case 0:
+        case TMPFS_NONE:
             break;
-        case 1:
+        case TMPFS_FILE:
             fname = malloc(entry.len + 1);
             if (fname == NULL)
                 return false;
             node = (tmpfs_dentry_t *) ops->create(L_FILE);
             if (node == NULL) {
                 free(fname);
                 return false;
+            }
-            if (!tmpfs_blockread(phone, block, bufpos, buflen, pos,
+            if (!libfs_blockread(phone, block, bufpos, buflen, pos,
-                fname, entry.len)) {
+                fname, entry.len, TMPFS_BLOCK_SIZE)) {
                 ops->destroy((void *) node);
                 free(fname);
                 return false;
+            }
             fname[entry.len] = 0;
                 free(fname);
                 return false;
+            }
             free(fname);
-            if (!tmpfs_blockread(phone, block, bufpos, buflen, pos,
+            if (!libfs_blockread(phone, block, bufpos, buflen, pos,
-                &size, sizeof(size)))
+                &size, sizeof(size), TMPFS_BLOCK_SIZE))
                 return false;
             size = uint32_t_le2host(size);
             node->data = malloc(size);
             if (node->data == NULL)
                 return false;
             node->size = size;
-            if (!tmpfs_blockread(phone, block, bufpos, buflen, pos,
+            if (!libfs_blockread(phone, block, bufpos, buflen, pos,
-                node->data, size))
+                node->data, size, TMPFS_BLOCK_SIZE))
                 return false;
             break;
-        case 2:
+        case TMPFS_DIRECTORY:
             fname = malloc(entry.len + 1);
             if (fname == NULL)
                 return false;
             node = (tmpfs_dentry_t *) ops->create(L_DIRECTORY);
             if (node == NULL) {
                 free(fname);
                 return false;
+            }
-            if (!tmpfs_blockread(phone, block, bufpos, buflen, pos,
+            if (!libfs_blockread(phone, block, bufpos, buflen, pos,
-                fname, entry.len)) {
+                fname, entry.len, TMPFS_BLOCK_SIZE)) {
                 ops->destroy((void *) node);
                 free(fname);
                 return false;
+            }
             fname[entry.len] = 0;
             break;
         default:
             return false;
+        }
-    } while (entry.type != 0);
+    } while (entry.type != TMPFS_NONE);
     return true;
+}
 bool tmpfs_restore(dev_handle_t dev)
+{
     libfs_ops_t *ops = &tmpfs_libfs_ops;
-    void *block = mmap(NULL, BLOCK_SIZE,
+    void *block = mmap(NULL, TMPFS_BLOCK_SIZE,
         PROTO_READ | PROTO_WRITE, MAP_ANONYMOUS | MAP_PRIVATE, 0, 0);
     if (block == NULL)
         return false;
     int phone = ipc_connect_me_to(PHONE_NS, SERVICE_DEVMAP,
         DEVMAP_CONNECT_TO_DEVICE, dev);
     if (phone < 0) {
-        munmap(block, BLOCK_SIZE);
+        munmap(block, TMPFS_BLOCK_SIZE);
         return false;
+    }
     if (ipc_share_out_start(phone, block, AS_AREA_READ | AS_AREA_WRITE) !=
         EOK)
         goto error;
-    size_t bufpos = 0;
+    off_t bufpos = 0;
     size_t buflen = 0;
-    size_t pos = 0;
+    off_t pos = 0;
     char tag[6];
-    if (!tmpfs_blockread(phone, block, &bufpos, &buflen, &pos, tag, 5))
+    if (!libfs_blockread(phone, block, &bufpos, &buflen, &pos, tag, 5,
+        TMPFS_BLOCK_SIZE))
         goto error;
     tag[5] = 0;
     if (strcmp(tag, "TMPFS") != 0)
         goto error;
     if (!tmpfs_restore_recursion(phone, block, &bufpos, &buflen, &pos,
         ops->root_get(dev)))
         goto error;
     ipc_hangup(phone);
-    munmap(block, BLOCK_SIZE);
+    munmap(block, TMPFS_BLOCK_SIZE);
     return true;
 error:
     ipc_hangup(phone);
-    munmap(block, BLOCK_SIZE);
+    munmap(block, TMPFS_BLOCK_SIZE);
     return false;
+}
 /**
  * @}

Subversion Repositories HelenOS

(root)//branches/tracing/uspace/srv/fs/tmpfs/tmpfs_dump.c – Rev 3424 → 3425