See <https://ci.trafficserver.apache.org/job/clang-format/40/changes>
Changes:
[jplev] TS-3786: Implementation of the RAFT consensus protocol.
------------------------------------------
[...truncated 5731 lines...]
raft.Propose(log_entry);
@@ -445,13 +495,14 @@ TEST_F(RaftTest, OneLogLog) {
EXPECT_EQ(servers_[0]->commits_[1]->data(), "b");
}
-TEST_F(RaftTest, OneTwoLogLog) {
+TEST_F(RaftTest, OneTwoLogLog)
+{
LogEntry config_log_entry(ConfigLogEntry(2));
StartUp(2, config_log_entry);
Ticks(20);
int ileader = servers_[0]->leader_[0] - '0';
int iother = ileader ? 0 : 1;
- auto& raft = *servers_[ileader]->raft_.get();
+ auto &raft = *servers_[ileader]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a");
raft.Propose(log_entry);
@@ -460,16 +511,13 @@ TEST_F(RaftTest, OneTwoLogLog) {
raft.Propose(log_entry);
Ticks(20);
EXPECT_EQ(servers_[ileader]->log_.size(), 7);
- EXPECT_NE(servers_[ileader]->log_[0]->vote(), ""); // vote.
- EXPECT_NE(servers_[ileader]->log_[1]->leader(), ""); // election.
- EXPECT_EQ(servers_[ileader]->log_[2]->data_committed(),
- servers_[ileader]->log_[1]->index());
+ EXPECT_NE(servers_[ileader]->log_[0]->vote(), ""); // vote.
+ EXPECT_NE(servers_[ileader]->log_[1]->leader(), ""); // election.
+ EXPECT_EQ(servers_[ileader]->log_[2]->data_committed(),
servers_[ileader]->log_[1]->index());
EXPECT_EQ(servers_[ileader]->log_[3]->data(), "a");
- EXPECT_EQ(servers_[ileader]->log_[4]->data_committed(),
- servers_[ileader]->log_[3]->index());
+ EXPECT_EQ(servers_[ileader]->log_[4]->data_committed(),
servers_[ileader]->log_[3]->index());
EXPECT_EQ(servers_[ileader]->log_[5]->data(), "b");
- EXPECT_EQ(servers_[ileader]->log_[6]->data_committed(),
- servers_[ileader]->log_[5]->index());
+ EXPECT_EQ(servers_[ileader]->log_[6]->data_committed(),
servers_[ileader]->log_[5]->index());
EXPECT_EQ(servers_[ileader]->commits_.size(), 2);
EXPECT_EQ(servers_[ileader]->commits_[0]->data(), "a");
EXPECT_EQ(servers_[ileader]->commits_[1]->data(), "b");
@@ -478,12 +526,13 @@ TEST_F(RaftTest, OneTwoLogLog) {
EXPECT_EQ(servers_[iother]->commits_[1]->data(), "b");
}
-TEST_F(RaftTest, OneTwoThreeLogDownLogUp) {
+TEST_F(RaftTest, OneTwoThreeLogDownLogUp)
+{
LogEntry config_log_entry(ConfigLogEntry(3));
StartUp(3, config_log_entry);
Ticks(20);
int ileader = servers_[0]->leader_[0] - '0';
- auto& raft = *servers_[ileader]->raft_.get();
+ auto &raft = *servers_[ileader]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a");
raft.Propose(log_entry);
@@ -506,12 +555,13 @@ TEST_F(RaftTest, OneTwoThreeLogDownLogUp) {
}
}
-TEST_F(RaftTest, OneTwoThreeLogLogThreeDamagedLogRestore) {
+TEST_F(RaftTest, OneTwoThreeLogLogThreeDamagedLogRestore)
+{
LogEntry config_log_entry(ConfigLogEntry(3));
StartUp(3, config_log_entry);
Ticks(20);
int ileader = servers_[0]->leader_[0] - '0';
- auto& raft = *servers_[ileader]->raft_.get();
+ auto &raft = *servers_[ileader]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a");
raft.Propose(log_entry);
@@ -531,23 +581,24 @@ TEST_F(RaftTest, OneTwoThreeLogLogThreeDamagedLogRestore)
{
}
}
-TEST_F(RaftTest, OneTwoLogLogThenThree) {
+TEST_F(RaftTest, OneTwoLogLogThenThree)
+{
LogEntry config_log_entry;
config_log_entry.mutable_config()->add_node("0");
config_log_entry.mutable_config()->add_node("1");
StartUp(2, config_log_entry);
Ticks(20);
int ileader = servers_[0]->leader_[0] - '0';
- auto& raft = *servers_[ileader]->raft_.get();
+ auto &raft = *servers_[ileader]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a");
raft.Propose(log_entry);
log_entry.set_data("b");
raft.Propose(log_entry);
Ticks(20);
- StartUp(1, config_log_entry); // Start node 2.
+ StartUp(1, config_log_entry); // Start node 2.
config_log_entry.mutable_config()->add_node("2");
- raft.Propose(config_log_entry); // Change config to [0, 1, 2].
+ raft.Propose(config_log_entry); // Change config to [0, 1, 2].
Ticks(20);
EXPECT_EQ(servers_[1]->commits_.size(), 3);
EXPECT_EQ(servers_[1]->commits_[0]->data(), "a");
@@ -560,11 +611,12 @@ TEST_F(RaftTest, OneTwoLogLogThenThree) {
EXPECT_EQ(servers_[2]->commits_[2]->config().node_size(), 3);
}
-TEST_F(RaftTest, OneRecover) {
+TEST_F(RaftTest, OneRecover)
+{
LogEntry config_log_entry;
StartUp(1, config_log_entry);
{
- auto& raft = *servers_[0]->raft_.get();
+ auto &raft = *servers_[0]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a");
raft.Propose(log_entry);
@@ -575,7 +627,8 @@ TEST_F(RaftTest, OneRecover) {
EXPECT_EQ(servers_[0]->commits_[0]->data(), "a");
}
-TEST_F(RaftTest, OneTwoThreeCrashAndBurnLeader) {
+TEST_F(RaftTest, OneTwoThreeCrashAndBurnLeader)
+{
LogEntry config_log_entry;
config_log_entry.mutable_config()->add_node("0");
config_log_entry.mutable_config()->add_node("1");
@@ -583,7 +636,7 @@ TEST_F(RaftTest, OneTwoThreeCrashAndBurnLeader) {
StartUp(3, config_log_entry);
Ticks(20);
int ileader = servers_[0]->leader_[0] - '0';
- auto& raft = *servers_[ileader]->raft_.get();
+ auto &raft = *servers_[ileader]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a");
raft.Propose(log_entry);
@@ -603,12 +656,13 @@ TEST_F(RaftTest, OneTwoThreeCrashAndBurnLeader) {
}
}
-TEST_F(RaftTest, FiveCrashLeaderAndAnotherAndRecover) {
+TEST_F(RaftTest, FiveCrashLeaderAndAnotherAndRecover)
+{
LogEntry config_log_entry(ConfigLogEntry(5));
StartUp(5, config_log_entry);
Ticks(20);
int ileader = servers_[0]->leader_[0] - '0';
- auto& raft = *servers_[ileader]->raft_.get();
+ auto &raft = *servers_[ileader]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a");
raft.Propose(log_entry);
@@ -630,12 +684,13 @@ TEST_F(RaftTest, FiveCrashLeaderAndAnotherAndRecover) {
EXPECT_EQ(servers_[(ileader + 1) % 5]->commits_[1]->data(), "b");
}
-TEST_F(RaftTest, FiveCrashAndBurnLeaderAndAnother) {
+TEST_F(RaftTest, FiveCrashAndBurnLeaderAndAnother)
+{
LogEntry config_log_entry(ConfigLogEntry(5));
StartUp(5, config_log_entry);
Ticks(20);
int ileader = servers_[0]->leader_[0] - '0';
- auto& raft = *servers_[ileader]->raft_.get();
+ auto &raft = *servers_[ileader]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a");
raft.Propose(log_entry);
@@ -656,7 +711,8 @@ TEST_F(RaftTest, FiveCrashAndBurnLeaderAndAnother) {
// Test that a log from a leader without quorum never is committed and that a
// log with the same index from a leader with quorum is.
-TEST_F(RaftTest, FiveLogDown3LogDown2Up3LogUp2) {
+TEST_F(RaftTest, FiveLogDown3LogDown2Up3LogUp2)
+{
LogEntry config_log_entry(ConfigLogEntry(5));
StartUp(5, config_log_entry);
Ticks(20);
@@ -664,7 +720,7 @@ TEST_F(RaftTest, FiveLogDown3LogDown2Up3LogUp2) {
down_.insert(to_string((ileader + 1) % 5));
down_.insert(to_string((ileader + 2) % 5));
down_.insert(to_string((ileader + 3) % 5));
- auto& raft = *servers_[ileader]->raft_.get();
+ auto &raft = *servers_[ileader]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a");
raft.Propose(log_entry);
@@ -676,7 +732,7 @@ TEST_F(RaftTest, FiveLogDown3LogDown2Up3LogUp2) {
down_.insert(to_string(ileader));
Ticks(20);
int ileader2 = servers_[((ileader + 1) % 5)]->leader_[0] - '0';
- auto& raft2 = *servers_[ileader2]->raft_.get();
+ auto &raft2 = *servers_[ileader2]->raft_.get();
log_entry.set_data("c");
raft2.Propose(log_entry);
log_entry.set_data("d");
@@ -692,13 +748,14 @@ TEST_F(RaftTest, FiveLogDown3LogDown2Up3LogUp2) {
}
}
-TEST_F(RaftTest, ReplicaFailover) {
+TEST_F(RaftTest, ReplicaFailover)
+{
LogEntry config_log_entry;
config_log_entry.mutable_config()->add_node("0");
config_log_entry.mutable_config()->add_replica("1");
StartUp(2, config_log_entry);
Ticks(20);
- auto& raft = *servers_[0]->raft_.get();
+ auto &raft = *servers_[0]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a");
raft.Propose(log_entry);
@@ -731,10 +788,11 @@ TEST_F(RaftTest, ReplicaFailover) {
EXPECT_EQ(servers_[1]->leader_, "1");
}
-TEST_F(RaftTest, OneSnapshotTwo) {
+TEST_F(RaftTest, OneSnapshotTwo)
+{
LogEntry config_log_entry;
StartUp(1, config_log_entry);
- auto& raft = *servers_[0]->raft_.get();
+ auto &raft = *servers_[0]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a=1");
raft.Propose(log_entry);
@@ -755,12 +813,13 @@ TEST_F(RaftTest, OneSnapshotTwo) {
EXPECT_EQ(servers_[0]->state_["b"].second, "3");
}
-TEST_F(RaftTest, OneTwoThreeSnapshotOneTwoCrashAndBurnThree) {
+TEST_F(RaftTest, OneTwoThreeSnapshotOneTwoCrashAndBurnThree)
+{
LogEntry config_log_entry(ConfigLogEntry(3));
StartUp(3, config_log_entry);
Ticks(20);
int ileader = servers_[0]->leader_[0] - '0';
- auto& raft = *servers_[ileader]->raft_.get();
+ auto &raft = *servers_[ileader]->raft_.get();
LogEntry log_entry;
log_entry.set_data("a=1");
raft.Propose(log_entry);
@@ -780,4 +839,4 @@ TEST_F(RaftTest,
OneTwoThreeSnapshotOneTwoCrashAndBurnThree) {
EXPECT_EQ(servers_[2]->state_["a"].second, "1");
EXPECT_EQ(servers_[2]->state_["b"].second, "3");
}
-} // namespace raft
+} // namespace raft
Build step 'Execute shell' marked build as failure
