File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -909,9 +909,8 @@ static int ompi_comm_allreduce_pmix_reduce_complete (ompi_comm_request_t *reques
909
909
}
910
910
911
911
PMIX_PDATA_CONSTRUCT (& pdat );
912
-
913
- info .value .type = OPAL_BYTE_OBJECT ;
914
- pdat .value .type = OPAL_BYTE_OBJECT ;
912
+ PMIX_INFO_CONSTRUCT (& info );
913
+ info .value .type = PMIX_BYTE_OBJECT ;
915
914
916
915
opal_dss .unload (& sbuf , (void * * )& info .value .data .bo .bytes , & rc );
917
916
info .value .data .bo .size = rc ;
@@ -959,6 +958,10 @@ static int ompi_comm_allreduce_pmix_reduce_complete (ompi_comm_request_t *reques
959
958
OBJ_DESTRUCT (& pdat );
960
959
return rc ;
961
960
}
961
+ if (PMIX_BYTE_OBJECT != pdat .value .type ) {
962
+ OBJ_DESTRUCT (& pdat );
963
+ return OPAL_ERR_TYPE_MISMATCH ;
964
+ }
962
965
963
966
OBJ_CONSTRUCT (& sbuf , opal_buffer_t );
964
967
opal_dss .load (& sbuf , pdat .value .data .bo .bytes , pdat .value .data .bo .size );
You can’t perform that action at this time.
0 commit comments