@@ -153,9 +153,10 @@ ompi_mtl_ofi_context_progress(int ctxt_id)
153
153
assert (ofi_req );
154
154
ret = ofi_req -> event_callback (& ompi_mtl_ofi_wc [i ], ofi_req );
155
155
if (OMPI_SUCCESS != ret ) {
156
- opal_output (0 , "%s:%d: Error returned by request event callback: %zd.\n"
157
- "*** The Open MPI OFI MTL is aborting the MPI job (via exit(3)).\n" ,
158
- __FILE__ , __LINE__ , ret );
156
+ opal_output (0 ,
157
+ "%s:%d: Error returned by request (type: %d) event callback: %zd.\n"
158
+ "*** The Open MPI OFI MTL is aborting the MPI job (via exit(3)).\n" ,
159
+ __FILE__ , __LINE__ , ofi_req -> type , ret );
159
160
fflush (stderr );
160
161
exit (1 );
161
162
}
@@ -671,6 +672,7 @@ ompi_mtl_ofi_ssend_recv(ompi_mtl_ofi_request_t *ack_req,
671
672
assert (ack_req );
672
673
673
674
ack_req -> parent = ofi_req ;
675
+ ack_req -> type = OMPI_MTL_OFI_ACK ;
674
676
ack_req -> event_callback = ompi_mtl_ofi_send_ack_callback ;
675
677
ack_req -> error_callback = ompi_mtl_ofi_send_ack_error_callback ;
676
678
@@ -882,6 +884,7 @@ ompi_mtl_ofi_send_generic(struct mca_mtl_base_module_t *mtl,
882
884
/**
883
885
* Create a send request, start it and wait until it completes.
884
886
*/
887
+ ofi_req .type = OMPI_MTL_OFI_SEND ;
885
888
ofi_req .event_callback = ompi_mtl_ofi_send_callback ;
886
889
ofi_req .error_callback = ompi_mtl_ofi_send_error_callback ;
887
890
@@ -1130,6 +1133,7 @@ ompi_mtl_ofi_isend_generic(struct mca_mtl_base_module_t *mtl,
1130
1133
}
1131
1134
set_thread_context (ctxt_id );
1132
1135
1136
+ ofi_req -> type = OMPI_MTL_OFI_SEND ;
1133
1137
ofi_req -> event_callback = ompi_mtl_ofi_isend_callback ;
1134
1138
ofi_req -> error_callback = ompi_mtl_ofi_send_error_callback ;
1135
1139
@@ -1142,7 +1146,6 @@ ompi_mtl_ofi_isend_generic(struct mca_mtl_base_module_t *mtl,
1142
1146
ompi_ret = ompi_mtl_datatype_pack (convertor , & start , & length , & free_after );
1143
1147
if (OPAL_UNLIKELY (OMPI_SUCCESS != ompi_ret )) return ompi_ret ;
1144
1148
1145
- ofi_req -> type = OMPI_MTL_OFI_SEND ;
1146
1149
ofi_req -> buffer = (free_after ) ? start : NULL ;
1147
1150
ofi_req -> length = length ;
1148
1151
ofi_req -> status .MPI_ERROR = OMPI_SUCCESS ;
0 commit comments