Changes in uspace/srv/fs/mfs/mfs_ops.c [36cb22f:5bf76c1] in mainline

File:

• uspace/srv/fs/mfs/mfs_ops.c (modified) (11 diffs)

uspace/srv/fs/mfs/mfs_ops.c

@@ -143 +143 @@
 {
         enum cache_mode cmode;
-        struct mfs_superblock *sb = NULL;
-        struct mfs3_superblock *sb3 = NULL;
-        struct mfs_sb_info *sbi = NULL;
-        struct mfs_instance *instance = NULL;
+        struct mfs_superblock *sb;
+        struct mfs3_superblock *sb3;
+        struct mfs_sb_info *sbi;
+        struct mfs_instance *instance;
         bool native, longnames;
         mfs_version_t version;
@@ -166 +166 @@
         sbi = malloc(sizeof(*sbi));
         if (!sbi) {
-                rc = ENOMEM;
-                goto out_error;
+                block_fini(service_id);
+                return ENOMEM;
         }
 
@@ -173 +173 @@
         instance = malloc(sizeof(*instance));
         if (!instance) {
-                rc = ENOMEM;
-                goto out_error;
+                free(sbi);
+                block_fini(service_id);
+                return ENOMEM;
         }
 
         sb = malloc(MFS_SUPERBLOCK_SIZE);
         if (!sb) {
-                rc = ENOMEM;
-                goto out_error;
+                free(instance);
+                free(sbi);
+                block_fini(service_id);
+                return ENOMEM;
         }
 
         /* Read the superblock */
         rc = block_read_direct(service_id, MFS_SUPERBLOCK << 1, 2, sb);
-        if (rc != EOK)
-                goto out_error;
+        if (rc != EOK) {
+                free(instance);
+                free(sbi);
+                free(sb);
+                block_fini(service_id);
+                return rc;
+        }
 
         sb3 = (struct mfs3_superblock *) sb;
@@ -199 +207 @@
                 /*Not recognized*/
                 mfsdebug("magic number not recognized\n");
-                rc = ENOTSUP;
-                goto out_error;
+                free(instance);
+                free(sbi);
+                free(sb);
+                block_fini(service_id);
+                return ENOTSUP;
         }
 
@@ -245 +256 @@
                                     MFS_MAX_NAME_LEN;
         }
-
-        if (sbi->log2_zone_size != 0) {
-                /* In MFS, file space is allocated per zones.
-                 * Zones are a collection of consecutive blocks on disk.
-                 *
-                 * The current MFS implementation supports only filesystems
-                 * where the size of a zone is equal to the
-                 * size of a block.
-                 */
-                rc = ENOTSUP;
-                goto out_error;
-        }
-
         sbi->itable_off = 2 + sbi->ibmap_blocks + sbi->zbmap_blocks;
+
+        free(sb);
 
         rc = block_cache_init(service_id, sbi->block_size, 0, cmode);
         if (rc != EOK) {
+                free(instance);
+                free(sbi);
+                block_cache_fini(service_id);
+                block_fini(service_id);
                 mfsdebug("block cache initialization failed\n");
-                rc = EINVAL;
-                goto out_error;
+                return EINVAL;
         }
 
@@ -292 +295 @@
         *linkcnt = 1;
 
-        free(sb);
-
         return mfs_node_put(fn);
-
-out_error:
-        block_fini(service_id);
-        if (sb)
-                free(sb);
-        if (sbi)
-                free(sbi);
-        if(instance)
-                free(instance);
-        return rc;
 }
 
@@ -889 +880 @@
         struct mfs_ino_info *ino_i = mnode->ino_i;
         const size_t bs = sbi->block_size;
-        size_t bytes = min(len, bs - (pos % bs));
+        size_t bytes = min(len, bs - pos % bs);
+        size_t boundary = ROUND_UP(ino_i->i_size, bs);
         uint32_t block;
 
@@ -895 +887 @@
                 flags = BLOCK_FLAGS_NOREAD;
 
-        r = mfs_read_map(&block, mnode, pos);
-        if (r != EOK)
-                goto out_err;
-
-        if (block == 0) {
-                /*Writing in a sparse block*/
+        if (pos < boundary) {
+                r = mfs_read_map(&block, mnode, pos);
+                if (r != EOK)
+                        goto out_err;
+
+                if (block == 0) {
+                        /*Writing in a sparse block*/
+                        r = mfs_alloc_zone(mnode->instance, &block);
+                        if (r != EOK)
+                                goto out_err;
+                        flags = BLOCK_FLAGS_NOREAD;
+                }
+        } else {
                 uint32_t dummy;
 
@@ -906 +905 @@
                 if (r != EOK)
                         goto out_err;
-                
+
                 r = mfs_write_map(mnode, pos, block, &dummy);
                 if (r != EOK)
                         goto out_err;
-
-                flags = BLOCK_FLAGS_NOREAD;
         }
 
@@ -919 +916 @@
                 goto out_err;
 
-        if (flags == BLOCK_FLAGS_NOREAD)
-                memset(b->data, 0, sbi->block_size);
-
-        async_data_write_finalize(callid, b->data + (pos % bs), bytes);
+        async_data_write_finalize(callid, b->data + pos % bs, bytes);
         b->dirty = true;
 
@@ -931 +925 @@
         }
 
-        if (pos + bytes > ino_i->i_size) {
-                ino_i->i_size = pos + bytes;
-                ino_i->dirty = true;
-        }
+        ino_i->i_size = pos + bytes;
+        ino_i->dirty = true;
         r = mfs_node_put(fn);
-        *nsize = ino_i->i_size;
+        *nsize = pos + bytes;
         *wbytes = bytes;
         return r;