summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorPablo Neira Ayuso <pablo@netfilter.org>2018-04-24 01:05:10 +0200
committerPablo Neira Ayuso <pablo@netfilter.org>2018-04-24 01:11:50 +0200
commit2daca4fa257ad9a7a7dbb1e249e7c24451b4e717 (patch)
tree330970e21fe44cca32ecce7cc105c42b1b77e7e0
parent05c42e8ae134d4a729443935c5e44ff7a7a020f6 (diff)
netlink: pass cmd object to netlink function calls
Simplify function footprint. Signed-off-by: Pablo Neira Ayuso <pablo@netfilter.org>
-rw-r--r--include/netlink.h78
-rw-r--r--src/netlink.c127
-rw-r--r--src/rule.c87
3 files changed, 129 insertions, 163 deletions
diff --git a/include/netlink.h b/include/netlink.h
index 240441dd..81eaaa25 100644
--- a/include/netlink.h
+++ b/include/netlink.h
@@ -115,48 +115,42 @@ extern int netlink_add_rule(struct netlink_ctx *ctx, const struct handle *h,
extern int netlink_delete_rule(struct netlink_ctx *ctx, const struct handle *h,
const struct location *loc);
extern int netlink_add_rule_batch(struct netlink_ctx *ctx,
- const struct handle *h,
- const struct rule *rule, uint32_t flags);
+ const struct cmd *cmd,
+ uint32_t flags);
extern int netlink_del_rule_batch(struct netlink_ctx *ctx,
- const struct handle *h,
- const struct location *loc);
+ const struct cmd *cmd);
extern int netlink_replace_rule_batch(struct netlink_ctx *ctx,
+ const struct cmd *cmd);
+
+extern int netlink_add_chain_batch(struct netlink_ctx *ctx,
+ const struct cmd *cmd, uint32_t flags);
+extern int netlink_rename_chain_batch(struct netlink_ctx *ctx,
const struct handle *h,
- const struct rule *rule,
- const struct location *loc);
-
-extern int netlink_add_chain_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc,
- const struct chain *chain, uint32_t flags);
-extern int netlink_rename_chain_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc, const char *name);
-extern int netlink_delete_chain_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc);
+ const struct cmd *cmd);
+extern int netlink_delete_chain_batch(struct netlink_ctx *ctx,
+ const struct cmd *cmd);
extern int netlink_list_chains(struct netlink_ctx *ctx, const struct handle *h,
const struct location *loc);
-extern int netlink_flush_chain(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc);
+extern int netlink_flush_chain(struct netlink_ctx *ctx, const struct cmd *cmd);
extern struct chain *netlink_delinearize_chain(struct netlink_ctx *ctx,
const struct nftnl_chain *nlc);
-extern int netlink_add_table_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc,
- const struct table *table, uint32_t flags);
-extern int netlink_delete_table_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc);
+extern int netlink_add_table_batch(struct netlink_ctx *ctx,
+ const struct cmd *cmd, uint32_t flags);
+extern int netlink_delete_table_batch(struct netlink_ctx *ctx,
+ const struct cmd *cmd);
extern int netlink_list_tables(struct netlink_ctx *ctx, const struct handle *h,
const struct location *loc);
extern int netlink_list_table(struct netlink_ctx *ctx, const struct handle *h,
const struct location *loc);
-extern int netlink_flush_table(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc);
+extern int netlink_flush_table(struct netlink_ctx *ctx, const struct cmd *cmd);
extern struct table *netlink_delinearize_table(struct netlink_ctx *ctx,
const struct nftnl_table *nlt);
-extern int netlink_add_set_batch(struct netlink_ctx *ctx, const struct handle *h,
- struct set *set, uint32_t flags);
-extern int netlink_delete_set_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc);
+extern int netlink_add_set_batch(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t flags);
+extern int netlink_delete_set_batch(struct netlink_ctx *ctx,
+ const struct cmd *cmd);
extern int netlink_list_sets(struct netlink_ctx *ctx, const struct handle *h,
const struct location *loc);
extern struct set *netlink_delinearize_set(struct netlink_ctx *ctx,
@@ -168,28 +162,26 @@ extern struct stmt *netlink_parse_set_expr(const struct set *set,
extern int netlink_add_setelems_batch(struct netlink_ctx *ctx, const struct handle *h,
const struct expr *expr, uint32_t flags);
-extern int netlink_delete_setelems_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct expr *expr);
+extern int netlink_delete_setelems_batch(struct netlink_ctx *ctx,
+ const struct cmd *cmd);
extern int netlink_get_setelems(struct netlink_ctx *ctx, const struct handle *h,
const struct location *loc, struct set *set);
extern int netlink_get_setelem(struct netlink_ctx *ctx, const struct handle *h,
const struct location *loc, struct table *table,
struct set *set, struct expr *init);
-extern int netlink_flush_setelems(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc);
+extern int netlink_flush_setelems(struct netlink_ctx *ctx, const struct cmd *cmd);
extern int netlink_delinearize_setelem(struct nftnl_set_elem *nlse,
const struct set *set,
struct nft_cache *cache);
extern int netlink_list_objs(struct netlink_ctx *ctx, const struct handle *h,
const struct location *loc);
-extern int netlink_reset_objs(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc, uint32_t type,
- bool dump);
-extern int netlink_add_obj(struct netlink_ctx *ctx, const struct handle *h,
- struct obj *obj, uint32_t flags);
-extern int netlink_delete_obj(struct netlink_ctx *ctx, const struct handle *h,
- struct location *loc, uint32_t type);
+extern int netlink_reset_objs(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t type, bool dump);
+extern int netlink_add_obj(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t flags);
+extern int netlink_delete_obj(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t type);
extern struct obj *netlink_delinearize_obj(struct netlink_ctx *ctx,
struct nftnl_obj *nlo);
@@ -197,11 +189,9 @@ extern int netlink_list_flowtables(struct netlink_ctx *ctx,
const struct handle *h,
const struct location *loc);
extern int netlink_add_flowtable(struct netlink_ctx *ctx,
- const struct handle *h, struct flowtable *ft,
- uint32_t flags);
+ const struct cmd *cmd, uint32_t flags);
extern int netlink_delete_flowtable(struct netlink_ctx *ctx,
- const struct handle *h,
- struct location *loc);
+ const struct cmd *cmd);
extern void netlink_dump_chain(const struct nftnl_chain *nlc,
struct netlink_ctx *ctx);
@@ -226,9 +216,7 @@ extern int netlink_io_error(struct netlink_ctx *ctx,
__netlink_init_error(__FILE__, __LINE__, strerror(errno));
extern void __noreturn __netlink_init_error(const char *file, int line, const char *reason);
-extern int netlink_flush_ruleset(struct netlink_ctx *ctx,
- const struct handle *h,
- const struct location *loc);
+extern int netlink_flush_ruleset(struct netlink_ctx *ctx, const struct cmd *cmd);
extern struct nftnl_ruleset *netlink_dump_ruleset(struct netlink_ctx *ctx,
const struct handle *h,
diff --git a/src/netlink.c b/src/netlink.c
index 89c0b9bf..d668fa8c 100644
--- a/src/netlink.c
+++ b/src/netlink.c
@@ -453,10 +453,10 @@ struct expr *netlink_alloc_data(const struct location *loc,
}
}
-int netlink_add_rule_batch(struct netlink_ctx *ctx,
- const struct handle *h,
- const struct rule *rule, uint32_t flags)
+int netlink_add_rule_batch(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t flags)
{
+ struct rule *rule = cmd->rule;
struct nftnl_rule *nlr;
int err;
@@ -469,10 +469,9 @@ int netlink_add_rule_batch(struct netlink_ctx *ctx,
return err;
}
-int netlink_replace_rule_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct rule *rule,
- const struct location *loc)
+int netlink_replace_rule_batch(struct netlink_ctx *ctx, const struct cmd *cmd)
{
+ struct rule *rule = cmd->rule;
struct nftnl_rule *nlr;
int err, flags = 0;
@@ -494,13 +493,12 @@ int netlink_replace_rule_batch(struct netlink_ctx *ctx, const struct handle *h,
return err;
}
-int netlink_del_rule_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc)
+int netlink_del_rule_batch(struct netlink_ctx *ctx, const struct cmd *cmd)
{
struct nftnl_rule *nlr;
int err;
- nlr = alloc_nftnl_rule(h);
+ nlr = alloc_nftnl_rule(&cmd->handle);
err = mnl_nft_rule_batch_del(nlr, ctx->batch, 0, ctx->seqnum);
nftnl_rule_free(nlr);
@@ -571,10 +569,9 @@ static int netlink_list_rules(struct netlink_ctx *ctx, const struct handle *h,
return 0;
}
-static int netlink_flush_rules(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc)
+static int netlink_flush_rules(struct netlink_ctx *ctx, const struct cmd *cmd)
{
- return netlink_del_rule_batch(ctx, h, loc);
+ return netlink_del_rule_batch(ctx, cmd);
}
void netlink_dump_chain(const struct nftnl_chain *nlc, struct netlink_ctx *ctx)
@@ -588,14 +585,14 @@ void netlink_dump_chain(const struct nftnl_chain *nlc, struct netlink_ctx *ctx)
fprintf(fp, "\n");
}
-int netlink_add_chain_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc,
- const struct chain *chain, uint32_t flags)
+int netlink_add_chain_batch(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t flags)
{
+ struct chain *chain = cmd->chain;
struct nftnl_chain *nlc;
int err;
- nlc = alloc_nftnl_chain(h);
+ nlc = alloc_nftnl_chain(&cmd->handle);
if (chain != NULL) {
if (chain->flags & CHAIN_F_BASECHAIN) {
nftnl_chain_set_u32(nlc, NFTNL_CHAIN_HOOKNUM,
@@ -620,11 +617,10 @@ int netlink_add_chain_batch(struct netlink_ctx *ctx, const struct handle *h,
return err;
}
-int netlink_rename_chain_batch(struct netlink_ctx *ctx,
- const struct handle *h,
- const struct location *loc,
- const char *name)
+int netlink_rename_chain_batch(struct netlink_ctx *ctx, const struct handle *h,
+ const struct cmd *cmd)
{
+ const char *name = cmd->arg;
struct nftnl_chain *nlc;
int err;
@@ -637,13 +633,12 @@ int netlink_rename_chain_batch(struct netlink_ctx *ctx,
return err;
}
-int netlink_delete_chain_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc)
+int netlink_delete_chain_batch(struct netlink_ctx *ctx, const struct cmd *cmd)
{
struct nftnl_chain *nlc;
int err;
- nlc = alloc_nftnl_chain(h);
+ nlc = alloc_nftnl_chain(&cmd->handle);
netlink_dump_chain(nlc, ctx);
err = mnl_nft_chain_batch_del(nlc, ctx->batch, 0, ctx->seqnum);
nftnl_chain_free(nlc);
@@ -746,22 +741,20 @@ int netlink_list_chains(struct netlink_ctx *ctx, const struct handle *h,
strerror(ENOENT));
}
-int netlink_flush_chain(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc)
+int netlink_flush_chain(struct netlink_ctx *ctx, const struct cmd *cmd)
{
- return netlink_del_rule_batch(ctx, h, loc);
+ return netlink_del_rule_batch(ctx, cmd);
}
-int netlink_add_table_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc,
- const struct table *table, uint32_t flags)
+int netlink_add_table_batch(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t flags)
{
struct nftnl_table *nlt;
int err;
- nlt = alloc_nftnl_table(h);
- if (table != NULL)
- nftnl_table_set_u32(nlt, NFTNL_TABLE_FLAGS, table->flags);
+ nlt = alloc_nftnl_table(&cmd->handle);
+ if (cmd->table != NULL)
+ nftnl_table_set_u32(nlt, NFTNL_TABLE_FLAGS, cmd->table->flags);
else
nftnl_table_set_u32(nlt, NFTNL_TABLE_FLAGS, 0);
@@ -771,13 +764,12 @@ int netlink_add_table_batch(struct netlink_ctx *ctx, const struct handle *h,
return err;
}
-int netlink_delete_table_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc)
+int netlink_delete_table_batch(struct netlink_ctx *ctx, const struct cmd *cmd)
{
struct nftnl_table *nlt;
int err;
- nlt = alloc_nftnl_table(h);
+ nlt = alloc_nftnl_table(&cmd->handle);
err = mnl_nft_table_batch_del(nlt, ctx->batch, 0, ctx->seqnum);
nftnl_table_free(nlt);
@@ -834,10 +826,9 @@ int netlink_list_table(struct netlink_ctx *ctx, const struct handle *h,
return netlink_list_rules(ctx, h, loc);
}
-int netlink_flush_table(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc)
+int netlink_flush_table(struct netlink_ctx *ctx, const struct cmd *cmd)
{
- return netlink_flush_rules(ctx, h, loc);
+ return netlink_flush_rules(ctx, cmd);
}
static enum nft_data_types dtype_map_to_kernel(const struct datatype *dtype)
@@ -990,15 +981,15 @@ struct set *netlink_delinearize_set(struct netlink_ctx *ctx,
return set;
}
-int netlink_add_set_batch(struct netlink_ctx *ctx,
- const struct handle *h, struct set *set,
+int netlink_add_set_batch(struct netlink_ctx *ctx, const struct cmd *cmd,
uint32_t flags)
{
struct nftnl_udata_buf *udbuf;
+ struct set *set = cmd->set;
struct nftnl_set *nls;
int err;
- nls = alloc_nftnl_set(h);
+ nls = alloc_nftnl_set(&cmd->handle);
nftnl_set_set_u32(nls, NFTNL_SET_FLAGS, set->flags);
nftnl_set_set_u32(nls, NFTNL_SET_KEY_TYPE,
dtype_map_to_kernel(set->key->dtype));
@@ -1060,13 +1051,12 @@ int netlink_add_set_batch(struct netlink_ctx *ctx,
return err;
}
-int netlink_delete_set_batch(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc)
+int netlink_delete_set_batch(struct netlink_ctx *ctx, const struct cmd *cmd)
{
struct nftnl_set *nls;
int err;
- nls = alloc_nftnl_set(h);
+ nls = alloc_nftnl_set(&cmd->handle);
err = mnl_nft_set_batch_del(nls, ctx->batch, 0, ctx->seqnum);
nftnl_set_free(nls);
@@ -1133,14 +1123,14 @@ int netlink_add_setelems_batch(struct netlink_ctx *ctx, const struct handle *h,
}
int netlink_delete_setelems_batch(struct netlink_ctx *ctx,
- const struct handle *h, const struct expr *expr)
+ const struct cmd *cmd)
{
struct nftnl_set *nls;
int err;
- nls = alloc_nftnl_set(h);
- if (expr)
- alloc_setelem_cache(expr, nls);
+ nls = alloc_nftnl_set(&cmd->handle);
+ if (cmd->expr)
+ alloc_setelem_cache(cmd->expr, nls);
netlink_dump_set(nls, ctx);
err = mnl_nft_setelem_batch_del(nls, ctx->batch, 0, ctx->seqnum);
@@ -1149,13 +1139,12 @@ int netlink_delete_setelems_batch(struct netlink_ctx *ctx,
return err;
}
-int netlink_flush_setelems(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc)
+int netlink_flush_setelems(struct netlink_ctx *ctx, const struct cmd *cmd)
{
struct nftnl_set *nls;
int err;
- nls = alloc_nftnl_set(h);
+ nls = alloc_nftnl_set(&cmd->handle);
netlink_dump_set(nls, ctx);
err = mnl_nft_setelem_batch_flush(nls, ctx->batch, 0, ctx->seqnum);
@@ -1413,13 +1402,13 @@ void netlink_dump_obj(struct nftnl_obj *nln, struct netlink_ctx *ctx)
fprintf(fp, "\n");
}
-int netlink_add_obj(struct netlink_ctx *ctx, const struct handle *h,
- struct obj *obj, uint32_t flags)
+int netlink_add_obj(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t flags)
{
struct nftnl_obj *nlo;
int err;
- nlo = alloc_nftnl_obj(h, obj);
+ nlo = alloc_nftnl_obj(&cmd->handle, cmd->object);
netlink_dump_obj(nlo, ctx);
err = mnl_nft_obj_batch_add(nlo, ctx->batch, flags, ctx->seqnum);
@@ -1428,13 +1417,13 @@ int netlink_add_obj(struct netlink_ctx *ctx, const struct handle *h,
return err;
}
-int netlink_delete_obj(struct netlink_ctx *ctx, const struct handle *h,
- struct location *loc, uint32_t type)
+int netlink_delete_obj(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t type)
{
struct nftnl_obj *nlo;
int err;
- nlo = __alloc_nftnl_obj(h, type);
+ nlo = __alloc_nftnl_obj(&cmd->handle, type);
netlink_dump_obj(nlo, ctx);
err = mnl_nft_obj_batch_del(nlo, ctx->batch, 0, ctx->seqnum);
@@ -1527,15 +1516,16 @@ static void netlink_dump_flowtable(struct nftnl_flowtable *flo,
fprintf(fp, "\n");
}
-int netlink_add_flowtable(struct netlink_ctx *ctx, const struct handle *h,
- struct flowtable *ft, uint32_t flags)
+int netlink_add_flowtable(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t flags)
{
+ struct flowtable *ft = cmd->flowtable;
struct nftnl_flowtable *flo;
const char *dev_array[8];
struct expr *expr;
int i = 0, err;
- flo = alloc_nftnl_flowtable(h, ft);
+ flo = alloc_nftnl_flowtable(&cmd->handle, ft);
nftnl_flowtable_set_u32(flo, NFTNL_FLOWTABLE_HOOKNUM, ft->hooknum);
nftnl_flowtable_set_u32(flo, NFTNL_FLOWTABLE_PRIO, ft->priority);
@@ -1553,13 +1543,12 @@ int netlink_add_flowtable(struct netlink_ctx *ctx, const struct handle *h,
return err;
}
-int netlink_delete_flowtable(struct netlink_ctx *ctx, const struct handle *h,
- struct location *loc)
+int netlink_delete_flowtable(struct netlink_ctx *ctx, const struct cmd *cmd)
{
struct nftnl_flowtable *flo;
int err;
- flo = alloc_nftnl_flowtable(h, NULL);
+ flo = alloc_nftnl_flowtable(&cmd->handle, NULL);
netlink_dump_flowtable(flo, ctx);
err = mnl_nft_flowtable_batch_del(flo, ctx->batch, 0, ctx->seqnum);
@@ -1600,9 +1589,10 @@ int netlink_list_objs(struct netlink_ctx *ctx, const struct handle *h,
return err;
}
-int netlink_reset_objs(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc, uint32_t type, bool dump)
+int netlink_reset_objs(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t type, bool dump)
{
+ const struct handle *h = &cmd->handle;
struct nftnl_obj_list *obj_cache;
int err;
@@ -1612,7 +1602,7 @@ int netlink_reset_objs(struct netlink_ctx *ctx, const struct handle *h,
if (errno == EINTR)
return -1;
- return netlink_io_error(ctx, loc,
+ return netlink_io_error(ctx, &cmd->location,
"Could not receive stateful object from kernel: %s",
strerror(errno));
}
@@ -1691,13 +1681,12 @@ int netlink_batch_send(struct netlink_ctx *ctx, struct list_head *err_list)
return mnl_batch_talk(ctx, err_list);
}
-int netlink_flush_ruleset(struct netlink_ctx *ctx, const struct handle *h,
- const struct location *loc)
+int netlink_flush_ruleset(struct netlink_ctx *ctx, const struct cmd *cmd)
{
struct nftnl_table *nlt;
int err;
- nlt = alloc_nftnl_table(h);
+ nlt = alloc_nftnl_table(&cmd->handle);
err = mnl_nft_table_batch_del(nlt, ctx->batch, 0, ctx->seqnum);
nftnl_table_free(nlt);
diff --git a/src/rule.c b/src/rule.c
index 30661457..68bc2e68 100644
--- a/src/rule.c
+++ b/src/rule.c
@@ -1094,9 +1094,11 @@ static int __do_add_setelems(struct netlink_ctx *ctx, const struct handle *h,
return 0;
}
-static int do_add_setelems(struct netlink_ctx *ctx, const struct handle *h,
- struct expr *init, uint32_t flags)
+static int do_add_setelems(struct netlink_ctx *ctx, struct cmd *cmd,
+ uint32_t flags)
{
+ struct handle *h = &cmd->handle;
+ struct expr *init = cmd->expr;
struct table *table;
struct set *set;
@@ -1111,16 +1113,18 @@ static int do_add_setelems(struct netlink_ctx *ctx, const struct handle *h,
return __do_add_setelems(ctx, h, set, init, flags);
}
-static int do_add_set(struct netlink_ctx *ctx, const struct handle *h,
- struct set *set, uint32_t flags)
+static int do_add_set(struct netlink_ctx *ctx, const struct cmd *cmd,
+ uint32_t flags)
{
+ struct set *set = cmd->set;
+
if (set->init != NULL) {
if (set->flags & NFT_SET_INTERVAL &&
set_to_intervals(ctx->msgs, set, set->init, true,
ctx->debug_mask, set->automerge) < 0)
return -1;
}
- if (netlink_add_set_batch(ctx, h, set, flags) < 0)
+ if (netlink_add_set_batch(ctx, cmd, flags) < 0)
return -1;
if (set->init != NULL) {
return __do_add_setelems(ctx, &set->handle, set, set->init,
@@ -1146,28 +1150,22 @@ static int do_command_add(struct netlink_ctx *ctx, struct cmd *cmd, bool excl)
switch (cmd->obj) {
case CMD_OBJ_TABLE:
- return netlink_add_table_batch(ctx, &cmd->handle,
- &cmd->location, cmd->table,
- flags);
+ return netlink_add_table_batch(ctx, cmd, flags);
case CMD_OBJ_CHAIN:
- return netlink_add_chain_batch(ctx, &cmd->handle,
- &cmd->location, cmd->chain,
- flags);
+ return netlink_add_chain_batch(ctx, cmd, flags);
case CMD_OBJ_RULE:
- return netlink_add_rule_batch(ctx, &cmd->handle,
- cmd->rule, flags | NLM_F_APPEND);
+ return netlink_add_rule_batch(ctx, cmd, flags | NLM_F_APPEND);
case CMD_OBJ_SET:
- return do_add_set(ctx, &cmd->handle, cmd->set, flags);
+ return do_add_set(ctx, cmd, flags);
case CMD_OBJ_SETELEM:
- return do_add_setelems(ctx, &cmd->handle, cmd->expr, flags);
+ return do_add_setelems(ctx, cmd, flags);
case CMD_OBJ_COUNTER:
case CMD_OBJ_QUOTA:
case CMD_OBJ_CT_HELPER:
case CMD_OBJ_LIMIT:
- return netlink_add_obj(ctx, &cmd->handle, cmd->object, flags);
+ return netlink_add_obj(ctx, cmd, flags);
case CMD_OBJ_FLOWTABLE:
- return netlink_add_flowtable(ctx, &cmd->handle, cmd->flowtable,
- flags);
+ return netlink_add_flowtable(ctx, cmd, flags);
default:
BUG("invalid command object type %u\n", cmd->obj);
}
@@ -1178,8 +1176,7 @@ static int do_command_replace(struct netlink_ctx *ctx, struct cmd *cmd)
{
switch (cmd->obj) {
case CMD_OBJ_RULE:
- return netlink_replace_rule_batch(ctx, &cmd->handle, cmd->rule,
- &cmd->location);
+ return netlink_replace_rule_batch(ctx, cmd);
default:
BUG("invalid command object type %u\n", cmd->obj);
}
@@ -1203,17 +1200,17 @@ static int do_command_insert(struct netlink_ctx *ctx, struct cmd *cmd)
switch (cmd->obj) {
case CMD_OBJ_RULE:
- return netlink_add_rule_batch(ctx, &cmd->handle,
- cmd->rule, flags);
+ return netlink_add_rule_batch(ctx, cmd, flags);
default:
BUG("invalid command object type %u\n", cmd->obj);
}
return 0;
}
-static int do_delete_setelems(struct netlink_ctx *ctx, const struct handle *h,
- struct expr *expr)
+static int do_delete_setelems(struct netlink_ctx *ctx, struct cmd *cmd)
{
+ struct handle *h = &cmd->handle;
+ struct expr *expr = cmd->expr;
struct table *table;
struct set *set;
@@ -1225,7 +1222,7 @@ static int do_delete_setelems(struct netlink_ctx *ctx, const struct handle *h,
ctx->debug_mask, set->automerge) < 0)
return -1;
- if (netlink_delete_setelems_batch(ctx, h, expr) < 0)
+ if (netlink_delete_setelems_batch(ctx, cmd) < 0)
return -1;
return 0;
@@ -1235,31 +1232,25 @@ static int do_command_delete(struct netlink_ctx *ctx, struct cmd *cmd)
{
switch (cmd->obj) {
case CMD_OBJ_TABLE:
- return netlink_delete_table_batch(ctx, &cmd->handle, &cmd->location);
+ return netlink_delete_table_batch(ctx, cmd);
case CMD_OBJ_CHAIN:
- return netlink_delete_chain_batch(ctx, &cmd->handle, &cmd->location);
+ return netlink_delete_chain_batch(ctx, cmd);
case CMD_OBJ_RULE:
- return netlink_del_rule_batch(ctx, &cmd->handle,
- &cmd->location);
+ return netlink_del_rule_batch(ctx, cmd);
case CMD_OBJ_SET:
- return netlink_delete_set_batch(ctx, &cmd->handle, &cmd->location);
+ return netlink_delete_set_batch(ctx, cmd);
case CMD_OBJ_SETELEM:
- return do_delete_setelems(ctx, &cmd->handle, cmd->expr);
+ return do_delete_setelems(ctx, cmd);
case CMD_OBJ_COUNTER:
- return netlink_delete_obj(ctx, &cmd->handle, &cmd->location,
- NFT_OBJECT_COUNTER);
+ return netlink_delete_obj(ctx, cmd, NFT_OBJECT_COUNTER);
case CMD_OBJ_QUOTA:
- return netlink_delete_obj(ctx, &cmd->handle, &cmd->location,
- NFT_OBJECT_QUOTA);
+ return netlink_delete_obj(ctx, cmd, NFT_OBJECT_QUOTA);
case CMD_OBJ_CT_HELPER:
- return netlink_delete_obj(ctx, &cmd->handle, &cmd->location,
- NFT_OBJECT_CT_HELPER);
+ return netlink_delete_obj(ctx, cmd, NFT_OBJECT_CT_HELPER);
case CMD_OBJ_LIMIT:
- return netlink_delete_obj(ctx, &cmd->handle, &cmd->location,
- NFT_OBJECT_LIMIT);
+ return netlink_delete_obj(ctx, cmd, NFT_OBJECT_LIMIT);
case CMD_OBJ_FLOWTABLE:
- return netlink_delete_flowtable(ctx, &cmd->handle,
- &cmd->location);
+ return netlink_delete_flowtable(ctx, cmd);
default:
BUG("invalid command object type %u\n", cmd->obj);
}
@@ -1946,7 +1937,7 @@ static int do_command_reset(struct netlink_ctx *ctx, struct cmd *cmd)
BUG("invalid command object type %u\n", cmd->obj);
}
- ret = netlink_reset_objs(ctx, &cmd->handle, &cmd->location, type, dump);
+ ret = netlink_reset_objs(ctx, cmd, type, dump);
list_for_each_entry_safe(obj, next, &ctx->list, list) {
table = table_lookup(&obj->handle, ctx->cache);
list_move(&obj->list, &table->objs);
@@ -1961,16 +1952,15 @@ static int do_command_flush(struct netlink_ctx *ctx, struct cmd *cmd)
{
switch (cmd->obj) {
case CMD_OBJ_TABLE:
- return netlink_flush_table(ctx, &cmd->handle, &cmd->location);
+ return netlink_flush_table(ctx, cmd);
case CMD_OBJ_CHAIN:
- return netlink_flush_chain(ctx, &cmd->handle, &cmd->location);
+ return netlink_flush_chain(ctx, cmd);
case CMD_OBJ_SET:
case CMD_OBJ_MAP:
case CMD_OBJ_METER:
- return netlink_flush_setelems(ctx, &cmd->handle,
- &cmd->location);
+ return netlink_flush_setelems(ctx, cmd);
case CMD_OBJ_RULESET:
- return netlink_flush_ruleset(ctx, &cmd->handle, &cmd->location);
+ return netlink_flush_ruleset(ctx, cmd);
default:
BUG("invalid command object type %u\n", cmd->obj);
}
@@ -1986,8 +1976,7 @@ static int do_command_rename(struct netlink_ctx *ctx, struct cmd *cmd)
case CMD_OBJ_CHAIN:
chain = chain_lookup(table, &cmd->handle);
- return netlink_rename_chain_batch(ctx, &chain->handle, &cmd->location,
- cmd->arg);
+ return netlink_rename_chain_batch(ctx, &chain->handle, cmd);
default:
BUG("invalid command object type %u\n", cmd->obj);
}