33 |
|
#ifndef IO_IFSTRSTREAM_HPP |
34 |
|
#define IO_IFSTRSTREAM_HPP |
35 |
|
|
36 |
+ |
#include <cassert> |
37 |
|
#include <cstring> |
38 |
|
#include <fstream> |
39 |
|
#include <sstream> |
40 |
|
|
41 |
|
#ifdef IS_MPI |
42 |
< |
#include <mpi.hpp> |
42 |
> |
#include <mpi.h> |
43 |
|
#endif |
44 |
|
|
45 |
|
namespace oopse { |
119 |
|
} |
120 |
|
|
121 |
|
/** |
122 |
< |
* |
122 |
> |
* virtual destructor will close the file(in single mode) and clear the stream buffer |
123 |
|
*/ |
124 |
|
~basic_ifstrstream(){ |
125 |
|
close(); |
176 |
|
* parallel mode) associated with the stream. |
177 |
|
*/ |
178 |
|
_Buf* rdbuf() const{ |
179 |
< |
return const_cast<_Buf*>(internalBuf_); |
179 |
> |
return static_cast<_Buf*>(internalBuf_); |
180 |
|
} |
181 |
|
|
182 |
|
private: |
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; |
340 |
|
bool isRead; /** file opened flag */ |
341 |
|
}; |
342 |
|
|
343 |
< |
typedef basic_istringstream<char, char_traits<char>, allocator<char> > ifstringstream; |
343 |
> |
typedef basic_ifstrstream<char, char_traits<char>, allocator<char> > ifstrstream; |
344 |
|
}//namespace oopse |
345 |
|
#endif //IO_IFSTRSTREAM_HPP |