summary refs log tree commit diff
path: root/clients/cloud-setup/nmcs-provider.c
diff options
context:
space:
mode:
authorMichael Biebl <biebl@debian.org>2020-10-05 22:27:18 +0200
committerMichael Biebl <biebl@debian.org>2020-10-05 22:27:18 +0200
commitaafc1dbe4712c86189bbc1d4d54ad8cb4c69be7e (patch)
treea2a9bb4d007339a0b1304540388230ccedac32bd /clients/cloud-setup/nmcs-provider.c
parente7b44ef4c80907346ec7492a09c45277459924fc (diff)
New upstream version 1.27.90 upstream/1.27.90
Diffstat (limited to 'clients/cloud-setup/nmcs-provider.c')
-rw-r--r--clients/cloud-setup/nmcs-provider.c250
1 files changed, 118 insertions, 132 deletions
diff --git a/clients/cloud-setup/nmcs-provider.c b/clients/cloud-setup/nmcs-provider.c
index bc21d876..e9e79a35 100644
--- a/clients/cloud-setup/nmcs-provider.c
+++ b/clients/cloud-setup/nmcs-provider.c
@@ -1,4 +1,4 @@
-// SPDX-License-Identifier: LGPL-2.1+
+/* SPDX-License-Identifier: LGPL-2.1+ */
 
 #include "nm-default.h"
 
@@ -8,239 +8,225 @@
 
 /*****************************************************************************/
 
-NM_GOBJECT_PROPERTIES_DEFINE_BASE (
-	PROP_HTTP_CLIENT,
-);
+NM_GOBJECT_PROPERTIES_DEFINE_BASE(PROP_HTTP_CLIENT, );
 
 typedef struct _NMCSProviderPrivate {
-	NMHttpClient *http_client;
+    NMHttpClient *http_client;
 } NMCSProviderPrivate;
 
-G_DEFINE_TYPE (NMCSProvider, nmcs_provider, G_TYPE_OBJECT);
+G_DEFINE_TYPE(NMCSProvider, nmcs_provider, G_TYPE_OBJECT);
 
 #define NMCS_PROVIDER_GET_PRIVATE(self) _NM_GET_PRIVATE_PTR(self, NMCSProvider, NMCS_IS_PROVIDER)
 
 /*****************************************************************************/
 
 const char *
-nmcs_provider_get_name (NMCSProvider *self)
+nmcs_provider_get_name(NMCSProvider *self)
 {
-	NMCSProviderClass *klass;
+    NMCSProviderClass *klass;
 
-	g_return_val_if_fail (NMCS_IS_PROVIDER (self), NULL);
+    g_return_val_if_fail(NMCS_IS_PROVIDER(self), NULL);
 
-	klass = NMCS_PROVIDER_GET_CLASS (self);
-	nm_assert (klass->_name);
-	return klass->_name;
+    klass = NMCS_PROVIDER_GET_CLASS(self);
+    nm_assert(klass->_name);
+    return klass->_name;
 }
 
 /*****************************************************************************/
 
 NMHttpClient *
-nmcs_provider_get_http_client (NMCSProvider *self)
+nmcs_provider_get_http_client(NMCSProvider *self)
 {
-	g_return_val_if_fail (NMCS_IS_PROVIDER (self), NULL);
+    g_return_val_if_fail(NMCS_IS_PROVIDER(self), NULL);
 
-	return NMCS_PROVIDER_GET_PRIVATE (self)->http_client;
+    return NMCS_PROVIDER_GET_PRIVATE(self)->http_client;
 }
 
 GMainContext *
-nmcs_provider_get_main_context (NMCSProvider *self)
+nmcs_provider_get_main_context(NMCSProvider *self)
 {
-	g_return_val_if_fail (NMCS_IS_PROVIDER (self), NULL);
+    g_return_val_if_fail(NMCS_IS_PROVIDER(self), NULL);
 
-	return nm_http_client_get_main_context (NMCS_PROVIDER_GET_PRIVATE (self)->http_client);
+    return nm_http_client_get_main_context(NMCS_PROVIDER_GET_PRIVATE(self)->http_client);
 }
 
 /*****************************************************************************/
 
 void
-nmcs_provider_detect (NMCSProvider *self,
-                      GCancellable *cancellable,
-                      GAsyncReadyCallback callback,
-                      gpointer user_data)
+nmcs_provider_detect(NMCSProvider *      self,
+                     GCancellable *      cancellable,
+                     GAsyncReadyCallback callback,
+                     gpointer            user_data)
 {
-	gs_unref_object GTask *task = NULL;
-	const char *env;
+    gs_unref_object GTask *task = NULL;
+    const char *           env;
 
-	g_return_if_fail (NMCS_IS_PROVIDER (self));
-	g_return_if_fail (!cancellable || G_IS_CANCELLABLE (cancellable));
+    g_return_if_fail(NMCS_IS_PROVIDER(self));
+    g_return_if_fail(!cancellable || G_IS_CANCELLABLE(cancellable));
 
-	task = nm_g_task_new (self, cancellable, nmcs_provider_detect, callback, user_data);
+    task = nm_g_task_new(self, cancellable, nmcs_provider_detect, callback, user_data);
 
-	nmcs_wait_for_objects_register (task);
+    nmcs_wait_for_objects_register(task);
 
-	env = g_getenv (NMCS_PROVIDER_GET_CLASS (self)->_env_provider_enabled);
-	if (!_nm_utils_ascii_str_to_bool (env, FALSE)) {
-		g_task_return_error (task,
-		                     nm_utils_error_new (NM_UTILS_ERROR_UNKNOWN,
-		                                         "provider is disabled"));
-		return;
-	}
+    env = g_getenv(NMCS_PROVIDER_GET_CLASS(self)->_env_provider_enabled);
+    if (!_nm_utils_ascii_str_to_bool(env, FALSE)) {
+        g_task_return_error(task,
+                            nm_utils_error_new(NM_UTILS_ERROR_UNKNOWN, "provider is disabled"));
+        return;
+    }
 
-	NMCS_PROVIDER_GET_CLASS (self)->detect (self,
-	                                        g_steal_pointer (&task));
+    NMCS_PROVIDER_GET_CLASS(self)->detect(self, g_steal_pointer(&task));
 }
 
 gboolean
-nmcs_provider_detect_finish (NMCSProvider *self,
-                             GAsyncResult *result,
-                             GError **error)
+nmcs_provider_detect_finish(NMCSProvider *self, GAsyncResult *result, GError **error)
 {
-	g_return_val_if_fail (NMCS_IS_PROVIDER (self), FALSE);
-	g_return_val_if_fail (nm_g_task_is_valid (result, self, nmcs_provider_detect), FALSE);
+    g_return_val_if_fail(NMCS_IS_PROVIDER(self), FALSE);
+    g_return_val_if_fail(nm_g_task_is_valid(result, self, nmcs_provider_detect), FALSE);
 
-	return g_task_propagate_boolean (G_TASK (result), error);
+    return g_task_propagate_boolean(G_TASK(result), error);
 }
 
 /*****************************************************************************/
 
 NMCSProviderGetConfigIfaceData *
-nmcs_provider_get_config_iface_data_new (gboolean was_requested)
+nmcs_provider_get_config_iface_data_new(gboolean was_requested)
 {
-	NMCSProviderGetConfigIfaceData *iface_data;
-
-	iface_data = g_slice_new (NMCSProviderGetConfigIfaceData);
-	*iface_data = (NMCSProviderGetConfigIfaceData) {
-		.iface_idx     = -1,
-		.was_requested = was_requested,
-	};
-	return iface_data;
+    NMCSProviderGetConfigIfaceData *iface_data;
+
+    iface_data  = g_slice_new(NMCSProviderGetConfigIfaceData);
+    *iface_data = (NMCSProviderGetConfigIfaceData){
+        .iface_idx     = -1,
+        .was_requested = was_requested,
+    };
+    return iface_data;
 }
 
 static void
-_iface_data_free (gpointer data)
+_iface_data_free(gpointer data)
 {
-	NMCSProviderGetConfigIfaceData *iface_data = data;
+    NMCSProviderGetConfigIfaceData *iface_data = data;
 
-	g_free (iface_data->ipv4s_arr);
-	g_free (iface_data->iproutes_arr);
+    g_free(iface_data->ipv4s_arr);
+    g_free(iface_data->iproutes_arr);
 
-	nm_g_slice_free (iface_data);
+    nm_g_slice_free(iface_data);
 }
 
 static void
-_get_config_data_free (gpointer data)
+_get_config_data_free(gpointer data)
 {
-	NMCSProviderGetConfigTaskData *get_config_data = data;
+    NMCSProviderGetConfigTaskData *get_config_data = data;
 
-	if (get_config_data->extra_destroy)
-		get_config_data->extra_destroy (get_config_data->extra_data);
+    if (get_config_data->extra_destroy)
+        get_config_data->extra_destroy(get_config_data->extra_data);
 
-	nm_clear_pointer (&get_config_data->result_dict, g_hash_table_unref);
+    nm_clear_pointer(&get_config_data->result_dict, g_hash_table_unref);
 
-	nm_g_slice_free (get_config_data);
+    nm_g_slice_free(get_config_data);
 }
 
 void
-nmcs_provider_get_config (NMCSProvider *self,
-                          gboolean any,
-                          const char *const*hwaddrs,
-                          GCancellable *cancellable,
-                          GAsyncReadyCallback callback,
-                          gpointer user_data)
+nmcs_provider_get_config(NMCSProvider *      self,
+                         gboolean            any,
+                         const char *const * hwaddrs,
+                         GCancellable *      cancellable,
+                         GAsyncReadyCallback callback,
+                         gpointer            user_data)
 {
-	NMCSProviderGetConfigTaskData *get_config_data;
+    NMCSProviderGetConfigTaskData *get_config_data;
 
-	g_return_if_fail (NMCS_IS_PROVIDER (self));
-	g_return_if_fail (!cancellable || G_IS_CANCELLABLE (cancellable));
+    g_return_if_fail(NMCS_IS_PROVIDER(self));
+    g_return_if_fail(!cancellable || G_IS_CANCELLABLE(cancellable));
 
-	get_config_data = g_slice_new (NMCSProviderGetConfigTaskData);
-	*get_config_data = (NMCSProviderGetConfigTaskData) {
-		.task        = nm_g_task_new (self, cancellable, nmcs_provider_get_config, callback, user_data),
-		.any         = any,
-		.result_dict = g_hash_table_new_full (nm_str_hash,
-		                                      g_str_equal,
-		                                      g_free,
-		                                      _iface_data_free),
-	};
+    get_config_data  = g_slice_new(NMCSProviderGetConfigTaskData);
+    *get_config_data = (NMCSProviderGetConfigTaskData){
+        .task = nm_g_task_new(self, cancellable, nmcs_provider_get_config, callback, user_data),
+        .any  = any,
+        .result_dict = g_hash_table_new_full(nm_str_hash, g_str_equal, g_free, _iface_data_free),
+    };
 
-	g_task_set_task_data (get_config_data->task, get_config_data, _get_config_data_free);
+    g_task_set_task_data(get_config_data->task, get_config_data, _get_config_data_free);
 
-	nmcs_wait_for_objects_register (get_config_data->task);
+    nmcs_wait_for_objects_register(get_config_data->task);
 
-	for (; hwaddrs && hwaddrs[0]; hwaddrs++) {
-		g_hash_table_insert (get_config_data->result_dict,
-		                     g_strdup (hwaddrs[0]),
-		                     nmcs_provider_get_config_iface_data_new (TRUE));
-	}
+    for (; hwaddrs && hwaddrs[0]; hwaddrs++) {
+        g_hash_table_insert(get_config_data->result_dict,
+                            g_strdup(hwaddrs[0]),
+                            nmcs_provider_get_config_iface_data_new(TRUE));
+    }
 
-	_LOGD ("get-config: starting");
+    _LOGD("get-config: starting");
 
-	NMCS_PROVIDER_GET_CLASS (self)->get_config (self, get_config_data);
+    NMCS_PROVIDER_GET_CLASS(self)->get_config(self, get_config_data);
 }
 
 GHashTable *
-nmcs_provider_get_config_finish (NMCSProvider *self,
-                                 GAsyncResult *result,
-                                 GError **error)
+nmcs_provider_get_config_finish(NMCSProvider *self, GAsyncResult *result, GError **error)
 {
-	g_return_val_if_fail (NMCS_IS_PROVIDER (self), FALSE);
-	g_return_val_if_fail (nm_g_task_is_valid (result, self, nmcs_provider_get_config), FALSE);
+    g_return_val_if_fail(NMCS_IS_PROVIDER(self), FALSE);
+    g_return_val_if_fail(nm_g_task_is_valid(result, self, nmcs_provider_get_config), FALSE);
 
-	return g_task_propagate_pointer (G_TASK (result), error);
+    return g_task_propagate_pointer(G_TASK(result), error);
 }
 
 /*****************************************************************************/
 
 static void
-set_property (GObject *object,
-              guint prop_id,
-              const GValue *value,
-              GParamSpec *pspec)
+set_property(GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec)
 {
-	NMCSProviderPrivate *priv = NMCS_PROVIDER_GET_PRIVATE (object);
-
-	switch (prop_id) {
-	case PROP_HTTP_CLIENT:
-		priv->http_client = g_value_dup_object (value);
-		g_return_if_fail (NM_IS_HTTP_CLIENT (priv->http_client));
-		break;
-	default:
-		G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
-		break;
-	}
+    NMCSProviderPrivate *priv = NMCS_PROVIDER_GET_PRIVATE(object);
+
+    switch (prop_id) {
+    case PROP_HTTP_CLIENT:
+        priv->http_client = g_value_dup_object(value);
+        g_return_if_fail(NM_IS_HTTP_CLIENT(priv->http_client));
+        break;
+    default:
+        G_OBJECT_WARN_INVALID_PROPERTY_ID(object, prop_id, pspec);
+        break;
+    }
 }
 
 /*****************************************************************************/
 
 static void
-nmcs_provider_init (NMCSProvider *self)
+nmcs_provider_init(NMCSProvider *self)
 {
-	NMCSProviderPrivate *priv;
+    NMCSProviderPrivate *priv;
 
-	priv = G_TYPE_INSTANCE_GET_PRIVATE (self, NMCS_TYPE_PROVIDER, NMCSProviderPrivate);
+    priv = G_TYPE_INSTANCE_GET_PRIVATE(self, NMCS_TYPE_PROVIDER, NMCSProviderPrivate);
 
-	self->_priv = priv;
+    self->_priv = priv;
 }
 
 static void
-dispose (GObject *object)
+dispose(GObject *object)
 {
-	NMCSProvider *self = NMCS_PROVIDER (object);
-	NMCSProviderPrivate *priv = NMCS_PROVIDER_GET_PRIVATE (self);
+    NMCSProvider *       self = NMCS_PROVIDER(object);
+    NMCSProviderPrivate *priv = NMCS_PROVIDER_GET_PRIVATE(self);
 
-	g_clear_object (&priv->http_client);
+    g_clear_object(&priv->http_client);
 
-	G_OBJECT_CLASS (nmcs_provider_parent_class)->dispose (object);
+    G_OBJECT_CLASS(nmcs_provider_parent_class)->dispose(object);
 }
 
 static void
-nmcs_provider_class_init (NMCSProviderClass *klass)
+nmcs_provider_class_init(NMCSProviderClass *klass)
 {
-	GObjectClass *object_class = G_OBJECT_CLASS (klass);
+    GObjectClass *object_class = G_OBJECT_CLASS(klass);
 
-	g_type_class_add_private (object_class, sizeof (NMCSProviderPrivate));
+    g_type_class_add_private(object_class, sizeof(NMCSProviderPrivate));
 
-	object_class->set_property = set_property;
-	object_class->dispose      = dispose;
+    object_class->set_property = set_property;
+    object_class->dispose      = dispose;
 
-	obj_properties[PROP_HTTP_CLIENT] =
-	    g_param_spec_object (NMCS_PROVIDER_HTTP_CLIENT, "", "",
-	                         NM_TYPE_HTTP_CLIENT,
-	                         G_PARAM_WRITABLE |
-	                         G_PARAM_CONSTRUCT_ONLY |
-	                         G_PARAM_STATIC_STRINGS);
+    obj_properties[PROP_HTTP_CLIENT] =
+        g_param_spec_object(NMCS_PROVIDER_HTTP_CLIENT,
+                            "",
+                            "",
+                            NM_TYPE_HTTP_CLIENT,
+                            G_PARAM_WRITABLE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_STRINGS);
 
-	g_object_class_install_properties (object_class, _PROPERTY_ENUMS_LAST, obj_properties);
+    g_object_class_install_properties(object_class, _PROPERTY_ENUMS_LAST, obj_properties);
 }