Run map updates async

projectcalico · Oct 14, 2024 · 5dd25a8 · 5dd25a8
1 parent 3ec891f
commit 5dd25a8
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/felix/dataplane/linux/int_dataplane.go b/felix/dataplane/linux/int_dataplane.go
@@ -2300,8 +2300,12 @@ func (d *InternalDataplane) apply() {
 	}
 
 	if d.maps != nil {
-		// TODO: Async, with wait group like sets.
-		d.maps.ApplyMapUpdates()
+		// If an nftables MapsDataplane implementation is configured, apply map updates.
+		ipSetsWG.Add(1)
+		go func(maps nftables.MapsDataplane) {
+			maps.ApplyMapUpdates()
+			ipSetsWG.Done()
+		}(d.maps)
 	}
 
 	// Update any VXLAN FDB entries.