From 7f9b32162e2208756965a0072d53f4fd25adcbe9 Mon Sep 17 00:00:00 2001 From: Philipp Mieden Date: Tue, 21 May 2019 09:55:55 +0200 Subject: [PATCH] used a simple channel send/receive instead of with a single case --- repo/loader.go | 19 ++++++++----------- 1 file changed, 8 insertions(+), 11 deletions(-) diff --git a/repo/loader.go b/repo/loader.go index 91f5682..8bfcfe9 100644 --- a/repo/loader.go +++ b/repo/loader.go @@ -14,18 +14,15 @@ import ( func (repo *Repo) updateRoutine() { go func() { - for { - log.Debug("update routine is about to select") - select { - case newDimension := <-repo.updateChannel: - log.Debug("update routine received a new dimension: " + newDimension.Dimension) - err := repo._updateDimension(newDimension.Dimension, newDimension.Node) - log.Debug("update routine received result") - if err != nil { - log.Debug(" update routine error: " + err.Error()) - } - repo.updateDoneChannel <- err + for newDimension := range repo.updateChannel { + log.Debug("update routine received a new dimension: " + newDimension.Dimension) + + err := repo._updateDimension(newDimension.Dimension, newDimension.Node) + log.Debug("update routine received result") + if err != nil { + log.Debug(" update routine error: " + err.Error()) } + repo.updateDoneChannel <- err } }() }