only call createQdiscAndAttach once for each interface

pkg/managers/pluginmanager/pluginmanager.go

@@ -126,17 +126,20 @@ func (p *PluginManager) Start(ctx context.Context) error {
 		return ErrZeroInterval
 	}
 
+	g, ctx := errgroup.WithContext(ctx)
+
 	if p.cfg.EnablePodLevel {
-		p.l.Info("starting watchers")
+		g.Go(func() error {
+			p.l.Info("starting watchers")
 
-		// Start watcher manager
-		if err := p.watcherManager.Start(ctx); err != nil {
-			return errors.Wrap(err, "failed to start watcher manager")
-		}
+			// Start watcher manager
+			if err := p.watcherManager.Start(ctx); err != nil {
+				return errors.Wrap(err, "failed to start watcher manager")
+			}
+			return nil
+		})
 	}
 
-	g, ctx := errgroup.WithContext(ctx)
-
 	// run conntrack GC
 	ct, err := conntrack.New()
 	if err != nil {

pkg/plugin/packetparser/packetparser_linux.go

@@ -382,23 +382,26 @@ func (p *packetParser) endpointWatcherCallbackFn(obj interface{}) {
 	iface := event.Obj.(netlink.LinkAttrs)
 
 	ifaceKey := ifaceToKey(iface)
-	lockMapVal, _ := p.interfaceLockMap.LoadOrStore(ifaceKey, &sync.Mutex{})
-	mu := lockMapVal.(*sync.Mutex)
-	mu.Lock()
-	defer mu.Unlock()
+	_, ifaceExist := p.interfaceLockMap.LoadOrStore(ifaceKey, struct{}{})
 
 	switch event.Type {
 	case endpoint.EndpointCreated:
-		p.l.Debug("Endpoint created", zap.String("name", iface.Name))
-		p.createQdiscAndAttach(iface, Veth)
+		if !ifaceExist {
+			p.l.Debug("Endpoint created", zap.String("name", iface.Name))
+			p.createQdiscAndAttach(iface, Veth)
+		}
 	case endpoint.EndpointDeleted:
-		p.l.Debug("Endpoint deleted", zap.String("name", iface.Name))
-		// Clean.
-		if value, ok := p.tcMap.Load(ifaceKey); ok {
-			v := value.(*tcValue)
-			p.clean(v.tc, v.qdisc)
-			// Delete from map.
-			p.tcMap.Delete(ifaceKey)
+		if ifaceExist {
+			p.l.Debug("Endpoint deleted", zap.String("name", iface.Name))
+			// Clean.
+			if value, ok := p.tcMap.Load(ifaceKey); ok {
+				v := value.(*tcValue)
+				p.clean(v.tc, v.qdisc)
+				// Delete from map.
+				p.tcMap.Delete(ifaceKey)
+			}
+			// Delete from interfaceLockMap.
+			p.interfaceLockMap.Delete(ifaceKey)
 		}
 	default:
 		// Unknown.

pkg/plugin/packetparser/types_linux.go

@@ -114,7 +114,7 @@ type packetParser struct {
 	tcMap    *sync.Map
 	reader   perfReader
 	enricher enricher.EnricherInterface
-	// interfaceLockMap is a map of key to *sync.Mutex.
+	// interfaceLockMap is a map of exisiting interfaces
 	interfaceLockMap    *sync.Map
 	endpointIngressInfo *ebpf.ProgramInfo
 	endpointEgressInfo  *ebpf.ProgramInfo