Method finished

src/log/recover.cpp:598–620

  }

  void finished(const Future<bool>& future)
  {
    if (future.isDiscarded()) {
      promise.discard();
      terminate(self());
    } else if (future.isFailed()) {
      promise.fail(future.failure());
      terminate(self());
    } else if (!future.get()) {
      // We add a random delay before each retry because we do not
      // want to saturate the network/disk IO in some cases. The delay
      // is chosen randomly to reduce the likelyhood of conflicts
      // (i.e., a replica receives a recover request while it is
      // changing its status).
      static const Duration T = Milliseconds(500);
      Duration d = T * (1.0 + (double) os::random() / RAND_MAX);
      VLOG(2) << "Retrying recovery in " << stringify(d);
      delay(d, self(), &Self::start);
    } else {
      promise.set(replica);
      terminate(self());
    }
  }

  const size_t quorum;
  Owned<Replica> replica;