mirrors/etcd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

functional-tester/tester: provide correct latency information to failure

Browse Source 
Signed-off-by: Gyuho Lee <gyuhox@gmail.com>
This commit is contained in:
Gyuho Lee
2018-04-03 11:21:19 -07:00
parent f25188d35b
commit 358a89c7e9
2 changed files with 10 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
tools/functional-tester/tester/cluster.go
View File

@ -283,11 +283,11 @@ func (clus *Cluster) updateFailures() {
case "BLACKHOLE_PEER_PORT_TX_RX_ALL": case "BLACKHOLE_PEER_PORT_TX_RX_ALL":
clus.failures = append(clus.failures, newFailureBlackholePeerPortTxRxAll()) clus.failures = append(clus.failures, newFailureBlackholePeerPortTxRxAll())
case "DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER": case "DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER":
clus.failures = append(clus.failures, newFailureDelayPeerPortTxRxOneFollower()) clus.failures = append(clus.failures, newFailureDelayPeerPortTxRxOneFollower(clus))
case "DELAY_PEER_PORT_TX_RX_LEADER": case "DELAY_PEER_PORT_TX_RX_LEADER":
clus.failures = append(clus.failures, newFailureDelayPeerPortTxRxLeader()) clus.failures = append(clus.failures, newFailureDelayPeerPortTxRxLeader(clus))
case "DELAY_PEER_PORT_TX_RX_ALL": case "DELAY_PEER_PORT_TX_RX_ALL":
clus.failures = append(clus.failures, newFailureDelayPeerPortTxRxAll()) clus.failures = append(clus.failures, newFailureDelayPeerPortTxRxAll(clus))
case "FAILPOINTS": case "FAILPOINTS":
fpFailures, fperr := failpointFailures(clus) fpFailures, fperr := failpointFailures(clus)
if len(fpFailures) == 0 { if len(fpFailures) == 0 {

16
tools/functional-tester/tester/failure_case_network_slow.go
View File

@ -22,9 +22,6 @@ import (
) )
const ( const (
// TODO
slowNetworkLatency = 500 // 500 millisecond
// delay duration to trigger leader election (default election timeout 1s) // delay duration to trigger leader election (default election timeout 1s)
triggerElectionDur = 5 * time.Second triggerElectionDur = 5 * time.Second
@ -45,8 +42,8 @@ func recoverDelayPeerPortTxRx(clus *Cluster, idx int) error {
return err return err
} }
func newFailureDelayPeerPortTxRxOneFollower() Failure { func newFailureDelayPeerPortTxRxOneFollower(clus *Cluster) Failure {
desc := fmt.Sprintf("delay follower peer port by adding %d ms latency", slowNetworkLatency) desc := fmt.Sprintf("delay follower peer port by %d ms", clus.Tester.DelayLatencyMs)
ff := failureByFunc{ ff := failureByFunc{
description: description(desc), description: description(desc),
injectMember: injectDelayPeerPortTxRx, injectMember: injectDelayPeerPortTxRx,
@ -59,8 +56,8 @@ func newFailureDelayPeerPortTxRxOneFollower() Failure {
} }
} }
func newFailureDelayPeerPortTxRxLeader() Failure { func newFailureDelayPeerPortTxRxLeader(clus *Cluster) Failure {
desc := fmt.Sprintf("delay leader peer port by adding %d ms latency", slowNetworkLatency) desc := fmt.Sprintf("delay leader peer port by %d ms", clus.Tester.DelayLatencyMs)
ff := failureByFunc{ ff := failureByFunc{
description: description(desc), description: description(desc),
injectMember: injectDelayPeerPortTxRx, injectMember: injectDelayPeerPortTxRx,
@ -73,9 +70,10 @@ func newFailureDelayPeerPortTxRxLeader() Failure {
} }
} }
func newFailureDelayPeerPortTxRxAll() Failure { func newFailureDelayPeerPortTxRxAll(clus *Cluster) Failure {
desc := fmt.Sprintf("delay all peer port by %d ms", clus.Tester.DelayLatencyMs)
f := &failureAll{ f := &failureAll{
description: "delay all peer port", description: description(desc),
injectMember: injectDelayPeerPortTxRx, injectMember: injectDelayPeerPortTxRx,
recoverMember: recoverDelayPeerPortTxRx, recoverMember: recoverDelayPeerPortTxRx,
} }