w1: keep balance of mutex locks and refcnts

w1_therm_eeprom() and w1_DS18B20_precision() decrement THERM_REFCNT
on error paths, while they did not increment it yet.

read_therm() unlocks bus mutex on some error paths,
while it is not acquired.

The patch makes sure all the functions keep the balance in usage of
the mutex and the THERM_REFCNT.

Found by Linux Driver Verification project (linuxtesting.org).

Signed-off-by: Alexey Khoroshilov <khoroshilov@ispras.ru>
Signed-off-by: Greg Kroah-Hartman <gregkh@linuxfoundation.org>
This commit is contained in:
Alexey Khoroshilov 2017-10-22 01:03:44 +03:00 committed by Greg Kroah-Hartman
parent d4035a8c1f
commit f53459c008

View file

@ -268,17 +268,18 @@ static inline int w1_therm_eeprom(struct device *device)
int ret, max_trying = 10; int ret, max_trying = 10;
u8 *family_data = sl->family_data; u8 *family_data = sl->family_data;
ret = mutex_lock_interruptible(&dev->bus_mutex);
if (ret != 0)
goto post_unlock;
if (!sl->family_data) { if (!sl->family_data) {
ret = -ENODEV; ret = -ENODEV;
goto pre_unlock; goto error;
} }
/* prevent the slave from going away in sleep */ /* prevent the slave from going away in sleep */
atomic_inc(THERM_REFCNT(family_data)); atomic_inc(THERM_REFCNT(family_data));
ret = mutex_lock_interruptible(&dev->bus_mutex);
if (ret != 0)
goto dec_refcnt;
memset(rom, 0, sizeof(rom)); memset(rom, 0, sizeof(rom));
while (max_trying--) { while (max_trying--) {
@ -306,17 +307,17 @@ static inline int w1_therm_eeprom(struct device *device)
sleep_rem = msleep_interruptible(tm); sleep_rem = msleep_interruptible(tm);
if (sleep_rem != 0) { if (sleep_rem != 0) {
ret = -EINTR; ret = -EINTR;
goto post_unlock; goto dec_refcnt;
} }
ret = mutex_lock_interruptible(&dev->bus_mutex); ret = mutex_lock_interruptible(&dev->bus_mutex);
if (ret != 0) if (ret != 0)
goto post_unlock; goto dec_refcnt;
} else if (!w1_strong_pullup) { } else if (!w1_strong_pullup) {
sleep_rem = msleep_interruptible(tm); sleep_rem = msleep_interruptible(tm);
if (sleep_rem != 0) { if (sleep_rem != 0) {
ret = -EINTR; ret = -EINTR;
goto pre_unlock; goto mt_unlock;
} }
} }
@ -324,11 +325,11 @@ static inline int w1_therm_eeprom(struct device *device)
} }
} }
pre_unlock: mt_unlock:
mutex_unlock(&dev->bus_mutex); mutex_unlock(&dev->bus_mutex);
dec_refcnt:
post_unlock:
atomic_dec(THERM_REFCNT(family_data)); atomic_dec(THERM_REFCNT(family_data));
error:
return ret; return ret;
} }
@ -350,20 +351,22 @@ static inline int w1_DS18B20_precision(struct device *device, int val)
if (val > 12 || val < 9) { if (val > 12 || val < 9) {
pr_warn("Unsupported precision\n"); pr_warn("Unsupported precision\n");
return -1; ret = -EINVAL;
goto error;
} }
ret = mutex_lock_interruptible(&dev->bus_mutex);
if (ret != 0)
goto post_unlock;
if (!sl->family_data) { if (!sl->family_data) {
ret = -ENODEV; ret = -ENODEV;
goto pre_unlock; goto error;
} }
/* prevent the slave from going away in sleep */ /* prevent the slave from going away in sleep */
atomic_inc(THERM_REFCNT(family_data)); atomic_inc(THERM_REFCNT(family_data));
ret = mutex_lock_interruptible(&dev->bus_mutex);
if (ret != 0)
goto dec_refcnt;
memset(rom, 0, sizeof(rom)); memset(rom, 0, sizeof(rom));
/* translate precision to bitmask (see datasheet page 9) */ /* translate precision to bitmask (see datasheet page 9) */
@ -411,11 +414,10 @@ static inline int w1_DS18B20_precision(struct device *device, int val)
} }
} }
pre_unlock:
mutex_unlock(&dev->bus_mutex); mutex_unlock(&dev->bus_mutex);
dec_refcnt:
post_unlock:
atomic_dec(THERM_REFCNT(family_data)); atomic_dec(THERM_REFCNT(family_data));
error:
return ret; return ret;
} }
@ -490,17 +492,18 @@ static ssize_t read_therm(struct device *device,
int ret, max_trying = 10; int ret, max_trying = 10;
u8 *family_data = sl->family_data; u8 *family_data = sl->family_data;
ret = mutex_lock_interruptible(&dev->bus_mutex);
if (ret != 0)
goto error;
if (!family_data) { if (!family_data) {
ret = -ENODEV; ret = -ENODEV;
goto mt_unlock; goto error;
} }
/* prevent the slave from going away in sleep */ /* prevent the slave from going away in sleep */
atomic_inc(THERM_REFCNT(family_data)); atomic_inc(THERM_REFCNT(family_data));
ret = mutex_lock_interruptible(&dev->bus_mutex);
if (ret != 0)
goto dec_refcnt;
memset(info->rom, 0, sizeof(info->rom)); memset(info->rom, 0, sizeof(info->rom));
while (max_trying--) { while (max_trying--) {
@ -542,7 +545,7 @@ static ssize_t read_therm(struct device *device,
sleep_rem = msleep_interruptible(tm); sleep_rem = msleep_interruptible(tm);
if (sleep_rem != 0) { if (sleep_rem != 0) {
ret = -EINTR; ret = -EINTR;
goto dec_refcnt; goto mt_unlock;
} }
} }
@ -567,10 +570,10 @@ static ssize_t read_therm(struct device *device,
break; break;
} }
dec_refcnt:
atomic_dec(THERM_REFCNT(family_data));
mt_unlock: mt_unlock:
mutex_unlock(&dev->bus_mutex); mutex_unlock(&dev->bus_mutex);
dec_refcnt:
atomic_dec(THERM_REFCNT(family_data));
error: error:
return ret; return ret;
} }