src/libsystemd-network/test-acd.c

   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
  20 #include <errno.h>
  21 #include <stdlib.h>
  22 #include <unistd.h>
  23
  24 #include <linux/veth.h>
  25 #include <net/if.h>
  26
  27 #include "sd-event.h"
  28 #include "sd-ipv4acd.h"
  29 #include "sd-netlink.h"
  30
  31 #include "in-addr-util.h"
  32 #include "netlink-util.h"
  33 #include "util.h"
  34
  35 static 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
  53 static 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
  75 static int test_acd(const char *ifname, const char *address) {
  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;
  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
 102 int 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 }