15  *      - Redistributions of source code must retain the above
19  *      - Redistributions in binary form must reproduce the above
42  * iwpm_valid_pid - Check if the userspace iwarp port mapper pid is valid
44  * Returns true if the pid is greater than zero, otherwise returns false
52  * iwpm_register_pid - Send a netlink query to userspace
53  *                     to get the iwarp port mapper pid
70 	int ret = -EINVAL;  in iwpm_register_pid()
80 	nlh->nlmsg_seq = iwpm_get_nlmsg_seq();  in iwpm_register_pid()
81 	nlmsg_request = iwpm_get_nlmsg_request(nlh->nlmsg_seq, nl_client, GFP_KERNEL);  in iwpm_register_pid()
88 	/* fill in the pid request message */  in iwpm_register_pid()
94 			    pm_msg->if_name, IWPM_NLA_REG_IF_NAME);  in iwpm_register_pid()
98 				pm_msg->dev_name, IWPM_NLA_REG_IBDEV_NAME);  in iwpm_register_pid()
109 		__func__, pm_msg->dev_name, pm_msg->if_name, iwpm_ulib_name);  in iwpm_register_pid()
113 		skb = NULL; /* skb is freed in the netlink send-op handling */  in iwpm_register_pid()
118 	nlmsg_request->req_buffer = pm_msg;  in iwpm_register_pid()
125 		iwpm_free_nlmsg_request(&nlmsg_request->kref);  in iwpm_register_pid()
130  * iwpm_add_mapping - Send a netlink add mapping request to
150 	int ret = -EINVAL;  in iwpm_add_mapping()
163 	nlh->nlmsg_seq = iwpm_get_nlmsg_seq();  in iwpm_add_mapping()
164 	nlmsg_request = iwpm_get_nlmsg_request(nlh->nlmsg_seq, nl_client, GFP_KERNEL);  in iwpm_add_mapping()
177 				&pm_msg->loc_addr, IWPM_NLA_MANAGE_ADDR);  in iwpm_add_mapping()
182 	if (pm_msg->flags && iwpm_ulib_version == IWPM_UABI_VERSION_MIN) {  in iwpm_add_mapping()
183 		ret = -EINVAL;  in iwpm_add_mapping()
187 		ret = ibnl_put_attr(skb, nlh, sizeof(u32), &pm_msg->flags,  in iwpm_add_mapping()
194 	nlmsg_request->req_buffer = pm_msg;  in iwpm_add_mapping()
198 		skb = NULL; /* skb is freed in the netlink send-op handling */  in iwpm_add_mapping()
210 		iwpm_free_nlmsg_request(&nlmsg_request->kref);  in iwpm_add_mapping()
215  * iwpm_add_and_query_mapping - Process the port mapper response to
233 	int ret = -EINVAL;  in iwpm_add_and_query_mapping()
241 	ret = -ENOMEM;  in iwpm_add_and_query_mapping()
247 	nlh->nlmsg_seq = iwpm_get_nlmsg_seq();  in iwpm_add_and_query_mapping()
248 	nlmsg_request = iwpm_get_nlmsg_request(nlh->nlmsg_seq,  in iwpm_add_and_query_mapping()
263 				&pm_msg->loc_addr, IWPM_NLA_QUERY_LOCAL_ADDR);  in iwpm_add_and_query_mapping()
267 				&pm_msg->rem_addr, IWPM_NLA_QUERY_REMOTE_ADDR);  in iwpm_add_and_query_mapping()
272 	if (pm_msg->flags && iwpm_ulib_version == IWPM_UABI_VERSION_MIN) {  in iwpm_add_and_query_mapping()
273 		ret = -EINVAL;  in iwpm_add_and_query_mapping()
277 		ret = ibnl_put_attr(skb, nlh, sizeof(u32), &pm_msg->flags,  in iwpm_add_and_query_mapping()
284 	nlmsg_request->req_buffer = pm_msg;  in iwpm_add_and_query_mapping()
288 		skb = NULL; /* skb is freed in the netlink send-op handling */  in iwpm_add_and_query_mapping()
299 		iwpm_free_nlmsg_request(&nlmsg_request->kref);  in iwpm_add_and_query_mapping()
304  * iwpm_remove_mapping - Send a netlink remove mapping request
320 	int ret = -EINVAL;  in iwpm_remove_mapping()
330 		ret = -ENOMEM;  in iwpm_remove_mapping()
335 	nlh->nlmsg_seq = iwpm_get_nlmsg_seq();  in iwpm_remove_mapping()
350 		skb = NULL; /* skb is freed in the netlink send-op handling */  in iwpm_remove_mapping()
365 /* netlink attribute policy for the received response to register pid request */
369 					.len = IWPM_DEVNAME_SIZE - 1 },
371 					.len = IWPM_ULIBNAME_SIZE - 1 },
377  * iwpm_register_pid_cb - Process the port mapper response to
382  * If successful, the function receives the userspace port mapper pid
394 	const char *msg_type = "Register Pid response";  in iwpm_register_pid_cb()
398 		return -EINVAL;  in iwpm_register_pid_cb()
405 		return -EINVAL;  in iwpm_register_pid_cb()
407 	pm_msg = nlmsg_request->req_buffer;  in iwpm_register_pid_cb()
408 	nl_client = nlmsg_request->nl_client;  in iwpm_register_pid_cb()
414 	if (strcmp(pm_msg->dev_name, dev_name) ||  in iwpm_register_pid_cb()
420 		nlmsg_request->err_code = IWPM_USER_LIB_INFO_ERR;  in iwpm_register_pid_cb()
423 	iwpm_user_pid = cb->nlh->nlmsg_pid;  in iwpm_register_pid_cb()
426 		pr_warn_once("%s: Down level iwpmd/pid %d.  Continuing...",  in iwpm_register_pid_cb()
428 	atomic_set(&echo_nlmsg_seq, cb->nlh->nlmsg_seq);  in iwpm_register_pid_cb()
429 	pr_debug("%s: iWarp Port Mapper (pid = %d) is available!\n",  in iwpm_register_pid_cb()
433 	nlmsg_request->request_done = 1;  in iwpm_register_pid_cb()
435 	kref_put(&nlmsg_request->kref, iwpm_free_nlmsg_request);  in iwpm_register_pid_cb()
437 	up(&nlmsg_request->sem);  in iwpm_register_pid_cb()
452  * iwpm_add_mapping_cb - Process the port mapper response to
470 		return -EINVAL;  in iwpm_add_mapping_cb()
472 	atomic_set(&echo_nlmsg_seq, cb->nlh->nlmsg_seq);  in iwpm_add_mapping_cb()
479 		return -EINVAL;  in iwpm_add_mapping_cb()
481 	pm_msg = nlmsg_request->req_buffer;  in iwpm_add_mapping_cb()
487 	if (iwpm_compare_sockaddr(local_sockaddr, &pm_msg->loc_addr)) {  in iwpm_add_mapping_cb()
488 		nlmsg_request->err_code = IWPM_USER_LIB_INFO_ERR;  in iwpm_add_mapping_cb()
491 	if (mapped_sockaddr->ss_family != local_sockaddr->ss_family) {  in iwpm_add_mapping_cb()
494 		nlmsg_request->err_code = IWPM_USER_LIB_INFO_ERR;  in iwpm_add_mapping_cb()
497 	memcpy(&pm_msg->mapped_loc_addr, mapped_sockaddr,  in iwpm_add_mapping_cb()
499 	iwpm_print_sockaddr(&pm_msg->loc_addr,  in iwpm_add_mapping_cb()
501 	iwpm_print_sockaddr(&pm_msg->mapped_loc_addr,  in iwpm_add_mapping_cb()
505 	nlmsg_request->request_done = 1;  in iwpm_add_mapping_cb()
507 	kref_put(&nlmsg_request->kref, iwpm_free_nlmsg_request);  in iwpm_add_mapping_cb()
509 	up(&nlmsg_request->sem);  in iwpm_add_mapping_cb()
514  * and response with remote address info
530  * iwpm_add_and_query_mapping_cb - Process the port mapper response to
550 		return -EINVAL;  in iwpm_add_and_query_mapping_cb()
551 	atomic_set(&echo_nlmsg_seq, cb->nlh->nlmsg_seq);  in iwpm_add_and_query_mapping_cb()
558 		return -EINVAL;  in iwpm_add_and_query_mapping_cb()
560 	pm_msg = nlmsg_request->req_buffer;  in iwpm_add_and_query_mapping_cb()
572 		pr_info("%s: Received a Reject (pid = %u, echo seq = %u)\n",  in iwpm_add_and_query_mapping_cb()
573 			__func__, cb->nlh->nlmsg_pid, msg_seq);  in iwpm_add_and_query_mapping_cb()
574 		nlmsg_request->err_code = IWPM_REMOTE_QUERY_REJECT;  in iwpm_add_and_query_mapping_cb()
576 	if (iwpm_compare_sockaddr(local_sockaddr, &pm_msg->loc_addr) ||  in iwpm_add_and_query_mapping_cb()
577 		iwpm_compare_sockaddr(remote_sockaddr, &pm_msg->rem_addr)) {  in iwpm_add_and_query_mapping_cb()
579 		nlmsg_request->err_code = IWPM_USER_LIB_INFO_ERR;  in iwpm_add_and_query_mapping_cb()
582 	if (mapped_loc_sockaddr->ss_family != local_sockaddr->ss_family ||  in iwpm_add_and_query_mapping_cb()
583 		mapped_rem_sockaddr->ss_family != remote_sockaddr->ss_family) {  in iwpm_add_and_query_mapping_cb()
586 		nlmsg_request->err_code = IWPM_USER_LIB_INFO_ERR;  in iwpm_add_and_query_mapping_cb()
589 	memcpy(&pm_msg->mapped_loc_addr, mapped_loc_sockaddr,  in iwpm_add_and_query_mapping_cb()
591 	memcpy(&pm_msg->mapped_rem_addr, mapped_rem_sockaddr,  in iwpm_add_and_query_mapping_cb()
594 	iwpm_print_sockaddr(&pm_msg->loc_addr,  in iwpm_add_and_query_mapping_cb()
596 	iwpm_print_sockaddr(&pm_msg->mapped_loc_addr,  in iwpm_add_and_query_mapping_cb()
598 	iwpm_print_sockaddr(&pm_msg->rem_addr,  in iwpm_add_and_query_mapping_cb()
599 			"query_mapping: Remote sockaddr:");  in iwpm_add_and_query_mapping_cb()
600 	iwpm_print_sockaddr(&pm_msg->mapped_rem_addr,  in iwpm_add_and_query_mapping_cb()
601 			"query_mapping: Mapped remote sockaddr:");  in iwpm_add_and_query_mapping_cb()
603 	nlmsg_request->request_done = 1;  in iwpm_add_and_query_mapping_cb()
605 	kref_put(&nlmsg_request->kref, iwpm_free_nlmsg_request);  in iwpm_add_and_query_mapping_cb()
607 	up(&nlmsg_request->sem);  in iwpm_add_and_query_mapping_cb()
612  * iwpm_remote_info_cb - Process remote connecting peer address info, which
627 	int ret = -EINVAL;  in iwpm_remote_info_cb()
629 	msg_type = "Remote Mapping info";  in iwpm_remote_info_cb()
634 	nl_client = RDMA_NL_GET_CLIENT(cb->nlh->nlmsg_type);  in iwpm_remote_info_cb()
635 	atomic_set(&echo_nlmsg_seq, cb->nlh->nlmsg_seq);  in iwpm_remote_info_cb()
646 	if (mapped_loc_sockaddr->ss_family != local_sockaddr->ss_family ||  in iwpm_remote_info_cb()
647 		mapped_rem_sockaddr->ss_family != remote_sockaddr->ss_family) {  in iwpm_remote_info_cb()
654 		ret = -ENOMEM;  in iwpm_remote_info_cb()
657 	memcpy(&rem_info->mapped_loc_sockaddr, mapped_loc_sockaddr,  in iwpm_remote_info_cb()
659 	memcpy(&rem_info->remote_sockaddr, remote_sockaddr,  in iwpm_remote_info_cb()
661 	memcpy(&rem_info->mapped_rem_sockaddr, mapped_rem_sockaddr,  in iwpm_remote_info_cb()
663 	rem_info->nl_client = nl_client;  in iwpm_remote_info_cb()
672 			"remote_info: Remote sockaddr:");  in iwpm_remote_info_cb()
674 			"remote_info: Mapped remote sockaddr:");  in iwpm_remote_info_cb()
681 					.len = IWPM_ULIBNAME_SIZE - 1 },
686  * iwpm_mapping_info_cb - Process a notification that the userspace
691  * Using the received port mapper pid, send all the local mapping
701 	int ret = -EINVAL;  in iwpm_mapping_info_cb()
716 	nl_client = RDMA_NL_GET_CLIENT(cb->nlh->nlmsg_type);  in iwpm_mapping_info_cb()
718 	atomic_set(&echo_nlmsg_seq, cb->nlh->nlmsg_seq);  in iwpm_mapping_info_cb()
719 	iwpm_user_pid = cb->nlh->nlmsg_pid;  in iwpm_mapping_info_cb()
722 		pr_warn_once("%s: Down level iwpmd/pid %d.  Continuing...",  in iwpm_mapping_info_cb()
727 	pr_debug("%s: iWarp Port Mapper (pid = %d) is available!\n",  in iwpm_mapping_info_cb()
741  * iwpm_ack_mapping_info_cb - Process the port mapper ack for
754 		return -EINVAL;  in iwpm_ack_mapping_info_cb()
758 		pr_info("%s: Invalid mapinfo number (sent = %u ack-ed = %u)\n",  in iwpm_ack_mapping_info_cb()
760 	atomic_set(&echo_nlmsg_seq, cb->nlh->nlmsg_seq);  in iwpm_ack_mapping_info_cb()
771  * iwpm_mapping_error_cb - Process port mapper notification for error
779 	int nl_client = RDMA_NL_GET_CLIENT(cb->nlh->nlmsg_type);  in iwpm_mapping_error_cb()
787 		return -EINVAL;  in iwpm_mapping_error_cb()
800 	atomic_set(&echo_nlmsg_seq, cb->nlh->nlmsg_seq);  in iwpm_mapping_error_cb()
801 	nlmsg_request->err_code = err_code;  in iwpm_mapping_error_cb()
802 	nlmsg_request->request_done = 1;  in iwpm_mapping_error_cb()
804 	kref_put(&nlmsg_request->kref, iwpm_free_nlmsg_request);  in iwpm_mapping_error_cb()
806 	up(&nlmsg_request->sem);  in iwpm_mapping_error_cb()
816  * iwpm_hello_cb - Process a hello message from iwpmd
821  * Using the received port mapper pid, send the kernel's abi_version
830 	int ret = -EINVAL;  in iwpm_hello_cb()
838 	nl_client = RDMA_NL_GET_CLIENT(cb->nlh->nlmsg_type);  in iwpm_hello_cb()
840 	atomic_set(&echo_nlmsg_seq, cb->nlh->nlmsg_seq);  in iwpm_hello_cb()
843 	iwpm_user_pid = cb->nlh->nlmsg_pid;  in iwpm_hello_cb()