Method write

SRC/runtime/commands/utilities/BinaryFileStream.cpp:245–304

}

int
BinaryFileStream::write(Vector& data)
{
  if (fileOpen == 0)
    this->open();

  //
  // if not parallel, just write the data
  //

  if (sendSelfCount == 0) {
    (*this) << data;
    return 0;
  }

  //
  // otherwise parallel, send the data if not p0
  //

  if (sendSelfCount < 0) {
    if (data.Size() != 0) {
      return theChannels[0]->sendVector(0, 0, data);
    } else
      return 0;
  }

  //
  // if p0 recv the data & write it out sorted
  //

  // recv data
  for (int i = 0; i <= sendSelfCount; ++i) {
    int numColumns = (*sizeColumns)(i);
    double* dataI  = theData[i];
    if (i == 0) {
      for (int j = 0; j < numColumns; j++) {
        dataI[j] = data(j);
      }
    } else {
      if (numColumns != 0) {
        theChannels[i - 1]->recvVector(0, 0, *(theRemoteData[i]));
      }
    }
  }

  Matrix& printMapping = *mapping;

  // write data
  for (int i = 0; i < maxCount + 1; ++i) {
    int fileID   = (int)printMapping(0, i);
    int startLoc = (int)printMapping(1, i);
    int numData  = (int)printMapping(2, i);
    double* data = theData[fileID];
    //    for (int j=0; j<numData; j++)
    theFile.write((char*)(&data[startLoc]), 8 * numData);
  }
  theFile << "\n";