From 23b8c36ced1e85a4212eeeadbf33c85d0ae65c93 Mon Sep 17 00:00:00 2001 From: Gyuho Lee Date: Wed, 11 Apr 2018 01:37:13 -0700 Subject: [PATCH] functional/tester: add "SIGQUIT_AND_REMOVE_LEADER_UNTIL_TRIGGER_SNAPSHOT" Signed-off-by: Gyuho Lee --- functional.yaml | 1 + functional/tester/cluster.go | 3 +++ functional/tester/cluster_test.go | 1 + functional/tester/failure_case_sigquit_remove.go | 7 +++++++ 4 files changed, 12 insertions(+) diff --git a/functional.yaml b/functional.yaml index 8a07e08f7..b0065fe2b 100644 --- a/functional.yaml +++ b/functional.yaml @@ -131,6 +131,7 @@ tester-config: - SIGQUIT_AND_REMOVE_ONE_FOLLOWER - SIGQUIT_AND_REMOVE_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT - SIGQUIT_AND_REMOVE_LEADER + - SIGQUIT_AND_REMOVE_LEADER_UNTIL_TRIGGER_SNAPSHOT - BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER - BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT - BLACKHOLE_PEER_PORT_TX_RX_LEADER diff --git a/functional/tester/cluster.go b/functional/tester/cluster.go index 074e1e73a..c3e75dede 100644 --- a/functional/tester/cluster.go +++ b/functional/tester/cluster.go @@ -170,6 +170,9 @@ func (clus *Cluster) updateFailures() { case "SIGQUIT_AND_REMOVE_LEADER": clus.failures = append(clus.failures, new_FailureCase_SIGQUIT_AND_REMOVE_LEADER(clus)) + case "SIGQUIT_AND_REMOVE_LEADER_UNTIL_TRIGGER_SNAPSHOT": + clus.failures = append(clus.failures, + new_FailureCase_SIGQUIT_AND_REMOVE_LEADER_UNTIL_TRIGGER_SNAPSHOT(clus)) case "BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER": clus.failures = append(clus.failures, diff --git a/functional/tester/cluster_test.go b/functional/tester/cluster_test.go index 0926a16ea..c3fc96e18 100644 --- a/functional/tester/cluster_test.go +++ b/functional/tester/cluster_test.go @@ -165,6 +165,7 @@ func Test_read(t *testing.T) { "SIGQUIT_AND_REMOVE_ONE_FOLLOWER", "SIGQUIT_AND_REMOVE_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT", "SIGQUIT_AND_REMOVE_LEADER", + "SIGQUIT_AND_REMOVE_LEADER_UNTIL_TRIGGER_SNAPSHOT", "BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER", "BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT", "BLACKHOLE_PEER_PORT_TX_RX_LEADER", diff --git a/functional/tester/failure_case_sigquit_remove.go b/functional/tester/failure_case_sigquit_remove.go index 308610066..c085ae919 100644 --- a/functional/tester/failure_case_sigquit_remove.go +++ b/functional/tester/failure_case_sigquit_remove.go @@ -187,6 +187,13 @@ func new_FailureCase_SIGQUIT_AND_REMOVE_LEADER(clus *Cluster) Failure { } } +func new_FailureCase_SIGQUIT_AND_REMOVE_LEADER_UNTIL_TRIGGER_SNAPSHOT(clus *Cluster) Failure { + return &failureUntilSnapshot{ + failureCase: rpcpb.FailureCase_SIGQUIT_AND_REMOVE_LEADER_UNTIL_TRIGGER_SNAPSHOT, + Failure: new_FailureCase_SIGQUIT_AND_REMOVE_LEADER(clus), + } +} + func describeMembers(mresp *clientv3.MemberListResponse) (ss []string) { ss = make([]string, len(mresp.Members)) for i, m := range mresp.Members {