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; |