|
Packit Service |
87a54e |
/* SPDX-License-Identifier: GPL-2.0-or-later */
|
|
Packit |
5756e2 |
/*
|
|
Packit |
5756e2 |
* Copyright (C) 2016 Red Hat, Inc.
|
|
Packit |
5756e2 |
*/
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
#include "nm-default.h"
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
#include "nm-checkpoint.h"
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
#include "nm-active-connection.h"
|
|
Packit |
5756e2 |
#include "nm-act-request.h"
|
|
Packit |
5756e2 |
#include "nm-libnm-core-intern/nm-auth-subject.h"
|
|
Packit |
5756e2 |
#include "nm-core-utils.h"
|
|
Packit |
5756e2 |
#include "nm-dbus-interface.h"
|
|
Packit |
5756e2 |
#include "devices/nm-device.h"
|
|
Packit |
5756e2 |
#include "nm-manager.h"
|
|
Packit |
5756e2 |
#include "settings/nm-settings.h"
|
|
Packit |
5756e2 |
#include "settings/nm-settings-connection.h"
|
|
Packit |
5756e2 |
#include "nm-simple-connection.h"
|
|
Packit |
5756e2 |
#include "nm-utils.h"
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
/*****************************************************************************/
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
typedef struct {
|
|
Packit Service |
a1bd4f |
char * original_dev_path;
|
|
Packit Service |
a1bd4f |
char * original_dev_name;
|
|
Packit Service |
a1bd4f |
NMDeviceType dev_type;
|
|
Packit Service |
a1bd4f |
NMDevice * device;
|
|
Packit Service |
a1bd4f |
NMConnection * applied_connection;
|
|
Packit Service |
a1bd4f |
NMConnection * settings_connection;
|
|
Packit Service |
a1bd4f |
guint64 ac_version_id;
|
|
Packit Service |
a1bd4f |
NMDeviceState state;
|
|
Packit Service |
a1bd4f |
bool is_software : 1;
|
|
Packit Service |
a1bd4f |
bool realized : 1;
|
|
Packit Service |
a1bd4f |
bool activation_lifetime_bound_to_profile_visibility : 1;
|
|
Packit Service |
a1bd4f |
NMUnmanFlagOp unmanaged_explicit;
|
|
Packit Service |
a1bd4f |
NMActivationReason activation_reason;
|
|
Packit Service |
a1bd4f |
gulong dev_exported_change_id;
|
|
Packit |
5756e2 |
} DeviceCheckpoint;
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
NM_GOBJECT_PROPERTIES_DEFINE(NMCheckpoint, PROP_DEVICES, PROP_CREATED, PROP_ROLLBACK_TIMEOUT, );
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
struct _NMCheckpointPrivate {
|
|
Packit Service |
a1bd4f |
/* properties */
|
|
Packit Service |
a1bd4f |
GHashTable *devices;
|
|
Packit Service |
a1bd4f |
GPtrArray * removed_devices;
|
|
Packit Service |
a1bd4f |
gint64 created_at_ms;
|
|
Packit Service |
a1bd4f |
guint32 rollback_timeout_s;
|
|
Packit Service |
a1bd4f |
guint timeout_id;
|
|
Packit Service |
a1bd4f |
/* private members */
|
|
Packit Service |
a1bd4f |
NMManager * manager;
|
|
Packit Service |
a1bd4f |
NMCheckpointCreateFlags flags;
|
|
Packit Service |
a1bd4f |
GHashTable * connection_uuids;
|
|
Packit Service |
a1bd4f |
gulong dev_removed_id;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
NMCheckpointTimeoutCallback timeout_cb;
|
|
Packit Service |
a1bd4f |
gpointer timeout_data;
|
|
Packit |
5756e2 |
};
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
struct _NMCheckpointClass {
|
|
Packit Service |
a1bd4f |
NMDBusObjectClass parent;
|
|
Packit |
5756e2 |
};
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
G_DEFINE_TYPE(NMCheckpoint, nm_checkpoint, NM_TYPE_DBUS_OBJECT)
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
#define NM_CHECKPOINT_GET_PRIVATE(self) _NM_GET_PRIVATE_PTR(self, NMCheckpoint, NM_IS_CHECKPOINT)
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
/*****************************************************************************/
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
#define _NMLOG_PREFIX_NAME "checkpoint"
|
|
Packit Service |
a1bd4f |
#define _NMLOG_DOMAIN LOGD_CORE
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
#define _NMLOG(level, ...) \
|
|
Packit Service |
a1bd4f |
G_STMT_START \
|
|
Packit Service |
a1bd4f |
{ \
|
|
Packit Service |
a1bd4f |
if (nm_logging_enabled(level, _NMLOG_DOMAIN)) { \
|
|
Packit Service |
a1bd4f |
char __prefix[32]; \
|
|
Packit Service |
a1bd4f |
\
|
|
Packit Service |
a1bd4f |
if (self) \
|
|
Packit Service |
a1bd4f |
g_snprintf(__prefix, \
|
|
Packit Service |
a1bd4f |
sizeof(__prefix), \
|
|
Packit Service |
a1bd4f |
"%s[%p]", \
|
|
Packit Service |
a1bd4f |
""_NMLOG_PREFIX_NAME \
|
|
Packit Service |
a1bd4f |
"", \
|
|
Packit Service |
a1bd4f |
(self)); \
|
|
Packit Service |
a1bd4f |
else \
|
|
Packit Service |
a1bd4f |
g_strlcpy(__prefix, _NMLOG_PREFIX_NAME, sizeof(__prefix)); \
|
|
Packit Service |
a1bd4f |
_nm_log((level), \
|
|
Packit Service |
a1bd4f |
(_NMLOG_DOMAIN), \
|
|
Packit Service |
a1bd4f |
0, \
|
|
Packit Service |
a1bd4f |
NULL, \
|
|
Packit Service |
a1bd4f |
NULL, \
|
|
Packit Service |
a1bd4f |
"%s: " _NM_UTILS_MACRO_FIRST(__VA_ARGS__), \
|
|
Packit Service |
a1bd4f |
__prefix _NM_UTILS_MACRO_REST(__VA_ARGS__)); \
|
|
Packit Service |
a1bd4f |
} \
|
|
Packit Service |
a1bd4f |
} \
|
|
Packit Service |
a1bd4f |
G_STMT_END
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
/*****************************************************************************/
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
void
|
|
Packit Service |
a1bd4f |
nm_checkpoint_log_destroy(NMCheckpoint *self)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
_LOGI("destroy %s", nm_dbus_object_get_path(NM_DBUS_OBJECT(self)));
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
void
|
|
Packit Service |
a1bd4f |
nm_checkpoint_set_timeout_callback(NMCheckpoint * self,
|
|
Packit Service |
a1bd4f |
NMCheckpointTimeoutCallback callback,
|
|
Packit Service |
a1bd4f |
gpointer user_data)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate *priv = NM_CHECKPOINT_GET_PRIVATE(self);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
/* in glib world, we would have a GSignal for this. But as there
|
|
Packit Service |
a1bd4f |
* is only one subscriber, it's simpler to just set and unset(!)
|
|
Packit Service |
a1bd4f |
* the callback this way. */
|
|
Packit Service |
a1bd4f |
priv->timeout_cb = callback;
|
|
Packit Service |
a1bd4f |
priv->timeout_data = user_data;
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
NMDevice *
|
|
Packit Service |
a1bd4f |
nm_checkpoint_includes_devices(NMCheckpoint *self, NMDevice *const *devices, guint n_devices)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate *priv = NM_CHECKPOINT_GET_PRIVATE(self);
|
|
Packit Service |
a1bd4f |
guint i;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
for (i = 0; i < n_devices; i++) {
|
|
Packit Service |
a1bd4f |
if (g_hash_table_contains(priv->devices, devices[i]))
|
|
Packit Service |
a1bd4f |
return devices[i];
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
return NULL;
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
NMDevice *
|
|
Packit Service |
a1bd4f |
nm_checkpoint_includes_devices_of(NMCheckpoint *self, NMCheckpoint *cp_for_devices)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate *priv = NM_CHECKPOINT_GET_PRIVATE(self);
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate *priv2 = NM_CHECKPOINT_GET_PRIVATE(cp_for_devices);
|
|
Packit Service |
a1bd4f |
GHashTableIter iter;
|
|
Packit Service |
a1bd4f |
NMDevice * device;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
g_hash_table_iter_init(&iter, priv2->devices);
|
|
Packit Service |
a1bd4f |
while (g_hash_table_iter_next(&iter, (gpointer *) &device, NULL)) {
|
|
Packit Service |
a1bd4f |
if (g_hash_table_contains(priv->devices, device))
|
|
Packit Service |
a1bd4f |
return device;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
return NULL;
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static NMSettingsConnection *
|
|
Packit Service |
a1bd4f |
find_settings_connection(NMCheckpoint * self,
|
|
Packit Service |
a1bd4f |
DeviceCheckpoint *dev_checkpoint,
|
|
Packit Service |
a1bd4f |
gboolean * need_update,
|
|
Packit Service |
a1bd4f |
gboolean * need_activation)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate * priv = NM_CHECKPOINT_GET_PRIVATE(self);
|
|
Packit Service |
a1bd4f |
NMActiveConnection * active;
|
|
Packit Service |
a1bd4f |
NMSettingsConnection *sett_conn;
|
|
Packit Service |
a1bd4f |
const char * uuid, *ac_uuid;
|
|
Packit Service |
a1bd4f |
const CList * tmp_clist;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
*need_activation = FALSE;
|
|
Packit Service |
a1bd4f |
*need_update = FALSE;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
uuid = nm_connection_get_uuid(dev_checkpoint->settings_connection);
|
|
Packit Service |
a1bd4f |
sett_conn = nm_settings_get_connection_by_uuid(NM_SETTINGS_GET, uuid);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (!sett_conn)
|
|
Packit Service |
a1bd4f |
return NULL;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
/* Now check if the connection changed, ... */
|
|
Packit Service |
a1bd4f |
if (!nm_connection_compare(dev_checkpoint->settings_connection,
|
|
Packit Service |
a1bd4f |
nm_settings_connection_get_connection(sett_conn),
|
|
Packit Service |
a1bd4f |
NM_SETTING_COMPARE_FLAG_EXACT)) {
|
|
Packit Service |
a1bd4f |
_LOGT("rollback: settings connection %s changed", uuid);
|
|
Packit Service |
a1bd4f |
*need_update = TRUE;
|
|
Packit Service |
a1bd4f |
*need_activation = TRUE;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
/* ... is active, ... */
|
|
Packit Service |
a1bd4f |
nm_manager_for_each_active_connection (priv->manager, active, tmp_clist) {
|
|
Packit Service |
a1bd4f |
ac_uuid =
|
|
Packit Service |
a1bd4f |
nm_settings_connection_get_uuid(nm_active_connection_get_settings_connection(active));
|
|
Packit Service |
a1bd4f |
if (nm_streq(uuid, ac_uuid)) {
|
|
Packit Service |
a1bd4f |
_LOGT("rollback: connection %s is active", uuid);
|
|
Packit Service |
a1bd4f |
break;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (!active) {
|
|
Packit Service |
a1bd4f |
_LOGT("rollback: connection %s is not active", uuid);
|
|
Packit Service |
a1bd4f |
*need_activation = TRUE;
|
|
Packit Service |
a1bd4f |
return sett_conn;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
/* ... or if the connection was reactivated/reapplied */
|
|
Packit Service |
a1bd4f |
if (nm_active_connection_version_id_get(active) != dev_checkpoint->ac_version_id) {
|
|
Packit Service |
a1bd4f |
_LOGT("rollback: active connection version id of %s changed", uuid);
|
|
Packit Service |
a1bd4f |
*need_activation = TRUE;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
return sett_conn;
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static gboolean
|
|
Packit Service |
a1bd4f |
restore_and_activate_connection(NMCheckpoint *self, DeviceCheckpoint *dev_checkpoint)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate * priv = NM_CHECKPOINT_GET_PRIVATE(self);
|
|
Packit Service |
a1bd4f |
NMSettingsConnection *connection;
|
|
Packit Service |
a1bd4f |
gs_unref_object NMAuthSubject * subject = NULL;
|
|
Packit Service |
a1bd4f |
GError * local_error = NULL;
|
|
Packit Service |
a1bd4f |
gboolean need_update, need_activation;
|
|
Packit Service |
a1bd4f |
NMSettingsConnectionPersistMode persist_mode;
|
|
Packit Service |
a1bd4f |
NMSettingsConnectionIntFlags sett_flags;
|
|
Packit Service |
a1bd4f |
NMSettingsConnectionIntFlags sett_mask;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
connection = find_settings_connection(self, dev_checkpoint, &need_update, &need_activation);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
/* FIXME: we need to ensure to re-create/update the profile for the
|
|
Packit Service |
a1bd4f |
* same settings plugin. E.g. if it was a keyfile in /run or /etc,
|
|
Packit Service |
a1bd4f |
* it must be again. If it was previously handled by a certain settings plugin,
|
|
Packit Service |
a1bd4f |
* so it must again.
|
|
Packit Service |
a1bd4f |
*
|
|
Packit Service |
a1bd4f |
* FIXME: preserve and restore the right settings flags (volatile, nm-generated). */
|
|
Packit Service |
a1bd4f |
sett_flags = NM_SETTINGS_CONNECTION_INT_FLAGS_NONE;
|
|
Packit Service |
a1bd4f |
sett_mask = NM_SETTINGS_CONNECTION_INT_FLAGS_NONE;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (connection) {
|
|
Packit Service |
a1bd4f |
if (need_update) {
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: updating connection %s", nm_settings_connection_get_uuid(connection));
|
|
Packit Service |
a1bd4f |
persist_mode = NM_SETTINGS_CONNECTION_PERSIST_MODE_KEEP;
|
|
Packit Service |
a1bd4f |
nm_settings_connection_update(connection,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->settings_connection,
|
|
Packit Service |
a1bd4f |
persist_mode,
|
|
Packit Service |
a1bd4f |
sett_flags,
|
|
Packit Service |
a1bd4f |
sett_mask,
|
|
Packit Service |
a1bd4f |
NM_SETTINGS_CONNECTION_UPDATE_REASON_NONE,
|
|
Packit Service |
a1bd4f |
"checkpoint-rollback",
|
|
Packit Service |
a1bd4f |
NULL);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
} else {
|
|
Packit Service |
a1bd4f |
/* The connection was deleted, recreate it */
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: adding connection %s again",
|
|
Packit Service |
a1bd4f |
nm_connection_get_uuid(dev_checkpoint->settings_connection));
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
persist_mode = NM_SETTINGS_CONNECTION_PERSIST_MODE_TO_DISK;
|
|
Packit Service |
a1bd4f |
if (!nm_settings_add_connection(NM_SETTINGS_GET,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->settings_connection,
|
|
Packit Service |
a1bd4f |
persist_mode,
|
|
Packit Service |
a1bd4f |
NM_SETTINGS_CONNECTION_ADD_REASON_NONE,
|
|
Packit Service |
a1bd4f |
sett_flags,
|
|
Packit Service |
a1bd4f |
&connection,
|
|
Packit Service |
a1bd4f |
&local_error)) {
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: connection add failure: %s", local_error->message);
|
|
Packit Service |
a1bd4f |
g_clear_error(&local_error);
|
|
Packit Service |
a1bd4f |
return FALSE;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
/* If the device is software, a brand new NMDevice may have been created */
|
|
Packit Service |
a1bd4f |
if (dev_checkpoint->is_software && !dev_checkpoint->device) {
|
|
Packit Service |
a1bd4f |
dev_checkpoint->device = nm_manager_get_device(priv->manager,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->original_dev_name,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->dev_type);
|
|
Packit Service |
a1bd4f |
nm_g_object_ref(dev_checkpoint->device);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
need_activation = TRUE;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (!dev_checkpoint->device) {
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: device cannot be restored");
|
|
Packit Service |
a1bd4f |
return FALSE;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (need_activation) {
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: reactivating connection %s", nm_settings_connection_get_uuid(connection));
|
|
Packit Service |
a1bd4f |
subject = nm_auth_subject_new_internal();
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
/* Disconnect the device if needed. This necessary because now
|
|
Packit Service |
a1bd4f |
* the manager prevents the reactivation of the same connection by
|
|
Packit Service |
a1bd4f |
* an internal subject. */
|
|
Packit Service |
a1bd4f |
if (nm_device_get_state(dev_checkpoint->device) > NM_DEVICE_STATE_DISCONNECTED
|
|
Packit Service |
a1bd4f |
&& nm_device_get_state(dev_checkpoint->device) < NM_DEVICE_STATE_DEACTIVATING) {
|
|
Packit Service |
a1bd4f |
nm_device_state_changed(dev_checkpoint->device,
|
|
Packit Service |
a1bd4f |
NM_DEVICE_STATE_DEACTIVATING,
|
|
Packit Service |
a1bd4f |
NM_DEVICE_STATE_REASON_NEW_ACTIVATION);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (!nm_manager_activate_connection(
|
|
Packit Service |
a1bd4f |
priv->manager,
|
|
Packit Service |
a1bd4f |
connection,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->applied_connection,
|
|
Packit Service |
a1bd4f |
NULL,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->device,
|
|
Packit Service |
a1bd4f |
subject,
|
|
Packit Service |
a1bd4f |
NM_ACTIVATION_TYPE_MANAGED,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->activation_reason,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->activation_lifetime_bound_to_profile_visibility
|
|
Packit Service |
a1bd4f |
? NM_ACTIVATION_STATE_FLAG_LIFETIME_BOUND_TO_PROFILE_VISIBILITY
|
|
Packit Service |
a1bd4f |
: NM_ACTIVATION_STATE_FLAG_NONE,
|
|
Packit Service |
a1bd4f |
&local_error)) {
|
|
Packit Service |
a1bd4f |
_LOGW("rollback: reactivation of connection %s/%s failed: %s",
|
|
Packit Service |
a1bd4f |
nm_settings_connection_get_id(connection),
|
|
Packit Service |
a1bd4f |
nm_settings_connection_get_uuid(connection),
|
|
Packit Service |
a1bd4f |
local_error->message);
|
|
Packit Service |
a1bd4f |
g_clear_error(&local_error);
|
|
Packit Service |
a1bd4f |
return FALSE;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
return TRUE;
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
GVariant *
|
|
Packit Service |
a1bd4f |
nm_checkpoint_rollback(NMCheckpoint *self)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate *priv = NM_CHECKPOINT_GET_PRIVATE(self);
|
|
Packit Service |
a1bd4f |
DeviceCheckpoint * dev_checkpoint;
|
|
Packit Service |
a1bd4f |
GHashTableIter iter;
|
|
Packit Service |
a1bd4f |
NMDevice * device;
|
|
Packit Service |
a1bd4f |
GVariantBuilder builder;
|
|
Packit Service |
a1bd4f |
uint i;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
_LOGI("rollback of %s", nm_dbus_object_get_path(NM_DBUS_OBJECT(self)));
|
|
Packit Service |
a1bd4f |
g_variant_builder_init(&builder, G_VARIANT_TYPE("a{su}"));
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
/* Start creating removed devices (if any and if possible) */
|
|
Packit Service |
a1bd4f |
if (priv->removed_devices) {
|
|
Packit Service |
a1bd4f |
for (i = 0; i < priv->removed_devices->len; i++) {
|
|
Packit Service |
a1bd4f |
guint32 result = NM_ROLLBACK_RESULT_OK;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
dev_checkpoint = priv->removed_devices->pdata[i];
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: restoring removed device %s (state %d, realized %d, explicitly "
|
|
Packit Service |
a1bd4f |
"unmanaged %d)",
|
|
Packit Service |
a1bd4f |
dev_checkpoint->original_dev_name,
|
|
Packit Service |
a1bd4f |
(int) dev_checkpoint->state,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->realized,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->unmanaged_explicit);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (dev_checkpoint->applied_connection) {
|
|
Packit Service |
a1bd4f |
if (!restore_and_activate_connection(self, dev_checkpoint))
|
|
Packit Service |
a1bd4f |
result = NM_ROLLBACK_RESULT_ERR_FAILED;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
g_variant_builder_add(&builder, "{su}", dev_checkpoint->original_dev_path, result);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
/* Start rolling-back each device */
|
|
Packit Service |
a1bd4f |
g_hash_table_iter_init(&iter, priv->devices);
|
|
Packit Service |
a1bd4f |
while (g_hash_table_iter_next(&iter, (gpointer *) &device, (gpointer *) &dev_checkpoint)) {
|
|
Packit Service |
a1bd4f |
guint32 result = NM_ROLLBACK_RESULT_OK;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: restoring device %s (state %d, realized %d, explicitly unmanaged %d)",
|
|
Packit Service |
a1bd4f |
dev_checkpoint->original_dev_name,
|
|
Packit Service |
a1bd4f |
(int) dev_checkpoint->state,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->realized,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->unmanaged_explicit);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (nm_device_is_real(device)) {
|
|
Packit Service |
a1bd4f |
if (!dev_checkpoint->realized) {
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: device was not realized, unmanage it");
|
|
Packit Service |
a1bd4f |
nm_device_set_unmanaged_by_flags_queue(device,
|
|
Packit Service |
a1bd4f |
NM_UNMANAGED_USER_EXPLICIT,
|
|
Packit Service |
a1bd4f |
TRUE,
|
|
Packit Service |
a1bd4f |
NM_DEVICE_STATE_REASON_NOW_UNMANAGED);
|
|
Packit Service |
a1bd4f |
goto next_dev;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
} else {
|
|
Packit Service |
a1bd4f |
if (dev_checkpoint->realized) {
|
|
Packit Service |
a1bd4f |
if (dev_checkpoint->is_software) {
|
|
Packit Service |
a1bd4f |
/* try to recreate software device */
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: software device not realized, will re-activate");
|
|
Packit Service |
a1bd4f |
goto activate;
|
|
Packit Service |
a1bd4f |
} else {
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: device is not realized");
|
|
Packit Service |
a1bd4f |
result = NM_ROLLBACK_RESULT_ERR_FAILED;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
goto next_dev;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
/* Manage the device again if needed */
|
|
Packit Service |
a1bd4f |
if (nm_device_get_unmanaged_flags(device, NM_UNMANAGED_USER_EXPLICIT)
|
|
Packit Service |
a1bd4f |
&& dev_checkpoint->unmanaged_explicit != NM_UNMAN_FLAG_OP_SET_UNMANAGED) {
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: restore unmanaged user-explicit");
|
|
Packit Service |
a1bd4f |
nm_device_set_unmanaged_by_flags_queue(device,
|
|
Packit Service |
a1bd4f |
NM_UNMANAGED_USER_EXPLICIT,
|
|
Packit Service |
a1bd4f |
dev_checkpoint->unmanaged_explicit,
|
|
Packit Service |
a1bd4f |
NM_DEVICE_STATE_REASON_NOW_MANAGED);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (dev_checkpoint->state == NM_DEVICE_STATE_UNMANAGED) {
|
|
Packit Service |
a1bd4f |
if (nm_device_get_state(device) != NM_DEVICE_STATE_UNMANAGED
|
|
Packit Service |
a1bd4f |
|| dev_checkpoint->unmanaged_explicit == NM_UNMAN_FLAG_OP_SET_UNMANAGED) {
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: explicitly unmanage device");
|
|
Packit Service |
a1bd4f |
nm_device_set_unmanaged_by_flags_queue(device,
|
|
Packit Service |
a1bd4f |
NM_UNMANAGED_USER_EXPLICIT,
|
|
Packit Service |
a1bd4f |
TRUE,
|
|
Packit Service |
a1bd4f |
NM_DEVICE_STATE_REASON_NOW_UNMANAGED);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
goto next_dev;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
activate:
|
|
Packit Service |
a1bd4f |
if (dev_checkpoint->applied_connection) {
|
|
Packit Service |
a1bd4f |
if (!restore_and_activate_connection(self, dev_checkpoint)) {
|
|
Packit Service |
a1bd4f |
result = NM_ROLLBACK_RESULT_ERR_FAILED;
|
|
Packit Service |
a1bd4f |
goto next_dev;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
} else {
|
|
Packit Service |
a1bd4f |
/* The device was initially disconnected, deactivate any existing connection */
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: disconnecting device");
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (nm_device_get_state(device) > NM_DEVICE_STATE_DISCONNECTED
|
|
Packit Service |
a1bd4f |
&& nm_device_get_state(device) < NM_DEVICE_STATE_DEACTIVATING) {
|
|
Packit Service |
a1bd4f |
nm_device_state_changed(device,
|
|
Packit Service |
a1bd4f |
NM_DEVICE_STATE_DEACTIVATING,
|
|
Packit Service |
a1bd4f |
NM_DEVICE_STATE_REASON_USER_REQUESTED);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
next_dev:
|
|
Packit Service |
a1bd4f |
g_variant_builder_add(&builder, "{su}", dev_checkpoint->original_dev_path, result);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (NM_FLAGS_HAS(priv->flags, NM_CHECKPOINT_CREATE_FLAG_DELETE_NEW_CONNECTIONS)) {
|
|
Packit Service |
a1bd4f |
NMSettingsConnection *con;
|
|
Packit Service |
a1bd4f |
gs_free NMSettingsConnection **list = NULL;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
g_return_val_if_fail(priv->connection_uuids, NULL);
|
|
Packit Service |
a1bd4f |
list = nm_settings_get_connections_clone(
|
|
Packit Service |
a1bd4f |
NM_SETTINGS_GET,
|
|
Packit Service |
a1bd4f |
NULL,
|
|
Packit Service |
a1bd4f |
NULL,
|
|
Packit Service |
a1bd4f |
NULL,
|
|
Packit Service |
a1bd4f |
nm_settings_connection_cmp_autoconnect_priority_p_with_data,
|
|
Packit Service |
a1bd4f |
NULL);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
for (i = 0; list[i]; i++) {
|
|
Packit Service |
a1bd4f |
con = list[i];
|
|
Packit Service |
a1bd4f |
if (!g_hash_table_contains(priv->connection_uuids,
|
|
Packit Service |
a1bd4f |
nm_settings_connection_get_uuid(con))) {
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: deleting new connection %s", nm_settings_connection_get_uuid(con));
|
|
Packit Service |
a1bd4f |
nm_settings_connection_delete(con, FALSE);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (NM_FLAGS_HAS(priv->flags, NM_CHECKPOINT_CREATE_FLAG_DISCONNECT_NEW_DEVICES)) {
|
|
Packit Service |
a1bd4f |
const CList * tmp_lst;
|
|
Packit Service |
a1bd4f |
NMDeviceState state;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
nm_manager_for_each_device (priv->manager, device, tmp_lst) {
|
|
Packit Service |
a1bd4f |
if (g_hash_table_contains(priv->devices, device))
|
|
Packit Service |
a1bd4f |
continue;
|
|
Packit Service |
a1bd4f |
state = nm_device_get_state(device);
|
|
Packit Service |
a1bd4f |
if (state > NM_DEVICE_STATE_DISCONNECTED && state < NM_DEVICE_STATE_DEACTIVATING) {
|
|
Packit Service |
a1bd4f |
_LOGD("rollback: disconnecting new device %s", nm_device_get_iface(device));
|
|
Packit Service |
a1bd4f |
nm_device_state_changed(device,
|
|
Packit Service |
a1bd4f |
NM_DEVICE_STATE_DEACTIVATING,
|
|
Packit Service |
a1bd4f |
NM_DEVICE_STATE_REASON_USER_REQUESTED);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
return g_variant_new("(a{su})", &builder);
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static void
|
|
Packit Service |
a1bd4f |
device_checkpoint_destroy(gpointer data)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
DeviceCheckpoint *dev_checkpoint = data;
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
nm_clear_g_signal_handler(dev_checkpoint->device, &dev_checkpoint->dev_exported_change_id);
|
|
Packit Service |
a1bd4f |
g_clear_object(&dev_checkpoint->applied_connection);
|
|
Packit Service |
a1bd4f |
g_clear_object(&dev_checkpoint->settings_connection);
|
|
Packit Service |
a1bd4f |
g_clear_object(&dev_checkpoint->device);
|
|
Packit Service |
a1bd4f |
g_free(dev_checkpoint->original_dev_path);
|
|
Packit Service |
a1bd4f |
g_free(dev_checkpoint->original_dev_name);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
g_slice_free(DeviceCheckpoint, dev_checkpoint);
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static void
|
|
Packit Service |
a1bd4f |
_move_dev_to_removed_devices(NMDevice *device, NMCheckpoint *checkpoint)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate *priv = NM_CHECKPOINT_GET_PRIVATE(checkpoint);
|
|
Packit Service |
a1bd4f |
DeviceCheckpoint * dev_checkpoint;
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
g_return_if_fail(device);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
dev_checkpoint = g_hash_table_lookup(priv->devices, device);
|
|
Packit Service |
a1bd4f |
if (!dev_checkpoint)
|
|
Packit Service |
a1bd4f |
return;
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
g_hash_table_steal(priv->devices, dev_checkpoint->device);
|
|
Packit Service |
a1bd4f |
nm_clear_g_signal_handler(dev_checkpoint->device, &dev_checkpoint->dev_exported_change_id);
|
|
Packit Service |
a1bd4f |
g_clear_object(&dev_checkpoint->device);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
if (!priv->removed_devices)
|
|
Packit Service |
a1bd4f |
priv->removed_devices =
|
|
Packit Service |
a1bd4f |
g_ptr_array_new_with_free_func((GDestroyNotify) device_checkpoint_destroy);
|
|
Packit Service |
a1bd4f |
g_ptr_array_add(priv->removed_devices, dev_checkpoint);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
_notify(checkpoint, PROP_DEVICES);
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static void
|
|
Packit Service |
a1bd4f |
_dev_exported_changed(NMDBusObject *obj, NMCheckpoint *checkpoint)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
_move_dev_to_removed_devices(NM_DEVICE(obj), checkpoint);
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static DeviceCheckpoint *
|
|
Packit Service |
a1bd4f |
device_checkpoint_create(NMCheckpoint *checkpoint, NMDevice *device)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
DeviceCheckpoint * dev_checkpoint;
|
|
Packit Service |
a1bd4f |
NMConnection * applied_connection;
|
|
Packit Service |
a1bd4f |
NMSettingsConnection *settings_connection;
|
|
Packit Service |
a1bd4f |
const char * path;
|
|
Packit Service |
a1bd4f |
NMActRequest * act_request;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
nm_assert(NM_IS_DEVICE(device));
|
|
Packit Service |
a1bd4f |
nm_assert(nm_device_is_real(device));
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
path = nm_dbus_object_get_path(NM_DBUS_OBJECT(device));
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
dev_checkpoint = g_slice_new0(DeviceCheckpoint);
|
|
Packit Service |
a1bd4f |
dev_checkpoint->device = g_object_ref(device);
|
|
Packit Service |
a1bd4f |
dev_checkpoint->original_dev_path = g_strdup(path);
|
|
Packit Service |
a1bd4f |
dev_checkpoint->original_dev_name = g_strdup(nm_device_get_iface(device));
|
|
Packit Service |
a1bd4f |
dev_checkpoint->dev_type = nm_device_get_device_type(device);
|
|
Packit Service |
a1bd4f |
dev_checkpoint->state = nm_device_get_state(device);
|
|
Packit Service |
a1bd4f |
dev_checkpoint->is_software = nm_device_is_software(device);
|
|
Packit Service |
a1bd4f |
dev_checkpoint->realized = nm_device_is_real(device);
|
|
Packit Service |
a1bd4f |
dev_checkpoint->dev_exported_change_id = g_signal_connect(device,
|
|
Packit Service |
a1bd4f |
NM_DBUS_OBJECT_EXPORTED_CHANGED,
|
|
Packit Service |
a1bd4f |
G_CALLBACK(_dev_exported_changed),
|
|
Packit Service |
a1bd4f |
checkpoint);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (nm_device_get_unmanaged_mask(device, NM_UNMANAGED_USER_EXPLICIT)) {
|
|
Packit Service |
a1bd4f |
dev_checkpoint->unmanaged_explicit =
|
|
Packit Service |
a1bd4f |
!!nm_device_get_unmanaged_flags(device, NM_UNMANAGED_USER_EXPLICIT);
|
|
Packit Service |
a1bd4f |
} else
|
|
Packit Service |
a1bd4f |
dev_checkpoint->unmanaged_explicit = NM_UNMAN_FLAG_OP_FORGET;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
act_request = nm_device_get_act_request(device);
|
|
Packit Service |
a1bd4f |
if (act_request) {
|
|
Packit Service |
a1bd4f |
settings_connection = nm_act_request_get_settings_connection(act_request);
|
|
Packit Service |
a1bd4f |
applied_connection = nm_act_request_get_applied_connection(act_request);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
dev_checkpoint->applied_connection = nm_simple_connection_new_clone(applied_connection);
|
|
Packit Service |
a1bd4f |
dev_checkpoint->settings_connection = nm_simple_connection_new_clone(
|
|
Packit Service |
a1bd4f |
nm_settings_connection_get_connection(settings_connection));
|
|
Packit Service |
a1bd4f |
dev_checkpoint->ac_version_id =
|
|
Packit Service |
a1bd4f |
nm_active_connection_version_id_get(NM_ACTIVE_CONNECTION(act_request));
|
|
Packit Service |
a1bd4f |
dev_checkpoint->activation_reason =
|
|
Packit Service |
a1bd4f |
nm_active_connection_get_activation_reason(NM_ACTIVE_CONNECTION(act_request));
|
|
Packit Service |
a1bd4f |
dev_checkpoint->activation_lifetime_bound_to_profile_visibility =
|
|
Packit Service |
a1bd4f |
NM_FLAGS_HAS(nm_active_connection_get_state_flags(NM_ACTIVE_CONNECTION(act_request)),
|
|
Packit Service |
a1bd4f |
NM_ACTIVATION_STATE_FLAG_LIFETIME_BOUND_TO_PROFILE_VISIBILITY);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
return dev_checkpoint;
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static gboolean
|
|
Packit Service |
a1bd4f |
_timeout_cb(gpointer user_data)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpoint * self = user_data;
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate *priv = NM_CHECKPOINT_GET_PRIVATE(self);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
priv->timeout_id = 0;
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
if (priv->timeout_cb)
|
|
Packit Service |
a1bd4f |
priv->timeout_cb(self, priv->timeout_data);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
/* beware, @self likely got destroyed! */
|
|
Packit Service |
a1bd4f |
return G_SOURCE_REMOVE;
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
void
|
|
Packit Service |
a1bd4f |
nm_checkpoint_adjust_rollback_timeout(NMCheckpoint *self, guint32 add_timeout)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
guint32 rollback_timeout_s;
|
|
Packit Service |
a1bd4f |
gint64 now_ms, add_timeout_ms, rollback_timeout_ms;
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate *priv = NM_CHECKPOINT_GET_PRIVATE(self);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
nm_clear_g_source(&priv->timeout_id);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
if (add_timeout == 0)
|
|
Packit Service |
a1bd4f |
rollback_timeout_s = 0;
|
|
Packit Service |
a1bd4f |
else {
|
|
Packit Service |
a1bd4f |
now_ms = nm_utils_get_monotonic_timestamp_msec();
|
|
Packit Service |
a1bd4f |
add_timeout_ms = ((gint64) add_timeout) * 1000;
|
|
Packit Service |
a1bd4f |
rollback_timeout_ms = (now_ms - priv->created_at_ms) + add_timeout_ms;
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
/* round to nearest integer second. Since NM_CHECKPOINT_ROLLBACK_TIMEOUT is
|
|
Packit Service |
a1bd4f |
* in units seconds, it will be able to exactly express the timeout. */
|
|
Packit Service |
a1bd4f |
rollback_timeout_s = NM_MIN((rollback_timeout_ms + 500) / 1000, (gint64) G_MAXUINT32);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
/* we expect the timeout to be positive, because add_timeout_ms is positive.
|
|
Packit Service |
a1bd4f |
* We cannot accept a zero, because it means "infinity". */
|
|
Packit Service |
a1bd4f |
nm_assert(rollback_timeout_s > 0);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
priv->timeout_id =
|
|
Packit Service |
a1bd4f |
g_timeout_add(NM_MIN(add_timeout_ms, (gint64) G_MAXUINT32), _timeout_cb, self);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
if (rollback_timeout_s != priv->rollback_timeout_s) {
|
|
Packit Service |
a1bd4f |
priv->rollback_timeout_s = rollback_timeout_s;
|
|
Packit Service |
a1bd4f |
_notify(self, PROP_ROLLBACK_TIMEOUT);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
/*****************************************************************************/
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static void
|
|
Packit Service |
a1bd4f |
get_property(GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpoint * self = NM_CHECKPOINT(object);
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate *priv = NM_CHECKPOINT_GET_PRIVATE(self);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
switch (prop_id) {
|
|
Packit Service |
a1bd4f |
case PROP_DEVICES:
|
|
Packit Service |
a1bd4f |
nm_dbus_utils_g_value_set_object_path_from_hash(value, priv->devices, FALSE);
|
|
Packit Service |
a1bd4f |
break;
|
|
Packit Service |
a1bd4f |
case PROP_CREATED:
|
|
Packit Service |
a1bd4f |
g_value_set_int64(
|
|
Packit Service |
a1bd4f |
value,
|
|
Packit Service |
a1bd4f |
nm_utils_monotonic_timestamp_as_boottime(priv->created_at_ms, NM_UTILS_NSEC_PER_MSEC));
|
|
Packit Service |
a1bd4f |
break;
|
|
Packit Service |
a1bd4f |
case PROP_ROLLBACK_TIMEOUT:
|
|
Packit Service |
a1bd4f |
g_value_set_uint(value, priv->rollback_timeout_s);
|
|
Packit Service |
a1bd4f |
break;
|
|
Packit Service |
a1bd4f |
default:
|
|
Packit Service |
a1bd4f |
G_OBJECT_WARN_INVALID_PROPERTY_ID(object, prop_id, pspec);
|
|
Packit Service |
a1bd4f |
break;
|
|
Packit Service |
a1bd4f |
}
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
/*****************************************************************************/
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static void
|
|
Packit Service |
a1bd4f |
nm_checkpoint_init(NMCheckpoint *self)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate *priv;
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
priv = G_TYPE_INSTANCE_GET_PRIVATE(self, NM_TYPE_CHECKPOINT, NMCheckpointPrivate);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
self->_priv = priv;
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
c_list_init(&self->checkpoints_lst);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
priv->devices = g_hash_table_new_full(nm_direct_hash, NULL, NULL, device_checkpoint_destroy);
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static void
|
|
Packit Service |
a1bd4f |
_device_removed(NMManager *manager, NMDevice *device, gpointer user_data)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
_move_dev_to_removed_devices(device, NM_CHECKPOINT(user_data));
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
NMCheckpoint *
|
|
Packit Service |
a1bd4f |
nm_checkpoint_new(NMManager * manager,
|
|
Packit Service |
a1bd4f |
GPtrArray * devices,
|
|
Packit Service |
a1bd4f |
guint32 rollback_timeout_s,
|
|
Packit Service |
a1bd4f |
NMCheckpointCreateFlags flags)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpoint * self;
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate * priv;
|
|
Packit Service |
a1bd4f |
NMSettingsConnection *const *con;
|
|
Packit Service |
a1bd4f |
gint64 rollback_timeout_ms;
|
|
Packit Service |
a1bd4f |
guint i;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
g_return_val_if_fail(manager, NULL);
|
|
Packit Service |
a1bd4f |
g_return_val_if_fail(devices, NULL);
|
|
Packit Service |
a1bd4f |
g_return_val_if_fail(devices->len > 0, NULL);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
self = g_object_new(NM_TYPE_CHECKPOINT, NULL);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
priv = NM_CHECKPOINT_GET_PRIVATE(self);
|
|
Packit Service |
a1bd4f |
priv->manager = g_object_ref(manager);
|
|
Packit Service |
a1bd4f |
priv->rollback_timeout_s = rollback_timeout_s;
|
|
Packit Service |
a1bd4f |
priv->created_at_ms = nm_utils_get_monotonic_timestamp_msec();
|
|
Packit Service |
a1bd4f |
priv->flags = flags;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (rollback_timeout_s != 0) {
|
|
Packit Service |
a1bd4f |
rollback_timeout_ms = ((gint64) rollback_timeout_s) * 1000;
|
|
Packit Service |
a1bd4f |
priv->timeout_id =
|
|
Packit Service |
a1bd4f |
g_timeout_add(NM_MIN(rollback_timeout_ms, (gint64) G_MAXUINT32), _timeout_cb, self);
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
if (NM_FLAGS_HAS(flags, NM_CHECKPOINT_CREATE_FLAG_DELETE_NEW_CONNECTIONS)) {
|
|
Packit Service |
a1bd4f |
priv->connection_uuids = g_hash_table_new_full(nm_str_hash, g_str_equal, g_free, NULL);
|
|
Packit Service |
a1bd4f |
for (con = nm_settings_get_connections(NM_SETTINGS_GET, NULL); *con; con++) {
|
|
Packit Service |
a1bd4f |
g_hash_table_add(priv->connection_uuids,
|
|
Packit Service |
a1bd4f |
g_strdup(nm_settings_connection_get_uuid(*con)));
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
for (i = 0; i < devices->len; i++) {
|
|
Packit Service |
a1bd4f |
NMDevice *device = devices->pdata[i];
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
/* As long as the check point instance exists, it will keep a reference
|
|
Packit Service |
a1bd4f |
* to the device also if the device gets removed (by rmmod or by deleting
|
|
Packit Service |
a1bd4f |
* a connection profile for a software device). */
|
|
Packit Service |
a1bd4f |
g_hash_table_insert(priv->devices, device, device_checkpoint_create(self, device));
|
|
Packit Service |
a1bd4f |
}
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
priv->dev_removed_id = g_signal_connect(priv->manager,
|
|
Packit Service |
a1bd4f |
NM_MANAGER_DEVICE_REMOVED,
|
|
Packit Service |
a1bd4f |
G_CALLBACK(_device_removed),
|
|
Packit Service |
a1bd4f |
self);
|
|
Packit Service |
a1bd4f |
return self;
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static void
|
|
Packit Service |
a1bd4f |
dispose(GObject *object)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
NMCheckpoint * self = NM_CHECKPOINT(object);
|
|
Packit Service |
a1bd4f |
NMCheckpointPrivate *priv = NM_CHECKPOINT_GET_PRIVATE(self);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
nm_assert(c_list_is_empty(&self->checkpoints_lst));
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
nm_clear_pointer(&priv->devices, g_hash_table_unref);
|
|
Packit Service |
a1bd4f |
nm_clear_pointer(&priv->connection_uuids, g_hash_table_unref);
|
|
Packit Service |
a1bd4f |
nm_clear_pointer(&priv->removed_devices, g_ptr_array_unref);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
nm_clear_g_signal_handler(priv->manager, &priv->dev_removed_id);
|
|
Packit Service |
a1bd4f |
g_clear_object(&priv->manager);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
nm_clear_g_source(&priv->timeout_id);
|
|
Packit |
5756e2 |
|
|
Packit Service |
a1bd4f |
G_OBJECT_CLASS(nm_checkpoint_parent_class)->dispose(object);
|
|
Packit |
5756e2 |
}
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static const NMDBusInterfaceInfoExtended interface_info_checkpoint = {
|
|
Packit Service |
a1bd4f |
.parent = NM_DEFINE_GDBUS_INTERFACE_INFO_INIT(
|
|
Packit Service |
a1bd4f |
NM_DBUS_INTERFACE_CHECKPOINT,
|
|
Packit Service |
a1bd4f |
.signals = NM_DEFINE_GDBUS_SIGNAL_INFOS(&nm_signal_info_property_changed_legacy, ),
|
|
Packit Service |
a1bd4f |
.properties = NM_DEFINE_GDBUS_PROPERTY_INFOS(
|
|
Packit Service |
a1bd4f |
NM_DEFINE_DBUS_PROPERTY_INFO_EXTENDED_READABLE_L("Devices",
|
|
Packit Service |
a1bd4f |
"ao",
|
|
Packit Service |
a1bd4f |
NM_CHECKPOINT_DEVICES),
|
|
Packit Service |
a1bd4f |
NM_DEFINE_DBUS_PROPERTY_INFO_EXTENDED_READABLE_L("Created", "x", NM_CHECKPOINT_CREATED),
|
|
Packit Service |
a1bd4f |
NM_DEFINE_DBUS_PROPERTY_INFO_EXTENDED_READABLE_L("RollbackTimeout",
|
|
Packit Service |
a1bd4f |
"u",
|
|
Packit Service |
a1bd4f |
NM_CHECKPOINT_ROLLBACK_TIMEOUT), ), ),
|
|
Packit Service |
a1bd4f |
.legacy_property_changed = TRUE,
|
|
Packit |
5756e2 |
};
|
|
Packit |
5756e2 |
|
|
Packit |
5756e2 |
static void
|
|
Packit Service |
a1bd4f |
nm_checkpoint_class_init(NMCheckpointClass *checkpoint_class)
|
|
Packit |
5756e2 |
{
|
|
Packit Service |
a1bd4f |
GObjectClass * object_class = G_OBJECT_CLASS(checkpoint_class);
|
|
Packit Service |
a1bd4f |
NMDBusObjectClass *dbus_object_class = NM_DBUS_OBJECT_CLASS(checkpoint_class);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
g_type_class_add_private(object_class, sizeof(NMCheckpointPrivate));
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
dbus_object_class->export_path = NM_DBUS_EXPORT_PATH_NUMBERED(NM_DBUS_PATH "/Checkpoint");
|
|
Packit Service |
a1bd4f |
dbus_object_class->interface_infos = NM_DBUS_INTERFACE_INFOS(&interface_info_checkpoint);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
object_class->dispose = dispose;
|
|
Packit Service |
a1bd4f |
object_class->get_property = get_property;
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
obj_properties[PROP_DEVICES] = g_param_spec_boxed(NM_CHECKPOINT_DEVICES,
|
|
Packit Service |
a1bd4f |
"",
|
|
Packit Service |
a1bd4f |
"",
|
|
Packit Service |
a1bd4f |
G_TYPE_STRV,
|
|
Packit Service |
a1bd4f |
G_PARAM_READABLE | G_PARAM_STATIC_STRINGS);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
obj_properties[PROP_CREATED] = g_param_spec_int64(NM_CHECKPOINT_CREATED,
|
|
Packit Service |
a1bd4f |
"",
|
|
Packit Service |
a1bd4f |
"",
|
|
Packit Service |
a1bd4f |
G_MININT64,
|
|
Packit Service |
a1bd4f |
G_MAXINT64,
|
|
Packit Service |
a1bd4f |
0,
|
|
Packit Service |
a1bd4f |
G_PARAM_READABLE | G_PARAM_STATIC_STRINGS);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
obj_properties[PROP_ROLLBACK_TIMEOUT] =
|
|
Packit Service |
a1bd4f |
g_param_spec_uint(NM_CHECKPOINT_ROLLBACK_TIMEOUT,
|
|
Packit Service |
a1bd4f |
"",
|
|
Packit Service |
a1bd4f |
"",
|
|
Packit Service |
a1bd4f |
0,
|
|
Packit Service |
a1bd4f |
G_MAXUINT32,
|
|
Packit Service |
a1bd4f |
0,
|
|
Packit Service |
a1bd4f |
G_PARAM_READABLE | G_PARAM_STATIC_STRINGS);
|
|
Packit Service |
a1bd4f |
|
|
Packit Service |
a1bd4f |
g_object_class_install_properties(object_class, _PROPERTY_ENUMS_LAST, obj_properties);
|
|
Packit |
5756e2 |
}
|