Browse Source

functional-tester/tester: add "newFailureNoFailWithNoStressForLiveness"

Signed-off-by: Gyuho Lee <gyuhox@gmail.com>
Gyuho Lee 7 years ago
parent
commit
0c20902d13

+ 2 - 2
tools/functional-tester/tester/cluster.go

@@ -294,10 +294,10 @@ func (clus *Cluster) updateFailures() {
 			}
 			}
 			clus.failures = append(clus.failures, fpFailures...)
 			clus.failures = append(clus.failures, fpFailures...)
 		case "NO_FAIL_WITH_STRESS":
 		case "NO_FAIL_WITH_STRESS":
-			clus.failures = append(clus.failures, newFailureNoOp())
+			clus.failures = append(clus.failures, newFailureNoFailWithStress())
 		case "NO_FAIL_WITH_NO_STRESS_FOR_LIVENESS":
 		case "NO_FAIL_WITH_NO_STRESS_FOR_LIVENESS":
 			// TODO
 			// TODO
-			clus.failures = append(clus.failures, newFailureNoOp())
+			clus.failures = append(clus.failures, newFailureNoFailWithNoStressForLiveness())
 		case "EXTERNAL":
 		case "EXTERNAL":
 			clus.failures = append(clus.failures, newFailureExternal(clus.Tester.ExternalExecPath))
 			clus.failures = append(clus.failures, newFailureExternal(clus.Tester.ExternalExecPath))
 		}
 		}

+ 22 - 6
tools/functional-tester/tester/failure_case_no_op.go

@@ -20,14 +20,14 @@ import (
 	"github.com/coreos/etcd/tools/functional-tester/rpcpb"
 	"github.com/coreos/etcd/tools/functional-tester/rpcpb"
 )
 )
 
 
-type failureNoOp failureByFunc
+type failureNoFailWithStress failureByFunc
 
 
-func (f *failureNoOp) Inject(clus *Cluster) error     { return nil }
-func (f *failureNoOp) Recover(clus *Cluster) error    { return nil }
-func (f *failureNoOp) FailureCase() rpcpb.FailureCase { return f.failureCase }
+func (f *failureNoFailWithStress) Inject(clus *Cluster) error     { return nil }
+func (f *failureNoFailWithStress) Recover(clus *Cluster) error    { return nil }
+func (f *failureNoFailWithStress) FailureCase() rpcpb.FailureCase { return f.failureCase }
 
 
-func newFailureNoOp() Failure {
-	f := &failureNoOp{
+func newFailureNoFailWithStress() Failure {
+	f := &failureNoFailWithStress{
 		failureCase: rpcpb.FailureCase_NO_FAIL_WITH_STRESS,
 		failureCase: rpcpb.FailureCase_NO_FAIL_WITH_STRESS,
 	}
 	}
 	return &failureDelay{
 	return &failureDelay{
@@ -35,3 +35,19 @@ func newFailureNoOp() Failure {
 		delayDuration: 5 * time.Second,
 		delayDuration: 5 * time.Second,
 	}
 	}
 }
 }
+
+type failureNoFailWithNoStressForLiveness failureByFunc
+
+func (f *failureNoFailWithNoStressForLiveness) Inject(clus *Cluster) error     { return nil }
+func (f *failureNoFailWithNoStressForLiveness) Recover(clus *Cluster) error    { return nil }
+func (f *failureNoFailWithNoStressForLiveness) FailureCase() rpcpb.FailureCase { return f.failureCase }
+
+func newFailureNoFailWithNoStressForLiveness() Failure {
+	f := &failureNoFailWithNoStressForLiveness{
+		failureCase: rpcpb.FailureCase_NO_FAIL_WITH_NO_STRESS_FOR_LIVENESS,
+	}
+	return &failureDelay{
+		Failure:       f,
+		delayDuration: 7 * time.Second,
+	}
+}