op_modifier);
else {
int ret;
- read_lock(&mlx4_priv(dev)->cmd.switch_lock);
+ down_read(&mlx4_priv(dev)->cmd.switch_sem);
if (mlx4_priv(dev)->cmd.use_events)
ret = mlx4_cmd_wait(dev, in_param, out_param,
out_is_imm, in_modifier,
ret = mlx4_cmd_poll(dev, in_param, out_param,
out_is_imm, in_modifier,
op_modifier, op, timeout);
- read_unlock(&mlx4_priv(dev)->cmd.switch_lock);
+ up_read(&mlx4_priv(dev)->cmd.switch_sem);
return ret;
}
}
int flags = 0;
if (!priv->cmd.initialized) {
- rwlock_init(&priv->cmd.switch_lock);
+ init_rwsem(&priv->cmd.switch_sem);
mutex_init(&priv->cmd.slave_cmd_mutex);
sema_init(&priv->cmd.poll_sem, 1);
priv->cmd.use_events = 0;
if (!priv->cmd.context)
return -ENOMEM;
- write_lock(&priv->cmd.switch_lock);
+ down_write(&priv->cmd.switch_sem);
for (i = 0; i < priv->cmd.max_cmds; ++i) {
priv->cmd.context[i].token = i;
priv->cmd.context[i].next = i + 1;
down(&priv->cmd.poll_sem);
priv->cmd.use_events = 1;
- write_unlock(&priv->cmd.switch_lock);
+ up_write(&priv->cmd.switch_sem);
return err;
}
struct mlx4_priv *priv = mlx4_priv(dev);
int i;
- write_lock(&priv->cmd.switch_lock);
+ down_write(&priv->cmd.switch_sem);
priv->cmd.use_events = 0;
for (i = 0; i < priv->cmd.max_cmds; ++i)
kfree(priv->cmd.context);
up(&priv->cmd.poll_sem);
- write_unlock(&priv->cmd.switch_lock);
+ up_write(&priv->cmd.switch_sem);
}
struct mlx4_cmd_mailbox *mlx4_alloc_cmd_mailbox(struct mlx4_dev *dev)
#include <linux/workqueue.h>
#include <linux/interrupt.h>
#include <linux/spinlock.h>
+#include <linux/rwsem.h>
#include <linux/mlx4/device.h>
#include <linux/mlx4/driver.h>
struct mutex slave_cmd_mutex;
struct semaphore poll_sem;
struct semaphore event_sem;
- rwlock_t switch_lock;
+ struct rw_semaphore switch_sem;
int max_cmds;
spinlock_t context_lock;
int free_head;