@@ -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 ));
@@ -263,8 +263,8 @@ mca_part_persist_progress(void)
263
263
264
264
err = opal_datatype_type_size (& (req -> req_datatype -> super ), & dt_size_ );
265
265
if (OMPI_SUCCESS != err ) return OMPI_ERROR ;
266
- dt_size = (dt_size_ > (size_t ) INT_MAX ) ? MPI_UNDEFINED : (int ) dt_size_ ;
267
- int32_t bytes = req -> real_count * dt_size ;
266
+ dt_size = (dt_size_ > (size_t ) UINT_MAX ) ? MPI_UNDEFINED : (uint32_t ) dt_size_ ;
267
+ uint32_t bytes = req -> real_count * dt_size ;
268
268
269
269
270
270
@@ -350,7 +350,7 @@ mca_part_persist_precv_init(void *buf,
350
350
{
351
351
int err = OMPI_SUCCESS ;
352
352
size_t dt_size_ ;
353
- int dt_size ;
353
+ uint32_t dt_size ;
354
354
mca_part_persist_list_t * new_progress_elem = NULL ;
355
355
356
356
mca_part_persist_precv_request_t * recvreq ;
@@ -382,7 +382,7 @@ mca_part_persist_precv_init(void *buf,
382
382
/* Compute total number of bytes */
383
383
err = opal_datatype_type_size (& (req -> req_datatype -> super ), & dt_size_ );
384
384
if (OMPI_SUCCESS != err ) return OMPI_ERROR ;
385
- dt_size = (dt_size_ > (size_t ) INT_MAX ) ? MPI_UNDEFINED : (int ) dt_size_ ;
385
+ dt_size = (dt_size_ > (size_t ) UINT_MAX ) ? MPI_UNDEFINED : (uint32_t ) dt_size_ ;
386
386
req -> req_bytes = parts * count * dt_size ;
387
387
388
388
/* Set ompi request initial values */
@@ -417,7 +417,7 @@ mca_part_persist_psend_init(const void* buf,
417
417
{
418
418
int err = OMPI_SUCCESS ;
419
419
size_t dt_size_ ;
420
- int dt_size ;
420
+ uint32_t dt_size ;
421
421
mca_part_persist_list_t * new_progress_elem = NULL ;
422
422
mca_part_persist_psend_request_t * sendreq ;
423
423
@@ -442,7 +442,7 @@ mca_part_persist_psend_init(const void* buf,
442
442
/* Determine total bytes to send. */
443
443
err = opal_datatype_type_size (& (req -> req_datatype -> super ), & dt_size_ );
444
444
if (OMPI_SUCCESS != err ) return OMPI_ERROR ;
445
- dt_size = (dt_size_ > (size_t ) INT_MAX ) ? MPI_UNDEFINED : (int ) dt_size_ ;
445
+ dt_size = (dt_size_ > (size_t ) UINT_MAX ) ? MPI_UNDEFINED : (uint32_t ) dt_size_ ;
446
446
req -> req_bytes = parts * count * dt_size ;
447
447
448
448
/* non-blocking send set-up data */
@@ -504,11 +504,11 @@ mca_part_persist_start(size_t count, ompi_request_t** requests)
504
504
{
505
505
if (MCA_PART_PERSIST_REQUEST_PSEND == req -> req_type ) {
506
506
req -> done_count = 0 ;
507
- memset ((void * )req -> flags ,0 ,sizeof (int32_t )* req -> real_parts );
507
+ memset ((void * )req -> flags ,0 ,sizeof (uint32_t )* req -> real_parts );
508
508
} else {
509
509
req -> done_count = 0 ;
510
510
err = req -> persist_reqs [0 ]-> req_start (req -> real_parts , req -> persist_reqs );
511
- memset ((void * )req -> flags ,0 ,sizeof (int32_t )* req -> real_parts );
511
+ memset ((void * )req -> flags ,0 ,sizeof (uint32_t )* req -> real_parts );
512
512
}
513
513
} else {
514
514
if (MCA_PART_PERSIST_REQUEST_PSEND == req -> req_type ) {
0 commit comments