diff --git a/pkg/adaptation/adaptation.go b/pkg/adaptation/adaptation.go index 141cb85b..9201e641 100644 --- a/pkg/adaptation/adaptation.go +++ b/pkg/adaptation/adaptation.go @@ -431,18 +431,16 @@ func (r *Adaptation) acceptPluginConnections(l net.Listener) error { continue } - r.Lock() - err = r.syncFn(ctx, p.synchronize) if err != nil { log.Infof(ctx, "failed to synchronize plugin: %v", err) } else { + r.Lock() r.plugins = append(r.plugins, p) r.sortPlugins() + r.Unlock() } - r.Unlock() - log.Infof(ctx, "plugin %q connected", p.name()) } }()