Lines Matching defs:rep_msg
1432 static void cm_format_rep(struct cm_rep_msg *rep_msg,
1436 cm_format_mad_hdr(&rep_msg->hdr, CM_REP_ATTR_ID, cm_id_priv->tid);
1437 rep_msg->local_comm_id = cm_id_priv->id.local_id;
1438 rep_msg->remote_comm_id = cm_id_priv->id.remote_id;
1439 cm_rep_set_local_qpn(rep_msg, cpu_to_be32(param->qp_num));
1440 cm_rep_set_starting_psn(rep_msg, cpu_to_be32(param->starting_psn));
1441 rep_msg->resp_resources = param->responder_resources;
1442 rep_msg->initiator_depth = param->initiator_depth;
1443 cm_rep_set_target_ack_delay(rep_msg, param->target_ack_delay);
1444 cm_rep_set_failover(rep_msg, param->failover_accepted);
1445 cm_rep_set_flow_ctrl(rep_msg, param->flow_control);
1446 cm_rep_set_rnr_retry_count(rep_msg, param->rnr_retry_count);
1447 cm_rep_set_srq(rep_msg, param->srq);
1448 rep_msg->local_ca_guid = cm_id_priv->id.device->node_guid;
1451 memcpy(rep_msg->private_data, param->private_data,
1460 struct cm_rep_msg *rep_msg;
1480 rep_msg = (struct cm_rep_msg *) msg->mad;
1481 cm_format_rep(rep_msg, cm_id_priv, param);
1496 cm_id_priv->rq_psn = cm_rep_get_starting_psn(rep_msg);
1497 cm_id_priv->local_qpn = cm_rep_get_local_qpn(rep_msg);
1570 struct cm_rep_msg *rep_msg;
1573 rep_msg = (struct cm_rep_msg *)work->mad_recv_wc->recv_buf.mad;
1575 param->remote_ca_guid = rep_msg->local_ca_guid;
1576 param->remote_qkey = be32_to_cpu(rep_msg->local_qkey);
1577 param->remote_qpn = be32_to_cpu(cm_rep_get_local_qpn(rep_msg));
1578 param->starting_psn = be32_to_cpu(cm_rep_get_starting_psn(rep_msg));
1579 param->responder_resources = rep_msg->initiator_depth;
1580 param->initiator_depth = rep_msg->resp_resources;
1581 param->target_ack_delay = cm_rep_get_target_ack_delay(rep_msg);
1582 param->failover_accepted = cm_rep_get_failover(rep_msg);
1583 param->flow_control = cm_rep_get_flow_ctrl(rep_msg);
1584 param->rnr_retry_count = cm_rep_get_rnr_retry_count(rep_msg);
1585 param->srq = cm_rep_get_srq(rep_msg);
1586 work->cm_event.private_data = &rep_msg->private_data;
1592 struct cm_rep_msg *rep_msg;
1597 rep_msg = (struct cm_rep_msg *) work->mad_recv_wc->recv_buf.mad;
1598 cm_id_priv = cm_acquire_id(rep_msg->remote_comm_id,
1599 rep_msg->local_comm_id);
1634 struct cm_rep_msg *rep_msg;
1638 rep_msg = (struct cm_rep_msg *)work->mad_recv_wc->recv_buf.mad;
1639 cm_id_priv = cm_acquire_id(rep_msg->remote_comm_id, 0);
1658 cm_id_priv->timewait_info->work.remote_id = rep_msg->local_comm_id;
1659 cm_id_priv->timewait_info->remote_ca_guid = rep_msg->local_ca_guid;
1660 cm_id_priv->timewait_info->remote_qpn = cm_rep_get_local_qpn(rep_msg);
1686 cm_id_priv->id.remote_id = rep_msg->local_comm_id;
1687 cm_id_priv->remote_qpn = cm_rep_get_local_qpn(rep_msg);
1688 cm_id_priv->initiator_depth = rep_msg->resp_resources;
1689 cm_id_priv->responder_resources = rep_msg->initiator_depth;
1690 cm_id_priv->sq_psn = cm_rep_get_starting_psn(rep_msg);
1691 cm_id_priv->rnr_retry_count = cm_rep_get_rnr_retry_count(rep_msg);