Merge pull request #41 from cloudflare/bugfix/deadlock

Fix for #40: change the position of the channel
cloudflare · Sep 30, 2019 · 610850e · 610850e
2 parents b521287 + 7719533
commit 610850e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/decoders/decoder.go b/decoders/decoder.go
@@ -39,11 +39,11 @@ func (w Worker) Start() {
 	go func() {
 		//log.Debugf("Worker %v started", w.Id)
 		for {
-			w.WorkerPool <- w.InMsg
 			select {
 			case <-w.Quit:
 				break
-			case msg := <-w.InMsg:
+			case w.WorkerPool <- w.InMsg:
+				msg := <-w.InMsg
 				timeTrackStart := time.Now()
 				err := w.DecoderParams.DecoderFunc(msg)
 				timeTrackStop := time.Now()