| 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; | 
| 256 |  | int metaDataBlockStart = -1; | 
| 257 |  | int metaDataBlockEnd = -1; | 
| 258 |  | int i; | 
| 259 | < | streamoff mdOffset; | 
| 259 | > | streamoff mdOffset(0); | 
| 260 |  | int mdFileVersion; | 
| 261 | + |  | 
| 262 |  |  | 
| 263 |  | #ifdef IS_MPI | 
| 264 |  | const int masterNode = 0; | 
| 265 |  | if (worldRank == masterNode) { | 
| 266 |  | #endif | 
| 267 |  |  | 
| 268 | < | std::ifstream mdFile_(mdFileName.c_str()); | 
| 268 | > | std::ifstream mdFile_; | 
| 269 | > | mdFile_.open(mdFileName.c_str(), ifstream::in | ifstream::binary); | 
| 270 |  |  | 
| 271 |  | if (mdFile_.fail()) { | 
| 272 |  | sprintf(painCave.errMsg, | 
| 499 |  | int nTarget; | 
| 500 |  | int done; | 
| 501 |  | int i; | 
| 500 | – | int j; | 
| 502 |  | int loops; | 
| 503 |  | int which_proc; | 
| 504 |  | int nProcessors; | 
| 919 |  | } | 
| 920 |  |  | 
| 921 |  | void SimCreator::loadCoordinates(SimInfo* info, const std::string& mdFileName) { | 
| 921 | – | Globals* simParams; | 
| 922 |  |  | 
| 923 | – | simParams = info->getSimParams(); | 
| 924 | – |  | 
| 923 |  | DumpReader reader(info, mdFileName); | 
| 924 |  | int nframes = reader.getNFrames(); | 
| 925 |  |  |