2 This file is part of systemd.
4 Copyright 2017 Susant Sahani
6 systemd is free software; you can redistribute it and/or modify it
7 under the terms of the GNU Lesser General Public License as published by
8 the Free Software Foundation; either version 2.1 of the License, or
9 (at your option) any later version.
11 systemd is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 Lesser General Public License for more details.
16 You should have received a copy of the GNU Lesser General Public License
17 along with systemd; If not, see <http://www.gnu.org/licenses/>.
22 #include "alloc-util.h"
23 #include "conf-parser.h"
24 #include "extract-word.h"
26 #include "parse-util.h"
27 #include "sd-netlink.h"
28 #include "string-util.h"
31 #include "networkd-manager.h"
33 #define GENEVE_FLOW_LABEL_MAX_MASK 0xFFFFFU
34 #define DEFAULT_GENEVE_DESTINATION_PORT 6081
36 /* callback for geneve netdev's created without a backing Link */
37 static int geneve_netdev_create_handler(sd_netlink
*rtnl
, sd_netlink_message
*m
, void *userdata
) {
38 _cleanup_netdev_unref_ NetDev
*netdev
= userdata
;
41 assert(netdev
->state
!= _NETDEV_STATE_INVALID
);
43 r
= sd_netlink_message_get_errno(m
);
45 log_netdev_info(netdev
, "Geneve netdev exists, using existing without changing its parameters");
47 log_netdev_warning_errno(netdev
, r
, "Geneve netdev could not be created: %m");
53 log_netdev_debug(netdev
, "Geneve created");
58 static int netdev_geneve_create(NetDev
*netdev
) {
59 _cleanup_(sd_netlink_message_unrefp
) sd_netlink_message
*m
= NULL
;
67 r
= sd_rtnl_message_new_link(netdev
->manager
->rtnl
, &m
, RTM_NEWLINK
, 0);
69 return log_netdev_error_errno(netdev
, r
, "Could not allocate RTM_NEWLINK message: %m");
71 r
= sd_netlink_message_append_string(m
, IFLA_IFNAME
, netdev
->ifname
);
73 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_IFNAME, attribute: %m");
76 r
= sd_netlink_message_append_ether_addr(m
, IFLA_ADDRESS
, netdev
->mac
);
78 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_ADDRESS attribute: %m");
82 r
= sd_netlink_message_append_u32(m
, IFLA_MTU
, netdev
->mtu
);
84 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_MTU attribute: %m");
87 r
= sd_netlink_message_open_container(m
, IFLA_LINKINFO
);
89 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_LINKINFO attribute: %m");
91 r
= sd_netlink_message_open_container_union(m
, IFLA_INFO_DATA
, netdev_kind_to_string(netdev
->kind
));
93 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_INFO_DATA attribute: %m");
95 if (v
->id
<= GENEVE_VID_MAX
) {
96 r
= sd_netlink_message_append_u32(m
, IFLA_GENEVE_ID
, v
->id
);
98 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_GENEVE_ID attribute: %m");
101 if (!in_addr_is_null(v
->remote_family
, &v
->remote
)) {
103 if (v
->remote_family
== AF_INET
)
104 r
= sd_netlink_message_append_in_addr(m
, IFLA_GENEVE_REMOTE
, &v
->remote
.in
);
106 r
= sd_netlink_message_append_in6_addr(m
, IFLA_GENEVE_REMOTE6
, &v
->remote
.in6
);
109 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_GENEVE_GROUP attribute: %m");
114 r
= sd_netlink_message_append_u8(m
, IFLA_GENEVE_TTL
, v
->ttl
);
116 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_GENEVE_TTL attribute: %m");
119 r
= sd_netlink_message_append_u8(m
, IFLA_GENEVE_TOS
, v
->tos
);
121 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_GENEVE_TOS attribute: %m");
123 r
= sd_netlink_message_append_u8(m
, IFLA_GENEVE_UDP_CSUM
, v
->udpcsum
);
125 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_GENEVE_UDP_CSUM attribute: %m");
127 r
= sd_netlink_message_append_u8(m
, IFLA_GENEVE_UDP_ZERO_CSUM6_TX
, v
->udp6zerocsumtx
);
129 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_GENEVE_UDP_ZERO_CSUM6_TX attribute: %m");
131 r
= sd_netlink_message_append_u8(m
, IFLA_GENEVE_UDP_ZERO_CSUM6_RX
, v
->udp6zerocsumrx
);
133 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_GENEVE_UDP_ZERO_CSUM6_RX attribute: %m");
135 if (v
->dest_port
!= DEFAULT_GENEVE_DESTINATION_PORT
) {
136 r
= sd_netlink_message_append_u16(m
, IFLA_GENEVE_PORT
, htobe16(v
->dest_port
));
138 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_GENEVE_PORT attribute: %m");
141 if (v
->flow_label
> 0) {
142 r
= sd_netlink_message_append_u32(m
, IFLA_GENEVE_LABEL
, htobe32(v
->flow_label
));
144 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_GENEVE_LABEL attribute: %m");
147 r
= sd_netlink_message_close_container(m
);
149 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_INFO_DATA attribute: %m");
151 r
= sd_netlink_message_close_container(m
);
153 return log_netdev_error_errno(netdev
, r
, "Could not append IFLA_LINKINFO attribute: %m");
155 r
= sd_netlink_call_async(netdev
->manager
->rtnl
, m
, geneve_netdev_create_handler
, netdev
, 0, NULL
);
157 return log_netdev_error_errno(netdev
, r
, "Could not send rtnetlink message: %m");
161 netdev
->state
= NETDEV_STATE_CREATING
;
163 log_netdev_debug(netdev
, "Creating");
169 int config_parse_geneve_vni(const char *unit
,
170 const char *filename
,
173 unsigned section_line
,
179 Geneve
*v
= userdata
;
188 r
= safe_atou32(rvalue
, &f
);
190 log_syntax(unit
, LOG_ERR
, filename
, line
, r
, "Failed to parse Geneve VNI '%s'.", rvalue
);
194 if (f
> GENEVE_VID_MAX
){
195 log_syntax(unit
, LOG_ERR
, filename
, line
, r
, "Geneve VNI out is of range '%s'.", rvalue
);
204 int config_parse_geneve_address(const char *unit
,
205 const char *filename
,
208 unsigned section_line
,
214 Geneve
*v
= userdata
;
215 union in_addr_union
*addr
= data
, buffer
;
223 r
= in_addr_from_string_auto(rvalue
, &f
, &buffer
);
225 log_syntax(unit
, LOG_ERR
, filename
, line
, r
, "geneve '%s' address is invalid, ignoring assignment: %s", lvalue
, rvalue
);
229 r
= in_addr_is_multicast(f
, &buffer
);
231 log_syntax(unit
, LOG_ERR
, filename
, line
, 0, "geneve invalid multicast '%s' address, ignoring assignment: %s", lvalue
, rvalue
);
235 v
->remote_family
= f
;
241 int config_parse_geneve_destination_port(const char *unit
,
242 const char *filename
,
245 unsigned section_line
,
251 Geneve
*v
= userdata
;
260 r
= parse_ip_port(rvalue
, &port
);
262 log_syntax(unit
, LOG_ERR
, filename
, line
, r
, "Failed to parse Geneve destination port '%s'.", rvalue
);
271 int config_parse_geneve_flow_label(const char *unit
,
272 const char *filename
,
275 unsigned section_line
,
281 Geneve
*v
= userdata
;
290 r
= safe_atou32(rvalue
, &f
);
292 log_syntax(unit
, LOG_ERR
, filename
, line
, r
, "Failed to parse Geneve flow label '%s'.", rvalue
);
296 if (f
& ~GENEVE_FLOW_LABEL_MAX_MASK
) {
297 log_syntax(unit
, LOG_ERR
, filename
, line
, r
,
298 "Geneve flow label '%s' not valid. Flow label range should be [0-1048575].", rvalue
);
307 static int netdev_geneve_verify(NetDev
*netdev
, const char *filename
) {
308 Geneve
*v
= GENEVE(netdev
);
315 log_warning("Invalid Geneve TTL value '0' configured in '%s'. Ignoring", filename
);
322 static void geneve_init(NetDev
*netdev
) {
331 v
->id
= GENEVE_VID_MAX
+ 1;
332 v
->dest_port
= DEFAULT_GENEVE_DESTINATION_PORT
;
334 v
->udp6zerocsumtx
= false;
335 v
->udp6zerocsumrx
= false;
338 const NetDevVTable geneve_vtable
= {
339 .object_size
= sizeof(Geneve
),
341 .sections
= "Match\0NetDev\0GENEVE\0",
342 .create
= netdev_geneve_create
,
343 .create_type
= NETDEV_CREATE_INDEPENDENT
,
344 .config_verify
= netdev_geneve_verify
,