Lines Matching refs:rej_msg
1202 struct cm_rej_msg *rej_msg, *rcv_msg; in cm_issue_rej() local
1211 rej_msg = (struct cm_rej_msg *) msg->mad; in cm_issue_rej()
1213 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, rcv_msg->hdr.tid); in cm_issue_rej()
1214 rej_msg->remote_comm_id = rcv_msg->local_comm_id; in cm_issue_rej()
1215 rej_msg->local_comm_id = rcv_msg->remote_comm_id; in cm_issue_rej()
1216 cm_rej_set_msg_rejected(rej_msg, msg_rejected); in cm_issue_rej()
1217 rej_msg->reason = cpu_to_be16(reason); in cm_issue_rej()
1220 cm_rej_set_reject_info_len(rej_msg, ari_length); in cm_issue_rej()
1221 memcpy(rej_msg->ari, ari, ari_length); in cm_issue_rej()
1358 static void cm_format_rej(struct cm_rej_msg *rej_msg, in cm_format_rej() argument
1366 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, cm_id_priv->tid); in cm_format_rej()
1367 rej_msg->remote_comm_id = cm_id_priv->id.remote_id; in cm_format_rej()
1371 rej_msg->local_comm_id = 0; in cm_format_rej()
1372 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ); in cm_format_rej()
1375 rej_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_rej()
1376 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ); in cm_format_rej()
1380 rej_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_rej()
1381 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REP); in cm_format_rej()
1384 rej_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_rej()
1385 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_OTHER); in cm_format_rej()
1389 rej_msg->reason = cpu_to_be16(reason); in cm_format_rej()
1391 cm_rej_set_reject_info_len(rej_msg, ari_length); in cm_format_rej()
1392 memcpy(rej_msg->ari, ari, ari_length); in cm_format_rej()
1396 memcpy(rej_msg->private_data, private_data, private_data_len); in cm_format_rej()
2306 struct cm_rej_msg *rej_msg; in cm_format_rej_event() local
2309 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad; in cm_format_rej_event()
2311 param->ari = rej_msg->ari; in cm_format_rej_event()
2312 param->ari_length = cm_rej_get_reject_info_len(rej_msg); in cm_format_rej_event()
2313 param->reason = __be16_to_cpu(rej_msg->reason); in cm_format_rej_event()
2314 work->cm_event.private_data = &rej_msg->private_data; in cm_format_rej_event()
2317 static struct cm_id_private * cm_acquire_rejected_id(struct cm_rej_msg *rej_msg) in cm_acquire_rejected_id() argument
2323 remote_id = rej_msg->local_comm_id; in cm_acquire_rejected_id()
2325 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_TIMEOUT) { in cm_acquire_rejected_id()
2327 timewait_info = cm_find_remote_id( *((__be64 *) rej_msg->ari), in cm_acquire_rejected_id()
2343 } else if (cm_rej_get_msg_rejected(rej_msg) == CM_MSG_RESPONSE_REQ) in cm_acquire_rejected_id()
2344 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, 0); in cm_acquire_rejected_id()
2346 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, remote_id); in cm_acquire_rejected_id()
2354 struct cm_rej_msg *rej_msg; in cm_rej_handler() local
2357 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad; in cm_rej_handler()
2358 cm_id_priv = cm_acquire_rejected_id(rej_msg); in cm_rej_handler()
2374 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_STALE_CONN) in cm_rej_handler()