etcd-tester: cancel lease stream; fix OOM panic

It was never closing lease keep-alive streams, leaking memory.
Fix OOM panics in etcd-tester (after 1K rounds).
This commit is contained in:
Gyu-Ho Lee 2016-12-13 04:58:23 -08:00
parent cc37beff35
commit 301abddc72

View File

@ -266,6 +266,7 @@ func (ls *leaseStresser) keepLeaseAlive(leaseID int64) {
defer ls.aliveWg.Done()
ctx, cancel := context.WithCancel(ls.ctx)
stream, err := ls.lc.LeaseKeepAlive(ctx)
defer func() { cancel() }()
for {
select {
case <-time.After(500 * time.Millisecond):