commit | d2d714401fd3223847c60e5499bfb58eb9109e43 | [log] [tgz] |
---|---|---|
author | Suharsh Sivakumar <suharshs@google.com> | Mon Jun 20 13:48:46 2016 -0700 |
committer | Suharsh Sivakumar <suharshs@google.com> | Tue Jun 21 00:33:56 2016 +0000 |
tree | 5dbd941c8a94a11b04ec406e1443b40f5c46fc13 | |
parent | c2acc089ac6c5ff8497549313ada92d178532c6d [diff] |
conncache: Fix cancellation leaks upon close. Change-Id: I3f951cab94423fb43fd36d78112f50367e97dc54
diff --git a/runtime/internal/flow/manager/conncache.go b/runtime/internal/flow/manager/conncache.go index 3bd8654..72e66c0 100644 --- a/runtime/internal/flow/manager/conncache.go +++ b/runtime/internal/flow/manager/conncache.go
@@ -466,6 +466,14 @@ err := NewErrCacheClosed(ctx) for _, e := range c.conns { e.conn.Close(ctx, err) + if e.cancel != nil { + e.cancel() + } + } + for _, r := range c.reserved { + if r.cancel != nil { + r.cancel() + } } c.conns = nil c.cache = nil