Commit 3065ae5b authored by David Sterba's avatar David Sterba

btrfs: add missing device::flush_bio puts

This fixes potential bio leaks, in several error paths. Unfortunatelly
the device structure freeing is opencoded in many places and I missed
them when introducing the flush_bio.

Most of the time, devices get freed through call_rcu(..., free_device),
so it at least it's not that easy to hit the leak, but it's still
possible through the path that frees stale devices.

Fixes: e0ae9994 ("btrfs: preallocate device flush bio")
Reviewed-by: default avatarNikolay Borisov <nborisov@suse.com>
Reviewed-by: default avatarAnand Jain <anand.jain@oracle.com>
Signed-off-by: default avatarDavid Sterba <dsterba@suse.com>
parent 5e9f2ad5
...@@ -189,6 +189,7 @@ static void free_fs_devices(struct btrfs_fs_devices *fs_devices) ...@@ -189,6 +189,7 @@ static void free_fs_devices(struct btrfs_fs_devices *fs_devices)
struct btrfs_device, dev_list); struct btrfs_device, dev_list);
list_del(&device->dev_list); list_del(&device->dev_list);
rcu_string_free(device->name); rcu_string_free(device->name);
bio_put(device->flush_bio);
kfree(device); kfree(device);
} }
kfree(fs_devices); kfree(fs_devices);
...@@ -578,6 +579,7 @@ static void btrfs_free_stale_device(struct btrfs_device *cur_dev) ...@@ -578,6 +579,7 @@ static void btrfs_free_stale_device(struct btrfs_device *cur_dev)
fs_devs->num_devices--; fs_devs->num_devices--;
list_del(&dev->dev_list); list_del(&dev->dev_list);
rcu_string_free(dev->name); rcu_string_free(dev->name);
bio_put(dev->flush_bio);
kfree(dev); kfree(dev);
} }
break; break;
...@@ -630,6 +632,7 @@ static noinline int device_list_add(const char *path, ...@@ -630,6 +632,7 @@ static noinline int device_list_add(const char *path,
name = rcu_string_strdup(path, GFP_NOFS); name = rcu_string_strdup(path, GFP_NOFS);
if (!name) { if (!name) {
bio_put(device->flush_bio);
kfree(device); kfree(device);
return -ENOMEM; return -ENOMEM;
} }
...@@ -742,6 +745,7 @@ static struct btrfs_fs_devices *clone_fs_devices(struct btrfs_fs_devices *orig) ...@@ -742,6 +745,7 @@ static struct btrfs_fs_devices *clone_fs_devices(struct btrfs_fs_devices *orig)
name = rcu_string_strdup(orig_dev->name->str, name = rcu_string_strdup(orig_dev->name->str,
GFP_KERNEL); GFP_KERNEL);
if (!name) { if (!name) {
bio_put(device->flush_bio);
kfree(device); kfree(device);
goto error; goto error;
} }
...@@ -807,6 +811,7 @@ void btrfs_close_extra_devices(struct btrfs_fs_devices *fs_devices, int step) ...@@ -807,6 +811,7 @@ void btrfs_close_extra_devices(struct btrfs_fs_devices *fs_devices, int step)
list_del_init(&device->dev_list); list_del_init(&device->dev_list);
fs_devices->num_devices--; fs_devices->num_devices--;
rcu_string_free(device->name); rcu_string_free(device->name);
bio_put(device->flush_bio);
kfree(device); kfree(device);
} }
...@@ -2353,6 +2358,7 @@ int btrfs_init_new_device(struct btrfs_fs_info *fs_info, const char *device_path ...@@ -2353,6 +2358,7 @@ int btrfs_init_new_device(struct btrfs_fs_info *fs_info, const char *device_path
name = rcu_string_strdup(device_path, GFP_KERNEL); name = rcu_string_strdup(device_path, GFP_KERNEL);
if (!name) { if (!name) {
bio_put(device->flush_bio);
kfree(device); kfree(device);
ret = -ENOMEM; ret = -ENOMEM;
goto error; goto error;
...@@ -2362,6 +2368,7 @@ int btrfs_init_new_device(struct btrfs_fs_info *fs_info, const char *device_path ...@@ -2362,6 +2368,7 @@ int btrfs_init_new_device(struct btrfs_fs_info *fs_info, const char *device_path
trans = btrfs_start_transaction(root, 0); trans = btrfs_start_transaction(root, 0);
if (IS_ERR(trans)) { if (IS_ERR(trans)) {
rcu_string_free(device->name); rcu_string_free(device->name);
bio_put(device->flush_bio);
kfree(device); kfree(device);
ret = PTR_ERR(trans); ret = PTR_ERR(trans);
goto error; goto error;
...@@ -2505,6 +2512,7 @@ int btrfs_init_new_device(struct btrfs_fs_info *fs_info, const char *device_path ...@@ -2505,6 +2512,7 @@ int btrfs_init_new_device(struct btrfs_fs_info *fs_info, const char *device_path
if (trans) if (trans)
btrfs_end_transaction(trans); btrfs_end_transaction(trans);
rcu_string_free(device->name); rcu_string_free(device->name);
bio_put(device->flush_bio);
kfree(device); kfree(device);
error: error:
blkdev_put(bdev, FMODE_EXCL); blkdev_put(bdev, FMODE_EXCL);
...@@ -2571,6 +2579,7 @@ int btrfs_init_dev_replace_tgtdev(struct btrfs_fs_info *fs_info, ...@@ -2571,6 +2579,7 @@ int btrfs_init_dev_replace_tgtdev(struct btrfs_fs_info *fs_info,
name = rcu_string_strdup(device_path, GFP_KERNEL); name = rcu_string_strdup(device_path, GFP_KERNEL);
if (!name) { if (!name) {
bio_put(device->flush_bio);
kfree(device); kfree(device);
ret = -ENOMEM; ret = -ENOMEM;
goto error; goto error;
...@@ -6288,6 +6297,7 @@ struct btrfs_device *btrfs_alloc_device(struct btrfs_fs_info *fs_info, ...@@ -6288,6 +6297,7 @@ struct btrfs_device *btrfs_alloc_device(struct btrfs_fs_info *fs_info,
ret = find_next_devid(fs_info, &tmp); ret = find_next_devid(fs_info, &tmp);
if (ret) { if (ret) {
bio_put(dev->flush_bio);
kfree(dev); kfree(dev);
return ERR_PTR(ret); return ERR_PTR(ret);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment