|
@@ -340,10 +340,9 @@ public class PeerRecoveryTargetService implements IndexEventListener {
|
|
|
@Override
|
|
|
public void messageReceived(final RecoveryTranslogOperationsRequest request, final TransportChannel channel,
|
|
|
Task task) throws IOException {
|
|
|
- try (RecoveryRef recoveryRef =
|
|
|
- onGoingRecoveries.getRecoverySafe(request.recoveryId(), request.shardId())) {
|
|
|
+ try (RecoveryRef recoveryRef = onGoingRecoveries.getRecoverySafe(request.recoveryId(), request.shardId())) {
|
|
|
final RecoveryTarget recoveryTarget = recoveryRef.target();
|
|
|
- final ActionListener<Void> listener = createOrFinishListener(recoveryRef, channel, Actions.FILES_INFO, request,
|
|
|
+ final ActionListener<Void> listener = createOrFinishListener(recoveryRef, channel, Actions.TRANSLOG_OPS, request,
|
|
|
nullVal -> new RecoveryTranslogOperationsResponse(recoveryTarget.indexShard().getLocalCheckpoint()));
|
|
|
if (listener == null) {
|
|
|
return;
|