@Test public void testApplyCurrentLogRecoveryBatch() { try { coordinator.applyCurrentLogRecoveryBatch(); } catch (final IllegalArgumentException e) { fail("IllegalArgumentException should not happen - if the pruning modification delegate is passed"); } }
@Override public void applyCurrentLogRecoveryBatch() { checkState(open, "call startLogRecovery before calling applyCurrentLogRecoveryBatch"); open = false; }
ShardRecoveryCoordinator implements RaftActorRecoveryCohort { @Override public void applyCurrentLogRecoveryBatch() { checkState(open, "call startLogRecovery before calling applyCurrentLogRecoveryBatch"); open = false; } }
ShardRecoveryCoordinator implements RaftActorRecoveryCohort { @Override public void applyCurrentLogRecoveryBatch() { checkState(open, "call startLogRecovery before calling applyCurrentLogRecoveryBatch"); open = false; } ShardRecoveryCoordinator(final ShardDataTree store, final String shardName, final Logger log); }
ShardRecoveryCoordinator implements RaftActorRecoveryCohort { @Override public void applyCurrentLogRecoveryBatch() { checkState(open, "call startLogRecovery before calling applyCurrentLogRecoveryBatch"); open = false; } ShardRecoveryCoordinator(final ShardDataTree store, final String shardName, final Logger log); @Override void startLogRecoveryBatch(final int maxBatchSize); @Override @SuppressWarnings("checkstyle:IllegalCatch") void appendRecoveredLogEntry(final Payload payload); @Override void applyCurrentLogRecoveryBatch(); @Override @SuppressWarnings("checkstyle:IllegalCatch") void applyRecoverySnapshot(final Snapshot.State snapshotState); }
ShardRecoveryCoordinator implements RaftActorRecoveryCohort { @Override public void applyCurrentLogRecoveryBatch() { checkState(open, "call startLogRecovery before calling applyCurrentLogRecoveryBatch"); open = false; } ShardRecoveryCoordinator(final ShardDataTree store, final String shardName, final Logger log); @Override void startLogRecoveryBatch(final int maxBatchSize); @Override @SuppressWarnings("checkstyle:IllegalCatch") void appendRecoveredLogEntry(final Payload payload); @Override void applyCurrentLogRecoveryBatch(); @Override @SuppressWarnings("checkstyle:IllegalCatch") void applyRecoverySnapshot(final Snapshot.State snapshotState);  }