]> git.proxmox.com Git - systemd.git/blame - src/libsystemd-network/test-acd.c
Merge tag 'upstream/229'
[systemd.git] / src / libsystemd-network / test-acd.c
CommitLineData
6300502b
MP
1/***
2 This file is part of systemd.
3
4 Copyright (C) 2014 Tom Gundersen <teg@jklm.no>
5
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.
10
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.
15
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/>.
18***/
19
6300502b 20#include <errno.h>
db2df898 21#include <stdlib.h>
6300502b
MP
22#include <unistd.h>
23
24#include <linux/veth.h>
25#include <net/if.h>
26
27#include "sd-event.h"
6300502b 28#include "sd-ipv4acd.h"
db2df898 29#include "sd-netlink.h"
6300502b 30
6300502b 31#include "in-addr-util.h"
db2df898
MP
32#include "netlink-util.h"
33#include "util.h"
6300502b
MP
34
35static void acd_handler(sd_ipv4acd *acd, int event, void *userdata) {
36 assert_se(acd);
37
38 switch (event) {
39 case SD_IPV4ACD_EVENT_BIND:
40 log_info("bound");
41 break;
42 case SD_IPV4ACD_EVENT_CONFLICT:
43 log_info("conflict");
44 break;
45 case SD_IPV4ACD_EVENT_STOP:
46 log_error("the client was stopped");
47 break;
48 default:
49 assert_not_reached("invalid ACD event");
50 }
51}
52
53static int client_run(int ifindex, const struct in_addr *pa, const struct ether_addr *ha, sd_event *e) {
54 sd_ipv4acd *acd;
55
56 assert_se(sd_ipv4acd_new(&acd) >= 0);
57 assert_se(sd_ipv4acd_attach_event(acd, e, 0) >= 0);
58
59 assert_se(sd_ipv4acd_set_index(acd, ifindex) >= 0);
60 assert_se(sd_ipv4acd_set_mac(acd, ha) >= 0);
61 assert_se(sd_ipv4acd_set_address(acd, pa) >= 0);
62 assert_se(sd_ipv4acd_set_callback(acd, acd_handler, NULL) >= 0);
63
64 log_info("starting IPv4ACD client");
65
66 assert_se(sd_ipv4acd_start(acd) >= 0);
67
68 assert_se(sd_event_loop(e) >= 0);
69
70 assert_se(!sd_ipv4acd_unref(acd));
71
72 return EXIT_SUCCESS;
73}
74
75static int test_acd(const char *ifname, const char *address) {
4c89c718
MP
76 _cleanup_(sd_event_unrefp) sd_event *e = NULL;
77 _cleanup_(sd_netlink_unrefp) sd_netlink *rtnl = NULL;
78 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *m = NULL, *reply = NULL;
6300502b
MP
79 union in_addr_union pa;
80 struct ether_addr ha;
81 int ifindex;
82
83 assert_se(in_addr_from_string(AF_INET, address, &pa) >= 0);
84
85 assert_se(sd_event_new(&e) >= 0);
86
87 assert_se(sd_netlink_open(&rtnl) >= 0);
88 assert_se(sd_netlink_attach_event(rtnl, e, 0) >= 0);
89
90 assert_se(sd_rtnl_message_new_link(rtnl, &m, RTM_GETLINK, 0) >= 0);
91 assert_se(sd_netlink_message_append_string(m, IFLA_IFNAME, ifname) >= 0);
92 assert_se(sd_netlink_call(rtnl, m, 0, &reply) >= 0);
93
94 assert_se(sd_rtnl_message_link_get_ifindex(reply, &ifindex) >= 0);
95 assert_se(sd_netlink_message_read_ether_addr(reply, IFLA_ADDRESS, &ha) >= 0);
96
97 client_run(ifindex, &pa.in, &ha, e);
98
99 return EXIT_SUCCESS;
100}
101
102int main(int argc, char *argv[]) {
103 log_set_max_level(LOG_DEBUG);
104 log_parse_environment();
105 log_open();
106
107 if (argc == 3)
108 return test_acd(argv[1], argv[2]);
109 else {
110 log_error("This program takes two arguments.\n"
111 "\t %s <ifname> <IPv4 address>", program_invocation_short_name);
112 return EXIT_FAILURE;
113 }
114}