Skip to content

Commit

Permalink
type casting in pread result
Browse files Browse the repository at this point in the history
  • Loading branch information
plopezx committed Jul 20, 2023
1 parent 3f42883 commit e74840c
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions src/mpi_distributed/data_generator.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -939,7 +939,7 @@ void* loadXY_DataGen(DG_Data* DG, int buffer_index, int ds_ptr) {
}
n_read = fread(bytesX, sizeof (unsigned char), DG->n_sizeX, DG->fpX);
*/
n_read = pread(fileno(DG->fpX), bytesX, DG->n_sizeX*sizeof (unsigned char), posX);
n_read = (int) pread(fileno(DG->fpX), bytesX, DG->n_sizeX*sizeof (unsigned char), posX);
} else {
#ifdef cMPI
MPICHECK(MPI_File_seek(DG->mfpX, posX, MPI_SEEK_SET));
Expand Down Expand Up @@ -979,7 +979,7 @@ void* loadXY_DataGen(DG_Data* DG, int buffer_index, int ds_ptr) {
if (err)
msg("Error fseek ", __func__);
n_read = fread(bytesY, sizeof (unsigned char), DG->n_sizeY, DG->fpY); */
n_read = pread(fileno(DG->fpY), bytesY, DG->n_sizeY*sizeof (float), posY);
n_read = (int) pread(fileno(DG->fpY), bytesY, DG->n_sizeY*sizeof (unsigned char), posY);
} else {
#ifdef cMPI
MPICHECK(MPI_File_seek(DG->mfpY, posY, MPI_SEEK_SET));
Expand Down Expand Up @@ -1072,7 +1072,7 @@ void* loadXY_DataGen_float(DG_Data* DG, int buffer_index, int ds_ptr) {
msg("Error fseek ", __func__);
}
n_read = fread(bytesX, sizeof (float), DG->n_sizeX, DG->fpX); */
n_read = pread(fileno(DG->fpX), bytesX, DG->n_sizeX*sizeof (float), posX);
n_read = (int) pread(fileno(DG->fpX), bytesX, DG->n_sizeX*sizeof (float), posX);
} else {
#ifdef cMPI
MPICHECK(MPI_File_seek(DG->mfpX, posX, MPI_SEEK_SET));
Expand All @@ -1082,7 +1082,7 @@ void* loadXY_DataGen_float(DG_Data* DG, int buffer_index, int ds_ptr) {
}

//if (n_read != DG->n_sizeX) {
if (n_read != DG->n_sizeX*sizeof (float)) {
if (n_read != DG->n_sizeX*sizeof(float)) {
printf("%s n_read %d n_size %d\n", __func__, n_read, DG->n_sizeX);
msg("Error freadX ", __func__);
}
Expand Down Expand Up @@ -1112,7 +1112,7 @@ void* loadXY_DataGen_float(DG_Data* DG, int buffer_index, int ds_ptr) {
if (err)
msg("Error fseek ", __func__);
n_read = fread(bytesY, sizeof (float), DG->n_sizeY, DG->fpY); */
n_read = pread(fileno(DG->fpY), bytesY, DG->n_sizeY*sizeof (float), posY);
n_read = (int) pread(fileno(DG->fpY), bytesY, DG->n_sizeY*sizeof (float), posY);
} else {
#ifdef cMPI
MPICHECK(MPI_File_seek(DG->mfpY, posY, MPI_SEEK_SET));
Expand Down

0 comments on commit e74840c

Please sign in to comment.