ofed/librdmacm/cma.c

63 	(req)->cmd = UCMA_CMD_##op;		\
520 	struct ucma_abi_create_id cmd;
532 	CMA_INIT_CMD_RESP(&cmd, sizeof cmd, CREATE_ID, &resp, sizeof resp);
533 	cmd.uid = (uintptr_t) id_priv;
534 	cmd.ps = ps;
535 	cmd.qp_type = qp_type;
537 	ret = write(id_priv->id.channel->fd, &cmd, sizeof cmd);
538 	if (ret != sizeof cmd)
566 	struct ucma_abi_destroy_id cmd;
569 	CMA_INIT_CMD_RESP(&cmd, sizeof cmd, DESTROY_ID, &resp, sizeof resp);
570 	cmd.id = handle;
572 	ret = write(fd, &cmd, sizeof cmd);
573 	if (ret != sizeof cmd)
623 	struct ucma_abi_query cmd;
627 	CMA_INIT_CMD_RESP(&cmd, sizeof cmd, QUERY, &resp, sizeof resp);
629 	cmd.id = id_priv->handle;
630 	cmd.option = UCMA_QUERY_ADDR;
632 	ret = write(id->channel->fd, &cmd, sizeof cmd);
633 	if (ret != sizeof cmd)
655 	struct ucma_abi_query cmd;
660 	CMA_INIT_CMD_RESP(&cmd, sizeof cmd, QUERY, &resp, sizeof resp);
662 	cmd.id = id_priv->handle;
663 	cmd.option = UCMA_QUERY_GID;
665 	ret = write(id->channel->fd, &cmd, sizeof cmd);
666 	if (ret != sizeof cmd)
715 	struct ucma_abi_query cmd;
721 	CMA_INIT_CMD_RESP(&cmd, sizeof cmd, QUERY, resp, size);
723 	cmd.id = id_priv->handle;
724 	cmd.option = UCMA_QUERY_PATH;
726 	ret = write(id->channel->fd, &cmd, sizeof cmd);
727 	if (ret != sizeof cmd)
749 	struct ucma_abi_query cmd;
753 	CMA_INIT_CMD_RESP(&cmd, sizeof cmd, QUERY_ROUTE, &resp, sizeof resp);
755 	cmd.id = id_priv->handle;
757 	ret = write(id->channel->fd, &cmd, sizeof cmd);
758 	if (ret != sizeof cmd)
798 	struct ucma_abi_bind cmd;
802 	CMA_INIT_CMD(&cmd, sizeof cmd, BIND);
804 	cmd.id = id_priv->handle;
805 	cmd.addr_size = addrlen;
806 	memcpy(&cmd.addr, addr, addrlen);
808 	ret = write(id->channel->fd, &cmd, sizeof cmd);
809 	if (ret != sizeof cmd)
820 	struct ucma_abi_bind_ip cmd;
831 	CMA_INIT_CMD(&cmd, sizeof cmd, BIND_IP);
833 	cmd.id = id_priv->handle;
834 	memcpy(&cmd.addr, addr, addrlen);
836 	ret = write(id->channel->fd, &cmd, sizeof cmd);
837 	if (ret != sizeof cmd)
876 	struct ucma_abi_resolve_addr cmd;
880 	CMA_INIT_CMD(&cmd, sizeof cmd, RESOLVE_ADDR);
882 	cmd.id = id_priv->handle;
883 	if ((cmd.src_size = src_len))
884 		memcpy(&cmd.src_addr, src_addr, src_len);
885 	memcpy(&cmd.dst_addr, dst_addr, dst_len);
886 	cmd.dst_size = dst_len;
887 	cmd.timeout_ms = timeout_ms;
889 	ret = write(id->channel->fd, &cmd, sizeof cmd);
890 	if (ret != sizeof cmd)
900 	struct ucma_abi_resolve_ip cmd;
916 	CMA_INIT_CMD(&cmd, sizeof cmd, RESOLVE_IP);
918 	cmd.id = id_priv->handle;
920 		memcpy(&cmd.src_addr, src_addr, src_len);
921 	memcpy(&cmd.dst_addr, dst_addr, dst_len);
922 	cmd.timeout_ms = timeout_ms;
924 	ret = write(id->channel->fd, &cmd, sizeof cmd);
925 	if (ret != sizeof cmd)
961 	struct ucma_abi_resolve_route cmd;
972 	CMA_INIT_CMD(&cmd, sizeof cmd, RESOLVE_ROUTE);
973 	cmd.id = id_priv->handle;
974 	cmd.timeout_ms = timeout_ms;
976 	ret = write(id->channel->fd, &cmd, sizeof cmd);
977 	if (ret != sizeof cmd)
992 	struct ucma_abi_init_qp_attr cmd;
997 	CMA_INIT_CMD_RESP(&cmd, sizeof cmd, INIT_QP_ATTR, &resp, sizeof resp);
999 	cmd.id = id_priv->handle;
1000 	cmd.qp_state = qp_attr->qp_state;
1002 	ret = write(id->channel->fd, &cmd, sizeof cmd);
1003 	if (ret != sizeof cmd)
1470 	struct ucma_abi_connect cmd;
1488 	CMA_INIT_CMD(&cmd, sizeof cmd, CONNECT);
1489 	cmd.id = id_priv->handle;
1491 		ucma_copy_conn_param_to_kern(id_priv, &cmd.conn_param,
1495 		ucma_copy_conn_param_to_kern(id_priv, &cmd.conn_param,
1499 		ucma_copy_conn_param_to_kern(id_priv, &cmd.conn_param,
1503 	ret = write(id->channel->fd, &cmd, sizeof cmd);
1504 	if (ret != sizeof cmd)
1517 	struct ucma_abi_listen cmd;
1521 	CMA_INIT_CMD(&cmd, sizeof cmd, LISTEN);
1523 	cmd.id = id_priv->handle;
1524 	cmd.backlog = backlog;
1526 	ret = write(id->channel->fd, &cmd, sizeof cmd);
1527 	if (ret != sizeof cmd)
1585 	struct ucma_abi_accept cmd;
1617 	CMA_INIT_CMD(&cmd, sizeof cmd, ACCEPT);
1618 	cmd.id = id_priv->handle;
1619 	cmd.uid = (uintptr_t) id_priv;
1621 		ucma_copy_conn_param_to_kern(id_priv, &cmd.conn_param,
1625 		ucma_copy_conn_param_to_kern(id_priv, &cmd.conn_param,
1629 	ret = write(id->channel->fd, &cmd, sizeof cmd);
1630 	if (ret != sizeof cmd) {
1644 	struct ucma_abi_reject cmd;
1648 	CMA_INIT_CMD(&cmd, sizeof cmd, REJECT);
1651 	cmd.id = id_priv->handle;
1653 		memcpy(cmd.private_data, private_data, private_data_len);
1654 		cmd.private_data_len = private_data_len;
1657 	ret = write(id->channel->fd, &cmd, sizeof cmd);
1658 	if (ret != sizeof cmd)
1666 	struct ucma_abi_notify cmd;
1670 	CMA_INIT_CMD(&cmd, sizeof cmd, NOTIFY);
1673 	cmd.id = id_priv->handle;
1674 	cmd.event = event;
1675 	ret = write(id->channel->fd, &cmd, sizeof cmd);
1676 	if (ret != sizeof cmd)
1696 	struct ucma_abi_disconnect cmd;
1704 	CMA_INIT_CMD(&cmd, sizeof cmd, DISCONNECT);
1706 	cmd.id = id_priv->handle;
1708 	ret = write(id->channel->fd, &cmd, sizeof cmd);
1709 	if (ret != sizeof cmd)
1742 		struct ucma_abi_join_mcast cmd;
1744 		CMA_INIT_CMD_RESP(&cmd, sizeof cmd, JOIN_MCAST, &resp, sizeof resp);
1745 		cmd.id = id_priv->handle;
1746 		memcpy(&cmd.addr, addr, addrlen);
1747 		cmd.addr_size = addrlen;
1748 		cmd.uid = (uintptr_t) mc;
1749 		cmd.reserved = 0;
1751 		ret = write(id->channel->fd, &cmd, sizeof cmd);
1752 		if (ret != sizeof cmd) {
1757 		struct ucma_abi_join_ip_mcast cmd;
1759 		CMA_INIT_CMD_RESP(&cmd, sizeof cmd, JOIN_IP_MCAST, &resp, sizeof resp);
1760 		cmd.id = id_priv->handle;
1761 		memcpy(&cmd.addr, addr, addrlen);
1762 		cmd.uid = (uintptr_t) mc;
1764 		ret = write(id->channel->fd, &cmd, sizeof cmd);
1765 		if (ret != sizeof cmd) {
1801 	struct ucma_abi_destroy_id cmd;
1827 	CMA_INIT_CMD_RESP(&cmd, sizeof cmd, LEAVE_MCAST, &resp, sizeof resp);
1828 	cmd.id = mc->handle;
1830 	ret = write(id->channel->fd, &cmd, sizeof cmd);
1831 	if (ret != sizeof cmd) {
1978 	struct ucma_abi_accept cmd;
1989 	CMA_INIT_CMD(&cmd, sizeof cmd, ACCEPT);
1990 	cmd.id = id_priv->handle;
1992 	ret = write(id_priv->id.channel->fd, &cmd, sizeof cmd);
1993 	if (ret != sizeof cmd) {
2058 	struct ucma_abi_get_event cmd;
2075 	CMA_INIT_CMD_RESP(&cmd, sizeof cmd, GET_EVENT, &resp, sizeof resp);
2076 	ret = write(channel->fd, &cmd, sizeof cmd);
2077 	if (ret != sizeof cmd) {
2235 	struct ucma_abi_set_option cmd;
2239 	CMA_INIT_CMD(&cmd, sizeof cmd, SET_OPTION);
2241 	cmd.id = id_priv->handle;
2242 	cmd.optval = (uintptr_t) optval;
2243 	cmd.level = level;
2244 	cmd.optname = optname;
2245 	cmd.optlen = optlen;
2247 	ret = write(id->channel->fd, &cmd, sizeof cmd);
2248 	if (ret != sizeof cmd)
2257 	struct ucma_abi_migrate_id cmd;
2271 	CMA_INIT_CMD_RESP(&cmd, sizeof cmd, MIGRATE_ID, &resp, sizeof resp);
2272 	cmd.id = id_priv->handle;
2273 	cmd.fd = id->channel->fd;
2275 	ret = write(channel->fd, &cmd, sizeof cmd);
2276 	if (ret != sizeof cmd) {