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