Lines Matching defs:mra_msg
1358 static void cm_format_mra(struct cm_mra_msg *mra_msg,
1363 cm_format_mad_hdr(&mra_msg->hdr, CM_MRA_ATTR_ID, cm_id_priv->tid);
1364 cm_mra_set_msg_mraed(mra_msg, msg_mraed);
1365 mra_msg->local_comm_id = cm_id_priv->id.local_id;
1366 mra_msg->remote_comm_id = cm_id_priv->id.remote_id;
1367 cm_mra_set_service_timeout(mra_msg, service_timeout);
1370 memcpy(mra_msg->private_data, private_data, private_data_len);
2491 static struct cm_id_private * cm_acquire_mraed_id(struct cm_mra_msg *mra_msg)
2493 switch (cm_mra_get_msg_mraed(mra_msg)) {
2495 return cm_acquire_id(mra_msg->remote_comm_id, 0);
2498 return cm_acquire_id(mra_msg->remote_comm_id,
2499 mra_msg->local_comm_id);
2508 struct cm_mra_msg *mra_msg;
2511 mra_msg = (struct cm_mra_msg *)work->mad_recv_wc->recv_buf.mad;
2512 cm_id_priv = cm_acquire_mraed_id(mra_msg);
2516 work->cm_event.private_data = &mra_msg->private_data;
2518 cm_mra_get_service_timeout(mra_msg);
2519 timeout = cm_convert_to_ms(cm_mra_get_service_timeout(mra_msg)) +
2531 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_REQ ||
2538 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_REP ||
2545 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_OTHER ||