// SPDX-License-Identifier: LGPL-2.1+
/*
* Copyright (C) 2018 Red Hat, Inc.
*/
#include "nm-default.h"
#include "nm-device-wifi-p2p.h"
#include <sys/socket.h>
#include "supplicant/nm-supplicant-manager.h"
#include "supplicant/nm-supplicant-interface.h"
#include "NetworkManagerUtils.h"
#include "devices/nm-device-private.h"
#include "nm-act-request.h"
#include "nm-core-internal.h"
#include "nm-glib-aux/nm-ref-string.h"
#include "nm-ip4-config.h"
#include "nm-manager.h"
#include "nm-manager.h"
#include "nm-setting-wifi-p2p.h"
#include "nm-utils.h"
#include "nm-wifi-p2p-peer.h"
#include "platform/nm-platform.h"
#include "platform/nmp-object.h"
#include "settings/nm-settings.h"
#include "devices/nm-device-logging.h"
_LOG_DECLARE_SELF(NMDeviceWifiP2P);
/*****************************************************************************/
NM_GOBJECT_PROPERTIES_DEFINE (NMDeviceWifiP2P,
PROP_PEERS,
);
typedef struct {
NMSupplicantManager *sup_mgr;
/* NOTE: In theory management and group ifaces could be identical. However,
* in practice, this cannot happen currently as NMDeviceWifiP2P is only
* created for existing non-P2P interfaces.
* (i.e. a single standalone P2P interface is not supported at this point)
*/
NMSupplicantInterface *mgmt_iface;
NMSupplicantInterface *group_iface;
CList peers_lst_head;
guint find_peer_timeout_id;
guint sup_timeout_id;
guint peer_dump_id;
guint peer_missing_id;
bool is_waiting_for_supplicant:1;
} NMDeviceWifiP2PPrivate;
struct _NMDeviceWifiP2P {
NMDevice parent;
NMDeviceWifiP2PPrivate _priv;
};
struct _NMDeviceWifiP2PClass {
NMDeviceClass parent;
};
G_DEFINE_TYPE (NMDeviceWifiP2P, nm_device_wifi_p2p, NM_TYPE_DEVICE)
#define NM_DEVICE_WIFI_P2P_GET_PRIVATE(self) _NM_GET_PRIVATE (self, NMDeviceWifiP2P, NM_IS_DEVICE_WIFI_P2P, NMDevice)
/*****************************************************************************/
static const NMDBusInterfaceInfoExtended interface_info_device_wifi_p2p;
static const GDBusSignalInfo nm_signal_info_wifi_p2p_peer_added;
static const GDBusSignalInfo nm_signal_info_wifi_p2p_peer_removed;
static void supplicant_group_interface_release (NMDeviceWifiP2P *self);
static void supplicant_interfaces_release (NMDeviceWifiP2P *self, gboolean set_is_waiting);
/*****************************************************************************/
static void
_peer_dump (NMDeviceWifiP2P *self,
NMLogLevel log_level,
const NMWifiP2PPeer *peer,
const char *prefix,
gint32 now_s)
{
char buf[1024];
_NMLOG (log_level, LOGD_WIFI_SCAN, "wifi-peer: %-7s %s",
prefix,
nm_wifi_p2p_peer_to_string (peer, buf, sizeof (buf), now_s));
}
static gboolean
peer_list_dump (gpointer user_data)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (user_data);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
priv->peer_dump_id = 0;
if (_LOGD_ENABLED (LOGD_WIFI_SCAN)) {
NMWifiP2PPeer *peer;
gint32 now_s = nm_utils_get_monotonic_timestamp_sec ();
_LOGD (LOGD_WIFI_SCAN, "P2P Peers: [now:%u]", now_s);
c_list_for_each_entry (peer, &priv->peers_lst_head, peers_lst)
_peer_dump (self, LOGL_DEBUG, peer, "dump", now_s);
}
return G_SOURCE_REMOVE;
}
static void
schedule_peer_list_dump (NMDeviceWifiP2P *self)
{
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
if ( !priv->peer_dump_id
&& _LOGD_ENABLED (LOGD_WIFI_SCAN))
priv->peer_dump_id = g_timeout_add_seconds (1, peer_list_dump, self);
}
/*****************************************************************************/
static void
_set_is_waiting_for_supplicant (NMDeviceWifiP2P *self, gboolean is_waiting)
{
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
if (priv->is_waiting_for_supplicant == (!!is_waiting))
return;
priv->is_waiting_for_supplicant = is_waiting;
if (is_waiting)
nm_device_add_pending_action (NM_DEVICE (self), NM_PENDING_ACTION_WAITING_FOR_SUPPLICANT, TRUE);
else
nm_device_remove_pending_action (NM_DEVICE (self), NM_PENDING_ACTION_WAITING_FOR_SUPPLICANT, TRUE);
}
/*****************************************************************************/
static gboolean
check_connection_peer_joined (NMDeviceWifiP2P *device)
{
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (device);
NMConnection *conn = nm_device_get_applied_connection (NM_DEVICE (device));
NMWifiP2PPeer *peer;
const char* group;
const char * const * groups;
if (!conn || !priv->group_iface)
return FALSE;
/* Comparing the object path found on the group_iface with the peers
* found on the mgmt_iface is legal. */
group = nm_supplicant_interface_get_p2p_group_path (priv->group_iface);
if (!group)
return FALSE;
/* NOTE: We currently only support connections to a specific peer */
peer = nm_wifi_p2p_peers_find_first_compatible (&priv->peers_lst_head, conn);
if (!peer)
return FALSE;
groups = nm_wifi_p2p_peer_get_groups (peer);
if ( !groups
|| !g_strv_contains (groups, group))
return FALSE;
return TRUE;
}
static gboolean
disconnect_on_connection_peer_missing_cb (gpointer user_data)
{
NMDevice *device = NM_DEVICE (user_data);
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (device);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
_LOGW (LOGD_WIFI, "Peer requested in connection is missing for too long, failing connection.");
priv->peer_missing_id = 0;
nm_device_state_changed (device,
NM_DEVICE_STATE_FAILED,
NM_DEVICE_STATE_REASON_PEER_NOT_FOUND);
return FALSE;
}
static void
update_disconnect_on_connection_peer_missing (NMDeviceWifiP2P *self)
{
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
NMDeviceState state;
state = nm_device_get_state (NM_DEVICE (self));
if ( state < NM_DEVICE_STATE_IP_CONFIG
|| state > NM_DEVICE_STATE_ACTIVATED) {
nm_clear_g_source (&priv->peer_missing_id);
return;
}
if (check_connection_peer_joined (self)) {
if (nm_clear_g_source (&priv->peer_missing_id))
_LOGD (LOGD_WIFI, "Peer requested in connection is joined, removing timeout");
return;
}
if (priv->peer_missing_id == 0) {
_LOGD (LOGD_WIFI, "Peer requested in connection is missing, adding timeout");
priv->peer_missing_id = g_timeout_add_seconds (5, disconnect_on_connection_peer_missing_cb, self);
}
}
static gboolean
is_available (NMDevice *device, NMDeviceCheckDevAvailableFlags flags)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (device);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
NMSupplicantInterfaceState supplicant_state;
if (!priv->mgmt_iface)
return FALSE;
supplicant_state = nm_supplicant_interface_get_state (priv->mgmt_iface);
return nm_supplicant_interface_state_is_operational (supplicant_state);
}
static gboolean
check_connection_compatible (NMDevice *device, NMConnection *connection, GError **error)
{
if (!NM_DEVICE_CLASS (nm_device_wifi_p2p_parent_class)->check_connection_compatible (device, connection, error))
return FALSE;
/* TODO: Allow limitting the interface using the HW-address? */
/* We don't need to check anything else here. The P2P device will only
* exists if we are able to establish a P2P connection, and there should
* be no further restrictions necessary.
*/
return TRUE;
}
static gboolean
complete_connection (NMDevice *device,
NMConnection *connection,
const char *specific_object,
NMConnection *const*existing_connections,
GError **error)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (device);
gs_free char *setting_name = NULL;
NMSettingWifiP2P *s_wifi_p2p;
NMWifiP2PPeer *peer;
const char *setting_peer;
s_wifi_p2p = NM_SETTING_WIFI_P2P (nm_connection_get_setting (connection, NM_TYPE_SETTING_WIFI_P2P));
if (!specific_object) {
/* If not given a specific object, we need at minimum a peer address */
if (!s_wifi_p2p) {
g_set_error (error,
NM_DEVICE_ERROR,
NM_DEVICE_ERROR_INVALID_CONNECTION,
"A '%s' setting is required if no Peer path was given",
NM_SETTING_WIFI_P2P_SETTING_NAME);
return FALSE;
}
setting_peer = nm_setting_wifi_p2p_get_peer (s_wifi_p2p);
if (!setting_peer) {
g_set_error (error,
NM_DEVICE_ERROR,
NM_DEVICE_ERROR_INVALID_CONNECTION,
"A '%s' setting with a valid Peer is required if no Peer path was given",
NM_SETTING_WIFI_P2P_SETTING_NAME);
return FALSE;
}
} else {
peer = nm_wifi_p2p_peer_lookup_for_device (NM_DEVICE (self), specific_object);
if (!peer) {
g_set_error (error,
NM_DEVICE_ERROR,
NM_DEVICE_ERROR_SPECIFIC_OBJECT_NOT_FOUND,
"The P2P peer %s is unknown",
specific_object);
return FALSE;
}
setting_peer = nm_wifi_p2p_peer_get_address (peer);
g_return_val_if_fail (setting_peer, FALSE);
}
/* Add a Wi-Fi P2P setting if one doesn't exist yet */
if (!s_wifi_p2p) {
s_wifi_p2p = NM_SETTING_WIFI_P2P (nm_setting_wifi_p2p_new ());
nm_connection_add_setting (connection, NM_SETTING (s_wifi_p2p));
}
g_object_set (G_OBJECT (s_wifi_p2p), NM_SETTING_WIFI_P2P_PEER, setting_peer, NULL);
setting_name = g_strdup_printf ("Wi-Fi P2P Peer %s", setting_peer);
nm_utils_complete_generic (nm_device_get_platform (device),
connection,
NM_SETTING_WIFI_P2P_SETTING_NAME,
existing_connections,
setting_name,
setting_name,
NULL,
NULL,
TRUE);
return TRUE;
}
/*
* supplicant_find_timeout_cb
*
* Called when the supplicant has been unable to find the peer we want to connect to.
*/
static gboolean
supplicant_find_timeout_cb (gpointer user_data)
{
NMDevice *device = NM_DEVICE (user_data);
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (user_data);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
priv->find_peer_timeout_id = 0;
nm_supplicant_interface_p2p_cancel_connect (priv->mgmt_iface);
if (nm_device_is_activating (device)) {
_LOGW (LOGD_DEVICE | LOGD_WIFI,
"Activation: (wifi-p2p) could not find peer, failing activation");
nm_device_state_changed (device, NM_DEVICE_STATE_FAILED,
NM_DEVICE_STATE_REASON_PEER_NOT_FOUND);
}
return G_SOURCE_REMOVE;
}
static NMActStageReturn
act_stage1_prepare (NMDevice *device, NMDeviceStateReason *out_failure_reason)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (device);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
NMConnection *connection;
NMSettingWifiP2P *s_wifi_p2p;
NMWifiP2PPeer *peer;
if (!priv->mgmt_iface) {
NM_SET_OUT (out_failure_reason, NM_DEVICE_STATE_REASON_SUPPLICANT_FAILED);
return NM_ACT_STAGE_RETURN_FAILURE;
}
connection = nm_device_get_applied_connection (NM_DEVICE (self));
g_return_val_if_fail (connection, NM_ACT_STAGE_RETURN_FAILURE);
s_wifi_p2p = NM_SETTING_WIFI_P2P (nm_connection_get_setting (connection, NM_TYPE_SETTING_WIFI_P2P));
g_return_val_if_fail (s_wifi_p2p, NM_ACT_STAGE_RETURN_FAILURE);
peer = nm_wifi_p2p_peers_find_first_compatible (&priv->peers_lst_head, connection);
if (!peer) {
/* Set up a timeout on the find attempt and run a find for the same period of time */
if (priv->find_peer_timeout_id == 0) {
priv->find_peer_timeout_id = g_timeout_add_seconds (10,
supplicant_find_timeout_cb,
self);
nm_supplicant_interface_p2p_start_find (priv->mgmt_iface, 10);
}
return NM_ACT_STAGE_RETURN_POSTPONE;
}
return NM_ACT_STAGE_RETURN_SUCCESS;
}
/*
* supplicant_connection_timeout_cb
*
* Called when the supplicant has been unable to connect to a peer
* within a specified period of time.
*/
static gboolean
supplicant_connection_timeout_cb (gpointer user_data)
{
NMDevice *device = NM_DEVICE (user_data);
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (user_data);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
priv->sup_timeout_id = 0;
nm_supplicant_interface_p2p_cancel_connect (priv->mgmt_iface);
if (nm_device_is_activating (device)) {
_LOGW (LOGD_DEVICE | LOGD_WIFI,
"Activation: (wifi-p2p) connecting took too long, failing activation");
nm_device_state_changed (device, NM_DEVICE_STATE_FAILED,
NM_DEVICE_STATE_REASON_SUPPLICANT_TIMEOUT);
}
return G_SOURCE_REMOVE;
}
static NMActStageReturn
act_stage2_config (NMDevice *device, NMDeviceStateReason *out_failure_reason)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (device);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
NMConnection *connection;
NMSettingWifiP2P *s_wifi_p2p;
NMWifiP2PPeer *peer;
GBytes *wfd_ies;
if (nm_clear_g_source (&priv->find_peer_timeout_id))
nm_assert_not_reached ();
if (!priv->mgmt_iface) {
NM_SET_OUT (out_failure_reason, NM_DEVICE_STATE_REASON_SUPPLICANT_FAILED);
return NM_ACT_STAGE_RETURN_FAILURE;
}
connection = nm_device_get_applied_connection (device);
g_return_val_if_fail (connection, NM_ACT_STAGE_RETURN_FAILURE);
nm_assert (NM_IS_SETTING_WIFI_P2P (nm_connection_get_setting (connection, NM_TYPE_SETTING_WIFI_P2P)));
/* The prepare stage ensures that the peer has been found */
peer = nm_wifi_p2p_peers_find_first_compatible (&priv->peers_lst_head, connection);
if (!peer) {
NM_SET_OUT (out_failure_reason, NM_DEVICE_STATE_REASON_PEER_NOT_FOUND);
return NM_ACT_STAGE_RETURN_FAILURE;
}
/* Set the WFD IEs before trying to establish the connection. */
s_wifi_p2p = NM_SETTING_WIFI_P2P (nm_connection_get_setting (connection, NM_TYPE_SETTING_WIFI_P2P));
wfd_ies = nm_setting_wifi_p2p_get_wfd_ies (s_wifi_p2p);
nm_supplicant_manager_set_wfd_ies (priv->sup_mgr, wfd_ies);
/* TODO: Grab secrets if we don't have them yet! */
/* TODO: Fix "pbc" being hardcoded here! */
nm_supplicant_interface_p2p_connect (priv->mgmt_iface,
nm_wifi_p2p_peer_get_supplicant_path (peer),
"pbc",
NULL);
/* Set up a timeout on the connect attempt */
if (priv->sup_timeout_id == 0) {
priv->sup_timeout_id = g_timeout_add_seconds (45,
supplicant_connection_timeout_cb,
self);
}
/* We'll get stage3 started when the P2P group has been started */
return NM_ACT_STAGE_RETURN_POSTPONE;
}
/*****************************************************************************/
static void
emit_signal_p2p_peer_add_remove (NMDeviceWifiP2P *device,
NMWifiP2PPeer *peer,
gboolean is_added /* or else is_removed */)
{
nm_dbus_object_emit_signal (NM_DBUS_OBJECT (device),
&interface_info_device_wifi_p2p,
is_added
? &nm_signal_info_wifi_p2p_peer_added
: &nm_signal_info_wifi_p2p_peer_removed,
"(o)",
nm_dbus_object_get_path (NM_DBUS_OBJECT (peer)));
}
static void
peer_add_remove (NMDeviceWifiP2P *self,
gboolean is_adding, /* or else removing */
NMWifiP2PPeer *peer,
gboolean recheck_available_connections)
{
NMDevice *device = NM_DEVICE (self);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
if (is_adding) {
g_object_ref (peer);
peer->wifi_device = device;
c_list_link_tail (&priv->peers_lst_head, &peer->peers_lst);
nm_dbus_object_export (NM_DBUS_OBJECT (peer));
_peer_dump (self, LOGL_DEBUG, peer, "added", 0);
emit_signal_p2p_peer_add_remove (self, peer, TRUE);
} else {
peer->wifi_device = NULL;
c_list_unlink (&peer->peers_lst);
_peer_dump (self, LOGL_DEBUG, peer, "removed", 0);
}
_notify (self, PROP_PEERS);
if (!is_adding) {
emit_signal_p2p_peer_add_remove (self, peer, FALSE);
nm_dbus_object_clear_and_unexport (&peer);
}
if (is_adding) {
/* If we are in prepare state, then we are currently runnign a find
* to search for the requested peer. */
if (priv->find_peer_timeout_id != 0) {
NMConnection *connection;
nm_assert (nm_device_get_state (device) == NM_DEVICE_STATE_PREPARE);
connection = nm_device_get_applied_connection (device);
nm_assert (NM_IS_CONNECTION (connection));
peer = nm_wifi_p2p_peers_find_first_compatible (&priv->peers_lst_head, connection);
if (peer) {
/* A peer for the connection was found, cancel the timeout and go to configure state. */
nm_clear_g_source (&priv->find_peer_timeout_id);
nm_device_activate_schedule_stage1_device_prepare (device, FALSE);
}
}
/* TODO: We may want to re-check auto-activation here, otherwise it will never work. */
}
update_disconnect_on_connection_peer_missing (self);
}
static void
remove_all_peers (NMDeviceWifiP2P *self)
{
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
NMWifiP2PPeer *peer;
if (c_list_is_empty (&priv->peers_lst_head))
return;
while ((peer = c_list_first_entry (&priv->peers_lst_head, NMWifiP2PPeer, peers_lst)))
peer_add_remove (self, FALSE, peer, FALSE);
nm_device_recheck_available_connections (NM_DEVICE (self));
}
/*****************************************************************************/
static NMActStageReturn
act_stage3_ip_config_start (NMDevice *device,
int addr_family,
gpointer *out_config,
NMDeviceStateReason *out_failure_reason)
{
gboolean indicate_addressing_running;
NMConnection *connection;
const char *method;
connection = nm_device_get_applied_connection (device);
method = nm_utils_get_ip_config_method (connection, addr_family);
if (addr_family == AF_INET)
indicate_addressing_running = NM_IN_STRSET (method, NM_SETTING_IP4_CONFIG_METHOD_AUTO);
else {
indicate_addressing_running = NM_IN_STRSET (method, NM_SETTING_IP6_CONFIG_METHOD_AUTO,
NM_SETTING_IP6_CONFIG_METHOD_DHCP);
}
if (indicate_addressing_running)
nm_platform_wifi_indicate_addressing_running (nm_device_get_platform (device), nm_device_get_ip_ifindex (device), TRUE);
return NM_DEVICE_CLASS (nm_device_wifi_p2p_parent_class)->act_stage3_ip_config_start (device, addr_family, out_config, out_failure_reason);
}
static void
deactivate (NMDevice *device)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (device);
int ifindex = nm_device_get_ip_ifindex (device);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
nm_clear_g_source (&priv->find_peer_timeout_id);
nm_clear_g_source (&priv->sup_timeout_id);
nm_clear_g_source (&priv->peer_missing_id);
if (priv->mgmt_iface)
nm_supplicant_interface_p2p_cancel_connect (priv->mgmt_iface);
if (priv->group_iface)
nm_supplicant_interface_p2p_disconnect (priv->group_iface);
/* Clear any critical protocol notification in the Wi-Fi stack */
if (ifindex > 0)
nm_platform_wifi_indicate_addressing_running (nm_device_get_platform (device), ifindex, FALSE);
}
static guint32
get_configured_mtu (NMDevice *device,
NMDeviceMtuSource *out_source,
gboolean *out_force)
{
*out_source = NM_DEVICE_MTU_SOURCE_NONE;
return 0;
}
static const char *
get_auto_ip_config_method (NMDevice *device, int addr_family)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (device);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
/* Override the AUTO method to mean shared if we are group owner. */
if ( priv->group_iface
&& nm_supplicant_interface_get_p2p_group_owner (priv->group_iface)) {
if (addr_family == AF_INET)
return NM_SETTING_IP4_CONFIG_METHOD_SHARED;
if (addr_family == AF_INET6)
return NM_SETTING_IP6_CONFIG_METHOD_SHARED;
}
return NULL;
}
static gboolean
unmanaged_on_quit (NMDevice *self)
{
return TRUE;
}
static void
supplicant_iface_state_cb (NMSupplicantInterface *iface,
int new_state_i,
int old_state_i,
int disconnect_reason,
gpointer user_data)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (user_data);
NMDevice *device = NM_DEVICE (self);
NMSupplicantInterfaceState new_state = new_state_i;
NMSupplicantInterfaceState old_state = old_state_i;
_LOGI (LOGD_DEVICE | LOGD_WIFI,
"supplicant management interface state: %s -> %s",
nm_supplicant_interface_state_to_string (old_state),
nm_supplicant_interface_state_to_string (new_state));
if (new_state == NM_SUPPLICANT_INTERFACE_STATE_DOWN) {
supplicant_interfaces_release (self, TRUE);
nm_device_queue_recheck_available (device,
NM_DEVICE_STATE_REASON_SUPPLICANT_AVAILABLE,
NM_DEVICE_STATE_REASON_SUPPLICANT_FAILED);
return;
}
if (old_state == NM_SUPPLICANT_INTERFACE_STATE_STARTING) {
_LOGD (LOGD_WIFI, "supplicant ready");
nm_device_queue_recheck_available (device,
NM_DEVICE_STATE_REASON_SUPPLICANT_AVAILABLE,
NM_DEVICE_STATE_REASON_SUPPLICANT_FAILED);
_set_is_waiting_for_supplicant (self, FALSE);
}
}
static void
supplicant_iface_peer_changed_cb (NMSupplicantInterface *iface,
NMSupplicantPeerInfo *peer_info,
gboolean is_present,
NMDeviceWifiP2P *self)
{
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
NMWifiP2PPeer *found_peer;
found_peer = nm_wifi_p2p_peers_find_by_supplicant_path (&priv->peers_lst_head, peer_info->peer_path->str);
if (!is_present) {
if (!found_peer)
return;
peer_add_remove (self, FALSE, found_peer, TRUE);
goto out;
}
if (found_peer) {
if (!nm_wifi_p2p_peer_update_from_properties (found_peer, peer_info))
return;
update_disconnect_on_connection_peer_missing (self);
_peer_dump (self, LOGL_DEBUG, found_peer, "updated", 0);
} else {
gs_unref_object NMWifiP2PPeer *peer = NULL;
peer = nm_wifi_p2p_peer_new_from_properties (peer_info);
peer_add_remove (self, TRUE, peer, TRUE);
}
out:
schedule_peer_list_dump (self);
}
static void
check_group_iface_ready (NMDeviceWifiP2P *self)
{
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);;
if (!priv->group_iface)
return;
if (!nm_supplicant_interface_state_is_operational (nm_supplicant_interface_get_state (priv->group_iface)))
return;
if (!nm_supplicant_interface_get_p2p_group_joined (priv->group_iface))
return;
nm_clear_g_source (&priv->sup_timeout_id);
update_disconnect_on_connection_peer_missing (self);
nm_device_activate_schedule_stage3_ip_config_start (NM_DEVICE (self));
}
static void
supplicant_group_iface_is_ready (NMDeviceWifiP2P *self)
{
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
_LOGD (LOGD_WIFI, "P2P Group supplicant ready");
if (!nm_device_set_ip_iface (NM_DEVICE (self), nm_supplicant_interface_get_ifname (priv->group_iface))) {
nm_device_state_changed (NM_DEVICE (self),
NM_DEVICE_STATE_FAILED,
NM_DEVICE_STATE_REASON_SUPPLICANT_FAILED);
return;
}
_set_is_waiting_for_supplicant (self, FALSE);
check_group_iface_ready (self);
}
static void
supplicant_group_iface_state_cb (NMSupplicantInterface *iface,
int new_state_i,
int old_state_i,
int disconnect_reason,
gpointer user_data)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (user_data);
NMSupplicantInterfaceState new_state = new_state_i;
NMSupplicantInterfaceState old_state = old_state_i;
_LOGI (LOGD_DEVICE | LOGD_WIFI,
"P2P Group supplicant interface state: %s -> %s",
nm_supplicant_interface_state_to_string (old_state),
nm_supplicant_interface_state_to_string (new_state));
if (new_state == NM_SUPPLICANT_INTERFACE_STATE_DOWN) {
supplicant_group_interface_release (self);
nm_device_state_changed (NM_DEVICE (self),
NM_DEVICE_STATE_DISCONNECTED,
NM_DEVICE_STATE_REASON_SUPPLICANT_DISCONNECT);
return;
}
if (old_state == NM_SUPPLICANT_INTERFACE_STATE_STARTING) {
supplicant_group_iface_is_ready (self);
return;
}
}
static void
supplicant_group_iface_group_finished_cb (NMSupplicantInterface *iface,
const char *iface_path,
void *user_data)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (user_data);
supplicant_group_interface_release (self);
nm_device_state_changed (NM_DEVICE (self),
NM_DEVICE_STATE_DISCONNECTED,
NM_DEVICE_STATE_REASON_SUPPLICANT_DISCONNECT);
}
static void
supplicant_iface_group_joined_updated_cb (NMSupplicantInterface *iface,
GParamSpec *pspec,
void *user_data)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (user_data);
check_group_iface_ready (self);
}
static void
supplicant_iface_group_started_cb (NMSupplicantInterface *iface,
NMSupplicantInterface *group_iface,
NMDeviceWifiP2P *self)
{
NMDeviceWifiP2PPrivate *priv;
NMSupplicantInterfaceState state;
g_return_if_fail (self);
if (!nm_device_is_activating (NM_DEVICE (self))) {
_LOGW (LOGD_DEVICE | LOGD_WIFI, "P2P: WPA supplicant notified a group start but we are not trying to connect! Ignoring the event.");
return;
}
priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
supplicant_group_interface_release (self);
priv->group_iface = g_object_ref (group_iface);
/* We need to wait for the interface to be ready and the group
* information to be resolved. */
g_signal_connect (priv->group_iface,
"notify::" NM_SUPPLICANT_INTERFACE_P2P_GROUP_JOINED,
G_CALLBACK (supplicant_iface_group_joined_updated_cb),
self);
g_signal_connect (priv->group_iface,
NM_SUPPLICANT_INTERFACE_STATE,
G_CALLBACK (supplicant_group_iface_state_cb),
self);
g_signal_connect (priv->group_iface, NM_SUPPLICANT_INTERFACE_GROUP_FINISHED,
G_CALLBACK (supplicant_group_iface_group_finished_cb),
self);
state = nm_supplicant_interface_get_state (priv->group_iface);
if (state == NM_SUPPLICANT_INTERFACE_STATE_STARTING) {
_set_is_waiting_for_supplicant (self, TRUE);
return;
}
supplicant_group_iface_is_ready (self);
}
static void
supplicant_group_interface_release (NMDeviceWifiP2P *self)
{
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
if (!priv->group_iface)
return;
g_signal_handlers_disconnect_by_data (priv->group_iface, self);
nm_supplicant_interface_p2p_disconnect (priv->group_iface);
g_clear_object (&priv->group_iface);
}
static void
supplicant_interfaces_release (NMDeviceWifiP2P *self, gboolean set_is_waiting)
{
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
nm_clear_g_source (&priv->peer_dump_id);
remove_all_peers (self);
if (priv->mgmt_iface) {
_LOGD (LOGD_DEVICE | LOGD_WIFI, "P2P: Releasing WPA supplicant interface.");
nm_supplicant_manager_set_wfd_ies (priv->sup_mgr, NULL);
g_signal_handlers_disconnect_by_data (priv->mgmt_iface, self);
g_clear_object (&priv->mgmt_iface);
nm_clear_g_source (&priv->find_peer_timeout_id);
nm_clear_g_source (&priv->sup_timeout_id);
}
supplicant_group_interface_release (self);
if (set_is_waiting)
_set_is_waiting_for_supplicant (self, TRUE);
}
static void
device_state_changed (NMDevice *device,
NMDeviceState new_state,
NMDeviceState old_state,
NMDeviceStateReason reason)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (device);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
update_disconnect_on_connection_peer_missing (self);
if (new_state <= NM_DEVICE_STATE_UNAVAILABLE) {
/* Clean up the supplicant interface because in these states the
* device cannot be used.
* Do not clean up for the UNMANAGED to UNAVAILABLE transition which
* will happen during initialization.
*/
if (priv->mgmt_iface && old_state > new_state)
supplicant_interfaces_release (self, TRUE);
/* TODO: More cleanup needed? */
}
switch (new_state) {
case NM_DEVICE_STATE_UNMANAGED:
break;
case NM_DEVICE_STATE_UNAVAILABLE:
if ( !priv->mgmt_iface
|| !nm_supplicant_interface_state_is_operational (nm_supplicant_interface_get_state (priv->mgmt_iface)))
_set_is_waiting_for_supplicant (self, TRUE);
break;
case NM_DEVICE_STATE_NEED_AUTH:
/* Disconnect? */
break;
case NM_DEVICE_STATE_IP_CHECK:
/* Clear any critical protocol notification in the wifi stack */
nm_platform_wifi_indicate_addressing_running (nm_device_get_platform (device), nm_device_get_ip_ifindex (device), FALSE);
break;
case NM_DEVICE_STATE_ACTIVATED:
//activation_success_handler (device);
break;
case NM_DEVICE_STATE_FAILED:
/* Clear any critical protocol notification in the wifi stack.
* At this point the IP device may have been removed already. */
nm_supplicant_manager_set_wfd_ies (priv->sup_mgr, NULL);
if (nm_device_get_ip_ifindex (device) > 0)
nm_platform_wifi_indicate_addressing_running (nm_device_get_platform (device), nm_device_get_ip_ifindex (device), FALSE);
break;
case NM_DEVICE_STATE_DISCONNECTED:
nm_supplicant_manager_set_wfd_ies (priv->sup_mgr, NULL);
break;
default:
break;
}
}
static void
impl_device_wifi_p2p_start_find (NMDBusObject *obj,
const NMDBusInterfaceInfoExtended *interface_info,
const NMDBusMethodInfoExtended *method_info,
GDBusConnection *connection,
const char *sender,
GDBusMethodInvocation *invocation,
GVariant *parameters)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (obj);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
gs_unref_variant GVariant *options = NULL;
const char *opts_key;
GVariant *opts_val;
GVariantIter iter;
gint32 timeout = 30;
g_variant_get (parameters, "(@a{sv})", &options);
g_variant_iter_init (&iter, options);
while (g_variant_iter_next (&iter, "{&sv}", &opts_key, &opts_val)) {
_nm_unused gs_unref_variant GVariant *opts_val_free = opts_val;
if (nm_streq (opts_key, "timeout")) {
if (!g_variant_is_of_type (opts_val, G_VARIANT_TYPE_INT32)) {
g_dbus_method_invocation_return_error_literal (invocation,
NM_DEVICE_ERROR,
NM_DEVICE_ERROR_INVALID_ARGUMENT,
"\"timeout\" must be an integer \"i\"");
return;
}
timeout = g_variant_get_int32 (opts_val);
if (timeout <= 0 || timeout > 600) {
g_dbus_method_invocation_return_error_literal (invocation,
NM_DEVICE_ERROR,
NM_DEVICE_ERROR_NOT_ALLOWED,
"The timeout for a find operation needs to be in the range of 1-600s.");
return;
}
continue;
}
g_dbus_method_invocation_return_error (invocation,
NM_DEVICE_ERROR,
NM_DEVICE_ERROR_INVALID_ARGUMENT,
"Unsupported options key \"%s\"",
opts_key);
return;
}
if (!priv->mgmt_iface) {
g_dbus_method_invocation_return_error_literal (invocation,
NM_DEVICE_ERROR,
NM_DEVICE_ERROR_NOT_ACTIVE,
"WPA Supplicant management interface is currently unavailable.");
return;
}
nm_supplicant_interface_p2p_start_find (priv->mgmt_iface, timeout);
g_dbus_method_invocation_return_value (invocation, NULL);
}
static void
impl_device_wifi_p2p_stop_find (NMDBusObject *obj,
const NMDBusInterfaceInfoExtended *interface_info,
const NMDBusMethodInfoExtended *method_info,
GDBusConnection *connection,
const char *sender,
GDBusMethodInvocation *invocation,
GVariant *parameters)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (obj);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
if (!priv->mgmt_iface) {
g_dbus_method_invocation_return_error_literal (invocation,
NM_DEVICE_ERROR,
NM_DEVICE_ERROR_NOT_ACTIVE,
"WPA Supplicant management interface is currently unavailable.");
return;
}
nm_supplicant_interface_p2p_stop_find (priv->mgmt_iface);
g_dbus_method_invocation_return_value (invocation, NULL);
}
/*****************************************************************************/
NMSupplicantInterface *
nm_device_wifi_p2p_get_mgmt_iface (NMDeviceWifiP2P *self)
{
g_return_val_if_fail (NM_IS_DEVICE_WIFI_P2P (self), NULL);
return NM_DEVICE_WIFI_P2P_GET_PRIVATE (self)->mgmt_iface;
}
void
nm_device_wifi_p2p_set_mgmt_iface (NMDeviceWifiP2P *self,
NMSupplicantInterface *iface)
{
NMDeviceWifiP2PPrivate *priv;
g_return_if_fail (NM_IS_DEVICE_WIFI_P2P (self));
g_return_if_fail (!iface || NM_IS_SUPPLICANT_INTERFACE (iface));
priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
if (priv->mgmt_iface == iface)
goto done;
supplicant_interfaces_release (self, FALSE);
if (!iface)
goto done;
_LOGD (LOGD_DEVICE | LOGD_WIFI, "P2P: WPA supplicant management interface changed to %s.",
nm_ref_string_get_str (nm_supplicant_interface_get_object_path (iface)));
priv->mgmt_iface = g_object_ref (iface);
g_signal_connect (priv->mgmt_iface,
NM_SUPPLICANT_INTERFACE_STATE,
G_CALLBACK (supplicant_iface_state_cb),
self);
g_signal_connect (priv->mgmt_iface,
NM_SUPPLICANT_INTERFACE_PEER_CHANGED,
G_CALLBACK (supplicant_iface_peer_changed_cb),
self);
g_signal_connect (priv->mgmt_iface,
NM_SUPPLICANT_INTERFACE_GROUP_STARTED,
G_CALLBACK (supplicant_iface_group_started_cb),
self);
done:
nm_device_queue_recheck_available (NM_DEVICE (self),
NM_DEVICE_STATE_REASON_SUPPLICANT_AVAILABLE,
NM_DEVICE_STATE_REASON_SUPPLICANT_FAILED);
_set_is_waiting_for_supplicant (self,
!priv->mgmt_iface
|| !nm_supplicant_interface_state_is_operational (nm_supplicant_interface_get_state (priv->mgmt_iface)));
}
void
nm_device_wifi_p2p_remove (NMDeviceWifiP2P* self)
{
g_signal_emit_by_name (self, NM_DEVICE_REMOVED);
}
/*****************************************************************************/
static const char *
get_type_description (NMDevice *device)
{
return "wifi-p2p";
}
/*****************************************************************************/
static const GDBusSignalInfo nm_signal_info_wifi_p2p_peer_added = NM_DEFINE_GDBUS_SIGNAL_INFO_INIT (
"PeerAdded",
.args = NM_DEFINE_GDBUS_ARG_INFOS (
NM_DEFINE_GDBUS_ARG_INFO ("peer", "o"),
),
);
static const GDBusSignalInfo nm_signal_info_wifi_p2p_peer_removed = NM_DEFINE_GDBUS_SIGNAL_INFO_INIT (
"PeerRemoved",
.args = NM_DEFINE_GDBUS_ARG_INFOS (
NM_DEFINE_GDBUS_ARG_INFO ("peer", "o"),
),
);
static const NMDBusInterfaceInfoExtended interface_info_device_wifi_p2p = {
.parent = NM_DEFINE_GDBUS_INTERFACE_INFO_INIT (
NM_DBUS_INTERFACE_DEVICE_WIFI_P2P,
.methods = NM_DEFINE_GDBUS_METHOD_INFOS (
NM_DEFINE_DBUS_METHOD_INFO_EXTENDED (
NM_DEFINE_GDBUS_METHOD_INFO_INIT (
"StartFind",
.in_args = NM_DEFINE_GDBUS_ARG_INFOS (
NM_DEFINE_GDBUS_ARG_INFO ("options", "a{sv}"),
),
),
.handle = impl_device_wifi_p2p_start_find,
),
NM_DEFINE_DBUS_METHOD_INFO_EXTENDED (
NM_DEFINE_GDBUS_METHOD_INFO_INIT (
"StopFind",
),
.handle = impl_device_wifi_p2p_stop_find,
),
),
.signals = NM_DEFINE_GDBUS_SIGNAL_INFOS (
&nm_signal_info_wifi_p2p_peer_added,
&nm_signal_info_wifi_p2p_peer_removed,
),
.properties = NM_DEFINE_GDBUS_PROPERTY_INFOS (
NM_DEFINE_DBUS_PROPERTY_INFO_EXTENDED_READABLE ("HwAddress", "s", NM_DEVICE_HW_ADDRESS),
NM_DEFINE_DBUS_PROPERTY_INFO_EXTENDED_READABLE ("Peers", "ao", NM_DEVICE_WIFI_P2P_PEERS),
),
),
.legacy_property_changed = FALSE,
};
/*****************************************************************************/
static void
get_property (GObject *object, guint prop_id,
GValue *value, GParamSpec *pspec)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (object);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
const char **list;
switch (prop_id) {
case PROP_PEERS:
list = nm_wifi_p2p_peers_get_paths (&priv->peers_lst_head);
g_value_take_boxed (value, nm_utils_strv_make_deep_copied (list));
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
}
}
/*****************************************************************************/
static void
nm_device_wifi_p2p_init (NMDeviceWifiP2P * self)
{
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (self);
c_list_init (&priv->peers_lst_head);
priv->sup_mgr = g_object_ref (nm_supplicant_manager_get ());
}
static void
constructed (GObject *object)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (object);
G_OBJECT_CLASS (nm_device_wifi_p2p_parent_class)->constructed (object);
_set_is_waiting_for_supplicant (self, TRUE);
}
NMDeviceWifiP2P *
nm_device_wifi_p2p_new (const char *iface)
{
return g_object_new (NM_TYPE_DEVICE_WIFI_P2P,
NM_DEVICE_IFACE, iface,
NM_DEVICE_TYPE_DESC, "802.11 Wi-Fi P2P",
NM_DEVICE_DEVICE_TYPE, NM_DEVICE_TYPE_WIFI_P2P,
NM_DEVICE_LINK_TYPE, NM_LINK_TYPE_WIFI,
NM_DEVICE_RFKILL_TYPE, RFKILL_TYPE_WLAN,
NULL);
}
static void
dispose (GObject *object)
{
NMDeviceWifiP2P *self = NM_DEVICE_WIFI_P2P (object);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (object);
g_clear_object (&priv->sup_mgr);
supplicant_interfaces_release (self, FALSE);
G_OBJECT_CLASS (nm_device_wifi_p2p_parent_class)->dispose (object);
}
static void
finalize (GObject *object)
{
NMDeviceWifiP2P *peer = NM_DEVICE_WIFI_P2P (object);
NMDeviceWifiP2PPrivate *priv = NM_DEVICE_WIFI_P2P_GET_PRIVATE (peer);
nm_assert (c_list_is_empty (&priv->peers_lst_head));
G_OBJECT_CLASS (nm_device_wifi_p2p_parent_class)->finalize (object);
}
static void
nm_device_wifi_p2p_class_init (NMDeviceWifiP2PClass *klass)
{
GObjectClass *object_class = G_OBJECT_CLASS (klass);
NMDBusObjectClass *dbus_object_class = NM_DBUS_OBJECT_CLASS (klass);
NMDeviceClass *device_class = NM_DEVICE_CLASS (klass);
object_class->constructed = constructed;
object_class->get_property = get_property;
object_class->dispose = dispose;
object_class->finalize = finalize;
dbus_object_class->interface_infos = NM_DBUS_INTERFACE_INFOS (&interface_info_device_wifi_p2p);
device_class->connection_type_supported = NM_SETTING_WIFI_P2P_SETTING_NAME;
device_class->connection_type_check_compatible = NM_SETTING_WIFI_P2P_SETTING_NAME;
device_class->link_types = NM_DEVICE_DEFINE_LINK_TYPES (NM_LINK_TYPE_WIFI_P2P);
device_class->get_type_description = get_type_description;
/* Do we need compatibility checking or is the default good enough? */
device_class->is_available = is_available;
device_class->check_connection_compatible = check_connection_compatible;
device_class->complete_connection = complete_connection;
device_class->act_stage1_prepare = act_stage1_prepare;
device_class->act_stage2_config = act_stage2_config;
device_class->get_configured_mtu = get_configured_mtu;
device_class->get_auto_ip_config_method = get_auto_ip_config_method;
device_class->act_stage3_ip_config_start = act_stage3_ip_config_start;
device_class->deactivate = deactivate;
device_class->unmanaged_on_quit = unmanaged_on_quit;
device_class->state_changed = device_state_changed;
obj_properties[PROP_PEERS] =
g_param_spec_boxed (NM_DEVICE_WIFI_P2P_PEERS, "", "",
G_TYPE_STRV,
G_PARAM_READABLE |
G_PARAM_STATIC_STRINGS);
g_object_class_install_properties (object_class, _PROPERTY_ENUMS_LAST, obj_properties);
}