From 691c1a3b7848685d5e85c0da932926560510abb7 Mon Sep 17 00:00:00 2001
From: Patrice Ferlet <metal3d@gmail.com>
Date: Fri, 17 Dec 2021 12:07:23 +0100
Subject: [PATCH] We must lock inside the goroutines

---
 generator/main.go | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/generator/main.go b/generator/main.go
index 3897f09..4abcd7c 100644
--- a/generator/main.go
+++ b/generator/main.go
@@ -279,20 +279,20 @@ func parseService(name string, s *compose.Service, ret chan interface{}) {
 	// But... some other deployment can wait for it, so we alert that this deployment hasn't got any
 	// associated service.
 	if len(s.Ports) == 0 {
-		locker.Lock()
 		// alert any current or **futur** waiters that this service is not exposed
 		go func() {
 			for {
 				select {
 				case <-time.Tick(1 * time.Millisecond):
+					locker.Lock()
 					for _, c := range serviceWaiters[name] {
 						c <- -1
 						close(c)
 					}
+					locker.Unlock()
 				}
 			}
 		}()
-		locker.Unlock()
 	}
 
 	// add the volumes in Values
@@ -397,6 +397,8 @@ func detected(name string, port int) {
 	}
 	servicesMap[name] = port
 	go func() {
+		locker.Lock()
+		defer locker.Unlock()
 		if cx, ok := serviceWaiters[name]; ok {
 			for _, c := range cx {
 				c <- port
@@ -419,6 +421,8 @@ func waitPort(name string) chan int {
 	c := make(chan int, 0)
 	serviceWaiters[name] = append(serviceWaiters[name], c)
 	go func() {
+		locker.Lock()
+		defer locker.Unlock()
 		if v, ok := servicesMap[name]; ok {
 			c <- v
 		}