Commit 96ab1ac1 authored by Dennis Dalessandro's avatar Dennis Dalessandro Committed by Doug Ledford

IB/qib: Use address handle in rdmavt and remove from qib

Original patch from Kamal Heib <kamalh@mellanox.com>, split
apart from original.

Remove AH from qib and use rdmavt version.
Reviewed-by: default avatarIra Weiny <ira.weiny@intel.com>
Signed-off-by: default avatarKamal Heib <kamalh@mellanox.com>
Signed-off-by: default avatarDennis Dalessandro <dennis.dalessandro@intel.com>
Signed-off-by: default avatarDoug Ledford <dledford@redhat.com>
parent 7c2e11fe
...@@ -5515,7 +5515,7 @@ static void try_7322_ipg(struct qib_pportdata *ppd) ...@@ -5515,7 +5515,7 @@ static void try_7322_ipg(struct qib_pportdata *ppd)
ret = PTR_ERR(ah); ret = PTR_ERR(ah);
else { else {
send_buf->ah = ah; send_buf->ah = ah;
ibp->smi_ah = to_iah(ah); ibp->smi_ah = ibah_to_rvtah(ah);
ret = 0; ret = 0;
} }
} else { } else {
......
...@@ -109,7 +109,7 @@ static void qib_send_trap(struct qib_ibport *ibp, void *data, unsigned len) ...@@ -109,7 +109,7 @@ static void qib_send_trap(struct qib_ibport *ibp, void *data, unsigned len)
ret = PTR_ERR(ah); ret = PTR_ERR(ah);
else { else {
send_buf->ah = ah; send_buf->ah = ah;
ibp->sm_ah = to_iah(ah); ibp->sm_ah = ibah_to_rvtah(ah);
ret = 0; ret = 0;
} }
} else } else
......
...@@ -439,7 +439,8 @@ static void clear_mr_refs(struct rvt_qp *qp, int clr_sends) ...@@ -439,7 +439,8 @@ static void clear_mr_refs(struct rvt_qp *qp, int clr_sends)
if (qp->ibqp.qp_type == IB_QPT_UD || if (qp->ibqp.qp_type == IB_QPT_UD ||
qp->ibqp.qp_type == IB_QPT_SMI || qp->ibqp.qp_type == IB_QPT_SMI ||
qp->ibqp.qp_type == IB_QPT_GSI) qp->ibqp.qp_type == IB_QPT_GSI)
atomic_dec(&to_iah(wqe->ud_wr.ah)->refcount); atomic_dec(
&ibah_to_rvtah(wqe->ud_wr.ah)->refcount);
if (++qp->s_last >= qp->s_size) if (++qp->s_last >= qp->s_size)
qp->s_last = 0; qp->s_last = 0;
} }
...@@ -596,7 +597,7 @@ int qib_modify_qp(struct ib_qp *ibqp, struct ib_qp_attr *attr, ...@@ -596,7 +597,7 @@ int qib_modify_qp(struct ib_qp *ibqp, struct ib_qp_attr *attr,
if (attr_mask & IB_QP_AV) { if (attr_mask & IB_QP_AV) {
if (attr->ah_attr.dlid >= be16_to_cpu(IB_MULTICAST_LID_BASE)) if (attr->ah_attr.dlid >= be16_to_cpu(IB_MULTICAST_LID_BASE))
goto inval; goto inval;
if (qib_check_ah(qp->ibqp.device, &attr->ah_attr)) if (rvt_check_ah(qp->ibqp.device, &attr->ah_attr))
goto inval; goto inval;
} }
...@@ -604,7 +605,7 @@ int qib_modify_qp(struct ib_qp *ibqp, struct ib_qp_attr *attr, ...@@ -604,7 +605,7 @@ int qib_modify_qp(struct ib_qp *ibqp, struct ib_qp_attr *attr,
if (attr->alt_ah_attr.dlid >= if (attr->alt_ah_attr.dlid >=
be16_to_cpu(IB_MULTICAST_LID_BASE)) be16_to_cpu(IB_MULTICAST_LID_BASE))
goto inval; goto inval;
if (qib_check_ah(qp->ibqp.device, &attr->alt_ah_attr)) if (rvt_check_ah(qp->ibqp.device, &attr->alt_ah_attr))
goto inval; goto inval;
if (attr->alt_pkey_index >= qib_get_npkeys(dd_from_dev(dev))) if (attr->alt_pkey_index >= qib_get_npkeys(dd_from_dev(dev)))
goto inval; goto inval;
......
...@@ -789,7 +789,7 @@ void qib_send_complete(struct rvt_qp *qp, struct rvt_swqe *wqe, ...@@ -789,7 +789,7 @@ void qib_send_complete(struct rvt_qp *qp, struct rvt_swqe *wqe,
if (qp->ibqp.qp_type == IB_QPT_UD || if (qp->ibqp.qp_type == IB_QPT_UD ||
qp->ibqp.qp_type == IB_QPT_SMI || qp->ibqp.qp_type == IB_QPT_SMI ||
qp->ibqp.qp_type == IB_QPT_GSI) qp->ibqp.qp_type == IB_QPT_GSI)
atomic_dec(&to_iah(wqe->ud_wr.ah)->refcount); atomic_dec(&ibah_to_rvtah(wqe->ud_wr.ah)->refcount);
/* See ch. 11.2.4.1 and 10.7.3.1 */ /* See ch. 11.2.4.1 and 10.7.3.1 */
if (!(qp->s_flags & QIB_S_SIGNAL_REQ_WR) || if (!(qp->s_flags & QIB_S_SIGNAL_REQ_WR) ||
......
...@@ -77,7 +77,7 @@ static void qib_ud_loopback(struct rvt_qp *sqp, struct rvt_swqe *swqe) ...@@ -77,7 +77,7 @@ static void qib_ud_loopback(struct rvt_qp *sqp, struct rvt_swqe *swqe)
goto drop; goto drop;
} }
ah_attr = &to_iah(swqe->ud_wr.ah)->attr; ah_attr = &ibah_to_rvtah(swqe->ud_wr.ah)->attr;
ppd = ppd_from_ibp(ibp); ppd = ppd_from_ibp(ibp);
if (qp->ibqp.qp_num > 1) { if (qp->ibqp.qp_num > 1) {
...@@ -279,7 +279,7 @@ int qib_make_ud_req(struct rvt_qp *qp) ...@@ -279,7 +279,7 @@ int qib_make_ud_req(struct rvt_qp *qp)
/* Construct the header. */ /* Construct the header. */
ibp = to_iport(qp->ibqp.device, qp->port_num); ibp = to_iport(qp->ibqp.device, qp->port_num);
ppd = ppd_from_ibp(ibp); ppd = ppd_from_ibp(ibp);
ah_attr = &to_iah(wqe->ud_wr.ah)->attr; ah_attr = &ibah_to_rvtah(wqe->ud_wr.ah)->attr;
if (ah_attr->dlid >= be16_to_cpu(IB_MULTICAST_LID_BASE)) { if (ah_attr->dlid >= be16_to_cpu(IB_MULTICAST_LID_BASE)) {
if (ah_attr->dlid != be16_to_cpu(IB_LID_PERMISSIVE)) if (ah_attr->dlid != be16_to_cpu(IB_LID_PERMISSIVE))
this_cpu_inc(ibp->pmastats->n_multicast_xmit); this_cpu_inc(ibp->pmastats->n_multicast_xmit);
......
...@@ -443,7 +443,7 @@ static int qib_post_one_send(struct rvt_qp *qp, struct ib_send_wr *wr, ...@@ -443,7 +443,7 @@ static int qib_post_one_send(struct rvt_qp *qp, struct ib_send_wr *wr,
qp->port_num - 1)->ibmtu) { qp->port_num - 1)->ibmtu) {
goto bail_inval_free; goto bail_inval_free;
} else { } else {
atomic_inc(&to_iah(ud_wr(wr)->ah)->refcount); atomic_inc(&ibah_to_rvtah(ud_wr(wr)->ah)->refcount);
avoid_schedule = 1; avoid_schedule = 1;
} }
wqe->ssn = qp->s_ssn++; wqe->ssn = qp->s_ssn++;
...@@ -1771,74 +1771,10 @@ static int qib_query_gid(struct ib_device *ibdev, u8 port, ...@@ -1771,74 +1771,10 @@ static int qib_query_gid(struct ib_device *ibdev, u8 port,
int qib_check_ah(struct ib_device *ibdev, struct ib_ah_attr *ah_attr) int qib_check_ah(struct ib_device *ibdev, struct ib_ah_attr *ah_attr)
{ {
/* A multicast address requires a GRH (see ch. 8.4.1). */
if (ah_attr->dlid >= be16_to_cpu(IB_MULTICAST_LID_BASE) &&
ah_attr->dlid != be16_to_cpu(IB_LID_PERMISSIVE) &&
!(ah_attr->ah_flags & IB_AH_GRH))
goto bail;
if ((ah_attr->ah_flags & IB_AH_GRH) &&
ah_attr->grh.sgid_index >= QIB_GUIDS_PER_PORT)
goto bail;
if (ah_attr->dlid == 0)
goto bail;
if (ah_attr->port_num < 1 ||
ah_attr->port_num > ibdev->phys_port_cnt)
goto bail;
if (ah_attr->static_rate != IB_RATE_PORT_CURRENT &&
ib_rate_to_mult(ah_attr->static_rate) < 0)
goto bail;
if (ah_attr->sl > 15) if (ah_attr->sl > 15)
goto bail;
return 0;
bail:
return -EINVAL; return -EINVAL;
}
/**
* qib_create_ah - create an address handle
* @pd: the protection domain
* @ah_attr: the attributes of the AH
*
* This may be called from interrupt context.
*/
static struct ib_ah *qib_create_ah(struct ib_pd *pd,
struct ib_ah_attr *ah_attr)
{
struct qib_ah *ah;
struct ib_ah *ret;
struct qib_ibdev *dev = to_idev(pd->device);
unsigned long flags;
if (qib_check_ah(pd->device, ah_attr)) {
ret = ERR_PTR(-EINVAL);
goto bail;
}
ah = kmalloc(sizeof(*ah), GFP_ATOMIC);
if (!ah) {
ret = ERR_PTR(-ENOMEM);
goto bail;
}
spin_lock_irqsave(&dev->n_ahs_lock, flags);
if (dev->n_ahs_allocated == ib_qib_max_ahs) {
spin_unlock_irqrestore(&dev->n_ahs_lock, flags);
kfree(ah);
ret = ERR_PTR(-ENOMEM);
goto bail;
}
dev->n_ahs_allocated++;
spin_unlock_irqrestore(&dev->n_ahs_lock, flags);
/* ib_create_ah() will initialize ah->ibah. */
ah->attr = *ah_attr;
atomic_set(&ah->refcount, 0);
ret = &ah->ibah;
bail: return 0;
return ret;
} }
struct ib_ah *qib_create_qp0_ah(struct qib_ibport *ibp, u16 dlid) struct ib_ah *qib_create_qp0_ah(struct qib_ibport *ibp, u16 dlid)
...@@ -1858,51 +1794,6 @@ struct ib_ah *qib_create_qp0_ah(struct qib_ibport *ibp, u16 dlid) ...@@ -1858,51 +1794,6 @@ struct ib_ah *qib_create_qp0_ah(struct qib_ibport *ibp, u16 dlid)
return ah; return ah;
} }
/**
* qib_destroy_ah - destroy an address handle
* @ibah: the AH to destroy
*
* This may be called from interrupt context.
*/
static int qib_destroy_ah(struct ib_ah *ibah)
{
struct qib_ibdev *dev = to_idev(ibah->device);
struct qib_ah *ah = to_iah(ibah);
unsigned long flags;
if (atomic_read(&ah->refcount) != 0)
return -EBUSY;
spin_lock_irqsave(&dev->n_ahs_lock, flags);
dev->n_ahs_allocated--;
spin_unlock_irqrestore(&dev->n_ahs_lock, flags);
kfree(ah);
return 0;
}
static int qib_modify_ah(struct ib_ah *ibah, struct ib_ah_attr *ah_attr)
{
struct qib_ah *ah = to_iah(ibah);
if (qib_check_ah(ibah->device, ah_attr))
return -EINVAL;
ah->attr = *ah_attr;
return 0;
}
static int qib_query_ah(struct ib_ah *ibah, struct ib_ah_attr *ah_attr)
{
struct qib_ah *ah = to_iah(ibah);
*ah_attr = ah->attr;
return 0;
}
/** /**
* qib_get_npkeys - return the size of the PKEY table for context 0 * qib_get_npkeys - return the size of the PKEY table for context 0
* @dd: the qlogic_ib device * @dd: the qlogic_ib device
...@@ -2073,7 +1964,6 @@ int qib_register_ib_device(struct qib_devdata *dd) ...@@ -2073,7 +1964,6 @@ int qib_register_ib_device(struct qib_devdata *dd)
/* Only need to initialize non-zero fields. */ /* Only need to initialize non-zero fields. */
spin_lock_init(&dev->qpt_lock); spin_lock_init(&dev->qpt_lock);
spin_lock_init(&dev->n_ahs_lock);
spin_lock_init(&dev->n_cqs_lock); spin_lock_init(&dev->n_cqs_lock);
spin_lock_init(&dev->n_qps_lock); spin_lock_init(&dev->n_qps_lock);
spin_lock_init(&dev->n_srqs_lock); spin_lock_init(&dev->n_srqs_lock);
...@@ -2175,10 +2065,10 @@ int qib_register_ib_device(struct qib_devdata *dd) ...@@ -2175,10 +2065,10 @@ int qib_register_ib_device(struct qib_devdata *dd)
ibdev->dealloc_ucontext = qib_dealloc_ucontext; ibdev->dealloc_ucontext = qib_dealloc_ucontext;
ibdev->alloc_pd = NULL; ibdev->alloc_pd = NULL;
ibdev->dealloc_pd = NULL; ibdev->dealloc_pd = NULL;
ibdev->create_ah = qib_create_ah; ibdev->create_ah = NULL;
ibdev->destroy_ah = qib_destroy_ah; ibdev->destroy_ah = NULL;
ibdev->modify_ah = qib_modify_ah; ibdev->modify_ah = NULL;
ibdev->query_ah = qib_query_ah; ibdev->query_ah = NULL;
ibdev->create_srq = qib_create_srq; ibdev->create_srq = qib_create_srq;
ibdev->modify_srq = qib_modify_srq; ibdev->modify_srq = qib_modify_srq;
ibdev->query_srq = qib_query_srq; ibdev->query_srq = qib_query_srq;
...@@ -2220,7 +2110,9 @@ int qib_register_ib_device(struct qib_devdata *dd) ...@@ -2220,7 +2110,9 @@ int qib_register_ib_device(struct qib_devdata *dd)
dd->verbs_dev.rdi.driver_f.port_callback = qib_create_port_files; dd->verbs_dev.rdi.driver_f.port_callback = qib_create_port_files;
dd->verbs_dev.rdi.driver_f.get_card_name = qib_get_card_name; dd->verbs_dev.rdi.driver_f.get_card_name = qib_get_card_name;
dd->verbs_dev.rdi.driver_f.get_pci_dev = qib_get_pci_dev; dd->verbs_dev.rdi.driver_f.get_pci_dev = qib_get_pci_dev;
dd->verbs_dev.rdi.driver_f.check_ah = qib_check_ah;
dd->verbs_dev.rdi.dparms.props.max_pd = ib_qib_max_pds; dd->verbs_dev.rdi.dparms.props.max_pd = ib_qib_max_pds;
dd->verbs_dev.rdi.dparms.props.max_ah = ib_qib_max_ahs;
dd->verbs_dev.rdi.flags = (RVT_FLAG_QP_INIT_DRIVER | dd->verbs_dev.rdi.flags = (RVT_FLAG_QP_INIT_DRIVER |
RVT_FLAG_CQ_INIT_DRIVER); RVT_FLAG_CQ_INIT_DRIVER);
dd->verbs_dev.rdi.dparms.lkey_table_size = qib_lkey_table_size; dd->verbs_dev.rdi.dparms.lkey_table_size = qib_lkey_table_size;
......
...@@ -222,13 +222,6 @@ struct qib_mcast { ...@@ -222,13 +222,6 @@ struct qib_mcast {
int n_attached; int n_attached;
}; };
/* Address Handle */
struct qib_ah {
struct ib_ah ibah;
struct ib_ah_attr attr;
atomic_t refcount;
};
/* /*
* This structure is used to contain the head pointer, tail pointer, * This structure is used to contain the head pointer, tail pointer,
* and completion queue entries as a single memory allocation so * and completion queue entries as a single memory allocation so
...@@ -419,8 +412,8 @@ struct qib_ibport { ...@@ -419,8 +412,8 @@ struct qib_ibport {
struct rvt_qp __rcu *qp0; struct rvt_qp __rcu *qp0;
struct rvt_qp __rcu *qp1; struct rvt_qp __rcu *qp1;
struct ib_mad_agent *send_agent; /* agent for SMI (traps) */ struct ib_mad_agent *send_agent; /* agent for SMI (traps) */
struct qib_ah *sm_ah; struct rvt_ah *sm_ah;
struct qib_ah *smi_ah; struct rvt_ah *smi_ah;
struct rb_root mcast_tree; struct rb_root mcast_tree;
spinlock_t lock; /* protect changes in this struct */ spinlock_t lock; /* protect changes in this struct */
...@@ -511,10 +504,6 @@ struct qib_ibdev { ...@@ -511,10 +504,6 @@ struct qib_ibdev {
u32 n_piowait; u32 n_piowait;
u32 n_txwait; u32 n_txwait;
u32 n_pds_allocated; /* number of PDs allocated for device */
spinlock_t n_pds_lock;
u32 n_ahs_allocated; /* number of AHs allocated for device */
spinlock_t n_ahs_lock;
u32 n_cqs_allocated; /* number of CQs allocated for device */ u32 n_cqs_allocated; /* number of CQs allocated for device */
spinlock_t n_cqs_lock; spinlock_t n_cqs_lock;
u32 n_qps_allocated; /* number of QPs allocated for device */ u32 n_qps_allocated; /* number of QPs allocated for device */
...@@ -545,11 +534,6 @@ struct qib_verbs_counters { ...@@ -545,11 +534,6 @@ struct qib_verbs_counters {
u32 vl15_dropped; u32 vl15_dropped;
}; };
static inline struct qib_ah *to_iah(struct ib_ah *ibah)
{
return container_of(ibah, struct qib_ah, ibah);
}
static inline struct qib_cq *to_icq(struct ib_cq *ibcq) static inline struct qib_cq *to_icq(struct ib_cq *ibcq)
{ {
return container_of(ibcq, struct qib_cq, ibcq); return container_of(ibcq, struct qib_cq, ibcq);
......
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