put mutex block around registry pod creation

Signed-off-by: akihikokuroda <[email protected]>

Author: akihikokuroda

pkg/controller/registry/reconciler/configmap.go

@@ -4,6 +4,7 @@ package reconciler
 import (
 	"context"
 	"fmt"
+	"sync"
 
 	"github.com/pkg/errors"
 	"github.com/sirupsen/logrus"
@@ -166,6 +167,7 @@ type ConfigMapRegistryReconciler struct {
 	Lister   operatorlister.OperatorLister
 	OpClient operatorclient.ClientInterface
 	Image    string
+	MuPod    sync.RWMutex
 }
 
 var _ RegistryEnsurer = &ConfigMapRegistryReconciler{}
@@ -354,6 +356,8 @@ func (c *ConfigMapRegistryReconciler) ensureRoleBinding(source configMapCatalogS
 
 func (c *ConfigMapRegistryReconciler) ensurePod(source configMapCatalogSourceDecorator, overwrite bool) error {
 	pod := source.Pod(c.Image)
+	c.MuPod.Lock()
+	defer c.MuPod.Unlock()
 	currentPods := c.currentPods(source, c.Image)
 	if len(currentPods) > 0 {
 		if !overwrite {