Lines Matching defs:rej_msg
1349 struct cm_rej_msg *rej_msg, *rcv_msg;
1358 rej_msg = (struct cm_rej_msg *) msg->mad;
1360 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, rcv_msg->hdr.tid);
1361 rej_msg->remote_comm_id = rcv_msg->local_comm_id;
1362 rej_msg->local_comm_id = rcv_msg->remote_comm_id;
1363 cm_rej_set_msg_rejected(rej_msg, msg_rejected);
1364 rej_msg->reason = cpu_to_be16(reason);
1367 cm_rej_set_reject_info_len(rej_msg, ari_length);
1368 memcpy(rej_msg->ari, ari, ari_length);
1519 static void cm_format_rej(struct cm_rej_msg *rej_msg,
1527 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, cm_id_priv->tid);
1528 rej_msg->remote_comm_id = cm_id_priv->id.remote_id;
1532 rej_msg->local_comm_id = 0;
1533 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ);
1536 rej_msg->local_comm_id = cm_id_priv->id.local_id;
1537 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ);
1541 rej_msg->local_comm_id = cm_id_priv->id.local_id;
1542 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REP);
1545 rej_msg->local_comm_id = cm_id_priv->id.local_id;
1546 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_OTHER);
1550 rej_msg->reason = cpu_to_be16(reason);
1552 cm_rej_set_reject_info_len(rej_msg, ari_length);
1553 memcpy(rej_msg->ari, ari, ari_length);
1557 memcpy(rej_msg->private_data, private_data, private_data_len);
2494 struct cm_rej_msg *rej_msg;
2497 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad;
2499 param->ari = rej_msg->ari;
2500 param->ari_length = cm_rej_get_reject_info_len(rej_msg);
2501 param->reason = __be16_to_cpu(rej_msg->reason);
2502 work->cm_event.private_data = &rej_msg->private_data;
2505 static struct cm_id_private * cm_acquire_rejected_id(struct cm_rej_msg *rej_msg)
2511 remote_id = rej_msg->local_comm_id;
2513 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_TIMEOUT) {
2515 timewait_info = cm_find_remote_id( *((__be64 *) rej_msg->ari),
2531 } else if (cm_rej_get_msg_rejected(rej_msg) == CM_MSG_RESPONSE_REQ)
2532 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, 0);
2534 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, remote_id);
2542 struct cm_rej_msg *rej_msg;
2545 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad;
2546 cm_id_priv = cm_acquire_rejected_id(rej_msg);
2562 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_STALE_CONN)