Lines Matching refs:rej_msg

1502 	struct cm_rej_msg *rej_msg, *rcv_msg;  in cm_issue_rej()  local
1511 rej_msg = (struct cm_rej_msg *) msg->mad; in cm_issue_rej()
1513 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, rcv_msg->hdr.tid); in cm_issue_rej()
1514 rej_msg->remote_comm_id = rcv_msg->local_comm_id; in cm_issue_rej()
1515 rej_msg->local_comm_id = rcv_msg->remote_comm_id; in cm_issue_rej()
1516 cm_rej_set_msg_rejected(rej_msg, msg_rejected); in cm_issue_rej()
1517 rej_msg->reason = cpu_to_be16(reason); in cm_issue_rej()
1520 cm_rej_set_reject_info_len(rej_msg, ari_length); in cm_issue_rej()
1521 memcpy(rej_msg->ari, ari, ari_length); in cm_issue_rej()
1763 static void cm_format_rej(struct cm_rej_msg *rej_msg, in cm_format_rej() argument
1771 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, cm_id_priv->tid); in cm_format_rej()
1772 rej_msg->remote_comm_id = cm_id_priv->id.remote_id; in cm_format_rej()
1776 rej_msg->local_comm_id = 0; in cm_format_rej()
1777 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ); in cm_format_rej()
1780 rej_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_rej()
1781 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ); in cm_format_rej()
1785 rej_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_rej()
1786 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REP); in cm_format_rej()
1789 rej_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_rej()
1790 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_OTHER); in cm_format_rej()
1794 rej_msg->reason = cpu_to_be16(reason); in cm_format_rej()
1796 cm_rej_set_reject_info_len(rej_msg, ari_length); in cm_format_rej()
1797 memcpy(rej_msg->ari, ari, ari_length); in cm_format_rej()
1801 memcpy(rej_msg->private_data, private_data, private_data_len); in cm_format_rej()
2800 struct cm_rej_msg *rej_msg; in cm_format_rej_event() local
2803 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad; in cm_format_rej_event()
2805 param->ari = rej_msg->ari; in cm_format_rej_event()
2806 param->ari_length = cm_rej_get_reject_info_len(rej_msg); in cm_format_rej_event()
2807 param->reason = __be16_to_cpu(rej_msg->reason); in cm_format_rej_event()
2808 work->cm_event.private_data = &rej_msg->private_data; in cm_format_rej_event()
2811 static struct cm_id_private * cm_acquire_rejected_id(struct cm_rej_msg *rej_msg) in cm_acquire_rejected_id() argument
2817 remote_id = rej_msg->local_comm_id; in cm_acquire_rejected_id()
2819 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_TIMEOUT) { in cm_acquire_rejected_id()
2821 timewait_info = cm_find_remote_id( *((__be64 *) rej_msg->ari), in cm_acquire_rejected_id()
2837 } else if (cm_rej_get_msg_rejected(rej_msg) == CM_MSG_RESPONSE_REQ) in cm_acquire_rejected_id()
2838 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, 0); in cm_acquire_rejected_id()
2840 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, remote_id); in cm_acquire_rejected_id()
2848 struct cm_rej_msg *rej_msg; in cm_rej_handler() local
2851 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad; in cm_rej_handler()
2852 cm_id_priv = cm_acquire_rejected_id(rej_msg); in cm_rej_handler()
2868 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_STALE_CONN) in cm_rej_handler()