Lines Matching refs:rej_msg

1499 	struct cm_rej_msg *rej_msg, *rcv_msg;  in cm_issue_rej()  local
1508 rej_msg = (struct cm_rej_msg *) msg->mad; in cm_issue_rej()
1510 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, rcv_msg->hdr.tid); in cm_issue_rej()
1511 rej_msg->remote_comm_id = rcv_msg->local_comm_id; in cm_issue_rej()
1512 rej_msg->local_comm_id = rcv_msg->remote_comm_id; in cm_issue_rej()
1513 cm_rej_set_msg_rejected(rej_msg, msg_rejected); in cm_issue_rej()
1514 rej_msg->reason = cpu_to_be16(reason); in cm_issue_rej()
1517 cm_rej_set_reject_info_len(rej_msg, ari_length); in cm_issue_rej()
1518 memcpy(rej_msg->ari, ari, ari_length); in cm_issue_rej()
1760 static void cm_format_rej(struct cm_rej_msg *rej_msg, in cm_format_rej() argument
1768 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, cm_id_priv->tid); in cm_format_rej()
1769 rej_msg->remote_comm_id = cm_id_priv->id.remote_id; in cm_format_rej()
1773 rej_msg->local_comm_id = 0; in cm_format_rej()
1774 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ); in cm_format_rej()
1777 rej_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_rej()
1778 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ); in cm_format_rej()
1782 rej_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_rej()
1783 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REP); in cm_format_rej()
1786 rej_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_rej()
1787 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_OTHER); in cm_format_rej()
1791 rej_msg->reason = cpu_to_be16(reason); in cm_format_rej()
1793 cm_rej_set_reject_info_len(rej_msg, ari_length); in cm_format_rej()
1794 memcpy(rej_msg->ari, ari, ari_length); in cm_format_rej()
1798 memcpy(rej_msg->private_data, private_data, private_data_len); in cm_format_rej()
2798 struct cm_rej_msg *rej_msg; in cm_format_rej_event() local
2801 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad; in cm_format_rej_event()
2803 param->ari = rej_msg->ari; in cm_format_rej_event()
2804 param->ari_length = cm_rej_get_reject_info_len(rej_msg); in cm_format_rej_event()
2805 param->reason = __be16_to_cpu(rej_msg->reason); in cm_format_rej_event()
2806 work->cm_event.private_data = &rej_msg->private_data; in cm_format_rej_event()
2809 static struct cm_id_private * cm_acquire_rejected_id(struct cm_rej_msg *rej_msg) in cm_acquire_rejected_id() argument
2815 remote_id = rej_msg->local_comm_id; in cm_acquire_rejected_id()
2817 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_TIMEOUT) { in cm_acquire_rejected_id()
2819 timewait_info = cm_find_remote_id( *((__be64 *) rej_msg->ari), in cm_acquire_rejected_id()
2834 } else if (cm_rej_get_msg_rejected(rej_msg) == CM_MSG_RESPONSE_REQ) in cm_acquire_rejected_id()
2835 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, 0); in cm_acquire_rejected_id()
2837 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, remote_id); in cm_acquire_rejected_id()
2845 struct cm_rej_msg *rej_msg; in cm_rej_handler() local
2848 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad; in cm_rej_handler()
2849 cm_id_priv = cm_acquire_rejected_id(rej_msg); in cm_rej_handler()
2865 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_STALE_CONN) in cm_rej_handler()