Lines Matching refs:rej_msg
1186 struct cm_rej_msg *rej_msg, *rcv_msg;
1195 rej_msg = (struct cm_rej_msg *) msg->mad;
1197 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, rcv_msg->hdr.tid);
1198 rej_msg->remote_comm_id = rcv_msg->local_comm_id;
1199 rej_msg->local_comm_id = rcv_msg->remote_comm_id;
1200 cm_rej_set_msg_rejected(rej_msg, msg_rejected);
1201 rej_msg->reason = cpu_to_be16(reason);
1204 cm_rej_set_reject_info_len(rej_msg, ari_length);
1205 memcpy(rej_msg->ari, ari, ari_length);
1342 static void cm_format_rej(struct cm_rej_msg *rej_msg,
1350 cm_format_mad_hdr(&rej_msg->hdr, CM_REJ_ATTR_ID, cm_id_priv->tid);
1351 rej_msg->remote_comm_id = cm_id_priv->id.remote_id;
1355 rej_msg->local_comm_id = 0;
1356 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ);
1359 rej_msg->local_comm_id = cm_id_priv->id.local_id;
1360 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REQ);
1364 rej_msg->local_comm_id = cm_id_priv->id.local_id;
1365 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_REP);
1368 rej_msg->local_comm_id = cm_id_priv->id.local_id;
1369 cm_rej_set_msg_rejected(rej_msg, CM_MSG_RESPONSE_OTHER);
1373 rej_msg->reason = cpu_to_be16(reason);
1375 cm_rej_set_reject_info_len(rej_msg, ari_length);
1376 memcpy(rej_msg->ari, ari, ari_length);
1380 memcpy(rej_msg->private_data, private_data, private_data_len);
2268 struct cm_rej_msg *rej_msg;
2271 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad;
2273 param->ari = rej_msg->ari;
2274 param->ari_length = cm_rej_get_reject_info_len(rej_msg);
2275 param->reason = __be16_to_cpu(rej_msg->reason);
2276 work->cm_event.private_data = &rej_msg->private_data;
2279 static struct cm_id_private * cm_acquire_rejected_id(struct cm_rej_msg *rej_msg)
2285 remote_id = rej_msg->local_comm_id;
2287 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_TIMEOUT) {
2289 timewait_info = cm_find_remote_id( *((__be64 *) rej_msg->ari),
2305 } else if (cm_rej_get_msg_rejected(rej_msg) == CM_MSG_RESPONSE_REQ)
2306 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, 0);
2308 cm_id_priv = cm_acquire_id(rej_msg->remote_comm_id, remote_id);
2316 struct cm_rej_msg *rej_msg;
2319 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad;
2320 cm_id_priv = cm_acquire_rejected_id(rej_msg);
2336 if (__be16_to_cpu(rej_msg->reason) == IB_CM_REJ_STALE_CONN)