Skip to content

Commit ed9e60a

Browse files
committed
Modify existing test to verify code change behaviour
Signed-off-by: Ashish Singh <ssashish@amazon.com>
1 parent 27e3218 commit ed9e60a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

server/src/test/java/org/opensearch/indices/replication/SegmentReplicationTargetServiceTests.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -625,6 +625,7 @@ public void testStartReplicationListenerSuccess() throws InterruptedException {
625625

626626
latch.await(2, TimeUnit.SECONDS);
627627
verify(spy, (atLeastOnce())).updateVisibleCheckpoint(eq(0L), eq(replicaShard));
628+
verify(spy, times(1)).processLatestReceivedCheckpoint(any(), any());
628629
}
629630

630631
public void testStartReplicationListenerFailure() throws InterruptedException {
@@ -851,4 +852,5 @@ public void testProcessCheckpointOnClusterStateUpdate() {
851852
spy.clusterChanged(new ClusterChangedEvent("ignored", oldState, newState));
852853
verify(spy, times(1)).processLatestReceivedCheckpoint(eq(replicaShard), any());
853854
}
855+
854856
}

0 commit comments

Comments
 (0)