Method run

src/slave/container_loggers/logrotate.cpp:149–161

Prepares and starts the loop which reads from stdin, writes to the leading log file, and manages total log size.

  // Prepares and starts the loop which reads from stdin, writes to the
  // leading log file, and manages total log size.
  Future<Nothing> run()
  {
    // NOTE: This is a prerequisuite for `io::read`.
    Try<Nothing> async = io::prepare_async(STDIN_FILENO);
    if (async.isError()) {
      return Failure("Failed to set async pipe: " + async.error());
    }

    // NOTE: This does not block.
    loop();

    return promise.future();
  }

  // Reads from stdin and writes to the leading log file.
  void loop()