| 1 |
|
/* |
| 2 |
< |
* Copyright (c) 2005 The University of Notre Dame. All Rights Reserved. |
| 2 |
> |
* copyright (c) 2005 The University of Notre Dame. All Rights Reserved. |
| 3 |
|
* |
| 4 |
|
* The University of Notre Dame grants you ("Licensee") a |
| 5 |
|
* non-exclusive, royalty free, license to use, modify and |
| 100 |
|
#ifdef IS_MPI |
| 101 |
|
int streamSize; |
| 102 |
|
const int masterNode = 0; |
| 103 |
< |
int commStatus; |
| 103 |
> |
|
| 104 |
|
if (worldRank == masterNode) { |
| 105 |
< |
commStatus = MPI_Bcast(&mdFileVersion, 1, MPI_INT, masterNode, MPI_COMM_WORLD); |
| 105 |
> |
MPI::COMM_WORLD.Bcast(&mdFileVersion, 1, MPI::INT, masterNode); |
| 106 |
|
#endif |
| 107 |
|
SimplePreprocessor preprocessor; |
| 108 |
< |
preprocessor.preprocess(rawMetaDataStream, filename, startOfMetaDataBlock, ppStream); |
| 108 |
> |
preprocessor.preprocess(rawMetaDataStream, filename, startOfMetaDataBlock, |
| 109 |
> |
ppStream); |
| 110 |
|
|
| 111 |
|
#ifdef IS_MPI |
| 112 |
|
//brocasting the stream size |
| 113 |
|
streamSize = ppStream.str().size() +1; |
| 114 |
< |
commStatus = MPI_Bcast(&streamSize, 1, MPI_LONG, masterNode, MPI_COMM_WORLD); |
| 115 |
< |
|
| 116 |
< |
commStatus = MPI_Bcast(static_cast<void*>(const_cast<char*>(ppStream.str().c_str())), streamSize, MPI_CHAR, masterNode, MPI_COMM_WORLD); |
| 116 |
< |
|
| 114 |
> |
MPI::COMM_WORLD.Bcast(&streamSize, 1, MPI::LONG, masterNode); |
| 115 |
> |
MPI::COMM_WORLD.Bcast(static_cast<void*>(const_cast<char*>(ppStream.str().c_str())), |
| 116 |
> |
streamSize, MPI::CHAR, masterNode); |
| 117 |
|
|
| 118 |
|
} else { |
| 119 |
|
|
| 120 |
< |
commStatus = MPI_Bcast(&mdFileVersion, 1, MPI_INT, masterNode, MPI_COMM_WORLD); |
| 120 |
> |
MPI::COMM_WORLD.Bcast(&mdFileVersion, 1, MPI::INT, masterNode); |
| 121 |
|
|
| 122 |
|
//get stream size |
| 123 |
< |
commStatus = MPI_Bcast(&streamSize, 1, MPI_LONG, masterNode, MPI_COMM_WORLD); |
| 123 |
> |
MPI::COMM_WORLD.Bcast(&streamSize, 1, MPI::LONG, masterNode); |
| 124 |
|
|
| 125 |
|
char* buf = new char[streamSize]; |
| 126 |
|
assert(buf); |
| 127 |
|
|
| 128 |
|
//receive file content |
| 129 |
< |
commStatus = MPI_Bcast(buf, streamSize, MPI_CHAR, masterNode, MPI_COMM_WORLD); |
| 129 |
> |
MPI::COMM_WORLD.Bcast(buf, streamSize, MPI::CHAR, masterNode); |
| 130 |
|
|
| 131 |
|
ppStream.str(buf); |
| 132 |
|
delete [] buf; |
| 499 |
|
int nTarget; |
| 500 |
|
int done; |
| 501 |
|
int i; |
| 502 |
– |
int j; |
| 502 |
|
int loops; |
| 503 |
|
int which_proc; |
| 504 |
|
int nProcessors; |
| 919 |
|
} |
| 920 |
|
|
| 921 |
|
void SimCreator::loadCoordinates(SimInfo* info, const std::string& mdFileName) { |
| 923 |
– |
Globals* simParams; |
| 922 |
|
|
| 925 |
– |
simParams = info->getSimParams(); |
| 926 |
– |
|
| 923 |
|
DumpReader reader(info, mdFileName); |
| 924 |
|
int nframes = reader.getNFrames(); |
| 925 |
|
|