Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

functional/tester: handle "raft.ErrProposalDropped"

Browse Source 
Signed-off-by: Gyuho Lee <gyuhox@gmail.com>
This commit is contained in:
Gyuho Lee 2018-04-16 15:13:30 -07:00
parent 35a80bc910
commit d1c2ae86ce
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
functional/tester/stresser_key.go
View File

@ -27,6 +27,7 @@ import (
"github.com/coreos/etcd/etcdserver" "github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes" "github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
"github.com/coreos/etcd/functional/rpcpb" "github.com/coreos/etcd/functional/rpcpb"
"github.com/coreos/etcd/raft"
"go.uber.org/zap" "go.uber.org/zap"
"golang.org/x/time/rate" "golang.org/x/time/rate"
@ -151,6 +152,8 @@ func (s *keyStresser) run() {
// capability check has not been done (in the beginning) // capability check has not been done (in the beginning)
case rpctypes.ErrTooManyRequests.Error(): case rpctypes.ErrTooManyRequests.Error():
// hitting the recovering member. // hitting the recovering member.
case raft.ErrProposalDropped.Error():
// removed member, or leadership has changed (old leader got raftpb.MsgProp)
case context.Canceled.Error(): case context.Canceled.Error():
// from stresser.Cancel method: // from stresser.Cancel method:
return return
@ -163,6 +166,7 @@ func (s *keyStresser) run() {
zap.String("stress-type", s.stype.String()), zap.String("stress-type", s.stype.String()),
zap.String("endpoint", s.m.EtcdClientEndpoint), zap.String("endpoint", s.m.EtcdClientEndpoint),
zap.String("error-type", reflect.TypeOf(err).String()), zap.String("error-type", reflect.TypeOf(err).String()),
zap.String("error-desc", rpctypes.ErrorDesc(err)),
zap.Error(err), zap.Error(err),
) )
return return