[Tarantool-patches] [PATCH v4 09/12] raft: introduce raft_start/stop_candidate
Vladislav Shpilevoy
v.shpilevoy at tarantool.org
Tue Apr 20 01:35:41 MSK 2021
Good job on the patch!
You didn't cover the stop_candidate call with demote flag true in the
unit tests. I added my commit on top of this one. See it on the branch
and below. Squash if you agree. Otherwise lets discuss.
====================
diff --git a/test/unit/raft.c b/test/unit/raft.c
index a718ab3f4..29e48da13 100644
--- a/test/unit/raft.c
+++ b/test/unit/raft.c
@@ -1270,29 +1270,50 @@ raft_test_too_long_wal_write(void)
static void
raft_test_start_stop_candidate(void)
{
- raft_start_test(4);
+ raft_start_test(8);
struct raft_node node;
raft_node_create(&node);
raft_node_cfg_is_candidate(&node, false);
raft_node_cfg_election_quorum(&node, 1);
- raft_start_candidate(&node.raft);
+ raft_node_start_candidate(&node);
raft_run_next_event();
is(node.raft.state, RAFT_STATE_LEADER, "became leader after "
- "start_candidate");
- raft_stop_candidate(&node.raft, false);
+ "start candidate");
+
+ raft_node_stop_candidate(&node);
raft_run_for(node.cfg_death_timeout);
is(node.raft.state, RAFT_STATE_LEADER, "remain leader after "
- "stop_candidate");
+ "stop candidate");
+
+ raft_node_demote_candidate(&node);
+ is(node.raft.state, RAFT_STATE_FOLLOWER, "demote drops a non-candidate "
+ "leader to a follower");
+
+ /*
+ * Ensure the non-candidate leader is demoted when sees a new term, and
+ * does not try election again.
+ */
+ raft_node_start_candidate(&node);
+ raft_run_next_event();
+ raft_node_stop_candidate(&node);
+ is(node.raft.state, RAFT_STATE_LEADER, "non-candidate but still "
+ "leader");
is(raft_node_send_vote_request(&node,
- 3 /* Term. */,
+ 4 /* Term. */,
"{}" /* Vclock. */,
2 /* Source. */
), 0, "vote request from 2");
is(node.raft.state, RAFT_STATE_FOLLOWER, "demote once new election "
- "starts");
+ "starts");
+
+ raft_run_for(node.cfg_election_timeout * 2);
+ is(node.raft.state, RAFT_STATE_FOLLOWER, "still follower");
+ is(node.raft.term, 4, "still the same term");
+
+ raft_node_destroy(&node);
raft_finish_test();
}
diff --git a/test/unit/raft.result b/test/unit/raft.result
index f9a8f249b..3a3dc5dd2 100644
--- a/test/unit/raft.result
+++ b/test/unit/raft.result
@@ -221,11 +221,15 @@ ok 12 - subtests
ok 13 - subtests
*** raft_test_too_long_wal_write: done ***
*** raft_test_start_stop_candidate ***
- 1..4
- ok 1 - became leader after start_candidate
- ok 2 - remain leader after stop_candidate
- ok 3 - vote request from 2
- ok 4 - demote once new election starts
+ 1..8
+ ok 1 - became leader after start candidate
+ ok 2 - remain leader after stop candidate
+ ok 3 - demote drops a non-candidate leader to a follower
+ ok 4 - non-candidate but still leader
+ ok 5 - vote request from 2
+ ok 6 - demote once new election starts
+ ok 7 - still follower
+ ok 8 - still the same term
ok 14 - subtests
*** raft_test_start_stop_candidate: done ***
*** main_f: done ***
diff --git a/test/unit/raft_test_utils.c b/test/unit/raft_test_utils.c
index b8735f373..452c05c81 100644
--- a/test/unit/raft_test_utils.c
+++ b/test/unit/raft_test_utils.c
@@ -387,6 +387,27 @@ raft_node_unblock(struct raft_node *node)
}
}
+void
+raft_node_start_candidate(struct raft_node *node)
+{
+ assert(raft_node_is_started(node));
+ raft_start_candidate(&node->raft);
+}
+
+void
+raft_node_stop_candidate(struct raft_node *node)
+{
+ assert(raft_node_is_started(node));
+ raft_stop_candidate(&node->raft, false);
+}
+
+void
+raft_node_demote_candidate(struct raft_node *node)
+{
+ assert(raft_node_is_started(node));
+ raft_stop_candidate(&node->raft, true);
+}
+
void
raft_node_cfg_is_enabled(struct raft_node *node, bool value)
{
diff --git a/test/unit/raft_test_utils.h b/test/unit/raft_test_utils.h
index bc3db0c2a..5f8618716 100644
--- a/test/unit/raft_test_utils.h
+++ b/test/unit/raft_test_utils.h
@@ -208,6 +208,23 @@ raft_node_block(struct raft_node *node);
void
raft_node_unblock(struct raft_node *node);
+/**
+ * Make the node candidate, and maybe start election if a leader is not known.
+ */
+void
+raft_node_start_candidate(struct raft_node *node);
+
+/**
+ * Make the node non-candidate for next elections, but if it is a leader right
+ * now, it will stay a leader.
+ */
+void
+raft_node_stop_candidate(struct raft_node *node);
+
+/** Stop the candidate and remove its leader role if present. */
+void
+raft_node_demote_candidate(struct raft_node *node);
+
/** Configuration methods. */
void
More information about the Tarantool-patches
mailing list