| 33 |
|
#ifndef IO_IFSTRSTREAM_HPP |
| 34 |
|
#define IO_IFSTRSTREAM_HPP |
| 35 |
|
|
| 36 |
+ |
#include <cassert> |
| 37 |
|
#include <cstring> |
| 38 |
|
#include <fstream> |
| 39 |
|
#include <sstream> |
| 210 |
|
|
| 211 |
|
//check the filename is the same |
| 212 |
|
filenameLen = strlen(filename); |
| 213 |
< |
commStatus = MPI_Bcast(filenameLen, 1, MPI_INT, masterNode, MPI_COMM_WORLD); |
| 214 |
< |
commStatus = MPI_Bcast(filename, filenameLen, MPI_CHAR, masterNode, MPI_COMM_WORLD); |
| 213 |
> |
commStatus = MPI_Bcast(&filenameLen, 1, MPI_INT, masterNode, MPI_COMM_WORLD); |
| 214 |
> |
commStatus = MPI_Bcast((void*)filename, filenameLen, MPI_CHAR, masterNode, MPI_COMM_WORLD); |
| 215 |
|
|
| 216 |
|
diffFilename = 0; |
| 217 |
< |
commStatus = MPI_Allreduce(diffFilename, error, 1, MPI_INT, MPI_COMM_WORLD); |
| 217 |
> |
commStatus = MPI_Allreduce(&diffFilename, &error, 1, MPI_INT, MPI_SUM, MPI_COMM_WORLD); |
| 218 |
|
|
| 219 |
|
//if file names are different just return false |
| 220 |
|
if (error > 0) |
| 226 |
|
|
| 227 |
|
if (fin.is_open()) { |
| 228 |
|
|
| 229 |
< |
fin.in.seekg(0, ios::end); |
| 229 |
> |
fin.seekg(0, ios::end); |
| 230 |
|
fileSize = fin.tellg(); |
| 231 |
< |
|
| 231 |
> |
fin.seekg(0, ios::beg); |
| 232 |
> |
|
| 233 |
|
// '\0' need one more char |
| 234 |
|
fbuf = new char[fileSize+1]; |
| 235 |
|
|
| 274 |
|
} else{ |
| 275 |
|
//check file name |
| 276 |
|
if (checkFilename) { |
| 277 |
< |
commStatus = MPI_Bcast(filenameLen, 1, MPI_INT, masterNode, MPI_COMM_WORLD); |
| 277 |
> |
commStatus = MPI_Bcast(&filenameLen, 1, MPI_INT, masterNode, MPI_COMM_WORLD); |
| 278 |
|
|
| 279 |
|
char * masterFilename = new char[filenameLen]; |
| 280 |
|
commStatus = MPI_Bcast(masterFilename, filenameLen, MPI_CHAR, masterNode, MPI_COMM_WORLD); |
| 286 |
|
|
| 287 |
|
delete masterFilename; |
| 288 |
|
|
| 289 |
< |
commStatus = MPI_Allreduce(diffFilename, error, 1, MPI_INT, MPI_COMM_WORLD); |
| 289 |
> |
commStatus = MPI_Allreduce(&diffFilename, &error, 1, MPI_INT, MPI_SUM, MPI_COMM_WORLD); |
| 290 |
|
|
| 291 |
|
if (error > 0) |
| 292 |
|
return false; |