commit 97f1efa0846c237fb3ee33991d86fb26a0ed34b0
author Suharsh Sivakumar <suharshs@google.com> Fri Oct 02 23:43:08 2015 +0000
committer Gerrit Code Review <noreply-gerritcodereview@google.com> Fri Oct 02 23:43:08 2015 +0000
tree ad741e0319974de5d0a75d33a819900dc24e4de4
parent 5d257c7a54080348eb793f024957bc05f1727052
parent 71e3210c0570c835509df661e3463a56a287da41

Merge "flow/manager: Fix condition for wg.Done()."

runtime/internal/flow/manager/manager.go

diff --git a/runtime/internal/flow/manager/manager.go b/runtime/internal/flow/manager/manager.go
index 185ff12..80099f4 100644
--- a/runtime/internal/flow/manager/manager.go
+++ b/runtime/internal/flow/manager/manager.go
@@ -73,7 +73,8 @@
 				// Periodically kill closed connections.
 				m.cache.KillConnections(ctx, 0)
 			case e := <-events:
-				if e.Status.Closed && !e.Status.LocalLameDuck || e.Status.LocalLameDuck {
+				if e.Status.Closed && !e.Status.LocalLameDuck ||
+					!e.Status.Closed && e.Status.LocalLameDuck {
 					m.ls.activeConns.Done()
 				}
 			}