Commit acbb67d5 authored by Linus Torvalds's avatar Linus Torvalds

Merge branch 'for-linus' of git://git.kernel.org/pub/scm/linux/kernel/git/roland/infiniband

* 'for-linus' of git://git.kernel.org/pub/scm/linux/kernel/git/roland/infiniband:
  IB/mthca: Use mmiowb after doorbell ring
  IB/ipath: Initialize diagpkt file on device init only
  RDMA/amso1100: Fix a NULL dereference in error path
  RDMA/amso1100: pci_module_init() conversion
parents 22a60f19 1f5c23e2
...@@ -1243,7 +1243,7 @@ static struct pci_driver c2_pci_driver = { ...@@ -1243,7 +1243,7 @@ static struct pci_driver c2_pci_driver = {
static int __init c2_init_module(void) static int __init c2_init_module(void)
{ {
return pci_module_init(&c2_pci_driver); return pci_register_driver(&c2_pci_driver);
} }
static void __exit c2_exit_module(void) static void __exit c2_exit_module(void)
......
...@@ -150,8 +150,8 @@ static int c2_rnic_query(struct c2_dev *c2dev, struct ib_device_attr *props) ...@@ -150,8 +150,8 @@ static int c2_rnic_query(struct c2_dev *c2dev, struct ib_device_attr *props)
(struct c2wr_rnic_query_rep *) (unsigned long) (vq_req->reply_msg); (struct c2wr_rnic_query_rep *) (unsigned long) (vq_req->reply_msg);
if (!reply) if (!reply)
err = -ENOMEM; err = -ENOMEM;
else
err = c2_errno(reply); err = c2_errno(reply);
if (err) if (err)
goto bail2; goto bail2;
......
...@@ -67,19 +67,54 @@ static struct file_operations diag_file_ops = { ...@@ -67,19 +67,54 @@ static struct file_operations diag_file_ops = {
.release = ipath_diag_release .release = ipath_diag_release
}; };
static ssize_t ipath_diagpkt_write(struct file *fp,
const char __user *data,
size_t count, loff_t *off);
static struct file_operations diagpkt_file_ops = {
.owner = THIS_MODULE,
.write = ipath_diagpkt_write,
};
static atomic_t diagpkt_count = ATOMIC_INIT(0);
static struct cdev *diagpkt_cdev;
static struct class_device *diagpkt_class_dev;
int ipath_diag_add(struct ipath_devdata *dd) int ipath_diag_add(struct ipath_devdata *dd)
{ {
char name[16]; char name[16];
int ret = 0;
if (atomic_inc_return(&diagpkt_count) == 1) {
ret = ipath_cdev_init(IPATH_DIAGPKT_MINOR,
"ipath_diagpkt", &diagpkt_file_ops,
&diagpkt_cdev, &diagpkt_class_dev);
if (ret) {
ipath_dev_err(dd, "Couldn't create ipath_diagpkt "
"device: %d", ret);
goto done;
}
}
snprintf(name, sizeof(name), "ipath_diag%d", dd->ipath_unit); snprintf(name, sizeof(name), "ipath_diag%d", dd->ipath_unit);
return ipath_cdev_init(IPATH_DIAG_MINOR_BASE + dd->ipath_unit, name, ret = ipath_cdev_init(IPATH_DIAG_MINOR_BASE + dd->ipath_unit, name,
&diag_file_ops, &dd->diag_cdev, &diag_file_ops, &dd->diag_cdev,
&dd->diag_class_dev); &dd->diag_class_dev);
if (ret)
ipath_dev_err(dd, "Couldn't create %s device: %d",
name, ret);
done:
return ret;
} }
void ipath_diag_remove(struct ipath_devdata *dd) void ipath_diag_remove(struct ipath_devdata *dd)
{ {
if (atomic_dec_and_test(&diagpkt_count))
ipath_cdev_cleanup(&diagpkt_cdev, &diagpkt_class_dev);
ipath_cdev_cleanup(&dd->diag_cdev, &dd->diag_class_dev); ipath_cdev_cleanup(&dd->diag_cdev, &dd->diag_class_dev);
} }
...@@ -275,30 +310,6 @@ bail: ...@@ -275,30 +310,6 @@ bail:
return ret; return ret;
} }
static ssize_t ipath_diagpkt_write(struct file *fp,
const char __user *data,
size_t count, loff_t *off);
static struct file_operations diagpkt_file_ops = {
.owner = THIS_MODULE,
.write = ipath_diagpkt_write,
};
static struct cdev *diagpkt_cdev;
static struct class_device *diagpkt_class_dev;
int __init ipath_diagpkt_add(void)
{
return ipath_cdev_init(IPATH_DIAGPKT_MINOR,
"ipath_diagpkt", &diagpkt_file_ops,
&diagpkt_cdev, &diagpkt_class_dev);
}
void __exit ipath_diagpkt_remove(void)
{
ipath_cdev_cleanup(&diagpkt_cdev, &diagpkt_class_dev);
}
/** /**
* ipath_diagpkt_write - write an IB packet * ipath_diagpkt_write - write an IB packet
* @fp: the diag data device file pointer * @fp: the diag data device file pointer
......
...@@ -2005,18 +2005,8 @@ static int __init infinipath_init(void) ...@@ -2005,18 +2005,8 @@ static int __init infinipath_init(void)
goto bail_group; goto bail_group;
} }
ret = ipath_diagpkt_add();
if (ret < 0) {
printk(KERN_ERR IPATH_DRV_NAME ": Unable to create "
"diag data device: error %d\n", -ret);
goto bail_ipathfs;
}
goto bail; goto bail;
bail_ipathfs:
ipath_exit_ipathfs();
bail_group: bail_group:
ipath_driver_remove_group(&ipath_driver.driver); ipath_driver_remove_group(&ipath_driver.driver);
......
...@@ -869,9 +869,6 @@ int ipath_device_create_group(struct device *, struct ipath_devdata *); ...@@ -869,9 +869,6 @@ int ipath_device_create_group(struct device *, struct ipath_devdata *);
void ipath_device_remove_group(struct device *, struct ipath_devdata *); void ipath_device_remove_group(struct device *, struct ipath_devdata *);
int ipath_expose_reset(struct device *); int ipath_expose_reset(struct device *);
int ipath_diagpkt_add(void);
void ipath_diagpkt_remove(void);
int ipath_init_ipathfs(void); int ipath_init_ipathfs(void);
void ipath_exit_ipathfs(void); void ipath_exit_ipathfs(void);
int ipathfs_add_device(struct ipath_devdata *); int ipathfs_add_device(struct ipath_devdata *);
......
...@@ -39,6 +39,8 @@ ...@@ -39,6 +39,8 @@
#include <linux/init.h> #include <linux/init.h>
#include <linux/hardirq.h> #include <linux/hardirq.h>
#include <asm/io.h>
#include <rdma/ib_pack.h> #include <rdma/ib_pack.h>
#include "mthca_dev.h" #include "mthca_dev.h"
...@@ -210,6 +212,11 @@ static inline void update_cons_index(struct mthca_dev *dev, struct mthca_cq *cq, ...@@ -210,6 +212,11 @@ static inline void update_cons_index(struct mthca_dev *dev, struct mthca_cq *cq,
mthca_write64(doorbell, mthca_write64(doorbell,
dev->kar + MTHCA_CQ_DOORBELL, dev->kar + MTHCA_CQ_DOORBELL,
MTHCA_GET_DOORBELL_LOCK(&dev->doorbell_lock)); MTHCA_GET_DOORBELL_LOCK(&dev->doorbell_lock));
/*
* Make sure doorbells don't leak out of CQ spinlock
* and reach the HCA out of order:
*/
mmiowb();
} }
} }
......
...@@ -39,6 +39,8 @@ ...@@ -39,6 +39,8 @@
#include <linux/string.h> #include <linux/string.h>
#include <linux/slab.h> #include <linux/slab.h>
#include <asm/io.h>
#include <rdma/ib_verbs.h> #include <rdma/ib_verbs.h>
#include <rdma/ib_cache.h> #include <rdma/ib_cache.h>
#include <rdma/ib_pack.h> #include <rdma/ib_pack.h>
...@@ -1732,6 +1734,11 @@ out: ...@@ -1732,6 +1734,11 @@ out:
mthca_write64(doorbell, mthca_write64(doorbell,
dev->kar + MTHCA_SEND_DOORBELL, dev->kar + MTHCA_SEND_DOORBELL,
MTHCA_GET_DOORBELL_LOCK(&dev->doorbell_lock)); MTHCA_GET_DOORBELL_LOCK(&dev->doorbell_lock));
/*
* Make sure doorbells don't leak out of SQ spinlock
* and reach the HCA out of order:
*/
mmiowb();
} }
qp->sq.next_ind = ind; qp->sq.next_ind = ind;
...@@ -1851,6 +1858,12 @@ out: ...@@ -1851,6 +1858,12 @@ out:
qp->rq.next_ind = ind; qp->rq.next_ind = ind;
qp->rq.head += nreq; qp->rq.head += nreq;
/*
* Make sure doorbells don't leak out of RQ spinlock and reach
* the HCA out of order:
*/
mmiowb();
spin_unlock_irqrestore(&qp->rq.lock, flags); spin_unlock_irqrestore(&qp->rq.lock, flags);
return err; return err;
} }
...@@ -2112,6 +2125,12 @@ out: ...@@ -2112,6 +2125,12 @@ out:
MTHCA_GET_DOORBELL_LOCK(&dev->doorbell_lock)); MTHCA_GET_DOORBELL_LOCK(&dev->doorbell_lock));
} }
/*
* Make sure doorbells don't leak out of SQ spinlock and reach
* the HCA out of order:
*/
mmiowb();
spin_unlock_irqrestore(&qp->sq.lock, flags); spin_unlock_irqrestore(&qp->sq.lock, flags);
return err; return err;
} }
......
...@@ -35,6 +35,8 @@ ...@@ -35,6 +35,8 @@
#include <linux/slab.h> #include <linux/slab.h>
#include <linux/string.h> #include <linux/string.h>
#include <asm/io.h>
#include "mthca_dev.h" #include "mthca_dev.h"
#include "mthca_cmd.h" #include "mthca_cmd.h"
#include "mthca_memfree.h" #include "mthca_memfree.h"
...@@ -595,6 +597,12 @@ int mthca_tavor_post_srq_recv(struct ib_srq *ibsrq, struct ib_recv_wr *wr, ...@@ -595,6 +597,12 @@ int mthca_tavor_post_srq_recv(struct ib_srq *ibsrq, struct ib_recv_wr *wr,
MTHCA_GET_DOORBELL_LOCK(&dev->doorbell_lock)); MTHCA_GET_DOORBELL_LOCK(&dev->doorbell_lock));
} }
/*
* Make sure doorbells don't leak out of SRQ spinlock and
* reach the HCA out of order:
*/
mmiowb();
spin_unlock_irqrestore(&srq->lock, flags); spin_unlock_irqrestore(&srq->lock, flags);
return err; return err;
} }
......
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