fix race conditions

Author: aphralG

internal/collector/otel_collector_plugin.go

@@ -217,9 +217,9 @@ func (oc *Collector) Close(ctx context.Context) error {
 		oc.service.Shutdown()
 		oc.cancel()
 
-		settings := oc.config.Client.Backoff
+		settings := *oc.config.Client.Backoff
 		settings.MaxElapsedTime = maxTimeToWaitForShutdown
-		err := backoff.WaitUntil(ctx, settings, func() error {
+		err := backoff.WaitUntil(ctx, &settings, func() error {
 			if oc.service.GetState() == otelcol.StateClosed {
 				return nil
 			}

internal/file/file_manager_service.go

@@ -178,9 +178,10 @@ func (fms *FileManagerService) UpdateOverview(
 		return response, nil
 	}
 
+	backoffSettings := fms.agentConfig.Client.Backoff
 	response, err := backoff.RetryWithData(
 		sendUpdateOverview,
-		backoffHelpers.Context(backOffCtx, fms.agentConfig.Client.Backoff),
+		backoffHelpers.Context(backOffCtx, backoffSettings),
 	)
 	if err != nil {
 		return err

internal/watcher/instance/instance_watcher_service.go

@@ -223,7 +223,9 @@ func (iw *InstanceWatcherService) checkForUpdates(
 				iw.sendNginxConfigContextUpdate(newCtx, nginxConfigContext)
 				iw.nginxConfigCache[nginxConfigContext.InstanceID] = nginxConfigContext
 				proto.UpdateNginxInstanceRuntime(newInstance, nginxConfigContext)
+				iw.cacheMutex.Lock()
 				iw.instanceCache[newInstance.GetInstanceMeta().GetInstanceId()] = newInstance
+				iw.cacheMutex.Unlock()
 			}
 		}
 	}

internal/watcher/process/process_operator.go

@@ -8,10 +8,10 @@ package process
 import (
 	"context"
 	"strings"
-
-	"github.com/shirou/gopsutil/v4/process"
+	"sync"
 
 	"github.com/nginx/agent/v3/pkg/nginxprocess"
+	"github.com/shirou/gopsutil/v4/process"
 )
 
 //go:generate go run github.com/maxbrunsfeld/counterfeiter/v6@v6.8.1 -generate
@@ -94,6 +94,10 @@ func (pw *ProcessOperator) Process(ctx context.Context, pid int32) (*nginxproces
 }
 
 func convertProcess(ctx context.Context, proc *process.Process) *nginxprocess.Process {
+	mu := &sync.Mutex{}
+
+	mu.Lock()
+	defer mu.Unlock()
 	ppid, _ := proc.PpidWithContext(ctx)
 	name, _ := proc.NameWithContext(ctx)
 	cmd, _ := proc.CmdlineWithContext(ctx)