feat: agent sync aggregate subnet

deepflowio · Dec 6, 2024 · bf70584 · bf70584
1 parent 4022fd2
commit bf70584
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/server/controller/genesis/updater.go b/server/controller/genesis/updater.go
@@ -451,7 +451,13 @@ func (v *GenesisSyncRpcUpdater) ParseHostAsVmPlatformInfo(info VIFRPCMessage, pe
 				break
 			}
 		}
-		networkName := fmt.Sprintf("Network-%s/%v", firstIP.Address, firstIP.MaskLen)
+		networkIP, err := netaddr.ParseIP(firstIP.Address)
+		if err != nil {
+			log.Errorf("parse first ip (%s) err: (%s)", firstIP.Address, err.Error())
+			continue
+		}
+		networkPrefix := netaddr.IPPrefixFrom(networkIP, uint8(firstIP.MaskLen))
+		networkName := fmt.Sprintf("Network-%s", networkPrefix.Masked().String())
 		network, ok := nameToNetwork[networkName]
 		vType := common.VIF_TYPE_LAN
 		netType := common.NETWORK_TYPE_LAN