2 * Copyright (c) 2005 Topspin Communications. All rights reserved.
3 * Copyright (c) 2005 Intel Corporation. All rights reserved.
5 * This software is available to you under a choice of one of two
6 * licenses. You may choose to be licensed under the terms of the GNU
7 * General Public License (GPL) Version 2, available from the file
8 * COPYING in the main directory of this source tree, or the
9 * OpenIB.org BSD license below:
11 * Redistribution and use in source and binary forms, with or
12 * without modification, are permitted provided that the following
15 * - Redistributions of source code must retain the above
16 * copyright notice, this list of conditions and the following
19 * - Redistributions in binary form must reproduce the above
20 * copyright notice, this list of conditions and the following
21 * disclaimer in the documentation and/or other materials
22 * provided with the distribution.
24 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
25 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
26 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
27 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
28 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
29 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
30 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
33 * $Id: ucm.c 4311 2005-12-05 18:42:01Z sean.hefty $
36 #include <linux/completion.h>
37 #include <linux/init.h>
39 #include <linux/module.h>
40 #include <linux/device.h>
41 #include <linux/err.h>
42 #include <linux/poll.h>
43 #include <linux/file.h>
44 #include <linux/mount.h>
45 #include <linux/cdev.h>
46 #include <linux/idr.h>
47 #include <linux/mutex.h>
49 #include <asm/uaccess.h>
51 #include <rdma/ib_cm.h>
52 #include <rdma/ib_user_cm.h>
53 #include <rdma/ib_marshall.h>
55 MODULE_AUTHOR("Libor Michalek");
56 MODULE_DESCRIPTION("InfiniBand userspace Connection Manager access");
57 MODULE_LICENSE("Dual BSD/GPL");
59 struct ib_ucm_device
{
62 struct class_device class_dev
;
63 struct ib_device
*ib_dev
;
67 struct mutex file_mutex
;
69 struct ib_ucm_device
*device
;
71 struct list_head ctxs
;
72 struct list_head events
;
73 wait_queue_head_t poll_wait
;
76 struct ib_ucm_context
{
78 struct completion comp
;
82 struct ib_ucm_file
*file
;
83 struct ib_cm_id
*cm_id
;
86 struct list_head events
; /* list of pending events. */
87 struct list_head file_list
; /* member in file ctx list */
91 struct ib_ucm_context
*ctx
;
92 struct list_head file_list
; /* member in file event list */
93 struct list_head ctx_list
; /* member in ctx event list */
95 struct ib_cm_id
*cm_id
;
96 struct ib_ucm_event_resp resp
;
105 IB_UCM_BASE_MINOR
= 224,
106 IB_UCM_MAX_DEVICES
= 32
109 #define IB_UCM_BASE_DEV MKDEV(IB_UCM_MAJOR, IB_UCM_BASE_MINOR)
111 static void ib_ucm_add_one(struct ib_device
*device
);
112 static void ib_ucm_remove_one(struct ib_device
*device
);
114 static struct ib_client ucm_client
= {
116 .add
= ib_ucm_add_one
,
117 .remove
= ib_ucm_remove_one
120 static DEFINE_MUTEX(ctx_id_mutex
);
121 static DEFINE_IDR(ctx_id_table
);
122 static DECLARE_BITMAP(dev_map
, IB_UCM_MAX_DEVICES
);
124 static struct ib_ucm_context
*ib_ucm_ctx_get(struct ib_ucm_file
*file
, int id
)
126 struct ib_ucm_context
*ctx
;
128 mutex_lock(&ctx_id_mutex
);
129 ctx
= idr_find(&ctx_id_table
, id
);
131 ctx
= ERR_PTR(-ENOENT
);
132 else if (ctx
->file
!= file
)
133 ctx
= ERR_PTR(-EINVAL
);
135 atomic_inc(&ctx
->ref
);
136 mutex_unlock(&ctx_id_mutex
);
141 static void ib_ucm_ctx_put(struct ib_ucm_context
*ctx
)
143 if (atomic_dec_and_test(&ctx
->ref
))
144 complete(&ctx
->comp
);
147 static inline int ib_ucm_new_cm_id(int event
)
149 return event
== IB_CM_REQ_RECEIVED
|| event
== IB_CM_SIDR_REQ_RECEIVED
;
152 static void ib_ucm_cleanup_events(struct ib_ucm_context
*ctx
)
154 struct ib_ucm_event
*uevent
;
156 mutex_lock(&ctx
->file
->file_mutex
);
157 list_del(&ctx
->file_list
);
158 while (!list_empty(&ctx
->events
)) {
160 uevent
= list_entry(ctx
->events
.next
,
161 struct ib_ucm_event
, ctx_list
);
162 list_del(&uevent
->file_list
);
163 list_del(&uevent
->ctx_list
);
164 mutex_unlock(&ctx
->file
->file_mutex
);
166 /* clear incoming connections. */
167 if (ib_ucm_new_cm_id(uevent
->resp
.event
))
168 ib_destroy_cm_id(uevent
->cm_id
);
171 mutex_lock(&ctx
->file
->file_mutex
);
173 mutex_unlock(&ctx
->file
->file_mutex
);
176 static struct ib_ucm_context
*ib_ucm_ctx_alloc(struct ib_ucm_file
*file
)
178 struct ib_ucm_context
*ctx
;
181 ctx
= kzalloc(sizeof *ctx
, GFP_KERNEL
);
185 atomic_set(&ctx
->ref
, 1);
186 init_completion(&ctx
->comp
);
188 INIT_LIST_HEAD(&ctx
->events
);
191 result
= idr_pre_get(&ctx_id_table
, GFP_KERNEL
);
195 mutex_lock(&ctx_id_mutex
);
196 result
= idr_get_new(&ctx_id_table
, ctx
, &ctx
->id
);
197 mutex_unlock(&ctx_id_mutex
);
198 } while (result
== -EAGAIN
);
203 list_add_tail(&ctx
->file_list
, &file
->ctxs
);
211 static void ib_ucm_event_req_get(struct ib_ucm_req_event_resp
*ureq
,
212 struct ib_cm_req_event_param
*kreq
)
214 ureq
->remote_ca_guid
= kreq
->remote_ca_guid
;
215 ureq
->remote_qkey
= kreq
->remote_qkey
;
216 ureq
->remote_qpn
= kreq
->remote_qpn
;
217 ureq
->qp_type
= kreq
->qp_type
;
218 ureq
->starting_psn
= kreq
->starting_psn
;
219 ureq
->responder_resources
= kreq
->responder_resources
;
220 ureq
->initiator_depth
= kreq
->initiator_depth
;
221 ureq
->local_cm_response_timeout
= kreq
->local_cm_response_timeout
;
222 ureq
->flow_control
= kreq
->flow_control
;
223 ureq
->remote_cm_response_timeout
= kreq
->remote_cm_response_timeout
;
224 ureq
->retry_count
= kreq
->retry_count
;
225 ureq
->rnr_retry_count
= kreq
->rnr_retry_count
;
226 ureq
->srq
= kreq
->srq
;
227 ureq
->port
= kreq
->port
;
229 ib_copy_path_rec_to_user(&ureq
->primary_path
, kreq
->primary_path
);
230 if (kreq
->alternate_path
)
231 ib_copy_path_rec_to_user(&ureq
->alternate_path
,
232 kreq
->alternate_path
);
235 static void ib_ucm_event_rep_get(struct ib_ucm_rep_event_resp
*urep
,
236 struct ib_cm_rep_event_param
*krep
)
238 urep
->remote_ca_guid
= krep
->remote_ca_guid
;
239 urep
->remote_qkey
= krep
->remote_qkey
;
240 urep
->remote_qpn
= krep
->remote_qpn
;
241 urep
->starting_psn
= krep
->starting_psn
;
242 urep
->responder_resources
= krep
->responder_resources
;
243 urep
->initiator_depth
= krep
->initiator_depth
;
244 urep
->target_ack_delay
= krep
->target_ack_delay
;
245 urep
->failover_accepted
= krep
->failover_accepted
;
246 urep
->flow_control
= krep
->flow_control
;
247 urep
->rnr_retry_count
= krep
->rnr_retry_count
;
248 urep
->srq
= krep
->srq
;
251 static void ib_ucm_event_sidr_rep_get(struct ib_ucm_sidr_rep_event_resp
*urep
,
252 struct ib_cm_sidr_rep_event_param
*krep
)
254 urep
->status
= krep
->status
;
255 urep
->qkey
= krep
->qkey
;
256 urep
->qpn
= krep
->qpn
;
259 static int ib_ucm_event_process(struct ib_cm_event
*evt
,
260 struct ib_ucm_event
*uvt
)
264 switch (evt
->event
) {
265 case IB_CM_REQ_RECEIVED
:
266 ib_ucm_event_req_get(&uvt
->resp
.u
.req_resp
,
267 &evt
->param
.req_rcvd
);
268 uvt
->data_len
= IB_CM_REQ_PRIVATE_DATA_SIZE
;
269 uvt
->resp
.present
= IB_UCM_PRES_PRIMARY
;
270 uvt
->resp
.present
|= (evt
->param
.req_rcvd
.alternate_path
?
271 IB_UCM_PRES_ALTERNATE
: 0);
273 case IB_CM_REP_RECEIVED
:
274 ib_ucm_event_rep_get(&uvt
->resp
.u
.rep_resp
,
275 &evt
->param
.rep_rcvd
);
276 uvt
->data_len
= IB_CM_REP_PRIVATE_DATA_SIZE
;
278 case IB_CM_RTU_RECEIVED
:
279 uvt
->data_len
= IB_CM_RTU_PRIVATE_DATA_SIZE
;
280 uvt
->resp
.u
.send_status
= evt
->param
.send_status
;
282 case IB_CM_DREQ_RECEIVED
:
283 uvt
->data_len
= IB_CM_DREQ_PRIVATE_DATA_SIZE
;
284 uvt
->resp
.u
.send_status
= evt
->param
.send_status
;
286 case IB_CM_DREP_RECEIVED
:
287 uvt
->data_len
= IB_CM_DREP_PRIVATE_DATA_SIZE
;
288 uvt
->resp
.u
.send_status
= evt
->param
.send_status
;
290 case IB_CM_MRA_RECEIVED
:
291 uvt
->resp
.u
.mra_resp
.timeout
=
292 evt
->param
.mra_rcvd
.service_timeout
;
293 uvt
->data_len
= IB_CM_MRA_PRIVATE_DATA_SIZE
;
295 case IB_CM_REJ_RECEIVED
:
296 uvt
->resp
.u
.rej_resp
.reason
= evt
->param
.rej_rcvd
.reason
;
297 uvt
->data_len
= IB_CM_REJ_PRIVATE_DATA_SIZE
;
298 uvt
->info_len
= evt
->param
.rej_rcvd
.ari_length
;
299 info
= evt
->param
.rej_rcvd
.ari
;
301 case IB_CM_LAP_RECEIVED
:
302 ib_copy_path_rec_to_user(&uvt
->resp
.u
.lap_resp
.path
,
303 evt
->param
.lap_rcvd
.alternate_path
);
304 uvt
->data_len
= IB_CM_LAP_PRIVATE_DATA_SIZE
;
305 uvt
->resp
.present
= IB_UCM_PRES_ALTERNATE
;
307 case IB_CM_APR_RECEIVED
:
308 uvt
->resp
.u
.apr_resp
.status
= evt
->param
.apr_rcvd
.ap_status
;
309 uvt
->data_len
= IB_CM_APR_PRIVATE_DATA_SIZE
;
310 uvt
->info_len
= evt
->param
.apr_rcvd
.info_len
;
311 info
= evt
->param
.apr_rcvd
.apr_info
;
313 case IB_CM_SIDR_REQ_RECEIVED
:
314 uvt
->resp
.u
.sidr_req_resp
.pkey
=
315 evt
->param
.sidr_req_rcvd
.pkey
;
316 uvt
->resp
.u
.sidr_req_resp
.port
=
317 evt
->param
.sidr_req_rcvd
.port
;
318 uvt
->data_len
= IB_CM_SIDR_REQ_PRIVATE_DATA_SIZE
;
320 case IB_CM_SIDR_REP_RECEIVED
:
321 ib_ucm_event_sidr_rep_get(&uvt
->resp
.u
.sidr_rep_resp
,
322 &evt
->param
.sidr_rep_rcvd
);
323 uvt
->data_len
= IB_CM_SIDR_REP_PRIVATE_DATA_SIZE
;
324 uvt
->info_len
= evt
->param
.sidr_rep_rcvd
.info_len
;
325 info
= evt
->param
.sidr_rep_rcvd
.info
;
328 uvt
->resp
.u
.send_status
= evt
->param
.send_status
;
333 uvt
->data
= kmemdup(evt
->private_data
, uvt
->data_len
, GFP_KERNEL
);
337 uvt
->resp
.present
|= IB_UCM_PRES_DATA
;
341 uvt
->info
= kmemdup(info
, uvt
->info_len
, GFP_KERNEL
);
345 uvt
->resp
.present
|= IB_UCM_PRES_INFO
;
355 static int ib_ucm_event_handler(struct ib_cm_id
*cm_id
,
356 struct ib_cm_event
*event
)
358 struct ib_ucm_event
*uevent
;
359 struct ib_ucm_context
*ctx
;
362 ctx
= cm_id
->context
;
364 uevent
= kzalloc(sizeof *uevent
, GFP_KERNEL
);
369 uevent
->cm_id
= cm_id
;
370 uevent
->resp
.uid
= ctx
->uid
;
371 uevent
->resp
.id
= ctx
->id
;
372 uevent
->resp
.event
= event
->event
;
374 result
= ib_ucm_event_process(event
, uevent
);
378 mutex_lock(&ctx
->file
->file_mutex
);
379 list_add_tail(&uevent
->file_list
, &ctx
->file
->events
);
380 list_add_tail(&uevent
->ctx_list
, &ctx
->events
);
381 wake_up_interruptible(&ctx
->file
->poll_wait
);
382 mutex_unlock(&ctx
->file
->file_mutex
);
388 /* Destroy new cm_id's */
389 return ib_ucm_new_cm_id(event
->event
);
392 static ssize_t
ib_ucm_event(struct ib_ucm_file
*file
,
393 const char __user
*inbuf
,
394 int in_len
, int out_len
)
396 struct ib_ucm_context
*ctx
;
397 struct ib_ucm_event_get cmd
;
398 struct ib_ucm_event
*uevent
;
402 if (out_len
< sizeof(struct ib_ucm_event_resp
))
405 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
408 mutex_lock(&file
->file_mutex
);
409 while (list_empty(&file
->events
)) {
410 mutex_unlock(&file
->file_mutex
);
412 if (file
->filp
->f_flags
& O_NONBLOCK
)
415 if (wait_event_interruptible(file
->poll_wait
,
416 !list_empty(&file
->events
)))
419 mutex_lock(&file
->file_mutex
);
422 uevent
= list_entry(file
->events
.next
, struct ib_ucm_event
, file_list
);
424 if (ib_ucm_new_cm_id(uevent
->resp
.event
)) {
425 ctx
= ib_ucm_ctx_alloc(file
);
431 ctx
->cm_id
= uevent
->cm_id
;
432 ctx
->cm_id
->context
= ctx
;
433 uevent
->resp
.id
= ctx
->id
;
436 if (copy_to_user((void __user
*)(unsigned long)cmd
.response
,
437 &uevent
->resp
, sizeof(uevent
->resp
))) {
443 if (cmd
.data_len
< uevent
->data_len
) {
447 if (copy_to_user((void __user
*)(unsigned long)cmd
.data
,
448 uevent
->data
, uevent
->data_len
)) {
455 if (cmd
.info_len
< uevent
->info_len
) {
459 if (copy_to_user((void __user
*)(unsigned long)cmd
.info
,
460 uevent
->info
, uevent
->info_len
)) {
466 list_del(&uevent
->file_list
);
467 list_del(&uevent
->ctx_list
);
468 uevent
->ctx
->events_reported
++;
474 mutex_unlock(&file
->file_mutex
);
478 static ssize_t
ib_ucm_create_id(struct ib_ucm_file
*file
,
479 const char __user
*inbuf
,
480 int in_len
, int out_len
)
482 struct ib_ucm_create_id cmd
;
483 struct ib_ucm_create_id_resp resp
;
484 struct ib_ucm_context
*ctx
;
487 if (out_len
< sizeof(resp
))
490 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
493 mutex_lock(&file
->file_mutex
);
494 ctx
= ib_ucm_ctx_alloc(file
);
495 mutex_unlock(&file
->file_mutex
);
500 ctx
->cm_id
= ib_create_cm_id(file
->device
->ib_dev
,
501 ib_ucm_event_handler
, ctx
);
502 if (IS_ERR(ctx
->cm_id
)) {
503 result
= PTR_ERR(ctx
->cm_id
);
508 if (copy_to_user((void __user
*)(unsigned long)cmd
.response
,
509 &resp
, sizeof(resp
))) {
516 ib_destroy_cm_id(ctx
->cm_id
);
518 mutex_lock(&ctx_id_mutex
);
519 idr_remove(&ctx_id_table
, ctx
->id
);
520 mutex_unlock(&ctx_id_mutex
);
525 static ssize_t
ib_ucm_destroy_id(struct ib_ucm_file
*file
,
526 const char __user
*inbuf
,
527 int in_len
, int out_len
)
529 struct ib_ucm_destroy_id cmd
;
530 struct ib_ucm_destroy_id_resp resp
;
531 struct ib_ucm_context
*ctx
;
534 if (out_len
< sizeof(resp
))
537 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
540 mutex_lock(&ctx_id_mutex
);
541 ctx
= idr_find(&ctx_id_table
, cmd
.id
);
543 ctx
= ERR_PTR(-ENOENT
);
544 else if (ctx
->file
!= file
)
545 ctx
= ERR_PTR(-EINVAL
);
547 idr_remove(&ctx_id_table
, ctx
->id
);
548 mutex_unlock(&ctx_id_mutex
);
554 wait_for_completion(&ctx
->comp
);
556 /* No new events will be generated after destroying the cm_id. */
557 ib_destroy_cm_id(ctx
->cm_id
);
558 /* Cleanup events not yet reported to the user. */
559 ib_ucm_cleanup_events(ctx
);
561 resp
.events_reported
= ctx
->events_reported
;
562 if (copy_to_user((void __user
*)(unsigned long)cmd
.response
,
563 &resp
, sizeof(resp
)))
570 static ssize_t
ib_ucm_attr_id(struct ib_ucm_file
*file
,
571 const char __user
*inbuf
,
572 int in_len
, int out_len
)
574 struct ib_ucm_attr_id_resp resp
;
575 struct ib_ucm_attr_id cmd
;
576 struct ib_ucm_context
*ctx
;
579 if (out_len
< sizeof(resp
))
582 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
585 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
589 resp
.service_id
= ctx
->cm_id
->service_id
;
590 resp
.service_mask
= ctx
->cm_id
->service_mask
;
591 resp
.local_id
= ctx
->cm_id
->local_id
;
592 resp
.remote_id
= ctx
->cm_id
->remote_id
;
594 if (copy_to_user((void __user
*)(unsigned long)cmd
.response
,
595 &resp
, sizeof(resp
)))
602 static ssize_t
ib_ucm_init_qp_attr(struct ib_ucm_file
*file
,
603 const char __user
*inbuf
,
604 int in_len
, int out_len
)
606 struct ib_uverbs_qp_attr resp
;
607 struct ib_ucm_init_qp_attr cmd
;
608 struct ib_ucm_context
*ctx
;
609 struct ib_qp_attr qp_attr
;
612 if (out_len
< sizeof(resp
))
615 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
618 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
622 resp
.qp_attr_mask
= 0;
623 memset(&qp_attr
, 0, sizeof qp_attr
);
624 qp_attr
.qp_state
= cmd
.qp_state
;
625 result
= ib_cm_init_qp_attr(ctx
->cm_id
, &qp_attr
, &resp
.qp_attr_mask
);
629 ib_copy_qp_attr_to_user(&resp
, &qp_attr
);
631 if (copy_to_user((void __user
*)(unsigned long)cmd
.response
,
632 &resp
, sizeof(resp
)))
640 static int ucm_validate_listen(__be64 service_id
, __be64 service_mask
)
642 service_id
&= service_mask
;
644 if (((service_id
& IB_CMA_SERVICE_ID_MASK
) == IB_CMA_SERVICE_ID
) ||
645 ((service_id
& IB_SDP_SERVICE_ID_MASK
) == IB_SDP_SERVICE_ID
))
651 static ssize_t
ib_ucm_listen(struct ib_ucm_file
*file
,
652 const char __user
*inbuf
,
653 int in_len
, int out_len
)
655 struct ib_ucm_listen cmd
;
656 struct ib_ucm_context
*ctx
;
659 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
662 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
666 result
= ucm_validate_listen(cmd
.service_id
, cmd
.service_mask
);
670 result
= ib_cm_listen(ctx
->cm_id
, cmd
.service_id
, cmd
.service_mask
,
677 static ssize_t
ib_ucm_notify(struct ib_ucm_file
*file
,
678 const char __user
*inbuf
,
679 int in_len
, int out_len
)
681 struct ib_ucm_notify cmd
;
682 struct ib_ucm_context
*ctx
;
685 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
688 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
692 result
= ib_cm_notify(ctx
->cm_id
, (enum ib_event_type
) cmd
.event
);
697 static int ib_ucm_alloc_data(const void **dest
, u64 src
, u32 len
)
706 data
= kmalloc(len
, GFP_KERNEL
);
710 if (copy_from_user(data
, (void __user
*)(unsigned long)src
, len
)) {
719 static int ib_ucm_path_get(struct ib_sa_path_rec
**path
, u64 src
)
721 struct ib_user_path_rec upath
;
722 struct ib_sa_path_rec
*sa_path
;
729 sa_path
= kmalloc(sizeof(*sa_path
), GFP_KERNEL
);
733 if (copy_from_user(&upath
, (void __user
*)(unsigned long)src
,
740 ib_copy_path_rec_from_user(sa_path
, &upath
);
745 static ssize_t
ib_ucm_send_req(struct ib_ucm_file
*file
,
746 const char __user
*inbuf
,
747 int in_len
, int out_len
)
749 struct ib_cm_req_param param
;
750 struct ib_ucm_context
*ctx
;
751 struct ib_ucm_req cmd
;
754 param
.private_data
= NULL
;
755 param
.primary_path
= NULL
;
756 param
.alternate_path
= NULL
;
758 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
761 result
= ib_ucm_alloc_data(¶m
.private_data
, cmd
.data
, cmd
.len
);
765 result
= ib_ucm_path_get(¶m
.primary_path
, cmd
.primary_path
);
769 result
= ib_ucm_path_get(¶m
.alternate_path
, cmd
.alternate_path
);
773 param
.private_data_len
= cmd
.len
;
774 param
.service_id
= cmd
.sid
;
775 param
.qp_num
= cmd
.qpn
;
776 param
.qp_type
= cmd
.qp_type
;
777 param
.starting_psn
= cmd
.psn
;
778 param
.peer_to_peer
= cmd
.peer_to_peer
;
779 param
.responder_resources
= cmd
.responder_resources
;
780 param
.initiator_depth
= cmd
.initiator_depth
;
781 param
.remote_cm_response_timeout
= cmd
.remote_cm_response_timeout
;
782 param
.flow_control
= cmd
.flow_control
;
783 param
.local_cm_response_timeout
= cmd
.local_cm_response_timeout
;
784 param
.retry_count
= cmd
.retry_count
;
785 param
.rnr_retry_count
= cmd
.rnr_retry_count
;
786 param
.max_cm_retries
= cmd
.max_cm_retries
;
789 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
791 result
= ib_send_cm_req(ctx
->cm_id
, ¶m
);
794 result
= PTR_ERR(ctx
);
797 kfree(param
.private_data
);
798 kfree(param
.primary_path
);
799 kfree(param
.alternate_path
);
803 static ssize_t
ib_ucm_send_rep(struct ib_ucm_file
*file
,
804 const char __user
*inbuf
,
805 int in_len
, int out_len
)
807 struct ib_cm_rep_param param
;
808 struct ib_ucm_context
*ctx
;
809 struct ib_ucm_rep cmd
;
812 param
.private_data
= NULL
;
814 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
817 result
= ib_ucm_alloc_data(¶m
.private_data
, cmd
.data
, cmd
.len
);
821 param
.qp_num
= cmd
.qpn
;
822 param
.starting_psn
= cmd
.psn
;
823 param
.private_data_len
= cmd
.len
;
824 param
.responder_resources
= cmd
.responder_resources
;
825 param
.initiator_depth
= cmd
.initiator_depth
;
826 param
.target_ack_delay
= cmd
.target_ack_delay
;
827 param
.failover_accepted
= cmd
.failover_accepted
;
828 param
.flow_control
= cmd
.flow_control
;
829 param
.rnr_retry_count
= cmd
.rnr_retry_count
;
832 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
835 result
= ib_send_cm_rep(ctx
->cm_id
, ¶m
);
838 result
= PTR_ERR(ctx
);
840 kfree(param
.private_data
);
844 static ssize_t
ib_ucm_send_private_data(struct ib_ucm_file
*file
,
845 const char __user
*inbuf
, int in_len
,
846 int (*func
)(struct ib_cm_id
*cm_id
,
847 const void *private_data
,
848 u8 private_data_len
))
850 struct ib_ucm_private_data cmd
;
851 struct ib_ucm_context
*ctx
;
852 const void *private_data
= NULL
;
855 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
858 result
= ib_ucm_alloc_data(&private_data
, cmd
.data
, cmd
.len
);
862 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
864 result
= func(ctx
->cm_id
, private_data
, cmd
.len
);
867 result
= PTR_ERR(ctx
);
873 static ssize_t
ib_ucm_send_rtu(struct ib_ucm_file
*file
,
874 const char __user
*inbuf
,
875 int in_len
, int out_len
)
877 return ib_ucm_send_private_data(file
, inbuf
, in_len
, ib_send_cm_rtu
);
880 static ssize_t
ib_ucm_send_dreq(struct ib_ucm_file
*file
,
881 const char __user
*inbuf
,
882 int in_len
, int out_len
)
884 return ib_ucm_send_private_data(file
, inbuf
, in_len
, ib_send_cm_dreq
);
887 static ssize_t
ib_ucm_send_drep(struct ib_ucm_file
*file
,
888 const char __user
*inbuf
,
889 int in_len
, int out_len
)
891 return ib_ucm_send_private_data(file
, inbuf
, in_len
, ib_send_cm_drep
);
894 static ssize_t
ib_ucm_send_info(struct ib_ucm_file
*file
,
895 const char __user
*inbuf
, int in_len
,
896 int (*func
)(struct ib_cm_id
*cm_id
,
903 struct ib_ucm_context
*ctx
;
904 struct ib_ucm_info cmd
;
905 const void *data
= NULL
;
906 const void *info
= NULL
;
909 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
912 result
= ib_ucm_alloc_data(&data
, cmd
.data
, cmd
.data_len
);
916 result
= ib_ucm_alloc_data(&info
, cmd
.info
, cmd
.info_len
);
920 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
922 result
= func(ctx
->cm_id
, cmd
.status
, info
, cmd
.info_len
,
926 result
= PTR_ERR(ctx
);
934 static ssize_t
ib_ucm_send_rej(struct ib_ucm_file
*file
,
935 const char __user
*inbuf
,
936 int in_len
, int out_len
)
938 return ib_ucm_send_info(file
, inbuf
, in_len
, (void *)ib_send_cm_rej
);
941 static ssize_t
ib_ucm_send_apr(struct ib_ucm_file
*file
,
942 const char __user
*inbuf
,
943 int in_len
, int out_len
)
945 return ib_ucm_send_info(file
, inbuf
, in_len
, (void *)ib_send_cm_apr
);
948 static ssize_t
ib_ucm_send_mra(struct ib_ucm_file
*file
,
949 const char __user
*inbuf
,
950 int in_len
, int out_len
)
952 struct ib_ucm_context
*ctx
;
953 struct ib_ucm_mra cmd
;
954 const void *data
= NULL
;
957 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
960 result
= ib_ucm_alloc_data(&data
, cmd
.data
, cmd
.len
);
964 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
966 result
= ib_send_cm_mra(ctx
->cm_id
, cmd
.timeout
, data
, cmd
.len
);
969 result
= PTR_ERR(ctx
);
975 static ssize_t
ib_ucm_send_lap(struct ib_ucm_file
*file
,
976 const char __user
*inbuf
,
977 int in_len
, int out_len
)
979 struct ib_ucm_context
*ctx
;
980 struct ib_sa_path_rec
*path
= NULL
;
981 struct ib_ucm_lap cmd
;
982 const void *data
= NULL
;
985 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
988 result
= ib_ucm_alloc_data(&data
, cmd
.data
, cmd
.len
);
992 result
= ib_ucm_path_get(&path
, cmd
.path
);
996 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
998 result
= ib_send_cm_lap(ctx
->cm_id
, path
, data
, cmd
.len
);
1001 result
= PTR_ERR(ctx
);
1009 static ssize_t
ib_ucm_send_sidr_req(struct ib_ucm_file
*file
,
1010 const char __user
*inbuf
,
1011 int in_len
, int out_len
)
1013 struct ib_cm_sidr_req_param param
;
1014 struct ib_ucm_context
*ctx
;
1015 struct ib_ucm_sidr_req cmd
;
1018 param
.private_data
= NULL
;
1021 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
1024 result
= ib_ucm_alloc_data(¶m
.private_data
, cmd
.data
, cmd
.len
);
1028 result
= ib_ucm_path_get(¶m
.path
, cmd
.path
);
1032 param
.private_data_len
= cmd
.len
;
1033 param
.service_id
= cmd
.sid
;
1034 param
.timeout_ms
= cmd
.timeout
;
1035 param
.max_cm_retries
= cmd
.max_cm_retries
;
1037 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
1039 result
= ib_send_cm_sidr_req(ctx
->cm_id
, ¶m
);
1040 ib_ucm_ctx_put(ctx
);
1042 result
= PTR_ERR(ctx
);
1045 kfree(param
.private_data
);
1050 static ssize_t
ib_ucm_send_sidr_rep(struct ib_ucm_file
*file
,
1051 const char __user
*inbuf
,
1052 int in_len
, int out_len
)
1054 struct ib_cm_sidr_rep_param param
;
1055 struct ib_ucm_sidr_rep cmd
;
1056 struct ib_ucm_context
*ctx
;
1061 if (copy_from_user(&cmd
, inbuf
, sizeof(cmd
)))
1064 result
= ib_ucm_alloc_data(¶m
.private_data
,
1065 cmd
.data
, cmd
.data_len
);
1069 result
= ib_ucm_alloc_data(¶m
.info
, cmd
.info
, cmd
.info_len
);
1073 param
.qp_num
= cmd
.qpn
;
1074 param
.qkey
= cmd
.qkey
;
1075 param
.status
= cmd
.status
;
1076 param
.info_length
= cmd
.info_len
;
1077 param
.private_data_len
= cmd
.data_len
;
1079 ctx
= ib_ucm_ctx_get(file
, cmd
.id
);
1081 result
= ib_send_cm_sidr_rep(ctx
->cm_id
, ¶m
);
1082 ib_ucm_ctx_put(ctx
);
1084 result
= PTR_ERR(ctx
);
1087 kfree(param
.private_data
);
1092 static ssize_t (*ucm_cmd_table
[])(struct ib_ucm_file
*file
,
1093 const char __user
*inbuf
,
1094 int in_len
, int out_len
) = {
1095 [IB_USER_CM_CMD_CREATE_ID
] = ib_ucm_create_id
,
1096 [IB_USER_CM_CMD_DESTROY_ID
] = ib_ucm_destroy_id
,
1097 [IB_USER_CM_CMD_ATTR_ID
] = ib_ucm_attr_id
,
1098 [IB_USER_CM_CMD_LISTEN
] = ib_ucm_listen
,
1099 [IB_USER_CM_CMD_NOTIFY
] = ib_ucm_notify
,
1100 [IB_USER_CM_CMD_SEND_REQ
] = ib_ucm_send_req
,
1101 [IB_USER_CM_CMD_SEND_REP
] = ib_ucm_send_rep
,
1102 [IB_USER_CM_CMD_SEND_RTU
] = ib_ucm_send_rtu
,
1103 [IB_USER_CM_CMD_SEND_DREQ
] = ib_ucm_send_dreq
,
1104 [IB_USER_CM_CMD_SEND_DREP
] = ib_ucm_send_drep
,
1105 [IB_USER_CM_CMD_SEND_REJ
] = ib_ucm_send_rej
,
1106 [IB_USER_CM_CMD_SEND_MRA
] = ib_ucm_send_mra
,
1107 [IB_USER_CM_CMD_SEND_LAP
] = ib_ucm_send_lap
,
1108 [IB_USER_CM_CMD_SEND_APR
] = ib_ucm_send_apr
,
1109 [IB_USER_CM_CMD_SEND_SIDR_REQ
] = ib_ucm_send_sidr_req
,
1110 [IB_USER_CM_CMD_SEND_SIDR_REP
] = ib_ucm_send_sidr_rep
,
1111 [IB_USER_CM_CMD_EVENT
] = ib_ucm_event
,
1112 [IB_USER_CM_CMD_INIT_QP_ATTR
] = ib_ucm_init_qp_attr
,
1115 static ssize_t
ib_ucm_write(struct file
*filp
, const char __user
*buf
,
1116 size_t len
, loff_t
*pos
)
1118 struct ib_ucm_file
*file
= filp
->private_data
;
1119 struct ib_ucm_cmd_hdr hdr
;
1122 if (len
< sizeof(hdr
))
1125 if (copy_from_user(&hdr
, buf
, sizeof(hdr
)))
1128 if (hdr
.cmd
< 0 || hdr
.cmd
>= ARRAY_SIZE(ucm_cmd_table
))
1131 if (hdr
.in
+ sizeof(hdr
) > len
)
1134 result
= ucm_cmd_table
[hdr
.cmd
](file
, buf
+ sizeof(hdr
),
1142 static unsigned int ib_ucm_poll(struct file
*filp
,
1143 struct poll_table_struct
*wait
)
1145 struct ib_ucm_file
*file
= filp
->private_data
;
1146 unsigned int mask
= 0;
1148 poll_wait(filp
, &file
->poll_wait
, wait
);
1150 if (!list_empty(&file
->events
))
1151 mask
= POLLIN
| POLLRDNORM
;
1156 static int ib_ucm_open(struct inode
*inode
, struct file
*filp
)
1158 struct ib_ucm_file
*file
;
1160 file
= kmalloc(sizeof(*file
), GFP_KERNEL
);
1164 INIT_LIST_HEAD(&file
->events
);
1165 INIT_LIST_HEAD(&file
->ctxs
);
1166 init_waitqueue_head(&file
->poll_wait
);
1168 mutex_init(&file
->file_mutex
);
1170 filp
->private_data
= file
;
1172 file
->device
= container_of(inode
->i_cdev
, struct ib_ucm_device
, dev
);
1177 static int ib_ucm_close(struct inode
*inode
, struct file
*filp
)
1179 struct ib_ucm_file
*file
= filp
->private_data
;
1180 struct ib_ucm_context
*ctx
;
1182 mutex_lock(&file
->file_mutex
);
1183 while (!list_empty(&file
->ctxs
)) {
1184 ctx
= list_entry(file
->ctxs
.next
,
1185 struct ib_ucm_context
, file_list
);
1186 mutex_unlock(&file
->file_mutex
);
1188 mutex_lock(&ctx_id_mutex
);
1189 idr_remove(&ctx_id_table
, ctx
->id
);
1190 mutex_unlock(&ctx_id_mutex
);
1192 ib_destroy_cm_id(ctx
->cm_id
);
1193 ib_ucm_cleanup_events(ctx
);
1196 mutex_lock(&file
->file_mutex
);
1198 mutex_unlock(&file
->file_mutex
);
1203 static void ib_ucm_release_class_dev(struct class_device
*class_dev
)
1205 struct ib_ucm_device
*dev
;
1207 dev
= container_of(class_dev
, struct ib_ucm_device
, class_dev
);
1208 cdev_del(&dev
->dev
);
1209 clear_bit(dev
->devnum
, dev_map
);
1213 static const struct file_operations ucm_fops
= {
1214 .owner
= THIS_MODULE
,
1215 .open
= ib_ucm_open
,
1216 .release
= ib_ucm_close
,
1217 .write
= ib_ucm_write
,
1218 .poll
= ib_ucm_poll
,
1221 static struct class ucm_class
= {
1222 .name
= "infiniband_cm",
1223 .release
= ib_ucm_release_class_dev
1226 static ssize_t
show_ibdev(struct class_device
*class_dev
, char *buf
)
1228 struct ib_ucm_device
*dev
;
1230 dev
= container_of(class_dev
, struct ib_ucm_device
, class_dev
);
1231 return sprintf(buf
, "%s\n", dev
->ib_dev
->name
);
1233 static CLASS_DEVICE_ATTR(ibdev
, S_IRUGO
, show_ibdev
, NULL
);
1235 static void ib_ucm_add_one(struct ib_device
*device
)
1237 struct ib_ucm_device
*ucm_dev
;
1239 if (!device
->alloc_ucontext
||
1240 rdma_node_get_transport(device
->node_type
) != RDMA_TRANSPORT_IB
)
1243 ucm_dev
= kzalloc(sizeof *ucm_dev
, GFP_KERNEL
);
1247 ucm_dev
->ib_dev
= device
;
1249 ucm_dev
->devnum
= find_first_zero_bit(dev_map
, IB_UCM_MAX_DEVICES
);
1250 if (ucm_dev
->devnum
>= IB_UCM_MAX_DEVICES
)
1253 set_bit(ucm_dev
->devnum
, dev_map
);
1255 cdev_init(&ucm_dev
->dev
, &ucm_fops
);
1256 ucm_dev
->dev
.owner
= THIS_MODULE
;
1257 kobject_set_name(&ucm_dev
->dev
.kobj
, "ucm%d", ucm_dev
->devnum
);
1258 if (cdev_add(&ucm_dev
->dev
, IB_UCM_BASE_DEV
+ ucm_dev
->devnum
, 1))
1261 ucm_dev
->class_dev
.class = &ucm_class
;
1262 ucm_dev
->class_dev
.dev
= device
->dma_device
;
1263 ucm_dev
->class_dev
.devt
= ucm_dev
->dev
.dev
;
1264 snprintf(ucm_dev
->class_dev
.class_id
, BUS_ID_SIZE
, "ucm%d",
1266 if (class_device_register(&ucm_dev
->class_dev
))
1269 if (class_device_create_file(&ucm_dev
->class_dev
,
1270 &class_device_attr_ibdev
))
1273 ib_set_client_data(device
, &ucm_client
, ucm_dev
);
1277 class_device_unregister(&ucm_dev
->class_dev
);
1279 cdev_del(&ucm_dev
->dev
);
1280 clear_bit(ucm_dev
->devnum
, dev_map
);
1286 static void ib_ucm_remove_one(struct ib_device
*device
)
1288 struct ib_ucm_device
*ucm_dev
= ib_get_client_data(device
, &ucm_client
);
1293 class_device_unregister(&ucm_dev
->class_dev
);
1296 static ssize_t
show_abi_version(struct class *class, char *buf
)
1298 return sprintf(buf
, "%d\n", IB_USER_CM_ABI_VERSION
);
1300 static CLASS_ATTR(abi_version
, S_IRUGO
, show_abi_version
, NULL
);
1302 static int __init
ib_ucm_init(void)
1306 ret
= register_chrdev_region(IB_UCM_BASE_DEV
, IB_UCM_MAX_DEVICES
,
1309 printk(KERN_ERR
"ucm: couldn't register device number\n");
1313 ret
= class_register(&ucm_class
);
1315 printk(KERN_ERR
"ucm: couldn't create class infiniband_cm\n");
1319 ret
= class_create_file(&ucm_class
, &class_attr_abi_version
);
1321 printk(KERN_ERR
"ucm: couldn't create abi_version attribute\n");
1325 ret
= ib_register_client(&ucm_client
);
1327 printk(KERN_ERR
"ucm: couldn't register client\n");
1333 class_unregister(&ucm_class
);
1335 unregister_chrdev_region(IB_UCM_BASE_DEV
, IB_UCM_MAX_DEVICES
);
1340 static void __exit
ib_ucm_cleanup(void)
1342 ib_unregister_client(&ucm_client
);
1343 class_unregister(&ucm_class
);
1344 unregister_chrdev_region(IB_UCM_BASE_DEV
, IB_UCM_MAX_DEVICES
);
1345 idr_destroy(&ctx_id_table
);
1348 module_init(ib_ucm_init
);
1349 module_exit(ib_ucm_cleanup
);