/* SPDX-License-Identifier: LGPL-2.1-or-later */ #include #include #include #include "alloc-util.h" #include "conf-parser.h" #include "extract-word.h" #include "geneve.h" #include "netlink-util.h" #include "networkd-manager.h" #include "parse-util.h" #include "string-table.h" #include "string-util.h" #include "strv.h" #define GENEVE_FLOW_LABEL_MAX_MASK 0xFFFFFU #define DEFAULT_GENEVE_DESTINATION_PORT 6081 static const char* const geneve_df_table[_NETDEV_GENEVE_DF_MAX] = { [NETDEV_GENEVE_DF_NO] = "no", [NETDEV_GENEVE_DF_YES] = "yes", [NETDEV_GENEVE_DF_INHERIT] = "inherit", }; DEFINE_STRING_TABLE_LOOKUP_WITH_BOOLEAN(geneve_df, GeneveDF, NETDEV_GENEVE_DF_YES); DEFINE_CONFIG_PARSE_ENUM(config_parse_geneve_df, geneve_df, GeneveDF, "Failed to parse Geneve IPDoNotFragment= setting"); static int netdev_geneve_fill_message_create(NetDev *netdev, Link *link, sd_netlink_message *m) { assert(m); Geneve *v = GENEVE(netdev); int r; if (v->id <= GENEVE_VID_MAX) { r = sd_netlink_message_append_u32(m, IFLA_GENEVE_ID, v->id); if (r < 0) return r; } if (in_addr_is_set(v->remote_family, &v->remote)) { if (v->remote_family == AF_INET) r = sd_netlink_message_append_in_addr(m, IFLA_GENEVE_REMOTE, &v->remote.in); else r = sd_netlink_message_append_in6_addr(m, IFLA_GENEVE_REMOTE6, &v->remote.in6); if (r < 0) return r; } if (v->inherit) { r = sd_netlink_message_append_u8(m, IFLA_GENEVE_TTL_INHERIT, 1); if (r < 0) return r; } else { r = sd_netlink_message_append_u8(m, IFLA_GENEVE_TTL, v->ttl); if (r < 0) return r; } r = sd_netlink_message_append_u8(m, IFLA_GENEVE_TOS, v->tos); if (r < 0) return r; r = sd_netlink_message_append_u8(m, IFLA_GENEVE_UDP_CSUM, v->udpcsum); if (r < 0) return r; r = sd_netlink_message_append_u8(m, IFLA_GENEVE_UDP_ZERO_CSUM6_TX, v->udp6zerocsumtx); if (r < 0) return r; r = sd_netlink_message_append_u8(m, IFLA_GENEVE_UDP_ZERO_CSUM6_RX, v->udp6zerocsumrx); if (r < 0) return r; if (v->dest_port != DEFAULT_GENEVE_DESTINATION_PORT) { r = sd_netlink_message_append_u16(m, IFLA_GENEVE_PORT, htobe16(v->dest_port)); if (r < 0) return r; } if (v->flow_label > 0) { r = sd_netlink_message_append_u32(m, IFLA_GENEVE_LABEL, htobe32(v->flow_label)); if (r < 0) return r; } if (v->inherit_inner_protocol) { r = sd_netlink_message_append_flag(m, IFLA_GENEVE_INNER_PROTO_INHERIT); if (r < 0) return r; } if (v->geneve_df != _NETDEV_GENEVE_DF_INVALID) { r = sd_netlink_message_append_u8(m, IFLA_GENEVE_DF, v->geneve_df); if (r < 0) return r; } return 0; } int config_parse_geneve_vni( const char *unit, const char *filename, unsigned line, const char *section, unsigned section_line, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata) { assert(filename); assert(lvalue); assert(rvalue); assert(data); Geneve *v = ASSERT_PTR(userdata); return config_parse_uint32_bounded( unit, filename, line, section, section_line, lvalue, rvalue, 0, GENEVE_VID_MAX, true, &v->id); } int config_parse_geneve_address( const char *unit, const char *filename, unsigned line, const char *section, unsigned section_line, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata) { assert(filename); assert(lvalue); assert(rvalue); assert(data); Geneve *v = ASSERT_PTR(userdata); union in_addr_union *addr = data, buffer; int r, f; r = in_addr_from_string_auto(rvalue, &f, &buffer); if (r < 0) { log_syntax(unit, LOG_WARNING, filename, line, r, "geneve '%s' address is invalid, ignoring assignment: %s", lvalue, rvalue); return 0; } r = in_addr_is_multicast(f, &buffer); if (r > 0) { log_syntax(unit, LOG_WARNING, filename, line, 0, "geneve invalid multicast '%s' address, ignoring assignment: %s", lvalue, rvalue); return 0; } v->remote_family = f; *addr = buffer; return 0; } int config_parse_geneve_flow_label( const char *unit, const char *filename, unsigned line, const char *section, unsigned section_line, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata) { assert(filename); assert(lvalue); assert(rvalue); assert(data); Geneve *v = ASSERT_PTR(userdata); uint32_t f; int r; r = safe_atou32(rvalue, &f); if (r < 0) { log_syntax(unit, LOG_WARNING, filename, line, r, "Failed to parse Geneve flow label '%s'.", rvalue); return 0; } if (f & ~GENEVE_FLOW_LABEL_MAX_MASK) { log_syntax(unit, LOG_WARNING, filename, line, 0, "Geneve flow label '%s' not valid. Flow label range should be [0-1048575].", rvalue); return 0; } v->flow_label = f; return 0; } int config_parse_geneve_ttl( const char *unit, const char *filename, unsigned line, const char *section, unsigned section_line, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata) { assert(filename); assert(lvalue); assert(rvalue); assert(data); Geneve *v = ASSERT_PTR(userdata); int r; if (streq(rvalue, "inherit")) { v->inherit = true; v->ttl = 0; /* unset the unused ttl field for clarity */ return 0; } r = config_parse_uint8_bounded( unit, filename, line, section, section_line, lvalue, rvalue, 0, UINT8_MAX, true, &v->ttl); if (r <= 0) return r; v->inherit = false; return 0; } static int netdev_geneve_verify(NetDev *netdev, const char *filename) { assert(filename); Geneve *v = GENEVE(netdev); if (v->id > GENEVE_VID_MAX) return log_netdev_warning_errno(netdev, SYNTHETIC_ERRNO(EINVAL), "%s: Geneve without valid VNI (or Virtual Network Identifier) configured. Ignoring.", filename); return 0; } static void geneve_init(NetDev *netdev) { Geneve *v = GENEVE(netdev); v->id = GENEVE_VID_MAX + 1; v->geneve_df = _NETDEV_GENEVE_DF_INVALID; v->dest_port = DEFAULT_GENEVE_DESTINATION_PORT; v->udpcsum = false; v->udp6zerocsumtx = false; v->udp6zerocsumrx = false; } const NetDevVTable geneve_vtable = { .object_size = sizeof(Geneve), .init = geneve_init, .sections = NETDEV_COMMON_SECTIONS "GENEVE\0", .fill_message_create = netdev_geneve_fill_message_create, .create_type = NETDEV_CREATE_INDEPENDENT, .config_verify = netdev_geneve_verify, .iftype = ARPHRD_ETHER, .generate_mac = true, };