Method exec

src/IO/Writer/Module/AsyncWriter.cpp:21–42

  // (do nothing here)
}
void AsyncWriter::exec(const async::ExecInfo& info, const AsyncWriterExec& params) {
  const void* data = info.buffer(PlanId);
  const size_t size = info.bufferSize(PlanId);
  const char* strData = reinterpret_cast<const char*>(data);

  int rank = 0;
  MPI_Comm_rank(MPI_COMM_WORLD, &rank);
  if (printPlan && rank == 0) {
    logInfo(rank) << "Printing current plan:" << std::string(strData, strData + size);
  }

  {
    // for the Hdf5 implementations, we'll need to serialize writes
    // (TODO: make one AsyncWriter only in total)
    const std::lock_guard lock(globalLock);
    writer = Writer(std::string(strData, strData + size));
    instance = std::optional(writer.beginWrite(info));
    // for now write synchronously
    instance.value().close();
    instance.reset();
  }
}
void AsyncWriter::execWait(const async::ExecInfo& info) {
  // TODO: async finalize
}