Lines Matching refs:mra_msg
1745 static void cm_format_mra(struct cm_mra_msg *mra_msg, in cm_format_mra() argument
1750 cm_format_mad_hdr(&mra_msg->hdr, CM_MRA_ATTR_ID, cm_id_priv->tid); in cm_format_mra()
1751 cm_mra_set_msg_mraed(mra_msg, msg_mraed); in cm_format_mra()
1752 mra_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_mra()
1753 mra_msg->remote_comm_id = cm_id_priv->id.remote_id; in cm_format_mra()
1754 cm_mra_set_service_timeout(mra_msg, service_timeout); in cm_format_mra()
1757 memcpy(mra_msg->private_data, private_data, private_data_len); in cm_format_mra()
2993 static struct cm_id_private * cm_acquire_mraed_id(struct cm_mra_msg *mra_msg) in cm_acquire_mraed_id() argument
2995 switch (cm_mra_get_msg_mraed(mra_msg)) { in cm_acquire_mraed_id()
2997 return cm_acquire_id(mra_msg->remote_comm_id, 0); in cm_acquire_mraed_id()
3000 return cm_acquire_id(mra_msg->remote_comm_id, in cm_acquire_mraed_id()
3001 mra_msg->local_comm_id); in cm_acquire_mraed_id()
3010 struct cm_mra_msg *mra_msg; in cm_mra_handler() local
3013 mra_msg = (struct cm_mra_msg *)work->mad_recv_wc->recv_buf.mad; in cm_mra_handler()
3014 cm_id_priv = cm_acquire_mraed_id(mra_msg); in cm_mra_handler()
3018 work->cm_event.private_data = &mra_msg->private_data; in cm_mra_handler()
3020 cm_mra_get_service_timeout(mra_msg); in cm_mra_handler()
3021 timeout = cm_convert_to_ms(cm_mra_get_service_timeout(mra_msg)) + in cm_mra_handler()
3027 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_REQ || in cm_mra_handler()
3034 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_REP || in cm_mra_handler()
3041 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_OTHER || in cm_mra_handler()