Lines Matching refs:mra_msg

1417 static void cm_format_mra(struct cm_mra_msg *mra_msg,  in cm_format_mra()  argument
1422 cm_format_mad_hdr(&mra_msg->hdr, CM_MRA_ATTR_ID, cm_id_priv->tid); in cm_format_mra()
1423 cm_mra_set_msg_mraed(mra_msg, msg_mraed); in cm_format_mra()
1424 mra_msg->local_comm_id = cm_id_priv->id.local_id; in cm_format_mra()
1425 mra_msg->remote_comm_id = cm_id_priv->id.remote_id; in cm_format_mra()
1426 cm_mra_set_service_timeout(mra_msg, service_timeout); in cm_format_mra()
1429 memcpy(mra_msg->private_data, private_data, private_data_len); in cm_format_mra()
2568 static struct cm_id_private * cm_acquire_mraed_id(struct cm_mra_msg *mra_msg) in cm_acquire_mraed_id() argument
2570 switch (cm_mra_get_msg_mraed(mra_msg)) { in cm_acquire_mraed_id()
2572 return cm_acquire_id(mra_msg->remote_comm_id, 0); in cm_acquire_mraed_id()
2575 return cm_acquire_id(mra_msg->remote_comm_id, in cm_acquire_mraed_id()
2576 mra_msg->local_comm_id); in cm_acquire_mraed_id()
2585 struct cm_mra_msg *mra_msg; in cm_mra_handler() local
2588 mra_msg = (struct cm_mra_msg *)work->mad_recv_wc->recv_buf.mad; in cm_mra_handler()
2589 cm_id_priv = cm_acquire_mraed_id(mra_msg); in cm_mra_handler()
2593 work->cm_event.private_data = &mra_msg->private_data; in cm_mra_handler()
2595 cm_mra_get_service_timeout(mra_msg); in cm_mra_handler()
2596 timeout = cm_convert_to_ms(cm_mra_get_service_timeout(mra_msg)) + in cm_mra_handler()
2602 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_REQ || in cm_mra_handler()
2609 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_REP || in cm_mra_handler()
2616 if (cm_mra_get_msg_mraed(mra_msg) != CM_MSG_RESPONSE_OTHER || in cm_mra_handler()