X-Git-Url: https://wimlib.net/git/?p=wimlib;a=blobdiff_plain;f=src%2Fmount_image.c;h=7fe8bb537fb1621a5e5742fba40aa98ed8347dde;hp=dd6d94c611d00663215d98591b36d7f0a9ecb775;hb=15ded30b9bcce7ac0388dec90dd4d6ef3d6d1596;hpb=3de1ec66f778edda19865482d685bc6f4e17faf7

diff --git a/src/mount_image.c b/src/mount_image.c
index dd6d94c6..7fe8bb53 100644
--- a/src/mount_image.c
+++ b/src/mount_image.c
@@ -458,9 +458,9 @@ wim_pathname_to_stream(const struct wimfs_context *ctx,
  * Returns 0 or a -errno code.
  */
 static int
-create_dentry(struct fuse_context *fuse_ctx, const char *path,
-	      mode_t mode, dev_t rdev, u32 attributes,
-	      struct wim_dentry **dentry_ret)
+create_file(struct fuse_context *fuse_ctx, const char *path,
+	    mode_t mode, dev_t rdev, u32 attributes,
+	    struct wim_dentry **dentry_ret)
 {
 	struct wimfs_context *wimfs_ctx = WIMFS_CTX(fuse_ctx);
 	struct wim_dentry *parent;
@@ -480,7 +480,7 @@ create_dentry(struct fuse_context *fuse_ctx, const char *path,
 	if (get_dentry_child_with_name(parent, basename, WIMLIB_CASE_SENSITIVE))
 		return -EEXIST;
 
-	if (new_dentry_with_inode(basename, &new_dentry))
+	if (new_dentry_with_new_inode(basename, true, &new_dentry))
 		return -ENOMEM;
 
 	new_inode = new_dentry->d_inode;
@@ -757,15 +757,9 @@ extract_blob_to_staging_dir(struct wim_inode *inode,
 		filedes_init(&fd->f_staging_fd, raw_fd);
 	}
 
-	/* Remove the appropriate count of file descriptors and stream
-	 * references from the old blob.  */
-	if (old_blob) {
+	if (old_blob)
 		old_blob->num_opened_fds -= new_blob->num_opened_fds;
-		for (u32 i = 0; i < inode->i_nlink; i++)
-			blob_decrement_refcnt(old_blob, ctx->wim->blob_table);
-	}
 
-	new_blob->refcnt            = inode->i_nlink;
 	new_blob->blob_location     = BLOB_IN_STAGING_FILE;
 	new_blob->staging_file_name = staging_file_name;
 	new_blob->staging_dir_fd    = ctx->staging_dir_fd;
@@ -773,7 +767,7 @@ extract_blob_to_staging_dir(struct wim_inode *inode,
 
 	prepare_unhashed_blob(new_blob, inode, strm->stream_id,
 			      &wim_get_current_image_metadata(ctx->wim)->unhashed_blobs);
-	stream_set_blob(strm, new_blob);
+	inode_replace_stream_blob(inode, strm, new_blob, ctx->wim->blob_table);
 	return 0;
 
 out_revert_fd_changes:
@@ -947,11 +941,8 @@ release_extra_refcnts(struct wimfs_context *ctx)
 	struct blob_table *blob_table = ctx->wim->blob_table;
 	struct blob_descriptor *blob, *tmp;
 
-	list_for_each_entry_safe(blob, tmp, list, orig_blob_list) {
-		u32 n = blob->out_refcnt;
-		while (n--)
-			blob_decrement_refcnt(blob, blob_table);
-	}
+	list_for_each_entry_safe(blob, tmp, list, orig_blob_list)
+		blob_subtract_refcnt(blob, blob_table, blob->out_refcnt);
 }
 
 /* Delete the 'struct blob_descriptor' for any stream that was modified
@@ -1027,6 +1018,7 @@ renew_current_image(struct wimfs_context *ctx)
 	new_blob = new_blob_descriptor();
 	if (!new_blob)
 		goto err_put_replace_imd;
+	new_blob->refcnt = 1;
 	new_blob->flags = WIM_RESHDR_FLAG_METADATA;
 	new_blob->unhashed = 1;
 
@@ -1405,11 +1397,9 @@ wimfs_link(const char *existing_path, const char *new_path)
 	if (get_dentry_child_with_name(dir, new_name, WIMLIB_CASE_SENSITIVE))
 		return -EEXIST;
 
-	if (new_dentry(new_name, &new_alias))
+	if (new_dentry_with_existing_inode(new_name, inode, &new_alias))
 		return -ENOMEM;
 
-	inode_ref_blobs(inode);
-	d_associate(new_alias, inode);
 	dentry_add_child(dir, new_alias);
 	touch_inode(dir->d_inode);
 	return 0;
@@ -1477,8 +1467,8 @@ wimfs_mkdir(const char *path, mode_t mode)
 	int ret;
 
 	/* Note: according to fuse.h, mode may not include S_IFDIR  */
-	ret = create_dentry(fuse_get_context(), path, mode | S_IFDIR, 0,
-			    FILE_ATTRIBUTE_DIRECTORY, &dentry);
+	ret = create_file(fuse_get_context(), path, mode | S_IFDIR, 0,
+			  FILE_ATTRIBUTE_DIRECTORY, &dentry);
 	if (ret)
 		return ret;
 	touch_parent(dentry);
@@ -1543,8 +1533,8 @@ wimfs_mknod(const char *path, mode_t mode, dev_t rdev)
 		/* Note: we still use FILE_ATTRIBUTE_NORMAL for device nodes,
 		 * named pipes, and sockets.  The real mode is in the UNIX
 		 * metadata.  */
-		ret = create_dentry(fuse_ctx, path, mode, rdev,
-				    FILE_ATTRIBUTE_NORMAL, &dentry);
+		ret = create_file(fuse_ctx, path, mode, rdev,
+				  FILE_ATTRIBUTE_NORMAL, &dentry);
 		if (ret)
 			return ret;
 		touch_parent(dentry);
@@ -1810,7 +1800,7 @@ wimfs_setxattr(const char *path, const char *name,
 {
 	struct wimfs_context *ctx = wimfs_get_context();
 	struct wim_inode *inode;
-	struct wim_inode_stream *existing_strm;
+	struct wim_inode_stream *strm;
 	const utf16lechar *uname;
 	int ret;
 
@@ -1852,8 +1842,8 @@ wimfs_setxattr(const char *path, const char *name,
 	if (ret)
 		return -errno;
 
-	existing_strm = inode_get_stream(inode, STREAM_TYPE_DATA, uname);
-	if (existing_strm) {
+	strm = inode_get_stream(inode, STREAM_TYPE_DATA, uname);
+	if (strm) {
 		ret = -EEXIST;
 		if (flags & XATTR_CREATE)
 			goto out_put_uname;
@@ -1863,14 +1853,22 @@ wimfs_setxattr(const char *path, const char *name,
 			goto out_put_uname;
 	}
 
-	if (!inode_add_stream_with_data(inode, STREAM_TYPE_DATA, uname,
-					value, size, ctx->wim->blob_table))
-	{
-		ret = -errno;
-		goto out_put_uname;
+	if (strm) {
+		if (!inode_replace_stream_data(inode, strm, value, size,
+					       ctx->wim->blob_table))
+		{
+			ret = -errno;
+			goto out_put_uname;
+		}
+	} else {
+		if (!inode_add_stream_with_data(inode, STREAM_TYPE_DATA, uname,
+						value, size, ctx->wim->blob_table))
+		{
+			ret = -errno;
+			goto out_put_uname;
+		}
 	}
-	if (existing_strm)
-		inode_remove_stream(inode, existing_strm, ctx->wim->blob_table);
+
 	ret = 0;
 out_put_uname:
 	tstr_put_utf16le(uname);
@@ -1885,8 +1883,8 @@ wimfs_symlink(const char *to, const char *from)
 	struct wim_dentry *dentry;
 	int ret;
 
-	ret = create_dentry(fuse_ctx, from, S_IFLNK | 0777, 0,
-			    FILE_ATTRIBUTE_REPARSE_POINT, &dentry);
+	ret = create_file(fuse_ctx, from, S_IFLNK | 0777, 0,
+			  FILE_ATTRIBUTE_REPARSE_POINT, &dentry);
 	if (ret)
 		return ret;
 	dentry->d_inode->i_reparse_tag = WIM_IO_REPARSE_TAG_SYMLINK;