|
Packit Service |
5ffa24 |
/* SPDX-License-Identifier: GPL-2.0-or-later */
|
|
Packit Service |
5ffa24 |
/*
|
|
Packit Service |
5ffa24 |
* Copyright (C) 2015 - 2018 Red Hat, Inc.
|
|
Packit Service |
5ffa24 |
*/
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
#include "nm-default.h"
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
#include "nm-acd-manager.h"
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
#include <netinet/in.h>
|
|
Packit Service |
5ffa24 |
#include <sys/types.h>
|
|
Packit Service |
5ffa24 |
#include <sys/wait.h>
|
|
Packit Service |
5ffa24 |
#include <linux/if_ether.h>
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
#include "platform/nm-platform.h"
|
|
Packit Service |
5ffa24 |
#include "nm-utils.h"
|
|
Packit Service |
5ffa24 |
#include "NetworkManagerUtils.h"
|
|
Packit Service |
5ffa24 |
#include "n-acd/src/n-acd.h"
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
/*****************************************************************************/
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
typedef enum {
|
|
Packit Service |
5ffa24 |
STATE_INIT,
|
|
Packit Service |
5ffa24 |
STATE_PROBING,
|
|
Packit Service |
5ffa24 |
STATE_PROBE_DONE,
|
|
Packit Service |
5ffa24 |
STATE_ANNOUNCING,
|
|
Packit Service |
5ffa24 |
} State;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
typedef struct {
|
|
Packit Service |
5ffa24 |
in_addr_t address;
|
|
Packit Service |
5ffa24 |
gboolean duplicate;
|
|
Packit Service |
5ffa24 |
NAcdProbe *probe;
|
|
Packit Service |
5ffa24 |
} AddressInfo;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
struct _NMAcdManager {
|
|
Packit Service |
5ffa24 |
int ifindex;
|
|
Packit Service |
5ffa24 |
guint8 hwaddr[ETH_ALEN];
|
|
Packit Service |
5ffa24 |
State state;
|
|
Packit Service |
5ffa24 |
GHashTable *addresses;
|
|
Packit Service |
5ffa24 |
guint completed;
|
|
Packit Service |
5ffa24 |
NAcd * acd;
|
|
Packit Service |
5ffa24 |
GSource * event_source;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
NMAcdCallbacks callbacks;
|
|
Packit Service |
5ffa24 |
gpointer user_data;
|
|
Packit Service |
5ffa24 |
};
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
/*****************************************************************************/
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
#define _NMLOG_DOMAIN LOGD_IP4
|
|
Packit Service |
5ffa24 |
#define _NMLOG_PREFIX_NAME "acd"
|
|
Packit Service |
5ffa24 |
#define _NMLOG(level, ...) \
|
|
Packit Service |
5ffa24 |
G_STMT_START \
|
|
Packit Service |
5ffa24 |
{ \
|
|
Packit Service |
5ffa24 |
char _sbuf[64]; \
|
|
Packit Service |
5ffa24 |
\
|
|
Packit Service |
5ffa24 |
nm_log((level), \
|
|
Packit Service |
5ffa24 |
_NMLOG_DOMAIN, \
|
|
Packit Service |
5ffa24 |
self && self->ifindex > 0 \
|
|
Packit Service |
5ffa24 |
? nm_platform_link_get_name(NM_PLATFORM_GET, self->ifindex) \
|
|
Packit Service |
5ffa24 |
: NULL, \
|
|
Packit Service |
5ffa24 |
NULL, \
|
|
Packit Service |
5ffa24 |
"%s%s: " _NM_UTILS_MACRO_FIRST(__VA_ARGS__), \
|
|
Packit Service |
5ffa24 |
_NMLOG_PREFIX_NAME, \
|
|
Packit Service |
5ffa24 |
self ? nm_sprintf_buf(_sbuf, "[%p,%d]", self, self->ifindex) \
|
|
Packit Service |
5ffa24 |
: "" _NM_UTILS_MACRO_REST(__VA_ARGS__)); \
|
|
Packit Service |
5ffa24 |
} \
|
|
Packit Service |
5ffa24 |
G_STMT_END
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
/*****************************************************************************/
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
static const char *
|
|
Packit Service |
5ffa24 |
_acd_event_to_string(unsigned int event)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
switch (event) {
|
|
Packit Service |
5ffa24 |
case N_ACD_EVENT_READY:
|
|
Packit Service |
5ffa24 |
return "ready";
|
|
Packit Service |
5ffa24 |
case N_ACD_EVENT_USED:
|
|
Packit Service |
5ffa24 |
return "used";
|
|
Packit Service |
5ffa24 |
case N_ACD_EVENT_DEFENDED:
|
|
Packit Service |
5ffa24 |
return "defended";
|
|
Packit Service |
5ffa24 |
case N_ACD_EVENT_CONFLICT:
|
|
Packit Service |
5ffa24 |
return "conflict";
|
|
Packit Service |
5ffa24 |
case N_ACD_EVENT_DOWN:
|
|
Packit Service |
5ffa24 |
return "down";
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
return NULL;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
#define ACD_EVENT_TO_STRING_BUF_SIZE 50
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
static const char *
|
|
Packit Service |
5ffa24 |
_acd_event_to_string_buf(unsigned event, char buffer[static ACD_EVENT_TO_STRING_BUF_SIZE])
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
const char *s;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
s = _acd_event_to_string(event);
|
|
Packit Service |
5ffa24 |
if (s)
|
|
Packit Service |
5ffa24 |
return s;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_snprintf(buffer, ACD_EVENT_TO_STRING_BUF_SIZE, "(%u)", event);
|
|
Packit Service |
5ffa24 |
return buffer;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
static const char *
|
|
Packit Service |
5ffa24 |
acd_error_to_string(int error)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
if (error < 0)
|
|
Packit Service |
5ffa24 |
return nm_strerror_native(-error);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
switch (error) {
|
|
Packit Service |
5ffa24 |
case _N_ACD_E_SUCCESS:
|
|
Packit Service |
5ffa24 |
return "success";
|
|
Packit Service |
5ffa24 |
case N_ACD_E_PREEMPTED:
|
|
Packit Service |
5ffa24 |
return "preempted";
|
|
Packit Service |
5ffa24 |
case N_ACD_E_INVALID_ARGUMENT:
|
|
Packit Service |
5ffa24 |
return "invalid argument";
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_return_val_if_reached(NULL);
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
static int
|
|
Packit Service |
5ffa24 |
acd_error_to_nmerr(int error, gboolean always_fail)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
if (error < 0)
|
|
Packit Service |
5ffa24 |
return -nm_errno_native(error);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
if (always_fail) {
|
|
Packit Service |
5ffa24 |
if (NM_IN_SET(error, N_ACD_E_PREEMPTED, N_ACD_E_INVALID_ARGUMENT))
|
|
Packit Service |
5ffa24 |
return -NME_UNSPEC;
|
|
Packit Service |
5ffa24 |
g_return_val_if_reached(-NME_UNSPEC);
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
/* so, @error is either zero (indicating success) or one
|
|
Packit Service |
5ffa24 |
* of the special status codes like N_ACD_E_*. In both cases,
|
|
Packit Service |
5ffa24 |
* return the positive value here. */
|
|
Packit Service |
5ffa24 |
if (NM_IN_SET(error, _N_ACD_E_SUCCESS, N_ACD_E_PREEMPTED, N_ACD_E_INVALID_ARGUMENT))
|
|
Packit Service |
5ffa24 |
return error;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_return_val_if_reached(error);
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
/*****************************************************************************/
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
/**
|
|
Packit Service |
5ffa24 |
* nm_acd_manager_add_address:
|
|
Packit Service |
5ffa24 |
* @self: a #NMAcdManager
|
|
Packit Service |
5ffa24 |
* @address: an IP address
|
|
Packit Service |
5ffa24 |
*
|
|
Packit Service |
5ffa24 |
* Add @address to the list of IP addresses to probe.
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
* Returns: %TRUE on success, %FALSE if the address was already in the list
|
|
Packit Service |
5ffa24 |
*/
|
|
Packit Service |
5ffa24 |
gboolean
|
|
Packit Service |
5ffa24 |
nm_acd_manager_add_address(NMAcdManager *self, in_addr_t address)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
AddressInfo *info;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_return_val_if_fail(self, FALSE);
|
|
Packit Service |
5ffa24 |
g_return_val_if_fail(self->state == STATE_INIT, FALSE);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
if (g_hash_table_lookup(self->addresses, GUINT_TO_POINTER(address)))
|
|
Packit Service |
5ffa24 |
return FALSE;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
info = g_slice_new0(AddressInfo);
|
|
Packit Service |
5ffa24 |
info->address = address;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_hash_table_insert(self->addresses, GUINT_TO_POINTER(address), info);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
return TRUE;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
static gboolean
|
|
Packit Service |
5ffa24 |
acd_event(int fd, GIOCondition condition, gpointer data)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
NMAcdManager *self = data;
|
|
Packit Service |
5ffa24 |
NAcdEvent * event;
|
|
Packit Service |
5ffa24 |
AddressInfo * info;
|
|
Packit Service |
5ffa24 |
gboolean emit_probe_terminated = FALSE;
|
|
Packit Service |
5ffa24 |
char address_str[INET_ADDRSTRLEN];
|
|
Packit Service |
5ffa24 |
int r;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
if (n_acd_dispatch(self->acd))
|
|
Packit Service |
5ffa24 |
return G_SOURCE_CONTINUE;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
while (!n_acd_pop_event(self->acd, &event) && event) {
|
|
Packit Service |
5ffa24 |
char to_string_buffer[ACD_EVENT_TO_STRING_BUF_SIZE];
|
|
Packit Service |
5ffa24 |
gs_free char *hwaddr_str = NULL;
|
|
Packit Service |
5ffa24 |
gboolean check_probing_done = FALSE;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
switch (event->event) {
|
|
Packit Service |
5ffa24 |
case N_ACD_EVENT_READY:
|
|
Packit Service |
5ffa24 |
n_acd_probe_get_userdata(event->ready.probe, (void **) &info;;
|
|
Packit Service |
5ffa24 |
info->duplicate = FALSE;
|
|
Packit Service |
5ffa24 |
if (self->state == STATE_ANNOUNCING) {
|
|
Packit Service |
5ffa24 |
/* fake probe ended, start announcing */
|
|
Packit Service |
5ffa24 |
r = n_acd_probe_announce(info->probe, N_ACD_DEFEND_ONCE);
|
|
Packit Service |
5ffa24 |
if (r) {
|
|
Packit Service |
5ffa24 |
_LOGW("couldn't announce address %s on interface '%s': %s",
|
|
Packit Service |
5ffa24 |
_nm_utils_inet4_ntop(info->address, address_str),
|
|
Packit Service |
5ffa24 |
nm_platform_link_get_name(NM_PLATFORM_GET, self->ifindex),
|
|
Packit Service |
5ffa24 |
acd_error_to_string(r));
|
|
Packit Service |
5ffa24 |
} else {
|
|
Packit Service |
5ffa24 |
_LOGD("announcing address %s",
|
|
Packit Service |
5ffa24 |
_nm_utils_inet4_ntop(info->address, address_str));
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
check_probing_done = TRUE;
|
|
Packit Service |
5ffa24 |
break;
|
|
Packit Service |
5ffa24 |
case N_ACD_EVENT_USED:
|
|
Packit Service |
5ffa24 |
n_acd_probe_get_userdata(event->used.probe, (void **) &info;;
|
|
Packit Service |
5ffa24 |
info->duplicate = TRUE;
|
|
Packit Service |
5ffa24 |
check_probing_done = TRUE;
|
|
Packit Service |
5ffa24 |
break;
|
|
Packit Service |
5ffa24 |
case N_ACD_EVENT_DEFENDED:
|
|
Packit Service |
5ffa24 |
n_acd_probe_get_userdata(event->defended.probe, (void **) &info;;
|
|
Packit Service |
5ffa24 |
_LOGD("defended address %s from host %s",
|
|
Packit Service |
5ffa24 |
_nm_utils_inet4_ntop(info->address, address_str),
|
|
Packit Service |
5ffa24 |
(hwaddr_str =
|
|
Packit Service |
5ffa24 |
nm_utils_hwaddr_ntoa(event->defended.sender, event->defended.n_sender)));
|
|
Packit Service |
5ffa24 |
break;
|
|
Packit Service |
5ffa24 |
case N_ACD_EVENT_CONFLICT:
|
|
Packit Service |
5ffa24 |
n_acd_probe_get_userdata(event->conflict.probe, (void **) &info;;
|
|
Packit Service |
5ffa24 |
_LOGW("conflict for address %s detected with host %s on interface '%s'",
|
|
Packit Service |
5ffa24 |
_nm_utils_inet4_ntop(info->address, address_str),
|
|
Packit Service |
5ffa24 |
(hwaddr_str =
|
|
Packit Service |
5ffa24 |
nm_utils_hwaddr_ntoa(event->defended.sender, event->defended.n_sender)),
|
|
Packit Service |
5ffa24 |
nm_platform_link_get_name(NM_PLATFORM_GET, self->ifindex));
|
|
Packit Service |
5ffa24 |
break;
|
|
Packit Service |
5ffa24 |
default:
|
|
Packit Service |
5ffa24 |
_LOGD("unhandled event '%s'", _acd_event_to_string_buf(event->event, to_string_buffer));
|
|
Packit Service |
5ffa24 |
break;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
if (check_probing_done && self->state == STATE_PROBING
|
|
Packit Service |
5ffa24 |
&& ++self->completed == g_hash_table_size(self->addresses)) {
|
|
Packit Service |
5ffa24 |
self->state = STATE_PROBE_DONE;
|
|
Packit Service |
5ffa24 |
emit_probe_terminated = TRUE;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
if (emit_probe_terminated) {
|
|
Packit Service |
5ffa24 |
if (self->callbacks.probe_terminated_callback) {
|
|
Packit Service |
5ffa24 |
self->callbacks.probe_terminated_callback(self, self->user_data);
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
return G_SOURCE_CONTINUE;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
static gboolean
|
|
Packit Service |
5ffa24 |
acd_probe_add(NMAcdManager *self, AddressInfo *info, guint64 timeout)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
NAcdProbeConfig *probe_config;
|
|
Packit Service |
5ffa24 |
int r;
|
|
Packit Service |
5ffa24 |
char sbuf[NM_UTILS_INET_ADDRSTRLEN];
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
r = n_acd_probe_config_new(&probe_config);
|
|
Packit Service |
5ffa24 |
if (r) {
|
|
Packit Service |
5ffa24 |
_LOGW("could not create probe config for %s on interface '%s': %s",
|
|
Packit Service |
5ffa24 |
_nm_utils_inet4_ntop(info->address, sbuf),
|
|
Packit Service |
5ffa24 |
nm_platform_link_get_name(NM_PLATFORM_GET, self->ifindex),
|
|
Packit Service |
5ffa24 |
acd_error_to_string(r));
|
|
Packit Service |
5ffa24 |
return FALSE;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
n_acd_probe_config_set_ip(probe_config, (struct in_addr){info->address});
|
|
Packit Service |
5ffa24 |
n_acd_probe_config_set_timeout(probe_config, timeout);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
r = n_acd_probe(self->acd, &info->probe, probe_config);
|
|
Packit Service |
5ffa24 |
if (r) {
|
|
Packit Service |
5ffa24 |
_LOGW("could not start probe for %s on interface '%s': %s",
|
|
Packit Service |
5ffa24 |
_nm_utils_inet4_ntop(info->address, sbuf),
|
|
Packit Service |
5ffa24 |
nm_platform_link_get_name(NM_PLATFORM_GET, self->ifindex),
|
|
Packit Service |
5ffa24 |
acd_error_to_string(r));
|
|
Packit Service |
5ffa24 |
n_acd_probe_config_free(probe_config);
|
|
Packit Service |
5ffa24 |
return FALSE;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
n_acd_probe_set_userdata(info->probe, info);
|
|
Packit Service |
5ffa24 |
n_acd_probe_config_free(probe_config);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
return TRUE;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
static int
|
|
Packit Service |
5ffa24 |
acd_init(NMAcdManager *self)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
NAcdConfig *config;
|
|
Packit Service |
5ffa24 |
int r;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
if (self->acd)
|
|
Packit Service |
5ffa24 |
return 0;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
r = n_acd_config_new(&config);
|
|
Packit Service |
5ffa24 |
if (r)
|
|
Packit Service |
5ffa24 |
return r;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
n_acd_config_set_ifindex(config, self->ifindex);
|
|
Packit Service |
5ffa24 |
n_acd_config_set_transport(config, N_ACD_TRANSPORT_ETHERNET);
|
|
Packit Service |
5ffa24 |
n_acd_config_set_mac(config, self->hwaddr, ETH_ALEN);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
r = n_acd_new(&self->acd, config);
|
|
Packit Service |
5ffa24 |
n_acd_config_free(config);
|
|
Packit Service |
5ffa24 |
return r;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
/**
|
|
Packit Service |
5ffa24 |
* nm_acd_manager_start_probe:
|
|
Packit Service |
5ffa24 |
* @self: a #NMAcdManager
|
|
Packit Service |
5ffa24 |
* @timeout: maximum probe duration in milliseconds
|
|
Packit Service |
5ffa24 |
* @error: location to store error, or %NULL
|
|
Packit Service |
5ffa24 |
*
|
|
Packit Service |
5ffa24 |
* Start probing IP addresses for duplicates; when the probe terminates a
|
|
Packit Service |
5ffa24 |
* PROBE_TERMINATED signal is emitted.
|
|
Packit Service |
5ffa24 |
*
|
|
Packit Service |
5ffa24 |
* Returns: 0 on success or a negative NetworkManager error code (NME_*).
|
|
Packit Service |
5ffa24 |
*/
|
|
Packit Service |
5ffa24 |
int
|
|
Packit Service |
5ffa24 |
nm_acd_manager_start_probe(NMAcdManager *self, guint timeout)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
GHashTableIter iter;
|
|
Packit Service |
5ffa24 |
AddressInfo * info;
|
|
Packit Service |
5ffa24 |
gboolean success = FALSE;
|
|
Packit Service |
5ffa24 |
int fd, r;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_return_val_if_fail(self, FALSE);
|
|
Packit Service |
5ffa24 |
g_return_val_if_fail(self->state == STATE_INIT, FALSE);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
r = acd_init(self);
|
|
Packit Service |
5ffa24 |
if (r) {
|
|
Packit Service |
5ffa24 |
_LOGW("couldn't init ACD for probing on interface '%s': %s",
|
|
Packit Service |
5ffa24 |
nm_platform_link_get_name(NM_PLATFORM_GET, self->ifindex),
|
|
Packit Service |
5ffa24 |
acd_error_to_string(r));
|
|
Packit Service |
5ffa24 |
return acd_error_to_nmerr(r, TRUE);
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
self->completed = 0;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_hash_table_iter_init(&iter, self->addresses);
|
|
Packit Service |
5ffa24 |
while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &info))
|
|
Packit Service |
5ffa24 |
success |= acd_probe_add(self, info, timeout);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
if (success)
|
|
Packit Service |
5ffa24 |
self->state = STATE_PROBING;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
nm_assert(!self->event_source);
|
|
Packit Service |
5ffa24 |
n_acd_get_fd(self->acd, &fd;;
|
|
Packit Service |
5ffa24 |
self->event_source =
|
|
Packit Service |
5ffa24 |
nm_g_unix_fd_source_new(fd, G_IO_IN, G_PRIORITY_DEFAULT, acd_event, self, NULL);
|
|
Packit Service |
5ffa24 |
g_source_attach(self->event_source, NULL);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
return success ? 0 : -NME_UNSPEC;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
/**
|
|
Packit Service |
5ffa24 |
* nm_acd_manager_check_address:
|
|
Packit Service |
5ffa24 |
* @self: a #NMAcdManager
|
|
Packit Service |
5ffa24 |
* @address: an IP address
|
|
Packit Service |
5ffa24 |
*
|
|
Packit Service |
5ffa24 |
* Check if an IP address is duplicate. @address must have been added with
|
|
Packit Service |
5ffa24 |
* nm_acd_manager_add_address().
|
|
Packit Service |
5ffa24 |
*
|
|
Packit Service |
5ffa24 |
* Returns: %TRUE if the address is not duplicate, %FALSE otherwise
|
|
Packit Service |
5ffa24 |
*/
|
|
Packit Service |
5ffa24 |
gboolean
|
|
Packit Service |
5ffa24 |
nm_acd_manager_check_address(NMAcdManager *self, in_addr_t address)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
AddressInfo *info;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_return_val_if_fail(self, FALSE);
|
|
Packit Service |
5ffa24 |
g_return_val_if_fail(NM_IN_SET(self->state, STATE_INIT, STATE_PROBE_DONE), FALSE);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
info = g_hash_table_lookup(self->addresses, GUINT_TO_POINTER(address));
|
|
Packit Service |
5ffa24 |
g_return_val_if_fail(info, FALSE);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
return !info->duplicate;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
/**
|
|
Packit Service |
5ffa24 |
* nm_acd_manager_announce_addresses:
|
|
Packit Service |
5ffa24 |
* @self: a #NMAcdManager
|
|
Packit Service |
5ffa24 |
*
|
|
Packit Service |
5ffa24 |
* Start announcing addresses.
|
|
Packit Service |
5ffa24 |
*
|
|
Packit Service |
5ffa24 |
* Returns: a negative NetworkManager error number or zero on success.
|
|
Packit Service |
5ffa24 |
*/
|
|
Packit Service |
5ffa24 |
int
|
|
Packit Service |
5ffa24 |
nm_acd_manager_announce_addresses(NMAcdManager *self)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
GHashTableIter iter;
|
|
Packit Service |
5ffa24 |
AddressInfo * info;
|
|
Packit Service |
5ffa24 |
int r;
|
|
Packit Service |
5ffa24 |
int fd;
|
|
Packit Service |
5ffa24 |
gboolean success = TRUE;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
r = acd_init(self);
|
|
Packit Service |
5ffa24 |
if (r) {
|
|
Packit Service |
5ffa24 |
_LOGW("couldn't init ACD for announcing addresses on interface '%s': %s",
|
|
Packit Service |
5ffa24 |
nm_platform_link_get_name(NM_PLATFORM_GET, self->ifindex),
|
|
Packit Service |
5ffa24 |
acd_error_to_string(r));
|
|
Packit Service |
5ffa24 |
return acd_error_to_nmerr(r, TRUE);
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
if (self->state == STATE_INIT) {
|
|
Packit Service |
5ffa24 |
/* n-acd can't announce without probing, therefore let's
|
|
Packit Service |
5ffa24 |
* start a fake probe with zero timeout and then perform
|
|
Packit Service |
5ffa24 |
* the announcement. */
|
|
Packit Service |
5ffa24 |
g_hash_table_iter_init(&iter, self->addresses);
|
|
Packit Service |
5ffa24 |
while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &info)) {
|
|
Packit Service |
5ffa24 |
if (!acd_probe_add(self, info, 0))
|
|
Packit Service |
5ffa24 |
success = FALSE;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
self->state = STATE_ANNOUNCING;
|
|
Packit Service |
5ffa24 |
} else if (self->state == STATE_ANNOUNCING) {
|
|
Packit Service |
5ffa24 |
char sbuf[NM_UTILS_INET_ADDRSTRLEN];
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_hash_table_iter_init(&iter, self->addresses);
|
|
Packit Service |
5ffa24 |
while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &info)) {
|
|
Packit Service |
5ffa24 |
if (info->duplicate)
|
|
Packit Service |
5ffa24 |
continue;
|
|
Packit Service |
5ffa24 |
r = n_acd_probe_announce(info->probe, N_ACD_DEFEND_ONCE);
|
|
Packit Service |
5ffa24 |
if (r) {
|
|
Packit Service |
5ffa24 |
_LOGW("couldn't announce address %s on interface '%s': %s",
|
|
Packit Service |
5ffa24 |
_nm_utils_inet4_ntop(info->address, sbuf),
|
|
Packit Service |
5ffa24 |
nm_platform_link_get_name(NM_PLATFORM_GET, self->ifindex),
|
|
Packit Service |
5ffa24 |
acd_error_to_string(r));
|
|
Packit Service |
5ffa24 |
success = FALSE;
|
|
Packit Service |
5ffa24 |
} else
|
|
Packit Service |
5ffa24 |
_LOGD("announcing address %s", _nm_utils_inet4_ntop(info->address, sbuf));
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
if (!self->event_source) {
|
|
Packit Service |
5ffa24 |
n_acd_get_fd(self->acd, &fd;;
|
|
Packit Service |
5ffa24 |
self->event_source =
|
|
Packit Service |
5ffa24 |
nm_g_unix_fd_source_new(fd, G_IO_IN, G_PRIORITY_DEFAULT, acd_event, self, NULL);
|
|
Packit Service |
5ffa24 |
g_source_attach(self->event_source, NULL);
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
return success ? 0 : -NME_UNSPEC;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
static void
|
|
Packit Service |
5ffa24 |
destroy_address_info(gpointer data)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
AddressInfo *info = (AddressInfo *) data;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
n_acd_probe_free(info->probe);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_slice_free(AddressInfo, info);
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
/*****************************************************************************/
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
NMAcdManager *
|
|
Packit Service |
5ffa24 |
nm_acd_manager_new(int ifindex,
|
|
Packit Service |
5ffa24 |
const guint8 * hwaddr,
|
|
Packit Service |
5ffa24 |
guint hwaddr_len,
|
|
Packit Service |
5ffa24 |
const NMAcdCallbacks *callbacks,
|
|
Packit Service |
5ffa24 |
gpointer user_data)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
NMAcdManager *self;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_return_val_if_fail(ifindex > 0, NULL);
|
|
Packit Service |
5ffa24 |
g_return_val_if_fail(hwaddr, NULL);
|
|
Packit Service |
5ffa24 |
g_return_val_if_fail(hwaddr_len == ETH_ALEN, NULL);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
self = g_slice_new0(NMAcdManager);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
if (callbacks)
|
|
Packit Service |
5ffa24 |
self->callbacks = *callbacks;
|
|
Packit Service |
5ffa24 |
self->user_data = user_data;
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
self->addresses = g_hash_table_new_full(nm_direct_hash, NULL, NULL, destroy_address_info);
|
|
Packit Service |
5ffa24 |
self->state = STATE_INIT;
|
|
Packit Service |
5ffa24 |
self->ifindex = ifindex;
|
|
Packit Service |
5ffa24 |
memcpy(self->hwaddr, hwaddr, ETH_ALEN);
|
|
Packit Service |
5ffa24 |
return self;
|
|
Packit Service |
5ffa24 |
}
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
void
|
|
Packit Service |
5ffa24 |
nm_acd_manager_free(NMAcdManager *self)
|
|
Packit Service |
5ffa24 |
{
|
|
Packit Service |
5ffa24 |
g_return_if_fail(self);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
if (self->callbacks.user_data_destroy)
|
|
Packit Service |
5ffa24 |
self->callbacks.user_data_destroy(self->user_data);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
nm_clear_pointer(&self->addresses, g_hash_table_destroy);
|
|
Packit Service |
5ffa24 |
nm_clear_g_source_inst(&self->event_source);
|
|
Packit Service |
5ffa24 |
nm_clear_pointer(&self->acd, n_acd_unref);
|
|
Packit Service |
5ffa24 |
|
|
Packit Service |
5ffa24 |
g_slice_free(NMAcdManager, self);
|
|
Packit Service |
5ffa24 |
}
|