@@ -46,12 +46,11 @@ mca_pml_yalla_check_request_state(mca_pml_yalla_base_request_t *req, mxm_req_bas
4646static int mca_pml_yalla_send_request_free (ompi_request_t * * request )
4747{
4848 mca_pml_yalla_send_request_t * sreq = (mca_pml_yalla_send_request_t * )(* request );
49- mca_pml_yalla_base_request_t * req = (mca_pml_yalla_base_request_t * )sreq ;
5049
5150 PML_YALLA_VERBOSE (9 , "free send request *%p=%p" , (void * )request , (void * )* request );
5251
53- if (mca_pml_yalla_check_request_state (req , PML_YALLA_MXM_REQBASE (sreq ))) {
54- mca_pml_yalla_request_release (req , & ompi_pml_yalla .send_reqs );
52+ if (mca_pml_yalla_check_request_state (& sreq -> super , PML_YALLA_MXM_REQBASE (sreq ))) {
53+ mca_pml_yalla_request_release (& sreq -> super , & ompi_pml_yalla .send_reqs );
5554 }
5655
5756 * request = MPI_REQUEST_NULL ;
@@ -86,12 +85,11 @@ static int mca_pml_yalla_send_request_cancel(ompi_request_t *request, int flag)
8685static int mca_pml_yalla_recv_request_free (ompi_request_t * * request )
8786{
8887 mca_pml_yalla_recv_request_t * rreq = (mca_pml_yalla_recv_request_t * )(* request );
89- mca_pml_yalla_base_request_t * req = (mca_pml_yalla_base_request_t * )rreq ;
9088
9189 PML_YALLA_VERBOSE (9 , "free receive request *%p=%p" , (void * )request , (void * )* request );
9290
93- if (mca_pml_yalla_check_request_state (req , PML_YALLA_MXM_REQBASE (rreq ))) {
94- mca_pml_yalla_request_release (req , & ompi_pml_yalla .recv_reqs );
91+ if (mca_pml_yalla_check_request_state (& rreq -> super , PML_YALLA_MXM_REQBASE (rreq ))) {
92+ mca_pml_yalla_request_release (& rreq -> super , & ompi_pml_yalla .recv_reqs );
9593 }
9694
9795 * request = MPI_REQUEST_NULL ;
0 commit comments