Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 97c7d1ea authored by Linus Torvalds's avatar Linus Torvalds
Browse files

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: (52 commits)
  IB/mlx4: Use kzalloc() for new QPs so flags are initialized to 0
  mlx4_core: Use MOD_STAT_CFG command to get minimal page size
  RDMA/cma: Simplify locking needed for serialization of callbacks
  RDMA/addr: Keep pointer to netdevice in struct rdma_dev_addr
  RDMA/cxgb3: Fixes for zero STag
  RDMA/core: Add local DMA L_Key support
  IB/mthca: Fix check of max_send_sge for special QPs
  IB/mthca: Use round_jiffies() for catastrophic error polling timer
  IB/mthca: Remove "stop" flag for catastrophic error polling timer
  IPoIB: Double default RX/TX ring sizes
  IPoIB/cm: Reduce connected mode TX object size
  IB/ipath: Use IEEE OUI for vendor_id reported by ibv_query_device()
  IPoIB: Use dev_set_mtu() to change mtu
  IPoIB: Use rtnl lock/unlock when changing device flags
  IPoIB: Get rid of ipoib_mcast_detach() wrapper
  IPoIB: Only set Q_Key once: after joining broadcast group
  IPoIB: Remove priv->mcast_mutex
  IPoIB: Remove unused IPOIB_MCAST_STARTED code
  RDMA/cxgb3: Set rkey field for new memory windows in iwch_alloc_mw()
  RDMA/nes: Get rid of ring_doorbell parameter of nes_post_cqp_request()
  ...
parents 4d3702b6 f507d28b

drivers/infiniband/core/addr.c

+24 −18
Original line number Diff line number Diff line
@@ -4,28 +4,33 @@ 
 * Copyright (c) 1999-2005, Mellanox Technologies, Inc. All rights reserved.

 * Copyright (c) 2005 Intel Corporation.  All rights reserved.

 *

 * This Software is licensed under one of the following licenses:

 * This software is available to you under a choice of one of two

 * licenses.  You may choose to be licensed under the terms of the GNU

 * General Public License (GPL) Version 2, available from the file

 * COPYING in the main directory of this source tree, or the

 * OpenIB.org BSD license below:

 *

 * 1) under the terms of the "Common Public License 1.0" a copy of which is

 *    available from the Open Source Initiative, see

 *    http://www.opensource.org/licenses/cpl.php.

 *     Redistribution and use in source and binary forms, with or

 *     without modification, are permitted provided that the following

 *     conditions are met:

 *

 * 2) under the terms of the "The BSD License" a copy of which is

 *    available from the Open Source Initiative, see

 *    http://www.opensource.org/licenses/bsd-license.php.

 *      - Redistributions of source code must retain the above

 *        copyright notice, this list of conditions and the following

 *        disclaimer.

 *

 * 3) under the terms of the "GNU General Public License (GPL) Version 2" a

 *    copy of which is available from the Open Source Initiative, see

 *    http://www.opensource.org/licenses/gpl-license.php.

 *      - Redistributions in binary form must reproduce the above

 *        copyright notice, this list of conditions and the following

 *        disclaimer in the documentation and/or other materials

 *        provided with the distribution.

 *

 * Licensee has the right to choose one of the above licenses.

 *

 * Redistributions of source code must retain the above copyright

 * notice and one of the license notices.

 *

 * Redistributions in binary form must reproduce both the above copyright

 * notice, one of the license notices in the documentation

 * and/or other materials provided with the distribution.

 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,

 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND

 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS

 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN

 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN

 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE

 * SOFTWARE.

 */



#include <linux/mutex.h>
@@ -100,6 +105,7 @@ int rdma_copy_addr(struct rdma_dev_addr *dev_addr, struct net_device *dev, 
	memcpy(dev_addr->broadcast, dev->broadcast, MAX_ADDR_LEN);

	if (dst_dev_addr)

		memcpy(dev_addr->dst_dev_addr, dst_dev_addr, MAX_ADDR_LEN);

	dev_addr->src_dev = dev;

	return 0;

}

EXPORT_SYMBOL(rdma_copy_addr);

drivers/infiniband/core/agent.h

+0 −2
Original line number Diff line number Diff line
@@ -32,8 +32,6 @@ 
 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN

 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE

 * SOFTWARE.

 *

 * $Id: agent.h 1389 2004-12-27 22:56:47Z roland $

 */



#ifndef __AGENT_H_

drivers/infiniband/core/cache.c

+0 −2
Original line number Diff line number Diff line
@@ -31,8 +31,6 @@ 
 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN

 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE

 * SOFTWARE.

 *

 * $Id: cache.c 1349 2004-12-16 21:09:43Z roland $

 */



#include <linux/module.h>

drivers/infiniband/core/cm.c

+0 −2
Original line number Diff line number Diff line
@@ -31,8 +31,6 @@ 
 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN

 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE

 * SOFTWARE.

 *

 * $Id: cm.c 4311 2005-12-05 18:42:01Z sean.hefty $

 */



#include <linux/completion.h>

drivers/infiniband/core/cma.c

+81 −81
Original line number Diff line number Diff line
@@ -4,29 +4,33 @@ 
 * Copyright (c) 1999-2005, Mellanox Technologies, Inc. All rights reserved.

 * Copyright (c) 2005-2006 Intel Corporation.  All rights reserved.

 *

 * This Software is licensed under one of the following licenses:

 * This software is available to you under a choice of one of two

 * licenses.  You may choose to be licensed under the terms of the GNU

 * General Public License (GPL) Version 2, available from the file

 * COPYING in the main directory of this source tree, or the

 * OpenIB.org BSD license below:

 *

 * 1) under the terms of the "Common Public License 1.0" a copy of which is

 *    available from the Open Source Initiative, see

 *    http://www.opensource.org/licenses/cpl.php.

 *     Redistribution and use in source and binary forms, with or

 *     without modification, are permitted provided that the following

 *     conditions are met:

 *

 * 2) under the terms of the "The BSD License" a copy of which is

 *    available from the Open Source Initiative, see

 *    http://www.opensource.org/licenses/bsd-license.php.

 *      - Redistributions of source code must retain the above

 *        copyright notice, this list of conditions and the following

 *        disclaimer.

 *

 * 3) under the terms of the "GNU General Public License (GPL) Version 2" a

 *    copy of which is available from the Open Source Initiative, see

 *    http://www.opensource.org/licenses/gpl-license.php.

 *

 * Licensee has the right to choose one of the above licenses.

 *

 * Redistributions of source code must retain the above copyright

 * notice and one of the license notices.

 *

 * Redistributions in binary form must reproduce both the above copyright

 * notice, one of the license notices in the documentation

 * and/or other materials provided with the distribution.

 *      - Redistributions in binary form must reproduce the above

 *        copyright notice, this list of conditions and the following

 *        disclaimer in the documentation and/or other materials

 *        provided with the distribution.

 *

 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,

 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND

 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS

 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN

 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN

 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE

 * SOFTWARE.

 */



#include <linux/completion.h>
@@ -126,8 +130,7 @@ struct rdma_id_private { 


	struct completion	comp;

	atomic_t		refcount;

	wait_queue_head_t	wait_remove;

	atomic_t		dev_remove;

	struct mutex		handler_mutex;



	int			backlog;

	int			timeout_ms;
@@ -351,26 +354,15 @@ static void cma_deref_id(struct rdma_id_private *id_priv) 
		complete(&id_priv->comp);

}



static int cma_disable_remove(struct rdma_id_private *id_priv,

static int cma_disable_callback(struct rdma_id_private *id_priv,

			      enum cma_state state)

{

	unsigned long flags;

	int ret;



	spin_lock_irqsave(&id_priv->lock, flags);

	if (id_priv->state == state) {

		atomic_inc(&id_priv->dev_remove);

		ret = 0;

	} else

		ret = -EINVAL;

	spin_unlock_irqrestore(&id_priv->lock, flags);

	return ret;

	mutex_lock(&id_priv->handler_mutex);

	if (id_priv->state != state) {

		mutex_unlock(&id_priv->handler_mutex);

		return -EINVAL;

	}



static void cma_enable_remove(struct rdma_id_private *id_priv)

{

	if (atomic_dec_and_test(&id_priv->dev_remove))

		wake_up(&id_priv->wait_remove);

	return 0;

}



static int cma_has_cm_dev(struct rdma_id_private *id_priv)
@@ -395,8 +387,7 @@ struct rdma_cm_id *rdma_create_id(rdma_cm_event_handler event_handler, 
	mutex_init(&id_priv->qp_mutex);

	init_completion(&id_priv->comp);

	atomic_set(&id_priv->refcount, 1);

	init_waitqueue_head(&id_priv->wait_remove);

	atomic_set(&id_priv->dev_remove, 0);

	mutex_init(&id_priv->handler_mutex);

	INIT_LIST_HEAD(&id_priv->listen_list);

	INIT_LIST_HEAD(&id_priv->mc_list);

	get_random_bytes(&id_priv->seq_num, sizeof id_priv->seq_num);
@@ -923,7 +914,7 @@ static int cma_ib_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) 
	struct rdma_cm_event event;

	int ret = 0;



	if (cma_disable_remove(id_priv, CMA_CONNECT))

	if (cma_disable_callback(id_priv, CMA_CONNECT))

		return 0;



	memset(&event, 0, sizeof event);
@@ -970,7 +961,7 @@ static int cma_ib_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) 
		event.param.conn.private_data_len = IB_CM_REJ_PRIVATE_DATA_SIZE;

		break;

	default:

		printk(KERN_ERR "RDMA CMA: unexpected IB CM event: %d",

		printk(KERN_ERR "RDMA CMA: unexpected IB CM event: %d\n",

		       ib_event->event);

		goto out;

	}
@@ -980,12 +971,12 @@ static int cma_ib_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) 
		/* Destroy the CM ID by returning a non-zero value. */

		id_priv->cm_id.ib = NULL;

		cma_exch(id_priv, CMA_DESTROYING);

		cma_enable_remove(id_priv);

		mutex_unlock(&id_priv->handler_mutex);

		rdma_destroy_id(&id_priv->id);

		return ret;

	}

out:

	cma_enable_remove(id_priv);

	mutex_unlock(&id_priv->handler_mutex);

	return ret;

}
@@ -998,6 +989,7 @@ static struct rdma_id_private *cma_new_conn_id(struct rdma_cm_id *listen_id, 
	union cma_ip_addr *src, *dst;

	__be16 port;

	u8 ip_ver;

	int ret;



	if (cma_get_net_info(ib_event->private_data, listen_id->ps,

			     &ip_ver, &port, &src, &dst))
@@ -1022,10 +1014,11 @@ static struct rdma_id_private *cma_new_conn_id(struct rdma_cm_id *listen_id, 
	if (rt->num_paths == 2)

		rt->path_rec[1] = *ib_event->param.req_rcvd.alternate_path;



	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 = RDMA_NODE_IB_CA;

	ret = rdma_translate_ip(&id->route.addr.src_addr,

				&id->route.addr.dev_addr);

	if (ret)

		goto destroy_id;



	id_priv = container_of(id, struct rdma_id_private, id);

	id_priv->state = CMA_CONNECT;
@@ -1095,7 +1088,7 @@ static int cma_req_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) 
	int offset, ret;



	listen_id = cm_id->context;

	if (cma_disable_remove(listen_id, CMA_LISTEN))

	if (cma_disable_callback(listen_id, CMA_LISTEN))

		return -ECONNABORTED;



	memset(&event, 0, sizeof event);
@@ -1116,7 +1109,7 @@ static int cma_req_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) 
		goto out;

	}



	atomic_inc(&conn_id->dev_remove);

	mutex_lock_nested(&conn_id->handler_mutex, SINGLE_DEPTH_NESTING);

	mutex_lock(&lock);

	ret = cma_acquire_dev(conn_id);

	mutex_unlock(&lock);
@@ -1138,7 +1131,7 @@ static int cma_req_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) 
		    !cma_is_ud_ps(conn_id->id.ps))

			ib_send_cm_mra(cm_id, CMA_CM_MRA_SETTING, NULL, 0);

		mutex_unlock(&lock);

		cma_enable_remove(conn_id);

		mutex_unlock(&conn_id->handler_mutex);

		goto out;

	}
@@ -1147,11 +1140,11 @@ static int cma_req_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) 


release_conn_id:

	cma_exch(conn_id, CMA_DESTROYING);

	cma_enable_remove(conn_id);

	mutex_unlock(&conn_id->handler_mutex);

	rdma_destroy_id(&conn_id->id);



out:

	cma_enable_remove(listen_id);

	mutex_unlock(&listen_id->handler_mutex);

	return ret;

}
@@ -1217,7 +1210,7 @@ static int cma_iw_handler(struct iw_cm_id *iw_id, struct iw_cm_event *iw_event) 
	struct sockaddr_in *sin;

	int ret = 0;



	if (cma_disable_remove(id_priv, CMA_CONNECT))

	if (cma_disable_callback(id_priv, CMA_CONNECT))

		return 0;



	memset(&event, 0, sizeof event);
@@ -1261,12 +1254,12 @@ static int cma_iw_handler(struct iw_cm_id *iw_id, struct iw_cm_event *iw_event) 
		/* Destroy the CM ID by returning a non-zero value. */

		id_priv->cm_id.iw = NULL;

		cma_exch(id_priv, CMA_DESTROYING);

		cma_enable_remove(id_priv);

		mutex_unlock(&id_priv->handler_mutex);

		rdma_destroy_id(&id_priv->id);

		return ret;

	}



	cma_enable_remove(id_priv);

	mutex_unlock(&id_priv->handler_mutex);

	return ret;

}
@@ -1282,7 +1275,7 @@ static int iw_conn_req_handler(struct iw_cm_id *cm_id, 
	struct ib_device_attr attr;



	listen_id = cm_id->context;

	if (cma_disable_remove(listen_id, CMA_LISTEN))

	if (cma_disable_callback(listen_id, CMA_LISTEN))

		return -ECONNABORTED;



	/* Create a new RDMA id for the new IW CM ID */
@@ -1294,19 +1287,19 @@ static int iw_conn_req_handler(struct iw_cm_id *cm_id, 
		goto out;

	}

	conn_id = container_of(new_cm_id, struct rdma_id_private, id);

	atomic_inc(&conn_id->dev_remove);

	mutex_lock_nested(&conn_id->handler_mutex, SINGLE_DEPTH_NESTING);

	conn_id->state = CMA_CONNECT;



	dev = ip_dev_find(&init_net, iw_event->local_addr.sin_addr.s_addr);

	if (!dev) {

		ret = -EADDRNOTAVAIL;

		cma_enable_remove(conn_id);

		mutex_unlock(&conn_id->handler_mutex);

		rdma_destroy_id(new_cm_id);

		goto out;

	}

	ret = rdma_copy_addr(&conn_id->id.route.addr.dev_addr, dev, NULL);

	if (ret) {

		cma_enable_remove(conn_id);

		mutex_unlock(&conn_id->handler_mutex);

		rdma_destroy_id(new_cm_id);

		goto out;

	}
@@ -1315,7 +1308,7 @@ static int iw_conn_req_handler(struct iw_cm_id *cm_id, 
	ret = cma_acquire_dev(conn_id);

	mutex_unlock(&lock);

	if (ret) {

		cma_enable_remove(conn_id);

		mutex_unlock(&conn_id->handler_mutex);

		rdma_destroy_id(new_cm_id);

		goto out;

	}
@@ -1331,7 +1324,7 @@ static int iw_conn_req_handler(struct iw_cm_id *cm_id, 


	ret = ib_query_device(conn_id->id.device, &attr);

	if (ret) {

		cma_enable_remove(conn_id);

		mutex_unlock(&conn_id->handler_mutex);

		rdma_destroy_id(new_cm_id);

		goto out;

	}
@@ -1347,14 +1340,17 @@ static int iw_conn_req_handler(struct iw_cm_id *cm_id, 
		/* User wants to destroy the CM ID */

		conn_id->cm_id.iw = NULL;

		cma_exch(conn_id, CMA_DESTROYING);

		cma_enable_remove(conn_id);

		mutex_unlock(&conn_id->handler_mutex);

		rdma_destroy_id(&conn_id->id);

		goto out;

	}



	mutex_unlock(&conn_id->handler_mutex);



out:

	if (dev)

		dev_put(dev);

	cma_enable_remove(listen_id);

	mutex_unlock(&listen_id->handler_mutex);

	return ret;

}
@@ -1446,7 +1442,7 @@ static void cma_listen_on_dev(struct rdma_id_private *id_priv, 
	ret = rdma_listen(id, id_priv->backlog);

	if (ret)

		printk(KERN_WARNING "RDMA CMA: cma_listen_on_dev, error %d, "

		       "listening on device %s", ret, cma_dev->device->name);

		       "listening on device %s\n", ret, cma_dev->device->name);

}



static void cma_listen_on_all(struct rdma_id_private *id_priv)
@@ -1586,7 +1582,7 @@ static void cma_work_handler(struct work_struct *_work) 
	struct rdma_id_private *id_priv = work->id;

	int destroy = 0;



	atomic_inc(&id_priv->dev_remove);

	mutex_lock(&id_priv->handler_mutex);

	if (!cma_comp_exch(id_priv, work->old_state, work->new_state))

		goto out;
@@ -1595,7 +1591,7 @@ static void cma_work_handler(struct work_struct *_work) 
		destroy = 1;

	}

out:

	cma_enable_remove(id_priv);

	mutex_unlock(&id_priv->handler_mutex);

	cma_deref_id(id_priv);

	if (destroy)

		rdma_destroy_id(&id_priv->id);
@@ -1758,7 +1754,7 @@ static void addr_handler(int status, struct sockaddr *src_addr, 
	struct rdma_cm_event event;



	memset(&event, 0, sizeof event);

	atomic_inc(&id_priv->dev_remove);

	mutex_lock(&id_priv->handler_mutex);



	/*

	 * Grab mutex to block rdma_destroy_id() from removing the device while
@@ -1787,13 +1783,13 @@ static void addr_handler(int status, struct sockaddr *src_addr, 


	if (id_priv->id.event_handler(&id_priv->id, &event)) {

		cma_exch(id_priv, CMA_DESTROYING);

		cma_enable_remove(id_priv);

		mutex_unlock(&id_priv->handler_mutex);

		cma_deref_id(id_priv);

		rdma_destroy_id(&id_priv->id);

		return;

	}

out:

	cma_enable_remove(id_priv);

	mutex_unlock(&id_priv->handler_mutex);

	cma_deref_id(id_priv);

}
@@ -2120,7 +2116,7 @@ static int cma_sidr_rep_handler(struct ib_cm_id *cm_id, 
	struct ib_cm_sidr_rep_event_param *rep = &ib_event->param.sidr_rep_rcvd;

	int ret = 0;



	if (cma_disable_remove(id_priv, CMA_CONNECT))

	if (cma_disable_callback(id_priv, CMA_CONNECT))

		return 0;



	memset(&event, 0, sizeof event);
@@ -2151,7 +2147,7 @@ static int cma_sidr_rep_handler(struct ib_cm_id *cm_id, 
		event.status = 0;

		break;

	default:

		printk(KERN_ERR "RDMA CMA: unexpected IB CM event: %d",

		printk(KERN_ERR "RDMA CMA: unexpected IB CM event: %d\n",

		       ib_event->event);

		goto out;

	}
@@ -2161,12 +2157,12 @@ static int cma_sidr_rep_handler(struct ib_cm_id *cm_id, 
		/* Destroy the CM ID by returning a non-zero value. */

		id_priv->cm_id.ib = NULL;

		cma_exch(id_priv, CMA_DESTROYING);

		cma_enable_remove(id_priv);

		mutex_unlock(&id_priv->handler_mutex);

		rdma_destroy_id(&id_priv->id);

		return ret;

	}

out:

	cma_enable_remove(id_priv);

	mutex_unlock(&id_priv->handler_mutex);

	return ret;

}
@@ -2564,8 +2560,8 @@ static int cma_ib_mc_handler(int status, struct ib_sa_multicast *multicast) 
	int ret;



	id_priv = mc->id_priv;

	if (cma_disable_remove(id_priv, CMA_ADDR_BOUND) &&

	    cma_disable_remove(id_priv, CMA_ADDR_RESOLVED))

	if (cma_disable_callback(id_priv, CMA_ADDR_BOUND) &&

	    cma_disable_callback(id_priv, CMA_ADDR_RESOLVED))

		return 0;



	mutex_lock(&id_priv->qp_mutex);
@@ -2590,12 +2586,12 @@ static int cma_ib_mc_handler(int status, struct ib_sa_multicast *multicast) 
	ret = id_priv->id.event_handler(&id_priv->id, &event);

	if (ret) {

		cma_exch(id_priv, CMA_DESTROYING);

		cma_enable_remove(id_priv);

		mutex_unlock(&id_priv->handler_mutex);

		rdma_destroy_id(&id_priv->id);

		return 0;

	}



	cma_enable_remove(id_priv);

	mutex_unlock(&id_priv->handler_mutex);

	return 0;

}
@@ -2754,6 +2750,7 @@ static int cma_remove_id_dev(struct rdma_id_private *id_priv) 
{

	struct rdma_cm_event event;

	enum cma_state state;

	int ret = 0;



	/* Record that we want to remove the device */

	state = cma_exch(id_priv, CMA_DEVICE_REMOVAL);
@@ -2761,15 +2758,18 @@ static int cma_remove_id_dev(struct rdma_id_private *id_priv) 
		return 0;



	cma_cancel_operation(id_priv, state);

	wait_event(id_priv->wait_remove, !atomic_read(&id_priv->dev_remove));

	mutex_lock(&id_priv->handler_mutex);



	/* Check for destruction from another callback. */

	if (!cma_comp(id_priv, CMA_DEVICE_REMOVAL))

		return 0;

		goto out;



	memset(&event, 0, sizeof event);

	event.event = RDMA_CM_EVENT_DEVICE_REMOVAL;

	return id_priv->id.event_handler(&id_priv->id, &event);

	ret = id_priv->id.event_handler(&id_priv->id, &event);

out:

	mutex_unlock(&id_priv->handler_mutex);

	return ret;

}



static void cma_process_remove(struct cma_device *cma_dev)