Commit 26a11eb1 authored by Santosh Nayak's avatar Santosh Nayak Committed by Mauro Carvalho Chehab

[media] dib0700: Return -EINTR and unlock mutex if locking attempts fails

In 'dib0700_i2c_xfer_new()' and 'dib0700_i2c_xfer_legacy()'
we are taking two locks:
                1. i2c_mutex
                2. usb_mutex
If attempt to take 'usb_mutex' lock fails then the previously taken
lock 'i2c_mutex' should be unlocked and -EINTR should be returned so
that caller can take appropriate action.

If locking attempt was interrupted by a signal then
we should return -EINTR. At present we are returning '0' for
such scenarios  which is wrong.

Replace -EAGAIN by -EINTR as a return type for the the scenario
where locking attempt was interrupted by signal.
Signed-off-by: default avatarSantosh Nayak <santoshprasadnayak@gmail.com>
Signed-off-by: default avatarMauro Carvalho Chehab <mchehab@redhat.com>
parent b115f400
...@@ -32,7 +32,7 @@ int dib0700_get_version(struct dvb_usb_device *d, u32 *hwversion, ...@@ -32,7 +32,7 @@ int dib0700_get_version(struct dvb_usb_device *d, u32 *hwversion,
if (mutex_lock_interruptible(&d->usb_mutex) < 0) { if (mutex_lock_interruptible(&d->usb_mutex) < 0) {
err("could not acquire lock"); err("could not acquire lock");
return 0; return -EINTR;
} }
ret = usb_control_msg(d->udev, usb_rcvctrlpipe(d->udev, 0), ret = usb_control_msg(d->udev, usb_rcvctrlpipe(d->udev, 0),
...@@ -118,7 +118,7 @@ int dib0700_set_gpio(struct dvb_usb_device *d, enum dib07x0_gpios gpio, u8 gpio_ ...@@ -118,7 +118,7 @@ int dib0700_set_gpio(struct dvb_usb_device *d, enum dib07x0_gpios gpio, u8 gpio_
if (mutex_lock_interruptible(&d->usb_mutex) < 0) { if (mutex_lock_interruptible(&d->usb_mutex) < 0) {
err("could not acquire lock"); err("could not acquire lock");
return 0; return -EINTR;
} }
st->buf[0] = REQUEST_SET_GPIO; st->buf[0] = REQUEST_SET_GPIO;
...@@ -139,7 +139,7 @@ static int dib0700_set_usb_xfer_len(struct dvb_usb_device *d, u16 nb_ts_packets) ...@@ -139,7 +139,7 @@ static int dib0700_set_usb_xfer_len(struct dvb_usb_device *d, u16 nb_ts_packets)
if (st->fw_version >= 0x10201) { if (st->fw_version >= 0x10201) {
if (mutex_lock_interruptible(&d->usb_mutex) < 0) { if (mutex_lock_interruptible(&d->usb_mutex) < 0) {
err("could not acquire lock"); err("could not acquire lock");
return 0; return -EINTR;
} }
st->buf[0] = REQUEST_SET_USB_XFER_LEN; st->buf[0] = REQUEST_SET_USB_XFER_LEN;
...@@ -178,7 +178,7 @@ static int dib0700_i2c_xfer_new(struct i2c_adapter *adap, struct i2c_msg *msg, ...@@ -178,7 +178,7 @@ static int dib0700_i2c_xfer_new(struct i2c_adapter *adap, struct i2c_msg *msg,
/* Ensure nobody else hits the i2c bus while we're sending our /* Ensure nobody else hits the i2c bus while we're sending our
sequence of messages, (such as the remote control thread) */ sequence of messages, (such as the remote control thread) */
if (mutex_lock_interruptible(&d->i2c_mutex) < 0) if (mutex_lock_interruptible(&d->i2c_mutex) < 0)
return -EAGAIN; return -EINTR;
for (i = 0; i < num; i++) { for (i = 0; i < num; i++) {
if (i == 0) { if (i == 0) {
...@@ -228,7 +228,8 @@ static int dib0700_i2c_xfer_new(struct i2c_adapter *adap, struct i2c_msg *msg, ...@@ -228,7 +228,8 @@ static int dib0700_i2c_xfer_new(struct i2c_adapter *adap, struct i2c_msg *msg,
/* Write request */ /* Write request */
if (mutex_lock_interruptible(&d->usb_mutex) < 0) { if (mutex_lock_interruptible(&d->usb_mutex) < 0) {
err("could not acquire lock"); err("could not acquire lock");
return 0; mutex_unlock(&d->i2c_mutex);
return -EINTR;
} }
st->buf[0] = REQUEST_NEW_I2C_WRITE; st->buf[0] = REQUEST_NEW_I2C_WRITE;
st->buf[1] = msg[i].addr << 1; st->buf[1] = msg[i].addr << 1;
...@@ -271,10 +272,11 @@ static int dib0700_i2c_xfer_legacy(struct i2c_adapter *adap, ...@@ -271,10 +272,11 @@ static int dib0700_i2c_xfer_legacy(struct i2c_adapter *adap,
int i,len; int i,len;
if (mutex_lock_interruptible(&d->i2c_mutex) < 0) if (mutex_lock_interruptible(&d->i2c_mutex) < 0)
return -EAGAIN; return -EINTR;
if (mutex_lock_interruptible(&d->usb_mutex) < 0) { if (mutex_lock_interruptible(&d->usb_mutex) < 0) {
err("could not acquire lock"); err("could not acquire lock");
return 0; mutex_unlock(&d->i2c_mutex);
return -EINTR;
} }
for (i = 0; i < num; i++) { for (i = 0; i < num; i++) {
...@@ -369,7 +371,7 @@ static int dib0700_set_clock(struct dvb_usb_device *d, u8 en_pll, ...@@ -369,7 +371,7 @@ static int dib0700_set_clock(struct dvb_usb_device *d, u8 en_pll,
if (mutex_lock_interruptible(&d->usb_mutex) < 0) { if (mutex_lock_interruptible(&d->usb_mutex) < 0) {
err("could not acquire lock"); err("could not acquire lock");
return 0; return -EINTR;
} }
st->buf[0] = REQUEST_SET_CLOCK; st->buf[0] = REQUEST_SET_CLOCK;
...@@ -401,7 +403,7 @@ int dib0700_set_i2c_speed(struct dvb_usb_device *d, u16 scl_kHz) ...@@ -401,7 +403,7 @@ int dib0700_set_i2c_speed(struct dvb_usb_device *d, u16 scl_kHz)
if (mutex_lock_interruptible(&d->usb_mutex) < 0) { if (mutex_lock_interruptible(&d->usb_mutex) < 0) {
err("could not acquire lock"); err("could not acquire lock");
return 0; return -EINTR;
} }
st->buf[0] = REQUEST_SET_I2C_PARAM; st->buf[0] = REQUEST_SET_I2C_PARAM;
...@@ -561,7 +563,7 @@ int dib0700_streaming_ctrl(struct dvb_usb_adapter *adap, int onoff) ...@@ -561,7 +563,7 @@ int dib0700_streaming_ctrl(struct dvb_usb_adapter *adap, int onoff)
if (mutex_lock_interruptible(&adap->dev->usb_mutex) < 0) { if (mutex_lock_interruptible(&adap->dev->usb_mutex) < 0) {
err("could not acquire lock"); err("could not acquire lock");
return 0; return -EINTR;
} }
st->buf[0] = REQUEST_ENABLE_VIDEO; st->buf[0] = REQUEST_ENABLE_VIDEO;
...@@ -611,7 +613,7 @@ int dib0700_change_protocol(struct rc_dev *rc, u64 rc_type) ...@@ -611,7 +613,7 @@ int dib0700_change_protocol(struct rc_dev *rc, u64 rc_type)
if (mutex_lock_interruptible(&d->usb_mutex) < 0) { if (mutex_lock_interruptible(&d->usb_mutex) < 0) {
err("could not acquire lock"); err("could not acquire lock");
return 0; return -EINTR;
} }
st->buf[0] = REQUEST_SET_RC; st->buf[0] = REQUEST_SET_RC;
......
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