infiniband/core/cm.c

1634 static void cm_format_rep(struct cm_rep_msg *rep_msg,
1638 	cm_format_mad_hdr(&rep_msg->hdr, CM_REP_ATTR_ID, cm_id_priv->tid);
1639 	rep_msg->local_comm_id = cm_id_priv->id.local_id;
1640 	rep_msg->remote_comm_id = cm_id_priv->id.remote_id;
1641 	cm_rep_set_local_qpn(rep_msg, cpu_to_be32(param->qp_num));
1642 	cm_rep_set_starting_psn(rep_msg, cpu_to_be32(param->starting_psn));
1643 	rep_msg->resp_resources = param->responder_resources;
1644 	rep_msg->initiator_depth = param->initiator_depth;
1645 	cm_rep_set_target_ack_delay(rep_msg,
1647 	cm_rep_set_failover(rep_msg, param->failover_accepted);
1648 	cm_rep_set_flow_ctrl(rep_msg, param->flow_control);
1649 	cm_rep_set_rnr_retry_count(rep_msg, param->rnr_retry_count);
1650 	cm_rep_set_srq(rep_msg, param->srq);
1651 	rep_msg->local_ca_guid = cm_id_priv->id.device->node_guid;
1654 		memcpy(rep_msg->private_data, param->private_data,
1663 	struct cm_rep_msg *rep_msg;
1683 	rep_msg = (struct cm_rep_msg *) msg->mad;
1684 	cm_format_rep(rep_msg, cm_id_priv, param);
1699 	cm_id_priv->rq_psn = cm_rep_get_starting_psn(rep_msg);
1700 	cm_id_priv->local_qpn = cm_rep_get_local_qpn(rep_msg);
1773 	struct cm_rep_msg *rep_msg;
1776 	rep_msg = (struct cm_rep_msg *)work->mad_recv_wc->recv_buf.mad;
1778 	param->remote_ca_guid = rep_msg->local_ca_guid;
1779 	param->remote_qkey = be32_to_cpu(rep_msg->local_qkey);
1780 	param->remote_qpn = be32_to_cpu(cm_rep_get_local_qpn(rep_msg));
1781 	param->starting_psn = be32_to_cpu(cm_rep_get_starting_psn(rep_msg));
1782 	param->responder_resources = rep_msg->initiator_depth;
1783 	param->initiator_depth = rep_msg->resp_resources;
1784 	param->target_ack_delay = cm_rep_get_target_ack_delay(rep_msg);
1785 	param->failover_accepted = cm_rep_get_failover(rep_msg);
1786 	param->flow_control = cm_rep_get_flow_ctrl(rep_msg);
1787 	param->rnr_retry_count = cm_rep_get_rnr_retry_count(rep_msg);
1788 	param->srq = cm_rep_get_srq(rep_msg);
1789 	work->cm_event.private_data = &rep_msg->private_data;
1795 	struct cm_rep_msg *rep_msg;
1799 	rep_msg = (struct cm_rep_msg *) work->mad_recv_wc->recv_buf.mad;
1800 	cm_id_priv = cm_acquire_id(rep_msg->remote_comm_id,
1801 				   rep_msg->local_comm_id);
1838 	struct cm_rep_msg *rep_msg;
1841 	rep_msg = (struct cm_rep_msg *)work->mad_recv_wc->recv_buf.mad;
1842 	cm_id_priv = cm_acquire_id(rep_msg->remote_comm_id, 0);
1861 	cm_id_priv->timewait_info->work.remote_id = rep_msg->local_comm_id;
1862 	cm_id_priv->timewait_info->remote_ca_guid = rep_msg->local_ca_guid;
1863 	cm_id_priv->timewait_info->remote_qpn = cm_rep_get_local_qpn(rep_msg);
1889 	cm_id_priv->id.remote_id = rep_msg->local_comm_id;
1890 	cm_id_priv->remote_qpn = cm_rep_get_local_qpn(rep_msg);
1891 	cm_id_priv->initiator_depth = rep_msg->resp_resources;
1892 	cm_id_priv->responder_resources = rep_msg->initiator_depth;
1893 	cm_id_priv->sq_psn = cm_rep_get_starting_psn(rep_msg);
1894 	cm_id_priv->rnr_retry_count = cm_rep_get_rnr_retry_count(rep_msg);
1895 	cm_id_priv->target_ack_delay = cm_rep_get_target_ack_delay(rep_msg);