@@ -234,16 +234,16 @@ mca_part_persist_progress(void)
234
234
235
235
if (done ) {
236
236
size_t dt_size_ ;
237
- int32_t dt_size ;
237
+ uint32_t dt_size ;
238
238
239
239
if (MCA_PART_PERSIST_REQUEST_PSEND == req -> req_type ) {
240
240
/* parse message */
241
241
req -> world_peer = req -> setup_info [1 ].world_rank ;
242
242
243
243
err = opal_datatype_type_size (& (req -> req_datatype -> super ), & dt_size_ );
244
244
if (OMPI_SUCCESS != err ) return OMPI_ERROR ;
245
- dt_size = (dt_size_ > (size_t ) INT_MAX ) ? MPI_UNDEFINED : (int ) dt_size_ ;
246
- int32_t bytes = req -> real_count * dt_size ;
245
+ dt_size = (dt_size_ > (size_t ) UINT_MAX ) ? MPI_UNDEFINED : (uint32_t ) dt_size_ ;
246
+ uint32_t bytes = req -> real_count * dt_size ;
247
247
248
248
/* Set up persistent sends */
249
249
req -> persist_reqs = (ompi_request_t * * ) malloc (sizeof (ompi_request_t * )* (req -> real_parts ));
@@ -261,8 +261,8 @@ mca_part_persist_progress(void)
261
261
262
262
err = opal_datatype_type_size (& (req -> req_datatype -> super ), & dt_size_ );
263
263
if (OMPI_SUCCESS != err ) return OMPI_ERROR ;
264
- dt_size = (dt_size_ > (size_t ) INT_MAX ) ? MPI_UNDEFINED : (int ) dt_size_ ;
265
- int32_t bytes = req -> real_count * dt_size ;
264
+ dt_size = (dt_size_ > (size_t ) UINT_MAX ) ? MPI_UNDEFINED : (uint32_t ) dt_size_ ;
265
+ uint32_t bytes = req -> real_count * dt_size ;
266
266
267
267
/* Set up persistent sends */
268
268
req -> persist_reqs = (ompi_request_t * * ) malloc (sizeof (ompi_request_t * )* (req -> real_parts ));
@@ -337,7 +337,7 @@ mca_part_persist_precv_init(void *buf,
337
337
{
338
338
int err = OMPI_SUCCESS ;
339
339
size_t dt_size_ ;
340
- int dt_size ;
340
+ uint32_t dt_size ;
341
341
mca_part_persist_list_t * new_progress_elem = NULL ;
342
342
343
343
mca_part_persist_precv_request_t * recvreq ;
@@ -369,7 +369,7 @@ mca_part_persist_precv_init(void *buf,
369
369
/* Compute total number of bytes */
370
370
err = opal_datatype_type_size (& (req -> req_datatype -> super ), & dt_size_ );
371
371
if (OMPI_SUCCESS != err ) return OMPI_ERROR ;
372
- dt_size = (dt_size_ > (size_t ) INT_MAX ) ? MPI_UNDEFINED : (int ) dt_size_ ;
372
+ dt_size = (dt_size_ > (size_t ) UINT_MAX ) ? MPI_UNDEFINED : (uint32_t ) dt_size_ ;
373
373
req -> req_bytes = parts * count * dt_size ;
374
374
375
375
@@ -405,7 +405,7 @@ mca_part_persist_psend_init(const void* buf,
405
405
{
406
406
int err = OMPI_SUCCESS ;
407
407
size_t dt_size_ ;
408
- int dt_size ;
408
+ uint32_t dt_size ;
409
409
mca_part_persist_list_t * new_progress_elem = NULL ;
410
410
mca_part_persist_psend_request_t * sendreq ;
411
411
@@ -430,7 +430,7 @@ mca_part_persist_psend_init(const void* buf,
430
430
/* Determine total bytes to send. */
431
431
err = opal_datatype_type_size (& (req -> req_datatype -> super ), & dt_size_ );
432
432
if (OMPI_SUCCESS != err ) return OMPI_ERROR ;
433
- dt_size = (dt_size_ > (size_t ) INT_MAX ) ? MPI_UNDEFINED : (int ) dt_size_ ;
433
+ dt_size = (dt_size_ > (size_t ) UINT_MAX ) ? MPI_UNDEFINED : (uint32_t ) dt_size_ ;
434
434
req -> req_bytes = parts * count * dt_size ;
435
435
436
436
@@ -494,11 +494,11 @@ mca_part_persist_start(size_t count, ompi_request_t** requests)
494
494
{
495
495
if (MCA_PART_PERSIST_REQUEST_PSEND == req -> req_type ) {
496
496
req -> done_count = 0 ;
497
- memset ((void * )req -> flags ,0 ,sizeof (int32_t )* req -> real_parts );
497
+ memset ((void * )req -> flags ,0 ,sizeof (uint32_t )* req -> real_parts );
498
498
} else {
499
499
req -> done_count = 0 ;
500
500
err = req -> persist_reqs [0 ]-> req_start (req -> real_parts , req -> persist_reqs );
501
- memset ((void * )req -> flags ,0 ,sizeof (int32_t )* req -> real_parts );
501
+ memset ((void * )req -> flags ,0 ,sizeof (uint32_t )* req -> real_parts );
502
502
}
503
503
} else {
504
504
if (MCA_PART_PERSIST_REQUEST_PSEND == req -> req_type ) {
0 commit comments