[client] Add missing peer ACL flush (#3247)

This commit is contained in:
Viktor Liu 2025-01-28 23:25:22 +01:00 committed by GitHub
parent 46766e7e24
commit e20be2397c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -348,6 +348,10 @@ func (m *AclManager) addIOFiltering(
UserData: userData,
})
if err := m.rConn.Flush(); err != nil {
return nil, fmt.Errorf(flushError, err)
}
rule := &Rule{
nftRule: nftRule,
mangleRule: m.createPreroutingRule(expressions, userData),
@ -359,6 +363,7 @@ func (m *AclManager) addIOFiltering(
if ipset != nil {
m.ipsetStore.AddReferenceToIpset(ipset.Name)
}
return rule, nil
}