fix: time.Ticker没有关闭，导致cpu使用率过高 #478

bcs-common/common/blog/glog/glog.go

@@ -886,7 +886,9 @@ const flushInterval = 30 * time.Second
 
 // flushDaemon periodically flushes the log file buffers.
 func (l *loggingT) flushDaemon() {
-	for _ = range time.NewTicker(flushInterval).C {
+	ticker := time.NewTicker(flushInterval)
+	defer ticker.Stop()
+	for _ = range ticker.C {
 		l.lockAndFlushAll()
 	}
 }

bcs-common/pkg/master/zookeeper.go

@@ -263,6 +263,9 @@ func (zk *ZookeeperMaster) masterLoop() {
 func (zk *ZookeeperMaster) healthLoop() {
 	masterTick := time.NewTicker(time.Second * 2)
 	selfTick := time.NewTicker(time.Second * 30)
+	defer masterTick.Stop()
+	defer selfTick.Stop()
+
 	for {
 		select {
 		case <-zk.exitCxt.Done():

bcs-common/pkg/reflector/reflector.go

@@ -73,8 +73,10 @@ func (r *Reflector) Run() {
 	blog.V(3).Infof("%s first resynchronization & watch success, register all ticker", r.name)
 	//create ticker for data object resync
 	syncTick := time.NewTicker(r.syncPeriod)
+	defer syncTick.Stop()
 	//create ticker check stable watcher
 	watchTick := time.NewTicker(time.Second * 2)
+	defer watchTick.Stop()
 	for {
 		select {
 		case <-r.cxt.Done():

bcs-common/pkg/storage/zookeeper/util.go

@@ -115,6 +115,7 @@ func (n *Node) Run() {
 		go n.childrenLoop()
 	}
 	tick := time.NewTicker(time.Second * 3)
+	defer tick.Stop()
 	for {
 		if n.isStopped {
 			return
@@ -208,6 +209,7 @@ func (n *Node) selfLoop() {
 	}
 	//wait for next event
 	forceTick := time.NewTicker(time.Second * 300)
+	defer forceTick.Stop()
 	for {
 		select {
 		case <-n.watchCxt.Done():

bcs-k8s/bcs-k8s-csi-tencentcloud/driver/cbs/controller.go

@@ -297,6 +297,7 @@ func (ctrl *cbsController) CreateVolume(ctx context.Context, req *csi.CreateVolu
 	disk := new(cbs.Disk)
 
 	ticker := time.NewTicker(time.Second * 5)
+	defer ticker.Stop()
 
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*120)
 	defer cancel()