int CompileWithWorker()

in tools/worker/compile_with_worker.cc [78:116]
26 lines of code
4 McCabe index (conditional complexity)

int CompileWithWorker(const std::vector<std::string> &args) {
  // Set up the input and output streams used to communicate with Bazel over
  // stdin and stdout.
  google::protobuf::io::FileInputStream file_input_stream(STDIN_FILENO);
  file_input_stream.SetCloseOnDelete(false);
  google::protobuf::io::FileOutputStream file_output_stream(STDOUT_FILENO);
  file_output_stream.SetCloseOnDelete(false);

  // Pass the "universal arguments" to the Swift work processor. They will be
  // rewritten to replace any placeholders if necessary, and then passed at the
  // beginning of any process invocation. Note that these arguments include the
  // tool itself (i.e., "swiftc").
  WorkProcessor swift_worker(args);

  while (true) {
    blaze::worker::WorkRequest request;
    if (!google::protobuf::util::ParseDelimitedFromZeroCopyStream(
            &request, &file_input_stream, nullptr)) {
      std::cerr << "Could not read WorkRequest from stdin. Killing worker "
                << "process.\n";
      return 254;
    }

    blaze::worker::WorkResponse response;
    swift_worker.ProcessWorkRequest(request, &response);

    if (!google::protobuf::util::SerializeDelimitedToZeroCopyStream(
            response, &file_output_stream)) {
      std::cerr << "Could not write WorkResponse to stdout. Killing worker "
                << "process.\n";
      return 254;
    }
    // Flush stdout after writing to ensure that Bazel doesn't hang waiting for
    // the response due to buffering.
    file_output_stream.Flush();
  }

  return 0;
}