From 107a07563fbde8b5af941e4e9c7a83fe6692fc6d Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Sun, 7 Aug 2016 14:28:16 -0700 Subject: [PATCH] tools/functional-tester: fix limiter --- tools/functional-tester/etcd-tester/stresser.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tools/functional-tester/etcd-tester/stresser.go b/tools/functional-tester/etcd-tester/stresser.go index d578b5958..c604951dc 100644 --- a/tools/functional-tester/etcd-tester/stresser.go +++ b/tools/functional-tester/etcd-tester/stresser.go @@ -179,7 +179,7 @@ func (s *stresser) Stress() error { s.conn = conn s.cancel = cancel s.wg = wg - s.rateLimiter = rate.NewLimiter(rate.Every(time.Second), s.qps) + s.rateLimiter = rate.NewLimiter(rate.Limit(s.qps), s.qps) s.mu.Unlock() kvc := pb.NewKVClient(conn)