From 012b7cc2dc1fe9cecc2eb4b56db567dd90e4491f Mon Sep 17 00:00:00 2001
From: Travis Nielsen <travisn@live.com>
Date: Fri, 28 Apr 2017 13:40:27 -0700
Subject: [PATCH] ensure the cluster channel is closed once

---
 pkg/operator/tracker.go | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/pkg/operator/tracker.go b/pkg/operator/tracker.go
index 4b1e234a3..19e6d8ce9 100644
--- a/pkg/operator/tracker.go
+++ b/pkg/operator/tracker.go
@@ -21,9 +21,9 @@ package operator
 import "sync"
 
 type tprTracker struct {
-	stopChMap   map[string]chan struct{}
-	clusterRVs  map[string]string
-	waitCluster sync.WaitGroup
+	stopChMap  map[string]chan struct{}
+	clusterRVs map[string]string
+	sync.RWMutex
 }
 
 func newTPRTracker() *tprTracker {
@@ -43,6 +43,8 @@ func (t *tprTracker) add(name, version string) {
 func (t *tprTracker) remove(name string) {
 	delete(t.clusterRVs, name)
 
+	t.Lock()
+	defer t.Unlock()
 	if stopCh, ok := t.stopChMap[name]; ok {
 		close(stopCh)
 	}
@@ -50,8 +52,10 @@ func (t *tprTracker) remove(name string) {
 }
 
 func (t *tprTracker) stop() {
+	t.Lock()
+	defer t.Unlock()
 	for _, stop := range t.stopChMap {
 		close(stop)
 	}
-	t.waitCluster.Wait()
+	t.stopChMap = map[string]chan struct{}{}
 }