From patchwork Sun Aug 5 09:19:22 2018 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Harsha Sharma X-Patchwork-Id: 953510 X-Patchwork-Delegate: pablo@netfilter.org Return-Path: X-Original-To: incoming@patchwork.ozlabs.org Delivered-To: patchwork-incoming@bilbo.ozlabs.org Authentication-Results: ozlabs.org; spf=none (mailfrom) smtp.mailfrom=vger.kernel.org (client-ip=209.132.180.67; helo=vger.kernel.org; envelope-from=netfilter-devel-owner@vger.kernel.org; receiver=) Authentication-Results: ozlabs.org; dmarc=fail (p=none dis=none) header.from=gmail.com Authentication-Results: ozlabs.org; dkim=fail reason="signature verification failed" (2048-bit key; unprotected) header.d=gmail.com header.i=@gmail.com header.b="g5mQW5mV"; dkim-atps=neutral Received: from vger.kernel.org (vger.kernel.org [209.132.180.67]) by ozlabs.org (Postfix) with ESMTP id 41jwHV2mkbz9s4c for ; Sun, 5 Aug 2018 19:20:38 +1000 (AEST) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1726245AbeHELXy (ORCPT ); Sun, 5 Aug 2018 07:23:54 -0400 Received: from mail-pl0-f41.google.com ([209.85.160.41]:46491 "EHLO mail-pl0-f41.google.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1726081AbeHELXy (ORCPT ); Sun, 5 Aug 2018 07:23:54 -0400 Received: by mail-pl0-f41.google.com with SMTP id t17-v6so4362092ply.13 for ; Sun, 05 Aug 2018 02:20:00 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=from:to:cc:subject:date:message-id; bh=RyA9k7T4sVZadDrtm/1sTj88AMmcOxs+F6DzllMsQsM=; b=g5mQW5mV3yHJt5rBb8SB8BnDtTKpV1QnckSEaAGN94OvhDOw4ODCb0xcxQfrWG/ytZ H9AyVdWxJKcWNYzBUyxmqpLLjISMWWN5yv4l6NwWT/dr2WnRebAY5cz7Aw1VY+V57VjN sNtI8UKkO5QXgCAaCNIErxu8cfPC4UUreJcvmrKW2Q06aV/bWMRHUNfkyKXFk14mzQvj 6CbKIDqiLopeVgY1kPmkDYFAwHVMAH7cIhvBfO50rTcw+L9Yeoa1I8ii9gGTSCsW1iXh 6gywn6oxlnwNwremUoKh0u+Ru+u4jDytvmXQHQy0XiKMOJE+G7J1VZY1LO5DTIB2LY8X BpzA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:to:cc:subject:date:message-id; bh=RyA9k7T4sVZadDrtm/1sTj88AMmcOxs+F6DzllMsQsM=; b=IYB+UaUgwYAQ8a7MDkHV5OiqwTUzf8c9GarOAB8F/rVd5ZJ9URWgQJ0F7yhTss1gb1 sntaG1Wg4Lm/+99D/yDOwfip7eoti8Wi9R/3cM2Iai+q9gGh1APp688HeX1WLJKD9xFn LgeJ8yP6K4vDw9/Nta6M7G1NUPUghg9n6yVv8cFP630+Z84woK6SgkXjmA6dEI9omdEa IGVSac+zDrsmp5pk7M2SefH+nUFu4yZvDTJ/G6yT1SCA1j5GBCluVjDaj89RaKM5LvQl zQv5fDLkQrtWH/6wwpHH+qOQ+32nkCqeucFm2mA42ltZKOKwAaDl93DZXwIBXvh6V9+W LviQ== X-Gm-Message-State: AOUpUlENs2qnWufg9hPYf8zYJtE5QPljGV1HWpVMBxS4Vwsi6lbrGvSC KaHbd+j69iJH41N8aW2LLX+UzgU2 X-Google-Smtp-Source: AAOMgpdmzSoHF6w0HY/dzld9kJqU8Lig85A6Ttz696nBDtBfvmgCCrm+bIaDHj8sUt20oinMZL1xCg== X-Received: by 2002:a17:902:142:: with SMTP id 60-v6mr10035634plb.330.1533460799869; Sun, 05 Aug 2018 02:19:59 -0700 (PDT) Received: from XDDDDD.iitr.ernet.in ([223.176.219.229]) by smtp.gmail.com with ESMTPSA id j22-v6sm11691785pfh.45.2018.08.05.02.19.53 (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Sun, 05 Aug 2018 02:19:59 -0700 (PDT) From: Harsha Sharma To: harshasharmaiitr@gmail.com, pablo@netfilter.org Cc: netfilter-devel@vger.kernel.org Subject: [PATCH libnftnl v4 1/3] src: add ct timeout support Date: Sun, 5 Aug 2018 14:49:22 +0530 Message-Id: <20180805091922.15230-1-harshasharmaiitr@gmail.com> X-Mailer: git-send-email 2.14.1 Sender: netfilter-devel-owner@vger.kernel.org Precedence: bulk List-ID: X-Mailing-List: netfilter-devel@vger.kernel.org Add support for ct timeout objects, used to assign connection tracking timeout policies. Signed-off-by: Harsha Sharma --- Changes in v4: - updated include/linux/netfilter/nf_tables.h Changes in v3: - minor changes updated with nft patch Changes in v2: - minor changes include/libnftnl/Makefile.am | 3 +- include/libnftnl/cttimeout.h | 39 ++++ include/libnftnl/object.h | 11 ++ include/linux/netfilter/nf_tables.h | 15 +- include/obj.h | 7 + src/Makefile.am | 1 + src/libnftnl.map | 2 + src/obj/ct_timeout.c | 371 ++++++++++++++++++++++++++++++++++++ src/object.c | 10 +- 9 files changed, 456 insertions(+), 3 deletions(-) create mode 100644 include/libnftnl/cttimeout.h create mode 100644 src/obj/ct_timeout.c diff --git a/include/libnftnl/Makefile.am b/include/libnftnl/Makefile.am index d846a57..a94f414 100644 --- a/include/libnftnl/Makefile.am +++ b/include/libnftnl/Makefile.am @@ -10,4 +10,5 @@ pkginclude_HEADERS = batch.h \ ruleset.h \ common.h \ udata.h \ - gen.h + gen.h \ + cttimeout.h diff --git a/include/libnftnl/cttimeout.h b/include/libnftnl/cttimeout.h new file mode 100644 index 0000000..6f0ef75 --- /dev/null +++ b/include/libnftnl/cttimeout.h @@ -0,0 +1,39 @@ +#ifndef _LIBNETFILTER_CTTIMEOUT_H_ +#define _LIBNETFILTER_CTTIMEOUT_H_ + +#include +#include +#include + +#ifdef __cplusplus +extern "C" { +#endif + +struct nftnl_obj_ct_timeout; + +enum nftnl_obj_ct_timeout_tcp_attr { + NFTA_CT_TIMEOUT_ATTR_TCP_SYN_SENT = 0, + NFTA_CT_TIMEOUT_ATTR_TCP_SYN_RECV, + NFTA_CT_TIMEOUT_ATTR_TCP_ESTABLISHED, + NFTA_CT_TIMEOUT_ATTR_TCP_FIN_WAIT, + NFTA_CT_TIMEOUT_ATTR_TCP_CLOSE_WAIT, + NFTA_CT_TIMEOUT_ATTR_TCP_LAST_ACK, + NFTA_CT_TIMEOUT_ATTR_TCP_TIME_WAIT, + NFTA_CT_TIMEOUT_ATTR_TCP_CLOSE, + NFTA_CT_TIMEOUT_ATTR_TCP_SYN_SENT2, + NFTA_CT_TIMEOUT_ATTR_TCP_RETRANS, + NFTA_CT_TIMEOUT_ATTR_TCP_UNACK, + NFTA_CT_TIMEOUT_ATTR_TCP_MAX +}; + +enum nftnl_obj_ct_timeout_udp_attr { + NFTA_CT_TIMEOUT_ATTR_UDP_UNREPLIED = 0, + NFTA_CT_TIMEOUT_ATTR_UDP_REPLIED, + NFTA_CT_TIMEOUT_ATTR_UDP_MAX +}; + +#ifdef __cplusplus +} /* extern "C" */ +#endif + +#endif diff --git a/include/libnftnl/object.h b/include/libnftnl/object.h index 93a40d0..14f6e83 100644 --- a/include/libnftnl/object.h +++ b/include/libnftnl/object.h @@ -7,6 +7,7 @@ #include #include +#include #ifdef __cplusplus extern "C" { @@ -41,6 +42,13 @@ enum { NFTNL_OBJ_CT_HELPER_L4PROTO, }; +enum { + NFTNL_OBJ_CT_TIMEOUT_L3PROTO = NFTNL_OBJ_BASE, + NFTNL_OBJ_CT_TIMEOUT_L4PROTO, + NFTNL_OBJ_CT_TIMEOUT_DATA, + NFTNL_OBJ_CT_TIMEOUT_POLICY, +}; + enum { NFTNL_OBJ_LIMIT_RATE = NFTNL_OBJ_BASE, NFTNL_OBJ_LIMIT_UNIT, @@ -64,6 +72,8 @@ void nftnl_obj_set_u16(struct nftnl_obj *ne, uint16_t attr, uint16_t val); void nftnl_obj_set_u32(struct nftnl_obj *ne, uint16_t attr, uint32_t val); void nftnl_obj_set_u64(struct nftnl_obj *obj, uint16_t attr, uint64_t val); void nftnl_obj_set_str(struct nftnl_obj *ne, uint16_t attr, const char *str); +int nftnl_timeout_policy_attr_set_u32(struct nftnl_obj *ne, uint32_t type, + uint32_t data); const void *nftnl_obj_get_data(struct nftnl_obj *ne, uint16_t attr, uint32_t *data_len); const void *nftnl_obj_get(struct nftnl_obj *ne, uint16_t attr); @@ -72,6 +82,7 @@ uint16_t nftnl_obj_get_u16(struct nftnl_obj *obj, uint16_t attr); uint32_t nftnl_obj_get_u32(struct nftnl_obj *ne, uint16_t attr); uint64_t nftnl_obj_get_u64(struct nftnl_obj *obj, uint16_t attr); const char *nftnl_obj_get_str(struct nftnl_obj *ne, uint16_t attr); +void *nftnl_obj_get_void(struct nftnl_obj *ne, uint16_t attr); void nftnl_obj_nlmsg_build_payload(struct nlmsghdr *nlh, const struct nftnl_obj *ne); diff --git a/include/linux/netfilter/nf_tables.h b/include/linux/netfilter/nf_tables.h index cc21ef0..e25bda0 100644 --- a/include/linux/netfilter/nf_tables.h +++ b/include/linux/netfilter/nf_tables.h @@ -969,6 +969,7 @@ enum nft_osf_attributes { * @NFT_CT_DST_IP: conntrack layer 3 protocol destination (IPv4 address) * @NFT_CT_SRC_IP6: conntrack layer 3 protocol source (IPv6 address) * @NFT_CT_DST_IP6: conntrack layer 3 protocol destination (IPv6 address) + * @NFT_CT_TIMEOUT: connection tracking timeout policy assigned to conntrack */ enum nft_ct_keys { NFT_CT_STATE, @@ -994,6 +995,7 @@ enum nft_ct_keys { NFT_CT_DST_IP, NFT_CT_SRC_IP6, NFT_CT_DST_IP6, + NFT_CT_TIMEOUT, __NFT_CT_MAX }; #define NFT_CT_MAX (__NFT_CT_MAX - 1) @@ -1395,13 +1397,24 @@ enum nft_ct_helper_attributes { }; #define NFTA_CT_HELPER_MAX (__NFTA_CT_HELPER_MAX - 1) +enum nft_ct_timeout_attributes { + NFTA_CT_TIMEOUT_UNSPEC, + NFTA_CT_TIMEOUT_L3PROTO, + NFTA_CT_TIMEOUT_L4PROTO, + NFTA_CT_TIMEOUT_DATA, + __NFTA_CT_TIMEOUT_MAX, +}; +#define NFTA_CT_TIMEOUT_MAX (__NFTA_CT_TIMEOUT_MAX - 1) + #define NFT_OBJECT_UNSPEC 0 #define NFT_OBJECT_COUNTER 1 #define NFT_OBJECT_QUOTA 2 #define NFT_OBJECT_CT_HELPER 3 #define NFT_OBJECT_LIMIT 4 #define NFT_OBJECT_CONNLIMIT 5 -#define __NFT_OBJECT_MAX 6 +#define NFT_OBJECT_TUNNEL 6 +#define NFT_OBJECT_CT_TIMEOUT 7 +#define __NFT_OBJECT_MAX 8 #define NFT_OBJECT_MAX (__NFT_OBJECT_MAX - 1) /** diff --git a/include/obj.h b/include/obj.h index 4a728c8..e6ac011 100644 --- a/include/obj.h +++ b/include/obj.h @@ -36,6 +36,12 @@ struct nftnl_obj { uint8_t l4proto; char name[16]; } ct_helper; + struct nftnl_obj_ct_timeout { + uint16_t l3proto; + uint8_t l4proto; + uint16_t polset; + uint32_t *timeout; + } ct_timeout; struct nftnl_obj_limit { uint64_t rate; uint64_t unit; @@ -63,6 +69,7 @@ struct obj_ops { extern struct obj_ops obj_ops_counter; extern struct obj_ops obj_ops_quota; extern struct obj_ops obj_ops_ct_helper; +extern struct obj_ops obj_ops_ct_timeout; extern struct obj_ops obj_ops_limit; #define nftnl_obj_data(obj) (void *)&obj->data diff --git a/src/Makefile.am b/src/Makefile.am index f92b4d2..2299713 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -62,4 +62,5 @@ libnftnl_la_SOURCES = utils.c \ obj/ct_helper.c \ obj/quota.c \ obj/limit.c \ + obj/ct_timeout.c \ libnftnl.map diff --git a/src/libnftnl.map b/src/libnftnl.map index 0d6b20c..8e2e544 100644 --- a/src/libnftnl.map +++ b/src/libnftnl.map @@ -340,6 +340,8 @@ LIBNFTNL_7 { nftnl_flowtable_list_add_tail; nftnl_flowtable_list_del; nftnl_flowtable_list_foreach; + nftnl_timeout_policy_attr_set_u32; + nftnl_obj_get_void; } LIBNFTNL_6; diff --git a/src/obj/ct_timeout.c b/src/obj/ct_timeout.c new file mode 100644 index 0000000..cd6cbc7 --- /dev/null +++ b/src/obj/ct_timeout.c @@ -0,0 +1,371 @@ +/* + * (C) 2017 Red Hat GmbH + * Author: Florian Westphal + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published + * by the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + */ + +#include +#include +#include +#include +#include + +#include + +#include "internal.h" +#include +#include +#include + +#include "obj.h" + +static const char *const tcp_state_to_name[] = { + [NFTA_CT_TIMEOUT_ATTR_TCP_SYN_SENT] = "SYN_SENT", + [NFTA_CT_TIMEOUT_ATTR_TCP_SYN_RECV] = "SYN_RECV", + [NFTA_CT_TIMEOUT_ATTR_TCP_ESTABLISHED] = "ESTABLISHED", + [NFTA_CT_TIMEOUT_ATTR_TCP_FIN_WAIT] = "FIN_WAIT", + [NFTA_CT_TIMEOUT_ATTR_TCP_CLOSE_WAIT] = "CLOSE_WAIT", + [NFTA_CT_TIMEOUT_ATTR_TCP_LAST_ACK] = "LAST_ACK", + [NFTA_CT_TIMEOUT_ATTR_TCP_TIME_WAIT] = "TIME_WAIT", + [NFTA_CT_TIMEOUT_ATTR_TCP_CLOSE] = "CLOSE", + [NFTA_CT_TIMEOUT_ATTR_TCP_SYN_SENT2] = "SYN_SENT2", + [NFTA_CT_TIMEOUT_ATTR_TCP_RETRANS] = "RETRANS", + [NFTA_CT_TIMEOUT_ATTR_TCP_UNACK] = "UNACKNOWLEDGED", +}; + +static uint32_t tcp_dflt_timeout[] = { + [NFTA_CT_TIMEOUT_ATTR_TCP_SYN_SENT] = 120, + [NFTA_CT_TIMEOUT_ATTR_TCP_SYN_RECV] = 60, + [NFTA_CT_TIMEOUT_ATTR_TCP_ESTABLISHED] = 432000, + [NFTA_CT_TIMEOUT_ATTR_TCP_FIN_WAIT] = 120, + [NFTA_CT_TIMEOUT_ATTR_TCP_CLOSE_WAIT] = 60, + [NFTA_CT_TIMEOUT_ATTR_TCP_LAST_ACK] = 30, + [NFTA_CT_TIMEOUT_ATTR_TCP_TIME_WAIT] = 120, + [NFTA_CT_TIMEOUT_ATTR_TCP_CLOSE] = 10, + [NFTA_CT_TIMEOUT_ATTR_TCP_SYN_SENT2] = 120, + [NFTA_CT_TIMEOUT_ATTR_TCP_RETRANS] = 300, + [NFTA_CT_TIMEOUT_ATTR_TCP_UNACK] = 300, +}; + +static const char *const udp_state_to_name[] = { + [NFTA_CT_TIMEOUT_ATTR_UDP_UNREPLIED] = "UNREPLIED", + [NFTA_CT_TIMEOUT_ATTR_UDP_REPLIED] = "REPLIED", +}; + +static uint32_t udp_dflt_timeout[] = { + [NFTA_CT_TIMEOUT_ATTR_UDP_UNREPLIED] = 30, + [NFTA_CT_TIMEOUT_ATTR_UDP_REPLIED] = 180, +}; + +static struct { + uint32_t attr_max; + const char *const *state_to_name; + uint32_t *dflt_timeout; +} timeout_protocol[IPPROTO_MAX] = { + [IPPROTO_TCP] = { + .attr_max = NFTA_CT_TIMEOUT_ATTR_TCP_MAX, + .state_to_name = tcp_state_to_name, + .dflt_timeout = tcp_dflt_timeout, + }, + [IPPROTO_UDP] = { + .attr_max = NFTA_CT_TIMEOUT_ATTR_UDP_MAX, + .state_to_name = udp_state_to_name, + .dflt_timeout = udp_dflt_timeout, + }, +}; + + +struct _container_policy_cb { + unsigned int nlattr_max; + void *tb; +}; + +int +nftnl_timeout_policy_attr_set_u32(struct nftnl_obj *e, + uint32_t type, uint32_t data) +{ + struct nftnl_obj_ct_timeout *t = nftnl_obj_data(e); + size_t timeout_array_size; + /* Layer 4 protocol needs to be already set. */ + if (!(e->flags & (1 << NFTNL_OBJ_CT_TIMEOUT_L4PROTO))) + return -1; + if (t->timeout == NULL) { + /* if not supported, default to generic protocol tracker. */ + if (timeout_protocol[t->l4proto].attr_max != 0) { + timeout_array_size = sizeof(uint32_t) * + timeout_protocol[t->l4proto].attr_max; + } else { + timeout_array_size = sizeof(uint32_t) * + timeout_protocol[IPPROTO_RAW].attr_max; + } + t->timeout = calloc(1, timeout_array_size); + if (t->timeout == NULL) + return -1; + } + + /* this state does not exists in this protocol tracker.*/ + if (type > timeout_protocol[t->l4proto].attr_max) + return -1; + + t->timeout[type] = data; + t->polset |= (1 << type); + + if (!(e->flags & (1 << NFTNL_OBJ_CT_TIMEOUT_POLICY))) + e->flags |= (1 << NFTNL_OBJ_CT_TIMEOUT_POLICY); + if (!(e->flags & (1 << NFTNL_OBJ_CT_TIMEOUT_DATA))) + e->flags |= (1 << NFTNL_OBJ_CT_TIMEOUT_DATA); + + return 0; +} +EXPORT_SYMBOL(nftnl_timeout_policy_attr_set_u32); + +static int +parse_timeout_attr_policy_cb(const struct nlattr *attr, void *data) +{ + struct _container_policy_cb *data_cb = data; + const struct nlattr **tb = data_cb->tb; + uint16_t type = mnl_attr_get_type(attr); + + if (mnl_attr_type_valid(attr, data_cb->nlattr_max) < 0) + return MNL_CB_OK; + + if (type <= data_cb->nlattr_max) { + if (mnl_attr_validate(attr, MNL_TYPE_U32) < 0) + abi_breakage(); + tb[type] = attr; + } + return MNL_CB_OK; +} + +static void +timeout_parse_attr_data(struct nftnl_obj *e, + const struct nlattr *nest) +{ + struct nftnl_obj_ct_timeout *t = nftnl_obj_data(e); + unsigned int attr_max = timeout_protocol[t->l4proto].attr_max; + struct nlattr *tb[attr_max]; + struct _container_policy_cb cnt = { + .nlattr_max = attr_max, + .tb = tb, + }; + unsigned int i; + + memset(tb, 0, sizeof(struct nlattr *) * attr_max); + + mnl_attr_parse_nested(nest, parse_timeout_attr_policy_cb, &cnt); + + for (i = 1; i <= attr_max; i++) { + if (tb[i]) { + nftnl_timeout_policy_attr_set_u32(e, i-1, + ntohl(mnl_attr_get_u32(tb[i]))); + } + } +} + +static int nftnl_obj_ct_timeout_set(struct nftnl_obj *e, uint16_t type, + const void *data, uint32_t data_len) +{ + struct nftnl_obj_ct_timeout *timeout = nftnl_obj_data(e); + + switch (type) { + case NFTNL_OBJ_CT_TIMEOUT_L3PROTO: + timeout->l3proto = *((uint16_t *)data); + break; + case NFTNL_OBJ_CT_TIMEOUT_L4PROTO: + timeout->l4proto = *((uint8_t *)data); + break; + default: + return -1; + } + return 0; +} + +static const void *nftnl_obj_ct_timeout_get(const struct nftnl_obj *e, + uint16_t type, uint32_t *data_len) +{ + struct nftnl_obj_ct_timeout *timeout = nftnl_obj_data(e); + + switch (type) { + case NFTNL_OBJ_CT_TIMEOUT_L3PROTO: + *data_len = sizeof(timeout->l3proto); + return &timeout->l3proto; + case NFTNL_OBJ_CT_TIMEOUT_L4PROTO: + *data_len = sizeof(timeout->l4proto); + return &timeout->l4proto; + case NFTNL_OBJ_CT_TIMEOUT_DATA: + *data_len = sizeof(timeout->timeout); + return timeout->timeout; + } + return NULL; +} + +static int nftnl_obj_ct_timeout_cb(const struct nlattr *attr, void *data) +{ + int type = mnl_attr_get_type(attr); + const struct nlattr **tb = data; + + if (mnl_attr_type_valid(attr, NFTA_CT_TIMEOUT_MAX) < 0) + return MNL_CB_OK; + + switch (type) { + case NFTA_CT_TIMEOUT_L3PROTO: + if (mnl_attr_validate(attr, MNL_TYPE_U16) < 0) + abi_breakage(); + break; + case NFTA_CT_TIMEOUT_L4PROTO: + if (mnl_attr_validate(attr, MNL_TYPE_U8) < 0) + abi_breakage(); + break; + case NFTA_CT_TIMEOUT_DATA: + if (mnl_attr_validate(attr, MNL_TYPE_NESTED) < 0) + abi_breakage(); + break; + } + + tb[type] = attr; + return MNL_CB_OK; +} + +static void +nftnl_obj_ct_timeout_build(struct nlmsghdr *nlh, const struct nftnl_obj *e) +{ + struct nftnl_obj_ct_timeout *timeout = nftnl_obj_data(e); + struct nlattr *nest; + + if (e->flags & (1 << NFTNL_OBJ_CT_TIMEOUT_L3PROTO)) + mnl_attr_put_u16(nlh, NFTA_CT_TIMEOUT_L3PROTO, htons(timeout->l3proto)); + if (e->flags & (1 << NFTNL_OBJ_CT_TIMEOUT_L4PROTO)) + mnl_attr_put_u8(nlh, NFTA_CT_TIMEOUT_L4PROTO, timeout->l4proto); + if (e->flags & (1 << NFTNL_OBJ_CT_TIMEOUT_DATA) && timeout->polset) { + nest = mnl_attr_nest_start(nlh, NFTA_CT_TIMEOUT_DATA); + for (int i = 0; i < timeout_protocol[timeout->l4proto].attr_max; i++) { + if (timeout->polset & (1 << i)) + mnl_attr_put_u32(nlh, i+1, htonl(timeout->timeout[i])); + } + mnl_attr_nest_end(nlh, nest); + } +} + +static int +nftnl_obj_ct_timeout_parse(struct nftnl_obj *e, struct nlattr *attr) +{ + struct nftnl_obj_ct_timeout *timeout = nftnl_obj_data(e); + struct nlattr *tb[NFTA_CT_TIMEOUT_MAX + 1] = {}; + + if (mnl_attr_parse_nested(attr, nftnl_obj_ct_timeout_cb, tb) < 0) + return -1; + + if (tb[NFTA_CT_TIMEOUT_L3PROTO]) { + timeout->l3proto = ntohs(mnl_attr_get_u16(tb[NFTA_CT_TIMEOUT_L3PROTO])); + e->flags |= (1 << NFTNL_OBJ_CT_TIMEOUT_L3PROTO); + } + if (tb[NFTA_CT_TIMEOUT_L4PROTO]) { + timeout->l4proto = mnl_attr_get_u8(tb[NFTA_CT_TIMEOUT_L4PROTO]); + e->flags |= (1 << NFTNL_OBJ_CT_TIMEOUT_L4PROTO); + } + if (tb[NFTA_CT_TIMEOUT_DATA]) { + timeout_parse_attr_data(e, tb[NFTA_CT_TIMEOUT_DATA]); + e->flags |= (1 << NFTNL_OBJ_CT_TIMEOUT_DATA); + } + return 0; +} + +static int nftnl_obj_ct_timeout_export(char *buf, size_t size, + const struct nftnl_obj *e, int type) +{ + struct nftnl_obj_ct_timeout *timeout = nftnl_obj_data(e); + + NFTNL_BUF_INIT(b, buf, size); + + if (e->flags & (1 << NFTNL_OBJ_CT_TIMEOUT_L3PROTO)) + nftnl_buf_u32(&b, type, timeout->l3proto, FAMILY); + if (e->flags & (1 << NFTNL_OBJ_CT_TIMEOUT_L4PROTO)) + nftnl_buf_u32(&b, type, timeout->l4proto, "service"); + + return nftnl_buf_done(&b); +} + +static int nftnl_obj_ct_timeout_snprintf_default(char *buf, size_t len, + const struct nftnl_obj *e) +{ + int ret = 0; + int offset = 0, remain = len; + + struct nftnl_obj_ct_timeout *timeout = nftnl_obj_data(e); + + if (e->flags & (1 << NFTNL_OBJ_CT_TIMEOUT_L3PROTO)) { + ret = snprintf(buf+offset, len, "family %d ", + timeout->l3proto); + SNPRINTF_BUFFER_SIZE(ret, remain, offset); + } + if (e->flags & (1 << NFTNL_OBJ_CT_TIMEOUT_L4PROTO)) { + ret = snprintf(buf+offset, len, "protocol %d ", + timeout->l4proto); + SNPRINTF_BUFFER_SIZE(ret, remain, offset); + } + if (e->flags & (1 << NFTNL_OBJ_CT_TIMEOUT_POLICY)) { + uint8_t l4num = timeout->l4proto; + int i; + + /* default to generic protocol tracker. */ + if (timeout_protocol[timeout->l4proto].attr_max == 0) + l4num = IPPROTO_RAW; + + ret = snprintf(buf+offset, len, "policy = {"); + SNPRINTF_BUFFER_SIZE(ret, remain, offset); + + for (i = 0; i < timeout_protocol[l4num].attr_max; i++) { + const char *state_name = + timeout_protocol[l4num].state_to_name[i][0] ? + timeout_protocol[l4num].state_to_name[i] : + "UNKNOWN"; + + if (timeout->timeout[i] != timeout_protocol[l4num].dflt_timeout[i]) { + ret = snprintf(buf+offset, len, + "%s = %u,", state_name, timeout->timeout[i]); + SNPRINTF_BUFFER_SIZE(ret, remain, offset); + } + } + + ret = snprintf(buf+offset, len, "}"); + SNPRINTF_BUFFER_SIZE(ret, remain, offset); + } + buf[offset] = '\0'; + + return ret; + +} + +static int nftnl_obj_ct_timeout_snprintf(char *buf, size_t len, uint32_t type, + uint32_t flags, + const struct nftnl_obj *e) +{ + if (len) + buf[0] = '\0'; + + switch (type) { + case NFTNL_OUTPUT_DEFAULT: + return nftnl_obj_ct_timeout_snprintf_default(buf, len, e); + case NFTNL_OUTPUT_JSON: + return nftnl_obj_ct_timeout_export(buf, len, e, type); + default: + break; + } + return -1; +} + +struct obj_ops obj_ops_ct_timeout = { + .name = "ct_timeout", + .type = NFT_OBJECT_CT_TIMEOUT, + .alloc_len = sizeof(struct nftnl_obj_ct_timeout), + .max_attr = NFTA_CT_TIMEOUT_MAX, + .set = nftnl_obj_ct_timeout_set, + .get = nftnl_obj_ct_timeout_get, + .parse = nftnl_obj_ct_timeout_parse, + .build = nftnl_obj_ct_timeout_build, + .snprintf = nftnl_obj_ct_timeout_snprintf, +}; diff --git a/src/object.c b/src/object.c index d8278f3..988c17d 100644 --- a/src/object.c +++ b/src/object.c @@ -30,6 +30,7 @@ static struct obj_ops *obj_ops[] = { [NFT_OBJECT_QUOTA] = &obj_ops_quota, [NFT_OBJECT_CT_HELPER] = &obj_ops_ct_helper, [NFT_OBJECT_LIMIT] = &obj_ops_limit, + [NFT_OBJECT_CT_TIMEOUT] = &obj_ops_ct_timeout, }; static struct obj_ops *nftnl_obj_ops_lookup(uint32_t type) @@ -206,6 +207,12 @@ uint32_t nftnl_obj_get_u32(struct nftnl_obj *obj, uint16_t attr) return ret == NULL ? 0 : *((uint32_t *)ret); } +EXPORT_SYMBOL(nftnl_obj_get_void); +void *nftnl_obj_get_void(struct nftnl_obj *obj, uint16_t attr) +{ + return (void *)nftnl_obj_get(obj, attr); +} + EXPORT_SYMBOL(nftnl_obj_get_u64); uint64_t nftnl_obj_get_u64(struct nftnl_obj *obj, uint16_t attr) { @@ -454,7 +461,8 @@ static int nftnl_obj_snprintf_dflt(char *buf, size_t size, obj); SNPRINTF_BUFFER_SIZE(ret, remain, offset); } - ret = snprintf(buf + offset, offset, "]"); + + ret = snprintf(buf + strlen(buf), offset, "]"); SNPRINTF_BUFFER_SIZE(ret, remain, offset); return offset;