提交 27a90695 编写于 作者: K Ksenija Stanojevic 提交者: Greg Kroah-Hartman

Staging: comedi: Use mutex instead of semaphore in usbduxfast.c

Replace binary semaphore with mutex because mutex gives better
performance.
This change is safe because the thread that decrements the value of semaphore
is also the one that increments it, and acts like a mutex where owner of the
lock is the only one that can release the lock.
Signed-off-by: NKsenija Stanojevic <ksenija.stanojevic@gmail.com>
Reviewed-by: NArnd Bergmann <arnd@arndb.de>
Signed-off-by: NGreg Kroah-Hartman <gregkh@linuxfoundation.org>
上级 1e5cae2f
...@@ -160,7 +160,7 @@ struct usbduxfast_private { ...@@ -160,7 +160,7 @@ struct usbduxfast_private {
s8 *inbuf; s8 *inbuf;
short int ai_cmd_running; /* asynchronous command is running */ short int ai_cmd_running; /* asynchronous command is running */
int ignore; /* counter which ignores the first buffers */ int ignore; /* counter which ignores the first buffers */
struct semaphore sem; struct mutex mut;
}; };
/* /*
...@@ -221,9 +221,9 @@ static int usbduxfast_ai_cancel(struct comedi_device *dev, ...@@ -221,9 +221,9 @@ static int usbduxfast_ai_cancel(struct comedi_device *dev,
struct usbduxfast_private *devpriv = dev->private; struct usbduxfast_private *devpriv = dev->private;
int ret; int ret;
down(&devpriv->sem); mutex_lock(&devpriv->mut);
ret = usbduxfast_ai_stop(dev, 1); ret = usbduxfast_ai_stop(dev, 1);
up(&devpriv->sem); mutex_unlock(&devpriv->mut);
return ret; return ret;
} }
...@@ -444,7 +444,7 @@ static int usbduxfast_ai_inttrig(struct comedi_device *dev, ...@@ -444,7 +444,7 @@ static int usbduxfast_ai_inttrig(struct comedi_device *dev,
if (trig_num != cmd->start_arg) if (trig_num != cmd->start_arg)
return -EINVAL; return -EINVAL;
down(&devpriv->sem); mutex_lock(&devpriv->mut);
if (!devpriv->ai_cmd_running) { if (!devpriv->ai_cmd_running) {
devpriv->ai_cmd_running = 1; devpriv->ai_cmd_running = 1;
...@@ -452,14 +452,14 @@ static int usbduxfast_ai_inttrig(struct comedi_device *dev, ...@@ -452,14 +452,14 @@ static int usbduxfast_ai_inttrig(struct comedi_device *dev,
if (ret < 0) { if (ret < 0) {
dev_err(dev->class_dev, "urbSubmit: err=%d\n", ret); dev_err(dev->class_dev, "urbSubmit: err=%d\n", ret);
devpriv->ai_cmd_running = 0; devpriv->ai_cmd_running = 0;
up(&devpriv->sem); mutex_unlock(&devpriv->mut);
return ret; return ret;
} }
s->async->inttrig = NULL; s->async->inttrig = NULL;
} else { } else {
dev_err(dev->class_dev, "ai is already running\n"); dev_err(dev->class_dev, "ai is already running\n");
} }
up(&devpriv->sem); mutex_unlock(&devpriv->mut);
return 1; return 1;
} }
...@@ -472,7 +472,7 @@ static int usbduxfast_ai_cmd(struct comedi_device *dev, ...@@ -472,7 +472,7 @@ static int usbduxfast_ai_cmd(struct comedi_device *dev,
int j, ret; int j, ret;
long steps, steps_tmp; long steps, steps_tmp;
down(&devpriv->sem); mutex_lock(&devpriv->mut);
if (devpriv->ai_cmd_running) { if (devpriv->ai_cmd_running) {
ret = -EBUSY; ret = -EBUSY;
goto cmd_exit; goto cmd_exit;
...@@ -751,7 +751,7 @@ static int usbduxfast_ai_cmd(struct comedi_device *dev, ...@@ -751,7 +751,7 @@ static int usbduxfast_ai_cmd(struct comedi_device *dev,
} }
cmd_exit: cmd_exit:
up(&devpriv->sem); mutex_unlock(&devpriv->mut);
return ret; return ret;
} }
...@@ -772,12 +772,12 @@ static int usbduxfast_ai_insn_read(struct comedi_device *dev, ...@@ -772,12 +772,12 @@ static int usbduxfast_ai_insn_read(struct comedi_device *dev,
int i, j, n, actual_length; int i, j, n, actual_length;
int ret; int ret;
down(&devpriv->sem); mutex_lock(&devpriv->mut);
if (devpriv->ai_cmd_running) { if (devpriv->ai_cmd_running) {
dev_err(dev->class_dev, dev_err(dev->class_dev,
"ai_insn_read not possible, async cmd is running\n"); "ai_insn_read not possible, async cmd is running\n");
up(&devpriv->sem); mutex_unlock(&devpriv->mut);
return -EBUSY; return -EBUSY;
} }
...@@ -799,7 +799,7 @@ static int usbduxfast_ai_insn_read(struct comedi_device *dev, ...@@ -799,7 +799,7 @@ static int usbduxfast_ai_insn_read(struct comedi_device *dev,
ret = usbduxfast_send_cmd(dev, SENDADCOMMANDS); ret = usbduxfast_send_cmd(dev, SENDADCOMMANDS);
if (ret < 0) { if (ret < 0) {
up(&devpriv->sem); mutex_unlock(&devpriv->mut);
return ret; return ret;
} }
...@@ -809,7 +809,7 @@ static int usbduxfast_ai_insn_read(struct comedi_device *dev, ...@@ -809,7 +809,7 @@ static int usbduxfast_ai_insn_read(struct comedi_device *dev,
&actual_length, 10000); &actual_length, 10000);
if (ret < 0) { if (ret < 0) {
dev_err(dev->class_dev, "insn timeout, no data\n"); dev_err(dev->class_dev, "insn timeout, no data\n");
up(&devpriv->sem); mutex_unlock(&devpriv->mut);
return ret; return ret;
} }
} }
...@@ -820,13 +820,13 @@ static int usbduxfast_ai_insn_read(struct comedi_device *dev, ...@@ -820,13 +820,13 @@ static int usbduxfast_ai_insn_read(struct comedi_device *dev,
&actual_length, 10000); &actual_length, 10000);
if (ret < 0) { if (ret < 0) {
dev_err(dev->class_dev, "insn data error: %d\n", ret); dev_err(dev->class_dev, "insn data error: %d\n", ret);
up(&devpriv->sem); mutex_unlock(&devpriv->mut);
return ret; return ret;
} }
n = actual_length / sizeof(u16); n = actual_length / sizeof(u16);
if ((n % 16) != 0) { if ((n % 16) != 0) {
dev_err(dev->class_dev, "insn data packet corrupted\n"); dev_err(dev->class_dev, "insn data packet corrupted\n");
up(&devpriv->sem); mutex_unlock(&devpriv->mut);
return -EINVAL; return -EINVAL;
} }
for (j = chan; (j < n) && (i < insn->n); j = j + 16) { for (j = chan; (j < n) && (i < insn->n); j = j + 16) {
...@@ -835,7 +835,7 @@ static int usbduxfast_ai_insn_read(struct comedi_device *dev, ...@@ -835,7 +835,7 @@ static int usbduxfast_ai_insn_read(struct comedi_device *dev,
} }
} }
up(&devpriv->sem); mutex_unlock(&devpriv->mut);
return insn->n; return insn->n;
} }
...@@ -930,7 +930,7 @@ static int usbduxfast_auto_attach(struct comedi_device *dev, ...@@ -930,7 +930,7 @@ static int usbduxfast_auto_attach(struct comedi_device *dev,
if (!devpriv) if (!devpriv)
return -ENOMEM; return -ENOMEM;
sema_init(&devpriv->sem, 1); mutex_init(&devpriv->mut);
usb_set_intfdata(intf, devpriv); usb_set_intfdata(intf, devpriv);
devpriv->duxbuf = kmalloc(SIZEOFDUXBUF, GFP_KERNEL); devpriv->duxbuf = kmalloc(SIZEOFDUXBUF, GFP_KERNEL);
...@@ -989,7 +989,7 @@ static void usbduxfast_detach(struct comedi_device *dev) ...@@ -989,7 +989,7 @@ static void usbduxfast_detach(struct comedi_device *dev)
if (!devpriv) if (!devpriv)
return; return;
down(&devpriv->sem); mutex_lock(&devpriv->mut);
usb_set_intfdata(intf, NULL); usb_set_intfdata(intf, NULL);
...@@ -1003,7 +1003,7 @@ static void usbduxfast_detach(struct comedi_device *dev) ...@@ -1003,7 +1003,7 @@ static void usbduxfast_detach(struct comedi_device *dev)
kfree(devpriv->duxbuf); kfree(devpriv->duxbuf);
up(&devpriv->sem); mutex_unlock(&devpriv->mut);
} }
static struct comedi_driver usbduxfast_driver = { static struct comedi_driver usbduxfast_driver = {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册