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