symious commented on code in PR #1296:
URL: https://github.com/apache/ratis/pull/1296#discussion_r2422455977
##########
ratis-examples/src/test/java/org/apache/ratis/examples/counter/TestCounter.java:
##########
@@ -59,4 +63,40 @@ public void testSeveralCounter(MiniRaftCluster cluster)
throws IOException, Inte
Assertions.assertEquals(30,
reply3.getMessage().getContent().asReadOnlyByteBuffer().getInt());
}
}
+
+ @ParameterizedTest
+ @MethodSource("data")
+ public void testSeveralCounterFromFollower(MiniRaftCluster cluster) throws
IOException, InterruptedException {
+ setAndStart(cluster);
+
+ List<RaftServer.Division> followers = cluster.getFollowers();
+ Assertions.assertEquals(2, followers.size());
+ final RaftPeerId f0 = followers.get(0).getId();
+ final RaftServer.Division d1 = cluster.getDivision(f0);
+
+ Message queryMessage = Message.valueOf("GET");
+
+ try (final RaftClient client = cluster.createClient()) {
+ for (int i = 0; i < 10; i++) {
+ client.io().send(Message.valueOf("INCREMENT"));
+ }
+ RaftClientReply reply1 = client.io().sendReadOnly(queryMessage);
+ Assertions.assertEquals(10, getCounterInt(reply1.getMessage()));
+ boolean isFollowerUptoDate = d1.okForLocalReadBounded(1000, 100);
+ // Clients can choose to query from local StateMachine or leader
Review Comment:
@szetszwo Add a new API for client to call this method directly. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
