提交 77d63b9a 编写于 作者: Y Yu Kuai 提交者: Zhong Jinghua

nbd: factor out a helper to get nbd_config without holding 'config_lock'

Offering: HULK
hulk inclusion
category: bugfix
bugzilla: 188902, https://gitee.com/openeuler/kernel/issues/I7EENU

----------------------------------------

There are no functional changes, just to make code cleaner and prepare
to fix null-ptr-dereference while accessing 'nbd->config'.
Signed-off-by: NYu Kuai <yukuai3@huawei.com>
Signed-off-by: NZhong Jinghua <zhongjinghua@huawei.com>
上级 7b8f440b
...@@ -389,6 +389,14 @@ static u32 req_to_nbd_cmd_type(struct request *req) ...@@ -389,6 +389,14 @@ static u32 req_to_nbd_cmd_type(struct request *req)
} }
} }
static struct nbd_config *nbd_get_config_unlocked(struct nbd_device *nbd)
{
if (refcount_inc_not_zero(&nbd->config_refs))
return nbd->config;
return NULL;
}
static enum blk_eh_timer_return nbd_xmit_timeout(struct request *req, static enum blk_eh_timer_return nbd_xmit_timeout(struct request *req,
bool reserved) bool reserved)
{ {
...@@ -404,13 +412,13 @@ static enum blk_eh_timer_return nbd_xmit_timeout(struct request *req, ...@@ -404,13 +412,13 @@ static enum blk_eh_timer_return nbd_xmit_timeout(struct request *req,
return BLK_EH_DONE; return BLK_EH_DONE;
} }
if (!refcount_inc_not_zero(&nbd->config_refs)) { config = nbd_get_config_unlocked(nbd);
if (!config) {
cmd->status = BLK_STS_TIMEOUT; cmd->status = BLK_STS_TIMEOUT;
__clear_bit(NBD_CMD_INFLIGHT, &cmd->flags); __clear_bit(NBD_CMD_INFLIGHT, &cmd->flags);
mutex_unlock(&cmd->lock); mutex_unlock(&cmd->lock);
goto done; goto done;
} }
config = nbd->config;
if (config->num_connections > 1 || if (config->num_connections > 1 ||
(config->num_connections == 1 && nbd->tag_set.timeout)) { (config->num_connections == 1 && nbd->tag_set.timeout)) {
...@@ -969,12 +977,12 @@ static int nbd_handle_cmd(struct nbd_cmd *cmd, int index) ...@@ -969,12 +977,12 @@ static int nbd_handle_cmd(struct nbd_cmd *cmd, int index)
struct nbd_sock *nsock; struct nbd_sock *nsock;
int ret; int ret;
if (!refcount_inc_not_zero(&nbd->config_refs)) { config = nbd_get_config_unlocked(nbd);
if (!config) {
dev_err_ratelimited(disk_to_dev(nbd->disk), dev_err_ratelimited(disk_to_dev(nbd->disk),
"Socks array is empty\n"); "Socks array is empty\n");
return -EINVAL; return -EINVAL;
} }
config = nbd->config;
if (index >= config->num_connections) { if (index >= config->num_connections) {
dev_err_ratelimited(disk_to_dev(nbd->disk), dev_err_ratelimited(disk_to_dev(nbd->disk),
...@@ -1564,6 +1572,7 @@ static int nbd_alloc_and_init_config(struct nbd_device *nbd) ...@@ -1564,6 +1572,7 @@ static int nbd_alloc_and_init_config(struct nbd_device *nbd)
static int nbd_open(struct block_device *bdev, fmode_t mode) static int nbd_open(struct block_device *bdev, fmode_t mode)
{ {
struct nbd_device *nbd; struct nbd_device *nbd;
struct nbd_config *config;
int ret = 0; int ret = 0;
mutex_lock(&nbd_index_mutex); mutex_lock(&nbd_index_mutex);
...@@ -1576,7 +1585,9 @@ static int nbd_open(struct block_device *bdev, fmode_t mode) ...@@ -1576,7 +1585,9 @@ static int nbd_open(struct block_device *bdev, fmode_t mode)
ret = -ENXIO; ret = -ENXIO;
goto out; goto out;
} }
if (!refcount_inc_not_zero(&nbd->config_refs)) {
config = nbd_get_config_unlocked(nbd);
if (!config) {
mutex_lock(&nbd->config_lock); mutex_lock(&nbd->config_lock);
if (refcount_inc_not_zero(&nbd->config_refs)) { if (refcount_inc_not_zero(&nbd->config_refs)) {
mutex_unlock(&nbd->config_lock); mutex_unlock(&nbd->config_lock);
...@@ -1591,7 +1602,7 @@ static int nbd_open(struct block_device *bdev, fmode_t mode) ...@@ -1591,7 +1602,7 @@ static int nbd_open(struct block_device *bdev, fmode_t mode)
refcount_inc(&nbd->refs); refcount_inc(&nbd->refs);
mutex_unlock(&nbd->config_lock); mutex_unlock(&nbd->config_lock);
set_bit(GD_NEED_PART_SCAN, &bdev->bd_disk->state); set_bit(GD_NEED_PART_SCAN, &bdev->bd_disk->state);
} else if (nbd_disconnected(nbd->config)) { } else if (nbd_disconnected(config)) {
set_bit(GD_NEED_PART_SCAN, &bdev->bd_disk->state); set_bit(GD_NEED_PART_SCAN, &bdev->bd_disk->state);
} }
out: out:
...@@ -2196,7 +2207,8 @@ static int nbd_genl_reconfigure(struct sk_buff *skb, struct genl_info *info) ...@@ -2196,7 +2207,8 @@ static int nbd_genl_reconfigure(struct sk_buff *skb, struct genl_info *info)
} }
mutex_unlock(&nbd_index_mutex); mutex_unlock(&nbd_index_mutex);
if (!refcount_inc_not_zero(&nbd->config_refs)) { config = nbd_get_config_unlocked(nbd);
if (!config) {
dev_err(nbd_to_dev(nbd), dev_err(nbd_to_dev(nbd),
"not configured, cannot reconfigure\n"); "not configured, cannot reconfigure\n");
nbd_put(nbd); nbd_put(nbd);
...@@ -2204,7 +2216,6 @@ static int nbd_genl_reconfigure(struct sk_buff *skb, struct genl_info *info) ...@@ -2204,7 +2216,6 @@ static int nbd_genl_reconfigure(struct sk_buff *skb, struct genl_info *info)
} }
mutex_lock(&nbd->config_lock); mutex_lock(&nbd->config_lock);
config = nbd->config;
if (!test_bit(NBD_RT_BOUND, &config->runtime_flags) || if (!test_bit(NBD_RT_BOUND, &config->runtime_flags) ||
!nbd->pid) { !nbd->pid) {
dev_err(nbd_to_dev(nbd), dev_err(nbd_to_dev(nbd),
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册