/**
 * Handles an OK install response.
 */
@SuppressWarnings("unused")
protected void handleInstallResponseOk(RaftMemberContext member, InstallRequest request, InstallResponse response) {
  // Reset the member failure count and update the member's status if necessary.
  succeedAttempt(member);

  // If the install request was completed successfully, set the member's snapshotIndex and reset
  // the next snapshot index/offset.
  if (request.complete()) {
    member.setNextSnapshotIndex(0);
    member.setNextSnapshotOffset(0);
    member.setSnapshotIndex(request.snapshotIndex());
  }
  // If more install requests remain, increment the member's snapshot offset.
  else {
    member.setNextSnapshotOffset(request.chunkOffset() + 1);
  }

  // Recursively append entries to the member.
  appendEntries(member);
}
 

/**
 * Handles an install response.
 */
protected void handleInstallResponse(RaftMemberContext member, InstallRequest request, InstallResponse response, long timestamp) {
  if (response.status() == RaftResponse.Status.OK) {
    handleInstallResponseOk(member, request, response);
  } else {
    handleInstallResponseError(member, request, response);
  }
}
 

/**
 * Handles an ERROR install response.
 */
@SuppressWarnings("unused")
protected void handleInstallResponseError(RaftMemberContext member, InstallRequest request, InstallResponse response) {
  log.warn("Failed to install {}", member.getMember().memberId());
  member.setNextSnapshotIndex(0);
  member.setNextSnapshotOffset(0);
}
 

@Override
public CompletableFuture<InstallResponse> onInstall(InstallRequest request) {
  logRequest(request);
  return Futures.completedFuture(logResponse(InstallResponse.builder()
      .withStatus(Status.ERROR)
      .withError(RaftError.Type.UNAVAILABLE)
      .build()));
}
 

@Override
public CompletableFuture<InstallResponse> install(MemberId memberId, InstallRequest request) {
  return sendAndReceive(memberId, "install", request);
}
 

@Override
public void registerInstallHandler(Function<InstallRequest,
    CompletableFuture<InstallResponse>> handler) {
  registerHandler("install", handler);
}
 

@Override
public CompletableFuture<InstallResponse> install(MemberId memberId, InstallRequest request) {
  return getServer(memberId).thenCompose(listener ->
      listener.install(encode(request))).thenApply(this::decode);
}
 

@Override
public void registerInstallHandler(Function<InstallRequest,
    CompletableFuture<InstallResponse>> handler) {
  this.installHandler = handler;
}
 

@Override
public CompletableFuture<InstallResponse> install(MemberId memberId, InstallRequest request) {
  return sendAndReceive(memberId, "install", request);
}
 

@Override
public void registerInstallHandler(Function<InstallRequest,
    CompletableFuture<InstallResponse>> handler) {
  registerHandler("install", handler);
}
 

@Override
public CompletableFuture<InstallResponse> install(MemberId memberId, InstallRequest request) {
  return getServer(memberId).thenCompose(listener ->
      listener.install(encode(request))).thenApply(this::decode);
}
 

@Override
public void registerInstallHandler(Function<InstallRequest,
    CompletableFuture<InstallResponse>> handler) {
  this.installHandler = handler;
}
 

@Override
public CompletableFuture<InstallResponse> install(MemberId memberId, InstallRequest request) {
  return sendAndReceive(context.installSubject, request, memberId);
}
 

@Override
public void registerInstallHandler(Function<InstallRequest, CompletableFuture<InstallResponse>> handler) {
  clusterCommunicator.subscribe(context.installSubject, serializer::decode, handler, serializer::encode);
}
 

@Override
protected void handleInstallResponse(RaftMemberContext member, InstallRequest request, InstallResponse response, long timestamp) {
  super.handleInstallResponse(member, request, response, timestamp);
  recordHeartbeat(member, timestamp);
}
 

@Override
public CompletableFuture<InstallResponse> onInstall(InstallRequest request) {
  CompletableFuture<InstallResponse> future = super.onInstall(request);
  resetHeartbeatTimeout();
  return future;
}
 

@Override
public CompletableFuture<InstallResponse> install(MemberId memberId, InstallRequest request) {
  return sendAndReceive(memberId, "install", request);
}
 

@Override
public void registerInstallHandler(Function<InstallRequest, CompletableFuture<InstallResponse>> handler) {
  registerHandler("install", handler);
}
 

@Override
public CompletableFuture<InstallResponse> install(MemberId memberId, InstallRequest request) {
  return getServer(memberId).thenCompose(listener -> listener.install(encode(request))).thenApply(this::decode);
}
 

@Override
public void registerInstallHandler(Function<InstallRequest, CompletableFuture<InstallResponse>> handler) {
  this.installHandler = handler;
}
 

/**
 * Handles an install request.
 *
 * @param request The request to handle.
 * @return A completable future to be completed with the request response.
 */
CompletableFuture<InstallResponse> onInstall(InstallRequest request);