@@ -206,7 +206,24 @@ int nft_cache_add_chain(struct nft_handle *h, const struct builtin_table *t,
{
struct nft_chain *nc = nft_chain_alloc(c);
- list_add_tail(&nc->head, &h->cache->table[t->type].chains->list);
+ if (nft_chain_builtin(nc)) {
+ uint32_t hooknum = nft_chain_hooknum(nc);
+
+ if (hooknum >= NF_INET_NUMHOOKS) {
+ nft_chain_free(nc);
+ return -EINVAL;
+ }
+
+ if (h->cache->table[t->type].base_chains[hooknum]) {
+ nft_chain_free(nc);
+ return -EEXIST;
+ }
+
+ h->cache->table[t->type].base_chains[hooknum] = nc;
+ } else {
+ list_add_tail(&nc->head,
+ &h->cache->table[t->type].chains->list);
+ }
hlist_add_head(&nc->hnode, chain_name_hlist(h, t, nft_chain_name(nc)));
return 0;
}
@@ -605,6 +622,19 @@ static int __flush_set_cache(struct nftnl_set *s, void *data)
return 0;
}
+static void flush_base_chain_cache(struct nft_chain **base_chains)
+{
+ int i;
+
+ for (i = 0; i < NF_INET_NUMHOOKS; i++) {
+ if (!base_chains[i])
+ continue;
+ hlist_del(&base_chains[i]->hnode);
+ nft_chain_free(base_chains[i]);
+ base_chains[i] = NULL;
+ }
+}
+
static int flush_cache(struct nft_handle *h, struct nft_cache *c,
const char *tablename)
{
@@ -616,6 +646,7 @@ static int flush_cache(struct nft_handle *h, struct nft_cache *c,
if (!table)
return 0;
+ flush_base_chain_cache(c->table[table->type].base_chains);
nft_chain_foreach(h, tablename, __flush_chain_cache, NULL);
if (c->table[table->type].sets)
@@ -628,6 +659,7 @@ static int flush_cache(struct nft_handle *h, struct nft_cache *c,
if (h->tables[i].name == NULL)
continue;
+ flush_base_chain_cache(c->table[i].base_chains);
if (c->table[i].chains) {
nft_chain_list_free(c->table[i].chains);
c->table[i].chains = NULL;
@@ -2380,12 +2380,22 @@ int nft_chain_foreach(struct nft_handle *h, const char *table,
const struct builtin_table *t;
struct nft_chain_list *list;
struct nft_chain *c, *c_bak;
- int ret;
+ int i, ret;
t = nft_table_builtin_find(h, table);
if (!t)
return -1;
+ for (i = 0; i < NF_INET_NUMHOOKS; i++) {
+ c = h->cache->table[t->type].base_chains[i];
+ if (!c)
+ continue;
+
+ ret = cb(c, data);
+ if (ret < 0)
+ return ret;
+ }
+
list = h->cache->table[t->type].chains;
if (!list)
return -1;
@@ -40,6 +40,7 @@ enum nft_cache_level {
struct nft_cache {
struct {
+ struct nft_chain *base_chains[NF_INET_NUMHOOKS];
struct nft_chain_list *chains;
struct nftnl_set_list *sets;
bool exists;
Preparing for sorted chain output, introduce a per-table array holding base chains indexed by nf_inet_hooks value. Since the latter is ordered correctly, iterating over the array will return base chains in expected order. Signed-off-by: Phil Sutter <phil@nwl.cc> --- Changes since v1: - Use nft_chain getters in nft_cache_add_chain(). - Introduce flush_base_chain_cache(). - Simplified patch since nft_cache_add_chain() hides some details. --- iptables/nft-cache.c | 34 +++++++++++++++++++++++++++++++++- iptables/nft.c | 12 +++++++++++- iptables/nft.h | 1 + 3 files changed, 45 insertions(+), 2 deletions(-)