[openib-general] Re: [PATCH v2 2/2] iWARP Core Changes.
Tom Tucker
tom at opengridcomputing.com
Wed Jun 7 15:13:27 PDT 2006
A reference is being taken on an iWARP device that is never getting
released. This prevents a participating iWARP netdev device from being
unloaded after a connection has been established on the passive side.
Search for ip_dev_find below...
On Wed, 2006-06-07 at 15:06 -0500, Steve Wise wrote:
> This patch contains modifications to the existing rdma header files,
> core files, drivers, and ulp files to support iWARP.
>
> Review updates:
>
> - copy_addr() -> rdma_copy_addr()
>
> - dst_dev_addr param in rdma_copy_addr to const.
>
> - various spacing nits with recasting
>
> - include linux/inetdevice.h to get ip_dev_find() prototype.
> ---
>
> drivers/infiniband/core/Makefile | 4
> drivers/infiniband/core/addr.c | 19 +
> drivers/infiniband/core/cache.c | 8 -
> drivers/infiniband/core/cm.c | 3
> drivers/infiniband/core/cma.c | 353 +++++++++++++++++++++++---
> drivers/infiniband/core/device.c | 6
> drivers/infiniband/core/mad.c | 11 +
> drivers/infiniband/core/sa_query.c | 5
> drivers/infiniband/core/smi.c | 18 +
> drivers/infiniband/core/sysfs.c | 18 +
> drivers/infiniband/core/ucm.c | 5
> drivers/infiniband/core/user_mad.c | 9 -
> drivers/infiniband/hw/ipath/ipath_verbs.c | 2
> drivers/infiniband/hw/mthca/mthca_provider.c | 2
> drivers/infiniband/ulp/ipoib/ipoib_main.c | 8 +
> drivers/infiniband/ulp/srp/ib_srp.c | 2
> include/rdma/ib_addr.h | 15 +
> include/rdma/ib_verbs.h | 39 +++
> 18 files changed, 435 insertions(+), 92 deletions(-)
>
> diff --git a/drivers/infiniband/core/Makefile b/drivers/infiniband/core/Makefile
> index 68e73ec..163d991 100644
> --- a/drivers/infiniband/core/Makefile
> +++ b/drivers/infiniband/core/Makefile
> @@ -1,7 +1,7 @@
> infiniband-$(CONFIG_INFINIBAND_ADDR_TRANS) := ib_addr.o rdma_cm.o
>
> obj-$(CONFIG_INFINIBAND) += ib_core.o ib_mad.o ib_sa.o \
> - ib_cm.o $(infiniband-y)
> + ib_cm.o iw_cm.o $(infiniband-y)
> obj-$(CONFIG_INFINIBAND_USER_MAD) += ib_umad.o
> obj-$(CONFIG_INFINIBAND_USER_ACCESS) += ib_uverbs.o ib_ucm.o
>
> @@ -14,6 +14,8 @@ ib_sa-y := sa_query.o
>
> ib_cm-y := cm.o
>
> +iw_cm-y := iwcm.o
> +
> rdma_cm-y := cma.o
>
> ib_addr-y := addr.o
> diff --git a/drivers/infiniband/core/addr.c b/drivers/infiniband/core/addr.c
> index d294bbc..83f84ef 100644
> --- a/drivers/infiniband/core/addr.c
> +++ b/drivers/infiniband/core/addr.c
> @@ -32,6 +32,7 @@ #include <linux/mutex.h>
> #include <linux/inetdevice.h>
> #include <linux/workqueue.h>
> #include <linux/if_arp.h>
> +#include <linux/inetdevice.h>
> #include <net/arp.h>
> #include <net/neighbour.h>
> #include <net/route.h>
> @@ -60,12 +61,15 @@ static LIST_HEAD(req_list);
> static DECLARE_WORK(work, process_req, NULL);
> static struct workqueue_struct *addr_wq;
>
> -static int copy_addr(struct rdma_dev_addr *dev_addr, struct net_device *dev,
> - unsigned char *dst_dev_addr)
> +int rdma_copy_addr(struct rdma_dev_addr *dev_addr, struct net_device *dev,
> + const unsigned char *dst_dev_addr)
> {
> switch (dev->type) {
> case ARPHRD_INFINIBAND:
> - dev_addr->dev_type = IB_NODE_CA;
> + dev_addr->dev_type = RDMA_NODE_IB_CA;
> + break;
> + case ARPHRD_ETHER:
> + dev_addr->dev_type = RDMA_NODE_RNIC;
> break;
> default:
> return -EADDRNOTAVAIL;
> @@ -77,6 +81,7 @@ static int copy_addr(struct rdma_dev_add
> memcpy(dev_addr->dst_dev_addr, dst_dev_addr, MAX_ADDR_LEN);
> return 0;
> }
> +EXPORT_SYMBOL(rdma_copy_addr);
>
> int rdma_translate_ip(struct sockaddr *addr, struct rdma_dev_addr *dev_addr)
> {
> @@ -88,7 +93,7 @@ int rdma_translate_ip(struct sockaddr *a
> if (!dev)
> return -EADDRNOTAVAIL;
>
> - ret = copy_addr(dev_addr, dev, NULL);
> + ret = rdma_copy_addr(dev_addr, dev, NULL);
> dev_put(dev);
> return ret;
> }
> @@ -160,7 +165,7 @@ static int addr_resolve_remote(struct so
>
> /* If the device does ARP internally, return 'done' */
> if (rt->idev->dev->flags & IFF_NOARP) {
> - copy_addr(addr, rt->idev->dev, NULL);
> + rdma_copy_addr(addr, rt->idev->dev, NULL);
> goto put;
> }
>
> @@ -180,7 +185,7 @@ static int addr_resolve_remote(struct so
> src_in->sin_addr.s_addr = rt->rt_src;
> }
>
> - ret = copy_addr(addr, neigh->dev, neigh->ha);
> + ret = rdma_copy_addr(addr, neigh->dev, neigh->ha);
> release:
> neigh_release(neigh);
> put:
> @@ -244,7 +249,7 @@ static int addr_resolve_local(struct soc
> if (ZERONET(src_ip)) {
> src_in->sin_family = dst_in->sin_family;
> src_in->sin_addr.s_addr = dst_ip;
> - ret = copy_addr(addr, dev, dev->dev_addr);
> + ret = rdma_copy_addr(addr, dev, dev->dev_addr);
> } else if (LOOPBACK(src_ip)) {
> ret = rdma_translate_ip((struct sockaddr *)dst_in, addr);
> if (!ret)
> diff --git a/drivers/infiniband/core/cache.c b/drivers/infiniband/core/cache.c
> index e05ca2c..061858c 100644
> --- a/drivers/infiniband/core/cache.c
> +++ b/drivers/infiniband/core/cache.c
> @@ -32,13 +32,12 @@
> * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> * SOFTWARE.
> *
> - * $Id: cache.c 1349 2004-12-16 21:09:43Z roland $
> + * $Id: cache.c 6885 2006-05-03 18:22:02Z sean.hefty $
> */
>
> #include <linux/module.h>
> #include <linux/errno.h>
> #include <linux/slab.h>
> -#include <linux/sched.h> /* INIT_WORK, schedule_work(), flush_scheduled_work() */
>
> #include <rdma/ib_cache.h>
>
> @@ -62,12 +61,13 @@ struct ib_update_work {
>
> static inline int start_port(struct ib_device *device)
> {
> - return device->node_type == IB_NODE_SWITCH ? 0 : 1;
> + return (device->node_type == RDMA_NODE_IB_SWITCH) ? 0 : 1;
> }
>
> static inline int end_port(struct ib_device *device)
> {
> - return device->node_type == IB_NODE_SWITCH ? 0 : device->phys_port_cnt;
> + return (device->node_type == RDMA_NODE_IB_SWITCH) ?
> + 0 : device->phys_port_cnt;
> }
>
> int ib_get_cached_gid(struct ib_device *device,
> diff --git a/drivers/infiniband/core/cm.c b/drivers/infiniband/core/cm.c
> index 1c7463b..cf43ccb 100644
> --- a/drivers/infiniband/core/cm.c
> +++ b/drivers/infiniband/core/cm.c
> @@ -3253,6 +3253,9 @@ static void cm_add_one(struct ib_device
> int ret;
> u8 i;
>
> + if (rdma_node_get_transport(device->node_type) != RDMA_TRANSPORT_IB)
> + return;
> +
> cm_dev = kmalloc(sizeof(*cm_dev) + sizeof(*port) *
> device->phys_port_cnt, GFP_KERNEL);
> if (!cm_dev)
> diff --git a/drivers/infiniband/core/cma.c b/drivers/infiniband/core/cma.c
> index 94555d2..414600c 100644
> --- a/drivers/infiniband/core/cma.c
> +++ b/drivers/infiniband/core/cma.c
> @@ -35,6 +35,7 @@ #include <linux/in6.h>
> #include <linux/mutex.h>
> #include <linux/random.h>
> #include <linux/idr.h>
> +#include <linux/inetdevice.h>
>
> #include <net/tcp.h>
>
> @@ -43,6 +44,7 @@ #include <rdma/rdma_cm_ib.h>
> #include <rdma/ib_cache.h>
> #include <rdma/ib_cm.h>
> #include <rdma/ib_sa.h>
> +#include <rdma/iw_cm.h>
>
> MODULE_AUTHOR("Sean Hefty");
> MODULE_DESCRIPTION("Generic RDMA CM Agent");
> @@ -124,6 +126,7 @@ struct rdma_id_private {
> int query_id;
> union {
> struct ib_cm_id *ib;
> + struct iw_cm_id *iw;
> } cm_id;
>
> u32 seq_num;
> @@ -259,13 +262,23 @@ static void cma_detach_from_dev(struct r
> id_priv->cma_dev = NULL;
> }
>
> -static int cma_acquire_ib_dev(struct rdma_id_private *id_priv)
> +static int cma_acquire_dev(struct rdma_id_private *id_priv)
> {
> + enum rdma_node_type dev_type = id_priv->id.route.addr.dev_addr.dev_type;
> struct cma_device *cma_dev;
> union ib_gid *gid;
> int ret = -ENODEV;
>
> - gid = ib_addr_get_sgid(&id_priv->id.route.addr.dev_addr);
> + switch (rdma_node_get_transport(dev_type)) {
> + case RDMA_TRANSPORT_IB:
> + gid = ib_addr_get_sgid(&id_priv->id.route.addr.dev_addr);
> + break;
> + case RDMA_TRANSPORT_IWARP:
> + gid = iw_addr_get_sgid(&id_priv->id.route.addr.dev_addr);
> + break;
> + default:
> + return -ENODEV;
> + }
>
> mutex_lock(&lock);
> list_for_each_entry(cma_dev, &dev_list, list) {
> @@ -280,16 +293,6 @@ static int cma_acquire_ib_dev(struct rdm
> return ret;
> }
>
> -static int cma_acquire_dev(struct rdma_id_private *id_priv)
> -{
> - switch (id_priv->id.route.addr.dev_addr.dev_type) {
> - case IB_NODE_CA:
> - return cma_acquire_ib_dev(id_priv);
> - default:
> - return -ENODEV;
> - }
> -}
> -
> static void cma_deref_id(struct rdma_id_private *id_priv)
> {
> if (atomic_dec_and_test(&id_priv->refcount))
> @@ -347,6 +350,16 @@ static int cma_init_ib_qp(struct rdma_id
> IB_QP_PKEY_INDEX | IB_QP_PORT);
> }
>
> +static int cma_init_iw_qp(struct rdma_id_private *id_priv, struct ib_qp *qp)
> +{
> + struct ib_qp_attr qp_attr;
> +
> + qp_attr.qp_state = IB_QPS_INIT;
> + qp_attr.qp_access_flags = IB_ACCESS_LOCAL_WRITE;
> +
> + return ib_modify_qp(qp, &qp_attr, IB_QP_STATE | IB_QP_ACCESS_FLAGS);
> +}
> +
> int rdma_create_qp(struct rdma_cm_id *id, struct ib_pd *pd,
> struct ib_qp_init_attr *qp_init_attr)
> {
> @@ -362,10 +375,13 @@ int rdma_create_qp(struct rdma_cm_id *id
> if (IS_ERR(qp))
> return PTR_ERR(qp);
>
> - switch (id->device->node_type) {
> - case IB_NODE_CA:
> + switch (rdma_node_get_transport(id->device->node_type)) {
> + case RDMA_TRANSPORT_IB:
> ret = cma_init_ib_qp(id_priv, qp);
> break;
> + case RDMA_TRANSPORT_IWARP:
> + ret = cma_init_iw_qp(id_priv, qp);
> + break;
> default:
> ret = -ENOSYS;
> break;
> @@ -451,13 +467,17 @@ int rdma_init_qp_attr(struct rdma_cm_id
> int ret;
>
> id_priv = container_of(id, struct rdma_id_private, id);
> - switch (id_priv->id.device->node_type) {
> - case IB_NODE_CA:
> + switch (rdma_node_get_transport(id_priv->id.device->node_type)) {
> + case RDMA_TRANSPORT_IB:
> ret = ib_cm_init_qp_attr(id_priv->cm_id.ib, qp_attr,
> qp_attr_mask);
> if (qp_attr->qp_state == IB_QPS_RTR)
> qp_attr->rq_psn = id_priv->seq_num;
> break;
> + case RDMA_TRANSPORT_IWARP:
> + ret = iw_cm_init_qp_attr(id_priv->cm_id.iw, qp_attr,
> + qp_attr_mask);
> + break;
> default:
> ret = -ENOSYS;
> break;
> @@ -590,8 +610,8 @@ static int cma_notify_user(struct rdma_i
>
> static void cma_cancel_route(struct rdma_id_private *id_priv)
> {
> - switch (id_priv->id.device->node_type) {
> - case IB_NODE_CA:
> + switch (rdma_node_get_transport(id_priv->id.device->node_type)) {
> + case RDMA_TRANSPORT_IB:
> if (id_priv->query)
> ib_sa_cancel_query(id_priv->query_id, id_priv->query);
> break;
> @@ -611,11 +631,15 @@ static void cma_destroy_listen(struct rd
> cma_exch(id_priv, CMA_DESTROYING);
>
> if (id_priv->cma_dev) {
> - switch (id_priv->id.device->node_type) {
> - case IB_NODE_CA:
> + switch (rdma_node_get_transport(id_priv->id.device->node_type)) {
> + case RDMA_TRANSPORT_IB:
> if (id_priv->cm_id.ib && !IS_ERR(id_priv->cm_id.ib))
> ib_destroy_cm_id(id_priv->cm_id.ib);
> break;
> + case RDMA_TRANSPORT_IWARP:
> + if (id_priv->cm_id.iw && !IS_ERR(id_priv->cm_id.iw))
> + iw_destroy_cm_id(id_priv->cm_id.iw);
> + break;
> default:
> break;
> }
> @@ -690,11 +714,15 @@ void rdma_destroy_id(struct rdma_cm_id *
> cma_cancel_operation(id_priv, state);
>
> if (id_priv->cma_dev) {
> - switch (id->device->node_type) {
> - case IB_NODE_CA:
> + switch (rdma_node_get_transport(id->device->node_type)) {
> + case RDMA_TRANSPORT_IB:
> if (id_priv->cm_id.ib && !IS_ERR(id_priv->cm_id.ib))
> ib_destroy_cm_id(id_priv->cm_id.ib);
> break;
> + case RDMA_TRANSPORT_IWARP:
> + if (id_priv->cm_id.iw && !IS_ERR(id_priv->cm_id.iw))
> + iw_destroy_cm_id(id_priv->cm_id.iw);
> + break;
> default:
> break;
> }
> @@ -868,7 +896,7 @@ static struct rdma_id_private *cma_new_i
> ib_addr_set_sgid(&rt->addr.dev_addr, &rt->path_rec[0].sgid);
> ib_addr_set_dgid(&rt->addr.dev_addr, &rt->path_rec[0].dgid);
> ib_addr_set_pkey(&rt->addr.dev_addr, be16_to_cpu(rt->path_rec[0].pkey));
> - rt->addr.dev_addr.dev_type = IB_NODE_CA;
> + rt->addr.dev_addr.dev_type = RDMA_NODE_IB_CA;
>
> id_priv = container_of(id, struct rdma_id_private, id);
> id_priv->state = CMA_CONNECT;
> @@ -897,7 +925,7 @@ static int cma_req_handler(struct ib_cm_
> }
>
> atomic_inc(&conn_id->dev_remove);
> - ret = cma_acquire_ib_dev(conn_id);
> + ret = cma_acquire_dev(conn_id);
> if (ret) {
> ret = -ENODEV;
> cma_release_remove(conn_id);
> @@ -981,6 +1009,123 @@ static void cma_set_compare_data(enum rd
> }
> }
>
> +static int cma_iw_handler(struct iw_cm_id *iw_id, struct iw_cm_event *iw_event)
> +{
> + struct rdma_id_private *id_priv = iw_id->context;
> + enum rdma_cm_event_type event = 0;
> + struct sockaddr_in *sin;
> + int ret = 0;
> +
> + atomic_inc(&id_priv->dev_remove);
> +
> + switch (iw_event->event) {
> + case IW_CM_EVENT_CLOSE:
> + event = RDMA_CM_EVENT_DISCONNECTED;
> + break;
> + case IW_CM_EVENT_CONNECT_REPLY:
> + sin = (struct sockaddr_in *) &id_priv->id.route.addr.src_addr;
> + *sin = iw_event->local_addr;
> + sin = (struct sockaddr_in *) &id_priv->id.route.addr.dst_addr;
> + *sin = iw_event->remote_addr;
> + if (iw_event->status)
> + event = RDMA_CM_EVENT_REJECTED;
> + else
> + event = RDMA_CM_EVENT_ESTABLISHED;
> + break;
> + case IW_CM_EVENT_ESTABLISHED:
> + event = RDMA_CM_EVENT_ESTABLISHED;
> + break;
> + default:
> + BUG_ON(1);
> + }
> +
> + ret = cma_notify_user(id_priv, event, iw_event->status,
> + iw_event->private_data,
> + iw_event->private_data_len);
> + if (ret) {
> + /* Destroy the CM ID by returning a non-zero value. */
> + id_priv->cm_id.iw = NULL;
> + cma_exch(id_priv, CMA_DESTROYING);
> + cma_release_remove(id_priv);
> + rdma_destroy_id(&id_priv->id);
> + return ret;
> + }
> +
> + cma_release_remove(id_priv);
> + return ret;
> +}
> +
> +static int iw_conn_req_handler(struct iw_cm_id *cm_id,
> + struct iw_cm_event *iw_event)
> +{
> + struct rdma_cm_id *new_cm_id;
> + struct rdma_id_private *listen_id, *conn_id;
> + struct sockaddr_in *sin;
> + struct net_device *dev;
> + int ret;
> +
> + listen_id = cm_id->context;
> + atomic_inc(&listen_id->dev_remove);
> + if (!cma_comp(listen_id, CMA_LISTEN)) {
> + ret = -ECONNABORTED;
> + goto out;
> + }
> +
> + /* Create a new RDMA id for the new IW CM ID */
> + new_cm_id = rdma_create_id(listen_id->id.event_handler,
> + listen_id->id.context,
> + RDMA_PS_TCP);
> + if (!new_cm_id) {
> + ret = -ENOMEM;
> + goto out;
> + }
> + conn_id = container_of(new_cm_id, struct rdma_id_private, id);
> + atomic_inc(&conn_id->dev_remove);
> + conn_id->state = CMA_CONNECT;
> +
we take a reference on the iWARP device here that we never release
> + dev = ip_dev_find(iw_event->local_addr.sin_addr.s_addr);
> + if (!dev) {
> + ret = -EADDRNOTAVAIL;
> + rdma_destroy_id(new_cm_id);
> + goto out;
> + }
> + ret = rdma_copy_addr(&conn_id->id.route.addr.dev_addr, dev, NULL);
> + if (ret) {
> + rdma_destroy_id(new_cm_id);
> + goto out;
> + }
> +
> + ret = cma_acquire_dev(conn_id);
> + if (ret) {
> + rdma_destroy_id(new_cm_id);
> + goto out;
> + }
> +
> + conn_id->cm_id.iw = cm_id;
> + cm_id->context = conn_id;
> + cm_id->cm_handler = cma_iw_handler;
> +
> + sin = (struct sockaddr_in *) &new_cm_id->route.addr.src_addr;
> + *sin = iw_event->local_addr;
> + sin = (struct sockaddr_in *) &new_cm_id->route.addr.dst_addr;
> + *sin = iw_event->remote_addr;
> +
> + ret = cma_notify_user(conn_id, RDMA_CM_EVENT_CONNECT_REQUEST, 0,
> + iw_event->private_data,
> + iw_event->private_data_len);
> + if (ret) {
> + /* User wants to destroy the CM ID */
> + conn_id->cm_id.iw = NULL;
> + cma_exch(conn_id, CMA_DESTROYING);
> + cma_release_remove(conn_id);
> + rdma_destroy_id(&conn_id->id);
> + }
> +
> +out:
We need to put a dev_put here or the reference on the device will never
get released and you won't be able to remove it after you've had at
least one connection. This is my bug....
dev_put(dev);
> + cma_release_remove(listen_id);
> + return ret;
> +}
> +
> static int cma_ib_listen(struct rdma_id_private *id_priv)
> {
> struct ib_cm_compare_data compare_data;
> @@ -1010,6 +1155,30 @@ static int cma_ib_listen(struct rdma_id_
> return ret;
> }
>
> +static int cma_iw_listen(struct rdma_id_private *id_priv, int backlog)
> +{
> + int ret;
> + struct sockaddr_in *sin;
> +
> + id_priv->cm_id.iw = iw_create_cm_id(id_priv->id.device,
> + iw_conn_req_handler,
> + id_priv);
> + if (IS_ERR(id_priv->cm_id.iw))
> + return PTR_ERR(id_priv->cm_id.iw);
> +
> + sin = (struct sockaddr_in *) &id_priv->id.route.addr.src_addr;
> + id_priv->cm_id.iw->local_addr = *sin;
> +
> + ret = iw_cm_listen(id_priv->cm_id.iw, backlog);
> +
> + if (ret) {
> + iw_destroy_cm_id(id_priv->cm_id.iw);
> + id_priv->cm_id.iw = NULL;
> + }
> +
> + return ret;
> +}
> +
> static int cma_listen_handler(struct rdma_cm_id *id,
> struct rdma_cm_event *event)
> {
> @@ -1085,12 +1254,17 @@ int rdma_listen(struct rdma_cm_id *id, i
> return -EINVAL;
>
> if (id->device) {
> - switch (id->device->node_type) {
> - case IB_NODE_CA:
> + switch (rdma_node_get_transport(id->device->node_type)) {
> + case RDMA_TRANSPORT_IB:
> ret = cma_ib_listen(id_priv);
> if (ret)
> goto err;
> break;
> + case RDMA_TRANSPORT_IWARP:
> + ret = cma_iw_listen(id_priv, backlog);
> + if (ret)
> + goto err;
> + break;
> default:
> ret = -ENOSYS;
> goto err;
> @@ -1229,6 +1403,23 @@ err:
> }
> EXPORT_SYMBOL(rdma_set_ib_paths);
>
> +static int cma_resolve_iw_route(struct rdma_id_private *id_priv, int timeout_ms)
> +{
> + struct cma_work *work;
> +
> + work = kzalloc(sizeof *work, GFP_KERNEL);
> + if (!work)
> + return -ENOMEM;
> +
> + work->id = id_priv;
> + INIT_WORK(&work->work, cma_work_handler, work);
> + work->old_state = CMA_ROUTE_QUERY;
> + work->new_state = CMA_ROUTE_RESOLVED;
> + work->event.event = RDMA_CM_EVENT_ROUTE_RESOLVED;
> + queue_work(cma_wq, &work->work);
> + return 0;
> +}
> +
> int rdma_resolve_route(struct rdma_cm_id *id, int timeout_ms)
> {
> struct rdma_id_private *id_priv;
> @@ -1239,10 +1430,13 @@ int rdma_resolve_route(struct rdma_cm_id
> return -EINVAL;
>
> atomic_inc(&id_priv->refcount);
> - switch (id->device->node_type) {
> - case IB_NODE_CA:
> + switch (rdma_node_get_transport(id->device->node_type)) {
> + case RDMA_TRANSPORT_IB:
> ret = cma_resolve_ib_route(id_priv, timeout_ms);
> break;
> + case RDMA_TRANSPORT_IWARP:
> + ret = cma_resolve_iw_route(id_priv, timeout_ms);
> + break;
> default:
> ret = -ENOSYS;
> break;
> @@ -1354,8 +1548,8 @@ static int cma_resolve_loopback(struct r
> ib_addr_get_sgid(&id_priv->id.route.addr.dev_addr));
>
> if (cma_zero_addr(&id_priv->id.route.addr.src_addr)) {
> - src_in = (struct sockaddr_in *)&id_priv->id.route.addr.src_addr;
> - dst_in = (struct sockaddr_in *)&id_priv->id.route.addr.dst_addr;
> + src_in = (struct sockaddr_in *) &id_priv->id.route.addr.src_addr;
> + dst_in = (struct sockaddr_in *) &id_priv->id.route.addr.dst_addr;
> src_in->sin_family = dst_in->sin_family;
> src_in->sin_addr.s_addr = dst_in->sin_addr.s_addr;
> }
> @@ -1646,6 +1840,47 @@ out:
> return ret;
> }
>
> +static int cma_connect_iw(struct rdma_id_private *id_priv,
> + struct rdma_conn_param *conn_param)
> +{
> + struct iw_cm_id *cm_id;
> + struct sockaddr_in* sin;
> + int ret;
> + struct iw_cm_conn_param iw_param;
> +
> + cm_id = iw_create_cm_id(id_priv->id.device, cma_iw_handler, id_priv);
> + if (IS_ERR(cm_id)) {
> + ret = PTR_ERR(cm_id);
> + goto out;
> + }
> +
> + id_priv->cm_id.iw = cm_id;
> +
> + sin = (struct sockaddr_in*) &id_priv->id.route.addr.src_addr;
> + cm_id->local_addr = *sin;
> +
> + sin = (struct sockaddr_in*) &id_priv->id.route.addr.dst_addr;
> + cm_id->remote_addr = *sin;
> +
> + ret = cma_modify_qp_rtr(&id_priv->id);
> + if (ret) {
> + iw_destroy_cm_id(cm_id);
> + return ret;
> + }
> +
> + iw_param.ord = conn_param->initiator_depth;
> + iw_param.ird = conn_param->responder_resources;
> + iw_param.private_data = conn_param->private_data;
> + iw_param.private_data_len = conn_param->private_data_len;
> + if (id_priv->id.qp)
> + iw_param.qpn = id_priv->qp_num;
> + else
> + iw_param.qpn = conn_param->qp_num;
> + ret = iw_cm_connect(cm_id, &iw_param);
> +out:
> + return ret;
> +}
> +
> int rdma_connect(struct rdma_cm_id *id, struct rdma_conn_param *conn_param)
> {
> struct rdma_id_private *id_priv;
> @@ -1661,10 +1896,13 @@ int rdma_connect(struct rdma_cm_id *id,
> id_priv->srq = conn_param->srq;
> }
>
> - switch (id->device->node_type) {
> - case IB_NODE_CA:
> + switch (rdma_node_get_transport(id->device->node_type)) {
> + case RDMA_TRANSPORT_IB:
> ret = cma_connect_ib(id_priv, conn_param);
> break;
> + case RDMA_TRANSPORT_IWARP:
> + ret = cma_connect_iw(id_priv, conn_param);
> + break;
> default:
> ret = -ENOSYS;
> break;
> @@ -1705,6 +1943,28 @@ static int cma_accept_ib(struct rdma_id_
> return ib_send_cm_rep(id_priv->cm_id.ib, &rep);
> }
>
> +static int cma_accept_iw(struct rdma_id_private *id_priv,
> + struct rdma_conn_param *conn_param)
> +{
> + struct iw_cm_conn_param iw_param;
> + int ret;
> +
> + ret = cma_modify_qp_rtr(&id_priv->id);
> + if (ret)
> + return ret;
> +
> + iw_param.ord = conn_param->initiator_depth;
> + iw_param.ird = conn_param->responder_resources;
> + iw_param.private_data = conn_param->private_data;
> + iw_param.private_data_len = conn_param->private_data_len;
> + if (id_priv->id.qp) {
> + iw_param.qpn = id_priv->qp_num;
> + } else
> + iw_param.qpn = conn_param->qp_num;
> +
> + return iw_cm_accept(id_priv->cm_id.iw, &iw_param);
> +}
> +
> int rdma_accept(struct rdma_cm_id *id, struct rdma_conn_param *conn_param)
> {
> struct rdma_id_private *id_priv;
> @@ -1720,13 +1980,16 @@ int rdma_accept(struct rdma_cm_id *id, s
> id_priv->srq = conn_param->srq;
> }
>
> - switch (id->device->node_type) {
> - case IB_NODE_CA:
> + switch (rdma_node_get_transport(id->device->node_type)) {
> + case RDMA_TRANSPORT_IB:
> if (conn_param)
> ret = cma_accept_ib(id_priv, conn_param);
> else
> ret = cma_rep_recv(id_priv);
> break;
> + case RDMA_TRANSPORT_IWARP:
> + ret = cma_accept_iw(id_priv, conn_param);
> + break;
> default:
> ret = -ENOSYS;
> break;
> @@ -1753,12 +2016,16 @@ int rdma_reject(struct rdma_cm_id *id, c
> if (!cma_comp(id_priv, CMA_CONNECT))
> return -EINVAL;
>
> - switch (id->device->node_type) {
> - case IB_NODE_CA:
> + switch (rdma_node_get_transport(id->device->node_type)) {
> + case RDMA_TRANSPORT_IB:
> ret = ib_send_cm_rej(id_priv->cm_id.ib,
> IB_CM_REJ_CONSUMER_DEFINED, NULL, 0,
> private_data, private_data_len);
> break;
> + case RDMA_TRANSPORT_IWARP:
> + ret = iw_cm_reject(id_priv->cm_id.iw,
> + private_data, private_data_len);
> + break;
> default:
> ret = -ENOSYS;
> break;
> @@ -1777,16 +2044,18 @@ int rdma_disconnect(struct rdma_cm_id *i
> !cma_comp(id_priv, CMA_DISCONNECT))
> return -EINVAL;
>
> - ret = cma_modify_qp_err(id);
> - if (ret)
> - goto out;
> -
> - switch (id->device->node_type) {
> - case IB_NODE_CA:
> + switch (rdma_node_get_transport(id->device->node_type)) {
> + case RDMA_TRANSPORT_IB:
> + ret = cma_modify_qp_err(id);
> + if (ret)
> + goto out;
> /* Initiate or respond to a disconnect. */
> if (ib_send_cm_dreq(id_priv->cm_id.ib, NULL, 0))
> ib_send_cm_drep(id_priv->cm_id.ib, NULL, 0);
> break;
> + case RDMA_TRANSPORT_IWARP:
> + ret = iw_cm_disconnect(id_priv->cm_id.iw, 0);
> + break;
> default:
> break;
> }
> diff --git a/drivers/infiniband/core/device.c b/drivers/infiniband/core/device.c
> index b2f3cb9..7318fba 100644
> --- a/drivers/infiniband/core/device.c
> +++ b/drivers/infiniband/core/device.c
> @@ -30,7 +30,7 @@
> * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> * SOFTWARE.
> *
> - * $Id: device.c 1349 2004-12-16 21:09:43Z roland $
> + * $Id: device.c 5943 2006-03-22 00:58:04Z roland $
> */
>
> #include <linux/module.h>
> @@ -505,7 +505,7 @@ int ib_query_port(struct ib_device *devi
> u8 port_num,
> struct ib_port_attr *port_attr)
> {
> - if (device->node_type == IB_NODE_SWITCH) {
> + if (device->node_type == RDMA_NODE_IB_SWITCH) {
> if (port_num)
> return -EINVAL;
> } else if (port_num < 1 || port_num > device->phys_port_cnt)
> @@ -580,7 +580,7 @@ int ib_modify_port(struct ib_device *dev
> u8 port_num, int port_modify_mask,
> struct ib_port_modify *port_modify)
> {
> - if (device->node_type == IB_NODE_SWITCH) {
> + if (device->node_type == RDMA_NODE_IB_SWITCH) {
> if (port_num)
> return -EINVAL;
> } else if (port_num < 1 || port_num > device->phys_port_cnt)
> diff --git a/drivers/infiniband/core/mad.c b/drivers/infiniband/core/mad.c
> index b38e02a..a928ecf 100644
> --- a/drivers/infiniband/core/mad.c
> +++ b/drivers/infiniband/core/mad.c
> @@ -1,5 +1,5 @@
> /*
> - * Copyright (c) 2004, 2005 Voltaire, Inc. All rights reserved.
> + * Copyright (c) 2004-2006 Voltaire, Inc. All rights reserved.
> * Copyright (c) 2005 Intel Corporation. All rights reserved.
> * Copyright (c) 2005 Mellanox Technologies Ltd. All rights reserved.
> *
> @@ -31,7 +31,7 @@
> * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> * SOFTWARE.
> *
> - * $Id: mad.c 5596 2006-03-03 01:00:07Z sean.hefty $
> + * $Id: mad.c 7294 2006-05-17 18:12:30Z roland $
> */
> #include <linux/dma-mapping.h>
> #include <rdma/ib_cache.h>
> @@ -2877,7 +2877,10 @@ static void ib_mad_init_device(struct ib
> {
> int start, end, i;
>
> - if (device->node_type == IB_NODE_SWITCH) {
> + if (rdma_node_get_transport(device->node_type) != RDMA_TRANSPORT_IB)
> + return;
> +
> + if (device->node_type == RDMA_NODE_IB_SWITCH) {
> start = 0;
> end = 0;
> } else {
> @@ -2924,7 +2927,7 @@ static void ib_mad_remove_device(struct
> {
> int i, num_ports, cur_port;
>
> - if (device->node_type == IB_NODE_SWITCH) {
> + if (device->node_type == RDMA_NODE_IB_SWITCH) {
> num_ports = 1;
> cur_port = 0;
> } else {
> diff --git a/drivers/infiniband/core/sa_query.c b/drivers/infiniband/core/sa_query.c
> index 501cc05..4230277 100644
> --- a/drivers/infiniband/core/sa_query.c
> +++ b/drivers/infiniband/core/sa_query.c
> @@ -887,7 +887,10 @@ static void ib_sa_add_one(struct ib_devi
> struct ib_sa_device *sa_dev;
> int s, e, i;
>
> - if (device->node_type == IB_NODE_SWITCH)
> + if (rdma_node_get_transport(device->node_type) != RDMA_TRANSPORT_IB)
> + return;
> +
> + if (device->node_type == RDMA_NODE_IB_SWITCH)
> s = e = 0;
> else {
> s = 1;
> diff --git a/drivers/infiniband/core/smi.c b/drivers/infiniband/core/smi.c
> index 35852e7..b81b2b9 100644
> --- a/drivers/infiniband/core/smi.c
> +++ b/drivers/infiniband/core/smi.c
> @@ -34,7 +34,7 @@
> * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> * SOFTWARE.
> *
> - * $Id: smi.c 1389 2004-12-27 22:56:47Z roland $
> + * $Id: smi.c 5258 2006-02-01 20:32:40Z sean.hefty $
> */
>
> #include <rdma/ib_smi.h>
> @@ -64,7 +64,7 @@ int smi_handle_dr_smp_send(struct ib_smp
>
> /* C14-9:2 */
> if (hop_ptr && hop_ptr < hop_cnt) {
> - if (node_type != IB_NODE_SWITCH)
> + if (node_type != RDMA_NODE_IB_SWITCH)
> return 0;
>
> /* smp->return_path set when received */
> @@ -77,7 +77,7 @@ int smi_handle_dr_smp_send(struct ib_smp
> if (hop_ptr == hop_cnt) {
> /* smp->return_path set when received */
> smp->hop_ptr++;
> - return (node_type == IB_NODE_SWITCH ||
> + return (node_type == RDMA_NODE_IB_SWITCH ||
> smp->dr_dlid == IB_LID_PERMISSIVE);
> }
>
> @@ -95,7 +95,7 @@ int smi_handle_dr_smp_send(struct ib_smp
>
> /* C14-13:2 */
> if (2 <= hop_ptr && hop_ptr <= hop_cnt) {
> - if (node_type != IB_NODE_SWITCH)
> + if (node_type != RDMA_NODE_IB_SWITCH)
> return 0;
>
> smp->hop_ptr--;
> @@ -107,7 +107,7 @@ int smi_handle_dr_smp_send(struct ib_smp
> if (hop_ptr == 1) {
> smp->hop_ptr--;
> /* C14-13:3 -- SMPs destined for SM shouldn't be here */
> - return (node_type == IB_NODE_SWITCH ||
> + return (node_type == RDMA_NODE_IB_SWITCH ||
> smp->dr_slid == IB_LID_PERMISSIVE);
> }
>
> @@ -142,7 +142,7 @@ int smi_handle_dr_smp_recv(struct ib_smp
>
> /* C14-9:2 -- intermediate hop */
> if (hop_ptr && hop_ptr < hop_cnt) {
> - if (node_type != IB_NODE_SWITCH)
> + if (node_type != RDMA_NODE_IB_SWITCH)
> return 0;
>
> smp->return_path[hop_ptr] = port_num;
> @@ -156,7 +156,7 @@ int smi_handle_dr_smp_recv(struct ib_smp
> smp->return_path[hop_ptr] = port_num;
> /* smp->hop_ptr updated when sending */
>
> - return (node_type == IB_NODE_SWITCH ||
> + return (node_type == RDMA_NODE_IB_SWITCH ||
> smp->dr_dlid == IB_LID_PERMISSIVE);
> }
>
> @@ -175,7 +175,7 @@ int smi_handle_dr_smp_recv(struct ib_smp
>
> /* C14-13:2 */
> if (2 <= hop_ptr && hop_ptr <= hop_cnt) {
> - if (node_type != IB_NODE_SWITCH)
> + if (node_type != RDMA_NODE_IB_SWITCH)
> return 0;
>
> /* smp->hop_ptr updated when sending */
> @@ -190,7 +190,7 @@ int smi_handle_dr_smp_recv(struct ib_smp
> return 1;
> }
> /* smp->hop_ptr updated when sending */
> - return (node_type == IB_NODE_SWITCH);
> + return (node_type == RDMA_NODE_IB_SWITCH);
> }
>
> /* C14-13:4 -- hop_ptr = 0 -> give to SM */
> diff --git a/drivers/infiniband/core/sysfs.c b/drivers/infiniband/core/sysfs.c
> index 21f9282..cfd2c06 100644
> --- a/drivers/infiniband/core/sysfs.c
> +++ b/drivers/infiniband/core/sysfs.c
> @@ -31,7 +31,7 @@
> * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> * SOFTWARE.
> *
> - * $Id: sysfs.c 1349 2004-12-16 21:09:43Z roland $
> + * $Id: sysfs.c 6940 2006-05-04 17:04:55Z roland $
> */
>
> #include "core_priv.h"
> @@ -589,10 +589,16 @@ static ssize_t show_node_type(struct cla
> return -ENODEV;
>
> switch (dev->node_type) {
> - case IB_NODE_CA: return sprintf(buf, "%d: CA\n", dev->node_type);
> - case IB_NODE_SWITCH: return sprintf(buf, "%d: switch\n", dev->node_type);
> - case IB_NODE_ROUTER: return sprintf(buf, "%d: router\n", dev->node_type);
> - default: return sprintf(buf, "%d: <unknown>\n", dev->node_type);
> + case RDMA_NODE_IB_CA:
> + return sprintf(buf, "%d: CA\n", dev->node_type);
> + case RDMA_NODE_RNIC:
> + return sprintf(buf, "%d: RNIC\n", dev->node_type);
> + case RDMA_NODE_IB_SWITCH:
> + return sprintf(buf, "%d: switch\n", dev->node_type);
> + case RDMA_NODE_IB_ROUTER:
> + return sprintf(buf, "%d: router\n", dev->node_type);
> + default:
> + return sprintf(buf, "%d: <unknown>\n", dev->node_type);
> }
> }
>
> @@ -708,7 +714,7 @@ int ib_device_register_sysfs(struct ib_d
> if (ret)
> goto err_put;
>
> - if (device->node_type == IB_NODE_SWITCH) {
> + if (device->node_type == RDMA_NODE_IB_SWITCH) {
> ret = add_port(device, 0);
> if (ret)
> goto err_put;
> diff --git a/drivers/infiniband/core/ucm.c b/drivers/infiniband/core/ucm.c
> index 67caf36..ad2e417 100644
> --- a/drivers/infiniband/core/ucm.c
> +++ b/drivers/infiniband/core/ucm.c
> @@ -30,7 +30,7 @@
> * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> * SOFTWARE.
> *
> - * $Id: ucm.c 4311 2005-12-05 18:42:01Z sean.hefty $
> + * $Id: ucm.c 7119 2006-05-11 16:40:38Z sean.hefty $
> */
>
> #include <linux/completion.h>
> @@ -1248,7 +1248,8 @@ static void ib_ucm_add_one(struct ib_dev
> {
> struct ib_ucm_device *ucm_dev;
>
> - if (!device->alloc_ucontext)
> + if (!device->alloc_ucontext ||
> + rdma_node_get_transport(device->node_type) != RDMA_TRANSPORT_IB)
> return;
>
> ucm_dev = kzalloc(sizeof *ucm_dev, GFP_KERNEL);
> diff --git a/drivers/infiniband/core/user_mad.c b/drivers/infiniband/core/user_mad.c
> index afe70a5..0cbd692 100644
> --- a/drivers/infiniband/core/user_mad.c
> +++ b/drivers/infiniband/core/user_mad.c
> @@ -1,6 +1,6 @@
> /*
> * Copyright (c) 2004 Topspin Communications. All rights reserved.
> - * Copyright (c) 2005 Voltaire, Inc. All rights reserved.
> + * Copyright (c) 2005-2006 Voltaire, Inc. All rights reserved.
> * Copyright (c) 2005 Sun Microsystems, Inc. All rights reserved.
> *
> * This software is available to you under a choice of one of two
> @@ -31,7 +31,7 @@
> * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> * SOFTWARE.
> *
> - * $Id: user_mad.c 5596 2006-03-03 01:00:07Z sean.hefty $
> + * $Id: user_mad.c 6041 2006-03-27 21:06:00Z halr $
> */
>
> #include <linux/module.h>
> @@ -967,7 +967,10 @@ static void ib_umad_add_one(struct ib_de
> struct ib_umad_device *umad_dev;
> int s, e, i;
>
> - if (device->node_type == IB_NODE_SWITCH)
> + if (rdma_node_get_transport(device->node_type) != RDMA_TRANSPORT_IB)
> + return;
> +
> + if (device->node_type == RDMA_NODE_IB_SWITCH)
> s = e = 0;
> else {
> s = 1;
> diff --git a/drivers/infiniband/hw/ipath/ipath_verbs.c b/drivers/infiniband/hw/ipath/ipath_verbs.c
> index 28fdbda..e4b45d7 100644
> --- a/drivers/infiniband/hw/ipath/ipath_verbs.c
> +++ b/drivers/infiniband/hw/ipath/ipath_verbs.c
> @@ -984,7 +984,7 @@ static void *ipath_register_ib_device(in
> (1ull << IB_USER_VERBS_CMD_QUERY_SRQ) |
> (1ull << IB_USER_VERBS_CMD_DESTROY_SRQ) |
> (1ull << IB_USER_VERBS_CMD_POST_SRQ_RECV);
> - dev->node_type = IB_NODE_CA;
> + dev->node_type = RDMA_NODE_IB_CA;
> dev->phys_port_cnt = 1;
> dev->dma_device = ipath_layer_get_device(dd);
> dev->class_dev.dev = dev->dma_device;
> diff --git a/drivers/infiniband/hw/mthca/mthca_provider.c b/drivers/infiniband/hw/mthca/mthca_provider.c
> index a2eae8a..5c31819 100644
> --- a/drivers/infiniband/hw/mthca/mthca_provider.c
> +++ b/drivers/infiniband/hw/mthca/mthca_provider.c
> @@ -1273,7 +1273,7 @@ int mthca_register_device(struct mthca_d
> (1ull << IB_USER_VERBS_CMD_MODIFY_SRQ) |
> (1ull << IB_USER_VERBS_CMD_QUERY_SRQ) |
> (1ull << IB_USER_VERBS_CMD_DESTROY_SRQ);
> - dev->ib_dev.node_type = IB_NODE_CA;
> + dev->ib_dev.node_type = RDMA_NODE_IB_CA;
> dev->ib_dev.phys_port_cnt = dev->limits.num_ports;
> dev->ib_dev.dma_device = &dev->pdev->dev;
> dev->ib_dev.class_dev.dev = &dev->pdev->dev;
> diff --git a/drivers/infiniband/ulp/ipoib/ipoib_main.c b/drivers/infiniband/ulp/ipoib/ipoib_main.c
> index 1c6ea1c..262427f 100644
> --- a/drivers/infiniband/ulp/ipoib/ipoib_main.c
> +++ b/drivers/infiniband/ulp/ipoib/ipoib_main.c
> @@ -1084,13 +1084,16 @@ static void ipoib_add_one(struct ib_devi
> struct ipoib_dev_priv *priv;
> int s, e, p;
>
> + if (rdma_node_get_transport(device->node_type) != RDMA_TRANSPORT_IB)
> + return;
> +
> dev_list = kmalloc(sizeof *dev_list, GFP_KERNEL);
> if (!dev_list)
> return;
>
> INIT_LIST_HEAD(dev_list);
>
> - if (device->node_type == IB_NODE_SWITCH) {
> + if (device->node_type == RDMA_NODE_IB_SWITCH) {
> s = 0;
> e = 0;
> } else {
> @@ -1114,6 +1117,9 @@ static void ipoib_remove_one(struct ib_d
> struct ipoib_dev_priv *priv, *tmp;
> struct list_head *dev_list;
>
> + if (rdma_node_get_transport(device->node_type) != RDMA_TRANSPORT_IB)
> + return;
> +
> dev_list = ib_get_client_data(device, &ipoib_client);
>
> list_for_each_entry_safe(priv, tmp, dev_list, list) {
> diff --git a/drivers/infiniband/ulp/srp/ib_srp.c b/drivers/infiniband/ulp/srp/ib_srp.c
> index f1401e1..bba2956 100644
> --- a/drivers/infiniband/ulp/srp/ib_srp.c
> +++ b/drivers/infiniband/ulp/srp/ib_srp.c
> @@ -1845,7 +1845,7 @@ static void srp_add_one(struct ib_device
> if (IS_ERR(srp_dev->fmr_pool))
> srp_dev->fmr_pool = NULL;
>
> - if (device->node_type == IB_NODE_SWITCH) {
> + if (device->node_type == RDMA_NODE_IB_SWITCH) {
> s = 0;
> e = 0;
> } else {
> diff --git a/include/rdma/ib_addr.h b/include/rdma/ib_addr.h
> index fcb5ba8..d95d3eb 100644
> --- a/include/rdma/ib_addr.h
> +++ b/include/rdma/ib_addr.h
> @@ -40,7 +40,7 @@ struct rdma_dev_addr {
> unsigned char src_dev_addr[MAX_ADDR_LEN];
> unsigned char dst_dev_addr[MAX_ADDR_LEN];
> unsigned char broadcast[MAX_ADDR_LEN];
> - enum ib_node_type dev_type;
> + enum rdma_node_type dev_type;
> };
>
> /**
> @@ -72,6 +72,9 @@ int rdma_resolve_ip(struct sockaddr *src
>
> void rdma_addr_cancel(struct rdma_dev_addr *addr);
>
> +int rdma_copy_addr(struct rdma_dev_addr *dev_addr, struct net_device *dev,
> + const unsigned char *dst_dev_addr);
> +
> static inline int ip_addr_size(struct sockaddr *addr)
> {
> return addr->sa_family == AF_INET6 ?
> @@ -111,4 +114,14 @@ static inline void ib_addr_set_dgid(stru
> memcpy(dev_addr->dst_dev_addr + 4, gid, sizeof *gid);
> }
>
> +static inline union ib_gid* iw_addr_get_sgid(struct rdma_dev_addr* rda)
> +{
> + return (union ib_gid *) rda->src_dev_addr;
> +}
> +
> +static inline union ib_gid* iw_addr_get_dgid(struct rdma_dev_addr* rda)
> +{
> + return (union ib_gid *) rda->dst_dev_addr;
> +}
> +
> #endif /* IB_ADDR_H */
> diff --git a/include/rdma/ib_verbs.h b/include/rdma/ib_verbs.h
> index aeb4fcd..eac2d8f 100644
> --- a/include/rdma/ib_verbs.h
> +++ b/include/rdma/ib_verbs.h
> @@ -35,7 +35,7 @@
> * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
> * SOFTWARE.
> *
> - * $Id: ib_verbs.h 1349 2004-12-16 21:09:43Z roland $
> + * $Id: ib_verbs.h 6885 2006-05-03 18:22:02Z sean.hefty $
> */
>
> #if !defined(IB_VERBS_H)
> @@ -56,12 +56,35 @@ union ib_gid {
> } global;
> };
>
> -enum ib_node_type {
> - IB_NODE_CA = 1,
> - IB_NODE_SWITCH,
> - IB_NODE_ROUTER
> +enum rdma_node_type {
> + /* IB values map to NodeInfo:NodeType. */
> + RDMA_NODE_IB_CA = 1,
> + RDMA_NODE_IB_SWITCH,
> + RDMA_NODE_IB_ROUTER,
> + RDMA_NODE_RNIC
> };
>
> +enum rdma_transport_type {
> + RDMA_TRANSPORT_IB,
> + RDMA_TRANSPORT_IWARP
> +};
> +
> +static inline enum rdma_transport_type
> +rdma_node_get_transport(enum rdma_node_type node_type)
> +{
> + switch (node_type) {
> + case RDMA_NODE_IB_CA:
> + case RDMA_NODE_IB_SWITCH:
> + case RDMA_NODE_IB_ROUTER:
> + return RDMA_TRANSPORT_IB;
> + case RDMA_NODE_RNIC:
> + return RDMA_TRANSPORT_IWARP;
> + default:
> + BUG();
> + return 0;
> + }
> +}
> +
> enum ib_device_cap_flags {
> IB_DEVICE_RESIZE_MAX_WR = 1,
> IB_DEVICE_BAD_PKEY_CNTR = (1<<1),
> @@ -78,6 +101,9 @@ enum ib_device_cap_flags {
> IB_DEVICE_RC_RNR_NAK_GEN = (1<<12),
> IB_DEVICE_SRQ_RESIZE = (1<<13),
> IB_DEVICE_N_NOTIFY_CQ = (1<<14),
> + IB_DEVICE_ZERO_STAG = (1<<15),
> + IB_DEVICE_SEND_W_INV = (1<<16),
> + IB_DEVICE_MEM_WINDOW = (1<<17)
> };
>
> enum ib_atomic_cap {
> @@ -830,6 +856,7 @@ struct ib_cache {
> u8 *lmc_cache;
> };
>
> +struct iw_cm_verbs;
> struct ib_device {
> struct device *dma_device;
>
> @@ -846,6 +873,8 @@ struct ib_device {
>
> u32 flags;
>
> + struct iw_cm_verbs *iwcm;
> +
> int (*query_device)(struct ib_device *device,
> struct ib_device_attr *device_attr);
> int (*query_port)(struct ib_device *device,
> -
> To unsubscribe from this list: send the line "unsubscribe netdev" in
> the body of a message to majordomo at vger.kernel.org
> More majordomo info at http://vger.kernel.org/majordomo-info.html
More information about the general
mailing list