diff --git a/tools/functional-tester/etcd-tester/stresser.go b/tools/functional-tester/etcd-tester/stresser.go index 205188b50..c5d8a4225 100644 --- a/tools/functional-tester/etcd-tester/stresser.go +++ b/tools/functional-tester/etcd-tester/stresser.go @@ -78,7 +78,8 @@ func (s *stresser) Stress() error { Value: []byte(randStr(s.KeySize)), }) putcancel() - if err == context.Canceled { + if grpc.ErrorDesc(err) == context.Canceled.Error() { + log.Printf("etcd-tester: stresser#%d is cancelled", i) return } s.mu.Lock() diff --git a/tools/functional-tester/etcd-tester/tester.go b/tools/functional-tester/etcd-tester/tester.go index ed18e1b9b..66b3aaba6 100644 --- a/tools/functional-tester/etcd-tester/tester.go +++ b/tools/functional-tester/etcd-tester/tester.go @@ -98,10 +98,10 @@ func (tt *tester) runLoop() { continue } if ok = isSameValueInMap(revs); ok { - log.Printf("etcd-tester: [round#%d case#%d] checking current revisions succeed!", i, j) + log.Printf("etcd-tester: [round#%d case#%d.%d] checking current revisions succeed!", i, j, k) break } else { - log.Printf("etcd-tester: [round#%d case#%d] current revisions %+v", i, j, revs) + log.Printf("etcd-tester: [round#%d case#%d.%d] current revisions %+v", i, j, k, revs) } } if !ok {