ofed/libibcm/cm.c

216 static void ib_cm_free_id(struct cm_id_private *cm_id_priv)
218 	pthread_cond_destroy(&cm_id_priv->cond);
219 	pthread_mutex_destroy(&cm_id_priv->mut);
220 	free(cm_id_priv);
226 	struct cm_id_private *cm_id_priv;
228 	cm_id_priv = malloc(sizeof *cm_id_priv);
229 	if (!cm_id_priv)
232 	memset(cm_id_priv, 0, sizeof *cm_id_priv);
233 	cm_id_priv->id.device = device;
234 	cm_id_priv->id.context = context;
235 	pthread_mutex_init(&cm_id_priv->mut, NULL);
236 	if (pthread_cond_init(&cm_id_priv->cond, NULL))
239 	return cm_id_priv;
241 err:	ib_cm_free_id(cm_id_priv);
250 	struct cm_id_private *cm_id_priv;
255 	cm_id_priv = ib_cm_alloc_id(device, context);
256 	if (!cm_id_priv)
260 	cmd->uid = (uintptr_t) cm_id_priv;
268 	cm_id_priv->id.handle = resp->id;
269 	*cm_id = &cm_id_priv->id;
272 err:	ib_cm_free_id(cm_id_priv);
280 	struct cm_id_private *cm_id_priv;
294 	cm_id_priv = container_of(cm_id, struct cm_id_private, id);
296 	pthread_mutex_lock(&cm_id_priv->mut);
297 	while (cm_id_priv->events_completed < resp->events_reported)
298 		pthread_cond_wait(&cm_id_priv->cond, &cm_id_priv->mut);
299 	pthread_mutex_unlock(&cm_id_priv->mut);
301 	ib_cm_free_id(cm_id_priv);
799 	struct cm_id_private *cm_id_priv;
891 		cm_id_priv = ib_cm_alloc_id(evt->cm_id->device,
893 		if (!cm_id_priv) {
897 		cm_id_priv->id.handle = resp->id;
898 		evt->cm_id = &cm_id_priv->id;
929 		cm_id_priv = ib_cm_alloc_id(evt->cm_id->device,
931 		if (!cm_id_priv) {
935 		cm_id_priv->id.handle = resp->id;
936 		evt->cm_id = &cm_id_priv->id;
976 	struct cm_id_private *cm_id_priv;
984 	cm_id_priv = container_of(event->cm_id, struct cm_id_private, id);
988 		cm_id_priv = container_of(event->param.req_rcvd.listen_id,
1006 		cm_id_priv = container_of(event->param.sidr_req_rcvd.listen_id,
1016 	pthread_mutex_lock(&cm_id_priv->mut);
1017 	cm_id_priv->events_completed++;
1018 	pthread_cond_signal(&cm_id_priv->cond);
1019 	pthread_mutex_unlock(&cm_id_priv->mut);