Method execute

system/lib/wasmfs/fuzzer/workload.cpp:71–119

}

void ReadWrite::execute() {
  // This function should produce a string that consists of 1 character type.
  work.resize(1 + rand.upTo(MAX_WORK));

  for (int i = 0; i < work.size(); i++) {
    work[i] = rand.getSingleSymbolString(FILE_SIZE);
  }
  // Generate a test file to read and write to.
  fd = open("test", O_CREAT | O_RDWR, 0777);
  assert(fd != -1);

  // Populate the file with initial data.
  assert(pwrite(fd, work.begin()->c_str(), work.begin()->size(), 0) != -1);

  // Create writer threads.
  std::vector<std::thread> writers;
  std::vector<std::thread> readers;

  for (int i = 0; i < NUM_WRITERS; i++) {
    std::thread th(&ReadWrite::writer, this);
    writers.emplace_back(std::move(th));
  }

  for (int i = 0; i < NUM_READERS; i++) {
    std::thread th(&ReadWrite::reader, this);
    readers.emplace_back(std::move(th));
  }

  // This atomic bool ensures that all threads have an equal chance of
  // starting first.
  go.store(true);

  std::this_thread::sleep_for(std::chrono::seconds(DURATION));

  // Stop file operations after pre-defined duration.
  stop.store(true);

  for (auto& th : writers) {
    th.join();
  }

  for (auto& th : readers) {
    th.join();
  }

  // Clean up files.
  unlink("test");
  close(fd);
}
} // namespace wasmfs