Lines Matching refs:rej_msg
1051 struct cm_rej_msg *rej_msg, *rcv_msg;
1060 rej_msg = (struct cm_rej_msg *) msg->mad;
1062 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, rcv_msg->hdr.tid);
1063 rej_msg->remote_comm_id = rcv_msg->local_comm_id;
1064 rej_msg->local_comm_id = rcv_msg->remote_comm_id;
1065 cm_rej_set_msg_rejected(rej_msg, msg_rejected);
1066 rej_msg->reason = cpu_to_be16(reason);
1069 cm_rej_set_reject_info_len(rej_msg, ari_length);
1070 memcpy(rej_msg->ari, ari, ari_length);
1208 static void cm_format_rej(struct cm_rej_msg *rej_msg,
1216 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, cm_id_priv->tid);
1217 rej_msg->remote_comm_id = cm_id_priv->id.remote_id;
1221 rej_msg->local_comm_id = 0;
1222 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ);
1225 rej_msg->local_comm_id = cm_id_priv->id.local_id;
1226 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ);
1230 rej_msg->local_comm_id = cm_id_priv->id.local_id;
1231 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REP);
1234 rej_msg->local_comm_id = cm_id_priv->id.local_id;
1235 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_OTHER);
1239 rej_msg->reason = cpu_to_be16(reason);
1241 cm_rej_set_reject_info_len(rej_msg, ari_length);
1242 memcpy(rej_msg->ari, ari, ari_length);
1246 memcpy(rej_msg->private_data, private_data, private_data_len);
2095 struct cm_rej_msg *rej_msg;
2098 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad;
2100 param->ari = rej_msg->ari;
2101 param->ari_length = cm_rej_get_reject_info_len(rej_msg);
2102 param->reason = __be16_to_cpu(rej_msg->reason);
2103 work->cm_event.private_data = &rej_msg->private_data;
2106 static struct cm_id_private * cm_acquire_rejected_id(struct cm_rej_msg *rej_msg)
2113 remote_id = rej_msg->local_comm_id;
2115 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_TIMEOUT) {
2117 timewait_info = cm_find_remote_id( *((__be64 *) rej_msg->ari),
2133 } else if (cm_rej_get_msg_rejected(rej_msg) == CM_MSG_RESPONSE_REQ)
2134 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, 0);
2136 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, remote_id);
2144 struct cm_rej_msg *rej_msg;
2148 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad;
2149 cm_id_priv = cm_acquire_rejected_id(rej_msg);
2165 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_STALE_CONN)