Lines Matching refs:mra_msg
1343 static void cm_format_mra(struct cm_mra_msg *mra_msg, in cm_format_mra() argument
1348 cm_format_mad_hdr(&mra_msg->hdr, CM_MRA_ATTR_ID, cm_id_priv->tid); in cm_format_mra()
1349 cm_mra_set_msg_mraed(mra_msg, msg_mraed); in cm_format_mra()
1350 mra_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_mra()
1351 mra_msg->remote_comm_id = cm_id_priv->id.remote_id; in cm_format_mra()
1352 cm_mra_set_service_timeout(mra_msg, service_timeout); in cm_format_mra()
1355 memcpy(mra_msg->private_data, private_data, private_data_len); in cm_format_mra()
2495 static struct cm_id_private * cm_acquire_mraed_id(struct cm_mra_msg *mra_msg) in cm_acquire_mraed_id() argument
2497 switch (cm_mra_get_msg_mraed(mra_msg)) { in cm_acquire_mraed_id()
2499 return cm_acquire_id(mra_msg->remote_comm_id, 0); in cm_acquire_mraed_id()
2502 return cm_acquire_id(mra_msg->remote_comm_id, in cm_acquire_mraed_id()
2503 mra_msg->local_comm_id); in cm_acquire_mraed_id()
2512 struct cm_mra_msg *mra_msg; in cm_mra_handler() local
2515 mra_msg = (struct cm_mra_msg *)work->mad_recv_wc->recv_buf.mad; in cm_mra_handler()
2516 cm_id_priv = cm_acquire_mraed_id(mra_msg); in cm_mra_handler()
2520 work->cm_event.private_data = &mra_msg->private_data; in cm_mra_handler()
2522 cm_mra_get_service_timeout(mra_msg); in cm_mra_handler()
2523 timeout = cm_convert_to_ms(cm_mra_get_service_timeout(mra_msg)) + in cm_mra_handler()
2529 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_REQ || in cm_mra_handler()
2536 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_REP || in cm_mra_handler()
2543 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_OTHER || in cm_mra_handler()