diff options
author | Pablo Neira Ayuso <pablo@netfilter.org> | 2014-05-19 12:21:46 +0200 |
---|---|---|
committer | Pablo Neira Ayuso <pablo@netfilter.org> | 2014-05-19 12:21:48 +0200 |
commit | 15cd2494198fa64cfcdf26298e0809cf14fafbbb (patch) | |
tree | 11dd1b5edec9cc82a3311cbf6c80e3fbaf2f6270 /src | |
parent | dda742096bdf19d6993da0412bd3f48f2fd463fd (diff) |
src: add table netlink messages to the batch
This patch moves the table messages to the netlink batch that
is sent to kernel-space.
Signed-off-by: Pablo Neira Ayuso <pablo@netfilter.org>
Diffstat (limited to 'src')
-rw-r--r-- | src/mnl.c | 34 | ||||
-rw-r--r-- | src/netlink.c | 77 |
2 files changed, 106 insertions, 5 deletions
@@ -550,6 +550,23 @@ int mnl_nft_table_add(struct mnl_socket *nf_sock, struct nft_table *nlt, return nft_mnl_talk(nf_sock, nlh, nlh->nlmsg_len, NULL, NULL); } +int mnl_nft_table_batch_add(struct mnl_socket *nf_sock, struct nft_table *nlt, + unsigned int flags, uint32_t seqnum) +{ + struct nlmsghdr *nlh; + + nlh = nft_table_nlmsg_build_hdr(mnl_nlmsg_batch_current(batch), + NFT_MSG_NEWTABLE, + nft_table_attr_get_u32(nlt, NFT_TABLE_ATTR_FAMILY), + flags, seqnum); + nft_table_nlmsg_build_payload(nlh, nlt); + + if (!mnl_nlmsg_batch_next(batch)) + mnl_batch_page_add(); + + return 0; +} + int mnl_nft_table_delete(struct mnl_socket *nf_sock, struct nft_table *nlt, unsigned int flags) { @@ -564,6 +581,23 @@ int mnl_nft_table_delete(struct mnl_socket *nf_sock, struct nft_table *nlt, return nft_mnl_talk(nf_sock, nlh, nlh->nlmsg_len, NULL, NULL); } +int mnl_nft_table_batch_del(struct mnl_socket *nf_sock, struct nft_table *nlt, + unsigned int flags, uint32_t seqnum) +{ + struct nlmsghdr *nlh; + + nlh = nft_table_nlmsg_build_hdr(mnl_nlmsg_batch_current(batch), + NFT_MSG_DELTABLE, + nft_table_attr_get_u32(nlt, NFT_TABLE_ATTR_FAMILY), + NLM_F_ACK, seqnum); + nft_table_nlmsg_build_payload(nlh, nlt); + + if (!mnl_nlmsg_batch_next(batch)) + mnl_batch_page_add(); + + return 0; +} + static int table_cb(const struct nlmsghdr *nlh, void *data) { struct nft_table_list *nlt_list = data; diff --git a/src/netlink.c b/src/netlink.c index 10a00fa8..e1307677 100644 --- a/src/netlink.c +++ b/src/netlink.c @@ -757,9 +757,10 @@ int netlink_flush_chain(struct netlink_ctx *ctx, const struct handle *h, return netlink_del_rule_batch(ctx, h, loc); } -int netlink_add_table(struct netlink_ctx *ctx, const struct handle *h, - const struct location *loc, const struct table *table, - bool excl) +static int netlink_add_table_compat(struct netlink_ctx *ctx, + const struct handle *h, + const struct location *loc, + const struct table *table, bool excl) { struct nft_table *nlt; int err; @@ -774,8 +775,43 @@ int netlink_add_table(struct netlink_ctx *ctx, const struct handle *h, return err; } -int netlink_delete_table(struct netlink_ctx *ctx, const struct handle *h, - const struct location *loc) +static int netlink_add_table_batch(struct netlink_ctx *ctx, + const struct handle *h, + const struct location *loc, + const struct table *table, bool excl) +{ + struct nft_table *nlt; + int err; + + nlt = alloc_nft_table(h); + err = mnl_nft_table_batch_add(nf_sock, nlt, excl ? NLM_F_EXCL : 0, + ctx->seqnum); + nft_table_free(nlt); + + if (err < 0) { + netlink_io_error(ctx, loc, "Could not add table: %s", + strerror(errno)); + } + return err; +} + +int netlink_add_table(struct netlink_ctx *ctx, const struct handle *h, + const struct location *loc, + const struct table *table, bool excl) +{ + int ret; + + if (ctx->batch_supported) + ret = netlink_add_table_batch(ctx, h, loc, table, excl); + else + ret = netlink_add_table_compat(ctx, h, loc, table, excl); + + return ret; +} + +static int netlink_del_table_compat(struct netlink_ctx *ctx, + const struct handle *h, + const struct location *loc) { struct nft_table *nlt; int err; @@ -790,6 +826,37 @@ int netlink_delete_table(struct netlink_ctx *ctx, const struct handle *h, return err; } +static int netlink_del_table_batch(struct netlink_ctx *ctx, + const struct handle *h, + const struct location *loc) +{ + struct nft_table *nlt; + int err; + + nlt = alloc_nft_table(h); + err = mnl_nft_table_batch_del(nf_sock, nlt, 0, ctx->seqnum); + nft_table_free(nlt); + + if (err < 0) { + netlink_io_error(ctx, loc, "Could not delete table: %s", + strerror(errno)); + } + return err; +} + +int netlink_delete_table(struct netlink_ctx *ctx, const struct handle *h, + const struct location *loc) +{ + int ret; + + if (ctx->batch_supported) + ret = netlink_del_table_batch(ctx, h, loc); + else + ret = netlink_del_table_compat(ctx, h, loc); + + return ret; +} + void netlink_dump_table(struct nft_table *nlt) { #ifdef DEBUG |