test

aphralG · aphralG · commit 535bd19f2348 · 2025-02-17T10:22:51.000Z
diff --git a/internal/watcher/watcher_plugin.go b/internal/watcher/watcher_plugin.go
@@ -170,7 +170,7 @@ func (w *Watcher) handleConfigApplySuccess(ctx context.Context, msg *bus.Message
 
 	slog.Info("handleConfigApplySuccess start")
 	w.watcherMutex.Lock()
-	defer w.watcherMutex.Unlock()
+	// defer w.watcherMutex.Unlock()
 	w.instancesWithConfigApplyInProgress = slices.DeleteFunc(
 		w.instancesWithConfigApplyInProgress,
 		func(element string) bool {
@@ -179,6 +179,7 @@ func (w *Watcher) handleConfigApplySuccess(ctx context.Context, msg *bus.Message
 	)
 	w.fileWatcherService.SetEnabled(true)
 
+	w.watcherMutex.Unlock()
 	w.instanceWatcherService.ReparseConfig(ctx, instanceID)
 	slog.Info("handleConfigApplySuccess done")
 }

Original file line number	Diff line number	Diff line change
`@@ -170,7 +170,7 @@ func (w Watcher) handleConfigApplySuccess(ctx context.Context, msg bus.Message`
`170`	`170`
`171`	`171`	`slog.Info("handleConfigApplySuccess start")`
`172`	`172`	`w.watcherMutex.Lock()`
`173`		`- defer w.watcherMutex.Unlock()`
	`173`	`+ // defer w.watcherMutex.Unlock()`
`174`	`174`	`w.instancesWithConfigApplyInProgress = slices.DeleteFunc(`
`175`	`175`	`w.instancesWithConfigApplyInProgress,`
`176`	`176`	`func(element string) bool {`
`@@ -179,6 +179,7 @@ func (w Watcher) handleConfigApplySuccess(ctx context.Context, msg bus.Message`
`179`	`179`	`)`
`180`	`180`	`w.fileWatcherService.SetEnabled(true)`
`181`	`181`
	`182`	`+ w.watcherMutex.Unlock()`
`182`	`183`	`w.instanceWatcherService.ReparseConfig(ctx, instanceID)`
`183`	`184`	`slog.Info("handleConfigApplySuccess done")`
`184`	`185`	`}`