| 38,17 → 38,12 |
|---|
| |
| #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 <libfs.h> |
| #include <ipc/services.h> |
| #include <ipc/devmap.h> |
| #include <sys/mman.h> |
| #include <libblock.h> |
| #include <byteorder.h> |
| |
| #define TMPFS_BLOCK_SIZE 1024 |
| 59,11 → 54,12 |
|---|
| } __attribute__((packed)); |
| |
| static bool |
| tmpfs_restore_recursion(int phone, void *block, off_t *bufpos, size_t *buflen, |
| off_t *pos, tmpfs_dentry_t *parent) |
| tmpfs_restore_recursion(int dev, off_t *bufpos, size_t *buflen, off_t *pos, |
| tmpfs_dentry_t *parent) |
| { |
| struct rdentry entry; |
| libfs_ops_t *ops = &tmpfs_libfs_ops; |
| int rc; |
| |
| do { |
| char *fname; |
| 70,8 → 66,8 |
|---|
| tmpfs_dentry_t *node; |
| uint32_t size; |
| |
| if (!libfs_blockread(phone, block, bufpos, buflen, pos, &entry, |
| sizeof(entry), TMPFS_BLOCK_SIZE)) |
| if (block_read(dev, bufpos, buflen, pos, &entry, sizeof(entry), |
| TMPFS_BLOCK_SIZE) != EOK) |
| return false; |
| |
| entry.len = uint32_t_le2host(entry.len); |
| 84,14 → 80,14 |
|---|
| if (fname == NULL) |
| return false; |
| |
| node = (tmpfs_dentry_t *) ops->create(L_FILE); |
| node = (tmpfs_dentry_t *) ops->create(dev, L_FILE); |
| if (node == NULL) { |
| free(fname); |
| return false; |
| } |
| |
| if (!libfs_blockread(phone, block, bufpos, buflen, pos, |
| fname, entry.len, TMPFS_BLOCK_SIZE)) { |
| if (block_read(dev, bufpos, buflen, pos, fname, |
| entry.len, TMPFS_BLOCK_SIZE) != EOK) { |
| ops->destroy((void *) node); |
| free(fname); |
| return false; |
| 98,7 → 94,8 |
|---|
| } |
| fname[entry.len] = 0; |
| |
| if (!ops->link((void *) parent, (void *) node, fname)) { |
| rc = ops->link((void *) parent, (void *) node, fname); |
| if (rc != EOK) { |
| ops->destroy((void *) node); |
| free(fname); |
| return false; |
| 105,8 → 102,8 |
|---|
| } |
| free(fname); |
| |
| if (!libfs_blockread(phone, block, bufpos, buflen, pos, |
| &size, sizeof(size), TMPFS_BLOCK_SIZE)) |
| if (block_read(dev, bufpos, buflen, pos, &size, |
| sizeof(size), TMPFS_BLOCK_SIZE) != EOK) |
| return false; |
| |
| size = uint32_t_le2host(size); |
| 116,8 → 113,8 |
|---|
| return false; |
| |
| node->size = size; |
| if (!libfs_blockread(phone, block, bufpos, buflen, pos, |
| node->data, size, TMPFS_BLOCK_SIZE)) |
| if (block_read(dev, bufpos, buflen, pos, node->data, |
| size, TMPFS_BLOCK_SIZE) != EOK) |
| return false; |
| |
| break; |
| 126,21 → 123,22 |
|---|
| if (fname == NULL) |
| return false; |
| |
| node = (tmpfs_dentry_t *) ops->create(L_DIRECTORY); |
| node = (tmpfs_dentry_t *) ops->create(dev, L_DIRECTORY); |
| if (node == NULL) { |
| free(fname); |
| return false; |
| } |
| |
| if (!libfs_blockread(phone, block, bufpos, buflen, pos, |
| fname, entry.len, TMPFS_BLOCK_SIZE)) { |
| if (block_read(dev, bufpos, buflen, pos, fname, |
| entry.len, TMPFS_BLOCK_SIZE) != EOK) { |
| ops->destroy((void *) node); |
| free(fname); |
| return false; |
| } |
| fname[entry.len] = 0; |
| |
| if (!ops->link((void *) parent, (void *) node, fname)) { |
| |
| rc = ops->link((void *) parent, (void *) node, fname); |
| if (rc != EOK) { |
| ops->destroy((void *) node); |
| free(fname); |
| return false; |
| 147,8 → 145,8 |
|---|
| } |
| free(fname); |
| |
| if (!tmpfs_restore_recursion(phone, block, bufpos, |
| buflen, pos, node)) |
| if (!tmpfs_restore_recursion(dev, bufpos, buflen, pos, |
| node)) |
| return false; |
| |
| break; |
| 163,32 → 161,19 |
|---|
| bool tmpfs_restore(dev_handle_t dev) |
| { |
| libfs_ops_t *ops = &tmpfs_libfs_ops; |
| int rc; |
| |
| void *block = mmap(NULL, TMPFS_BLOCK_SIZE, |
| PROTO_READ | PROTO_WRITE, MAP_ANONYMOUS | MAP_PRIVATE, 0, 0); |
| rc = block_init(dev, TMPFS_BLOCK_SIZE); |
| if (rc != EOK) |
| return false; |
| |
| 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, TMPFS_BLOCK_SIZE); |
| return false; |
| } |
| |
| if (ipc_share_out_start(phone, block, AS_AREA_READ | AS_AREA_WRITE) != |
| EOK) |
| goto error; |
| |
| off_t bufpos = 0; |
| size_t buflen = 0; |
| off_t pos = 0; |
| |
| char tag[6]; |
| if (!libfs_blockread(phone, block, &bufpos, &buflen, &pos, tag, 5, |
| TMPFS_BLOCK_SIZE)) |
| if (block_read(dev, &bufpos, &buflen, &pos, tag, 5, |
| TMPFS_BLOCK_SIZE) != EOK) |
| goto error; |
| |
| tag[5] = 0; |
| 195,17 → 180,15 |
|---|
| if (strcmp(tag, "TMPFS") != 0) |
| goto error; |
| |
| if (!tmpfs_restore_recursion(phone, block, &bufpos, &buflen, &pos, |
| if (!tmpfs_restore_recursion(dev, &bufpos, &buflen, &pos, |
| ops->root_get(dev))) |
| goto error; |
| |
| ipc_hangup(phone); |
| munmap(block, TMPFS_BLOCK_SIZE); |
| block_fini(dev); |
| return true; |
| |
| error: |
| ipc_hangup(phone); |
| munmap(block, TMPFS_BLOCK_SIZE); |
| block_fini(dev); |
| return false; |
| } |
| |