|
Packit Service |
dff8e4 |
/* SPDX-License-Identifier: LGPL-2.1-or-later */
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
#include "libnm-client-aux-extern/nm-default-client.h"
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
#include "nmcs-provider-gcp.h"
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
#include "nm-cloud-setup-utils.h"
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
/*****************************************************************************/
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
#define HTTP_TIMEOUT_MS 3000
|
|
Packit Service |
dff8e4 |
#define HTTP_REQ_MAX_DATA 512 * 1024
|
|
Packit Service |
dff8e4 |
#define HTTP_POLL_TIMEOUT_MS 10000
|
|
Packit Service |
dff8e4 |
#define HTTP_RATE_LIMIT_MS 1000
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
#define NM_GCP_HOST "metadata.google.internal"
|
|
Packit Service |
dff8e4 |
#define NM_GCP_BASE "http://" NM_GCP_HOST
|
|
Packit Service |
dff8e4 |
#define NM_GCP_API_VERSION "/v1"
|
|
Packit Service |
dff8e4 |
#define NM_GCP_METADATA_URL_BASE NM_GCP_BASE "/computeMetadata" NM_GCP_API_VERSION "/instance"
|
|
Packit Service |
dff8e4 |
#define NM_GCP_METADATA_URL_NET "/network-interfaces/"
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
#define NM_GCP_METADATA_HEADER "Metadata-Flavor: Google"
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
#define _gcp_uri_concat(...) nmcs_utils_uri_build_concat(NM_GCP_METADATA_URL_BASE, __VA_ARGS__)
|
|
Packit Service |
dff8e4 |
#define _gcp_uri_interfaces(...) _gcp_uri_concat(NM_GCP_METADATA_URL_NET, ##__VA_ARGS__)
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
/*****************************************************************************/
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
struct _NMCSProviderGCP {
|
|
Packit Service |
dff8e4 |
NMCSProvider parent;
|
|
Packit Service |
dff8e4 |
};
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
struct _NMCSProviderGCPClass {
|
|
Packit Service |
dff8e4 |
NMCSProviderClass parent;
|
|
Packit Service |
dff8e4 |
};
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
G_DEFINE_TYPE(NMCSProviderGCP, nmcs_provider_gcp, NMCS_TYPE_PROVIDER);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
/*****************************************************************************/
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
static void
|
|
Packit Service |
dff8e4 |
_detect_get_meta_data_done_cb(GObject *source, GAsyncResult *result, gpointer user_data)
|
|
Packit Service |
dff8e4 |
{
|
|
Packit Service |
dff8e4 |
gs_unref_object GTask *task = user_data;
|
|
Packit Service |
dff8e4 |
gs_free_error GError *get_error = NULL;
|
|
Packit Service |
dff8e4 |
gs_free_error GError *error = NULL;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_http_client_poll_get_finish(NM_HTTP_CLIENT(source), result, NULL, NULL, &get_error);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (nm_utils_error_is_cancelled(get_error)) {
|
|
Packit Service |
dff8e4 |
g_task_return_error(task, g_steal_pointer(&get_error));
|
|
Packit Service |
dff8e4 |
return;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (get_error) {
|
|
Packit Service |
dff8e4 |
nm_utils_error_set(&error,
|
|
Packit Service |
dff8e4 |
NM_UTILS_ERROR_UNKNOWN,
|
|
Packit Service |
dff8e4 |
"failure to get GCP metadata: %s",
|
|
Packit Service |
dff8e4 |
get_error->message);
|
|
Packit Service |
dff8e4 |
g_task_return_error(task, g_steal_pointer(&error));
|
|
Packit Service |
dff8e4 |
return;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
g_task_return_boolean(task, TRUE);
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
static void
|
|
Packit Service |
dff8e4 |
detect(NMCSProvider *provider, GTask *task)
|
|
Packit Service |
dff8e4 |
{
|
|
Packit Service |
dff8e4 |
NMHttpClient *http_client;
|
|
Packit Service |
dff8e4 |
gs_free char *uri = NULL;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
http_client = nmcs_provider_get_http_client(provider);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_http_client_poll_get(http_client,
|
|
Packit Service |
dff8e4 |
(uri = _gcp_uri_concat("id")),
|
|
Packit Service |
dff8e4 |
HTTP_TIMEOUT_MS,
|
|
Packit Service |
dff8e4 |
256 * 1024,
|
|
Packit Service |
dff8e4 |
7000,
|
|
Packit Service |
dff8e4 |
1000,
|
|
Packit Service |
dff8e4 |
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
|
Packit Service |
dff8e4 |
g_task_get_cancellable(task),
|
|
Packit Service |
dff8e4 |
NULL,
|
|
Packit Service |
dff8e4 |
NULL,
|
|
Packit Service |
dff8e4 |
_detect_get_meta_data_done_cb,
|
|
Packit Service |
dff8e4 |
task);
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
/*****************************************************************************/
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
typedef struct {
|
|
Packit Service |
dff8e4 |
NMCSProviderGetConfigTaskData * get_config_data;
|
|
Packit Service |
dff8e4 |
NMCSProviderGetConfigIfaceData *iface_get_config;
|
|
Packit Service |
dff8e4 |
gssize intern_iface_idx;
|
|
Packit Service |
dff8e4 |
gssize extern_iface_idx;
|
|
Packit Service |
dff8e4 |
guint n_fips_pending;
|
|
Packit Service |
dff8e4 |
} GCPIfaceData;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
static void
|
|
Packit Service |
dff8e4 |
_gcp_iface_data_destroy(GCPIfaceData *iface_data)
|
|
Packit Service |
dff8e4 |
{
|
|
Packit Service |
dff8e4 |
nm_g_slice_free(iface_data);
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
static void
|
|
Packit Service |
dff8e4 |
_get_config_fip_cb(GObject *source, GAsyncResult *result, gpointer user_data)
|
|
Packit Service |
dff8e4 |
{
|
|
Packit Service |
dff8e4 |
NMCSProviderGetConfigTaskData * get_config_data;
|
|
Packit Service |
dff8e4 |
NMCSProviderGetConfigIfaceData *iface_get_config;
|
|
Packit Service |
dff8e4 |
gs_unref_bytes GBytes *response = NULL;
|
|
Packit Service |
dff8e4 |
GCPIfaceData * iface_data = user_data;
|
|
Packit Service |
dff8e4 |
gs_free_error GError *error = NULL;
|
|
Packit Service |
dff8e4 |
gs_free char * ipaddr = NULL;
|
|
Packit Service |
dff8e4 |
NMIPRoute ** routes_arr;
|
|
Packit Service |
dff8e4 |
NMIPRoute * route_new;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_http_client_poll_get_finish(NM_HTTP_CLIENT(source), result, NULL, &response, &error);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (nm_utils_error_is_cancelled(error))
|
|
Packit Service |
dff8e4 |
return;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
get_config_data = iface_data->get_config_data;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (error)
|
|
Packit Service |
dff8e4 |
goto out_done;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
ipaddr = nmcs_utils_ipaddr_normalize_gbytes(AF_INET, response);
|
|
Packit Service |
dff8e4 |
if (!ipaddr) {
|
|
Packit Service |
dff8e4 |
error =
|
|
Packit Service |
dff8e4 |
nm_utils_error_new(NM_UTILS_ERROR_UNKNOWN, "forwarded-ip is not a valid ip address");
|
|
Packit Service |
dff8e4 |
goto out_done;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
_LOGI("GCP interface[%" G_GSSIZE_FORMAT "]: adding forwarded-ip %s",
|
|
Packit Service |
dff8e4 |
iface_data->intern_iface_idx,
|
|
Packit Service |
dff8e4 |
ipaddr);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
iface_get_config = iface_data->iface_get_config;
|
|
Packit Service |
dff8e4 |
routes_arr = iface_get_config->iproutes_arr;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
route_new = nm_ip_route_new(AF_INET, ipaddr, 32, NULL, 100, &error);
|
|
Packit Service |
dff8e4 |
if (error)
|
|
Packit Service |
dff8e4 |
goto out_done;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_ip_route_set_attribute(route_new, NM_IP_ROUTE_ATTRIBUTE_TYPE, g_variant_new_string("local"));
|
|
Packit Service |
dff8e4 |
routes_arr[iface_get_config->iproutes_len] = route_new;
|
|
Packit Service |
dff8e4 |
++iface_get_config->iproutes_len;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
out_done:
|
|
Packit Service |
dff8e4 |
if (!error) {
|
|
Packit Service |
dff8e4 |
--iface_data->n_fips_pending;
|
|
Packit Service |
dff8e4 |
if (iface_data->n_fips_pending > 0)
|
|
Packit Service |
dff8e4 |
return;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
--get_config_data->n_pending;
|
|
Packit Service |
dff8e4 |
_nmcs_provider_get_config_task_maybe_return(get_config_data, g_steal_pointer(&error));
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
static void
|
|
Packit Service |
dff8e4 |
_get_config_ips_list_cb(GObject *source, GAsyncResult *result, gpointer user_data)
|
|
Packit Service |
dff8e4 |
{
|
|
Packit Service |
dff8e4 |
NMCSProviderGetConfigTaskData *get_config_data;
|
|
Packit Service |
dff8e4 |
gs_unref_ptrarray GPtrArray *uri_arr = NULL;
|
|
Packit Service |
dff8e4 |
gs_unref_bytes GBytes *response = NULL;
|
|
Packit Service |
dff8e4 |
GCPIfaceData * iface_data = user_data;
|
|
Packit Service |
dff8e4 |
gs_free_error GError *error = NULL;
|
|
Packit Service |
dff8e4 |
const char * response_str = NULL;
|
|
Packit Service |
dff8e4 |
gsize response_len;
|
|
Packit Service |
dff8e4 |
const char * line;
|
|
Packit Service |
dff8e4 |
gsize line_len;
|
|
Packit Service |
dff8e4 |
guint i;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_http_client_poll_get_finish(NM_HTTP_CLIENT(source), result, NULL, &response, &error);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (nm_utils_error_is_cancelled(error))
|
|
Packit Service |
dff8e4 |
return;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
get_config_data = iface_data->get_config_data;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (error)
|
|
Packit Service |
dff8e4 |
goto out_error;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
response_str = g_bytes_get_data(response, &response_len);
|
|
Packit Service |
dff8e4 |
/* NMHttpClient guarantees that there is a trailing NUL after the data. */
|
|
Packit Service |
dff8e4 |
nm_assert(response_str[response_len] == 0);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
uri_arr = g_ptr_array_new_with_free_func(g_free);
|
|
Packit Service |
dff8e4 |
while (nm_utils_parse_next_line(&response_str, &response_len, &line, &line_len)) {
|
|
Packit Service |
dff8e4 |
gint64 fip_index;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
/* Truncate the string. It's safe to do, because we own @response an it has an
|
|
Packit Service |
dff8e4 |
* extra NUL character after the buffer. */
|
|
Packit Service |
dff8e4 |
((char *) line)[line_len] = '\0';
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
fip_index = _nm_utils_ascii_str_to_int64(line, 10, 0, G_MAXINT64, -1);
|
|
Packit Service |
dff8e4 |
if (fip_index < 0)
|
|
Packit Service |
dff8e4 |
continue;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
g_ptr_array_add(uri_arr,
|
|
Packit Service |
dff8e4 |
g_strdup_printf("%" G_GSSIZE_FORMAT "/forwarded-ips/%" G_GINT64_FORMAT,
|
|
Packit Service |
dff8e4 |
iface_data->intern_iface_idx,
|
|
Packit Service |
dff8e4 |
fip_index));
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
iface_data->n_fips_pending = uri_arr->len;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
_LOGI("GCP interface[%" G_GSSIZE_FORMAT "]: found %u forwarded ips",
|
|
Packit Service |
dff8e4 |
iface_data->intern_iface_idx,
|
|
Packit Service |
dff8e4 |
iface_data->n_fips_pending);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (iface_data->n_fips_pending == 0) {
|
|
Packit Service |
dff8e4 |
error = nm_utils_error_new(NM_UTILS_ERROR_UNKNOWN, "found no forwarded ip");
|
|
Packit Service |
dff8e4 |
goto out_error;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
iface_data->iface_get_config->iproutes_arr = g_new(NMIPRoute *, iface_data->n_fips_pending);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
for (i = 0; i < uri_arr->len; ++i) {
|
|
Packit Service |
dff8e4 |
const char * str = uri_arr->pdata[i];
|
|
Packit Service |
dff8e4 |
gs_free const char *uri = NULL;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_http_client_poll_get(NM_HTTP_CLIENT(source),
|
|
Packit Service |
dff8e4 |
(uri = _gcp_uri_interfaces(str)),
|
|
Packit Service |
dff8e4 |
HTTP_TIMEOUT_MS,
|
|
Packit Service |
dff8e4 |
HTTP_REQ_MAX_DATA,
|
|
Packit Service |
dff8e4 |
HTTP_POLL_TIMEOUT_MS,
|
|
Packit Service |
dff8e4 |
HTTP_RATE_LIMIT_MS,
|
|
Packit Service |
dff8e4 |
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
|
Packit Service |
dff8e4 |
get_config_data->intern_cancellable,
|
|
Packit Service |
dff8e4 |
NULL,
|
|
Packit Service |
dff8e4 |
NULL,
|
|
Packit Service |
dff8e4 |
_get_config_fip_cb,
|
|
Packit Service |
dff8e4 |
iface_data);
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
return;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
out_error:
|
|
Packit Service |
dff8e4 |
--get_config_data->n_pending;
|
|
Packit Service |
dff8e4 |
_nmcs_provider_get_config_task_maybe_return(get_config_data, g_steal_pointer(&error));
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
static void
|
|
Packit Service |
dff8e4 |
_get_config_iface_cb(GObject *source, GAsyncResult *result, gpointer user_data)
|
|
Packit Service |
dff8e4 |
{
|
|
Packit Service |
dff8e4 |
gs_unref_bytes GBytes *response = NULL;
|
|
Packit Service |
dff8e4 |
GCPIfaceData * iface_data = user_data;
|
|
Packit Service |
dff8e4 |
gs_free_error GError * error = NULL;
|
|
Packit Service |
dff8e4 |
gs_free char * v_hwaddr = NULL;
|
|
Packit Service |
dff8e4 |
const char * hwaddr = NULL;
|
|
Packit Service |
dff8e4 |
gs_free const char * uri = NULL;
|
|
Packit Service |
dff8e4 |
char sbuf[100];
|
|
Packit Service |
dff8e4 |
NMCSProviderGetConfigTaskData *get_config_data;
|
|
Packit Service |
dff8e4 |
gboolean is_requested;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_http_client_poll_get_finish(NM_HTTP_CLIENT(source), result, NULL, &response, &error);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (nm_utils_error_is_cancelled(error))
|
|
Packit Service |
dff8e4 |
return;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
get_config_data = iface_data->get_config_data;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (error)
|
|
Packit Service |
dff8e4 |
goto out_done;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
v_hwaddr = nmcs_utils_hwaddr_normalize_gbytes(response);
|
|
Packit Service |
dff8e4 |
if (!v_hwaddr) {
|
|
Packit Service |
dff8e4 |
_LOGI("GCP interface[%" G_GSSIZE_FORMAT "]: invalid MAC address returned",
|
|
Packit Service |
dff8e4 |
iface_data->intern_iface_idx);
|
|
Packit Service |
dff8e4 |
error = nm_utils_error_new(NM_UTILS_ERROR_UNKNOWN,
|
|
Packit Service |
dff8e4 |
"invalid MAC address for index %" G_GSSIZE_FORMAT,
|
|
Packit Service |
dff8e4 |
iface_data->intern_iface_idx);
|
|
Packit Service |
dff8e4 |
goto out_done;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (!g_hash_table_lookup_extended(get_config_data->result_dict,
|
|
Packit Service |
dff8e4 |
v_hwaddr,
|
|
Packit Service |
dff8e4 |
(gpointer *) &hwaddr,
|
|
Packit Service |
dff8e4 |
(gpointer *) &iface_data->iface_get_config)) {
|
|
Packit Service |
dff8e4 |
if (!get_config_data->any) {
|
|
Packit Service |
dff8e4 |
_LOGD("get-config: skip fetching meta data for %s (%" G_GSSIZE_FORMAT ")",
|
|
Packit Service |
dff8e4 |
v_hwaddr,
|
|
Packit Service |
dff8e4 |
iface_data->intern_iface_idx);
|
|
Packit Service |
dff8e4 |
goto out_done;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
iface_data->iface_get_config = nmcs_provider_get_config_iface_data_new(FALSE);
|
|
Packit Service |
dff8e4 |
g_hash_table_insert(get_config_data->result_dict,
|
|
Packit Service |
dff8e4 |
(char *) (hwaddr = g_steal_pointer(&v_hwaddr)),
|
|
Packit Service |
dff8e4 |
iface_data->iface_get_config);
|
|
Packit Service |
dff8e4 |
is_requested = FALSE;
|
|
Packit Service |
dff8e4 |
} else {
|
|
Packit Service |
dff8e4 |
if (iface_data->iface_get_config->iface_idx >= 0) {
|
|
Packit Service |
dff8e4 |
_LOGI("GCP interface[%" G_GSSIZE_FORMAT "]: duplicate MAC address %s returned",
|
|
Packit Service |
dff8e4 |
iface_data->intern_iface_idx,
|
|
Packit Service |
dff8e4 |
hwaddr);
|
|
Packit Service |
dff8e4 |
error = nm_utils_error_new(NM_UTILS_ERROR_UNKNOWN,
|
|
Packit Service |
dff8e4 |
"duplicate MAC address for index %" G_GSSIZE_FORMAT,
|
|
Packit Service |
dff8e4 |
iface_data->intern_iface_idx);
|
|
Packit Service |
dff8e4 |
goto out_done;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
is_requested = TRUE;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
iface_data->iface_get_config->iface_idx = iface_data->extern_iface_idx;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
_LOGI("GCP interface[%" G_GSSIZE_FORMAT "]: found a %sdevice with hwaddr %s",
|
|
Packit Service |
dff8e4 |
iface_data->intern_iface_idx,
|
|
Packit Service |
dff8e4 |
is_requested ? "requested " : "",
|
|
Packit Service |
dff8e4 |
hwaddr);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_sprintf_buf(sbuf, "%" G_GSSIZE_FORMAT "/forwarded-ips/", iface_data->intern_iface_idx);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_http_client_poll_get(NM_HTTP_CLIENT(source),
|
|
Packit Service |
dff8e4 |
(uri = _gcp_uri_interfaces(sbuf)),
|
|
Packit Service |
dff8e4 |
HTTP_TIMEOUT_MS,
|
|
Packit Service |
dff8e4 |
HTTP_REQ_MAX_DATA,
|
|
Packit Service |
dff8e4 |
HTTP_POLL_TIMEOUT_MS,
|
|
Packit Service |
dff8e4 |
HTTP_RATE_LIMIT_MS,
|
|
Packit Service |
dff8e4 |
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
|
Packit Service |
dff8e4 |
get_config_data->intern_cancellable,
|
|
Packit Service |
dff8e4 |
NULL,
|
|
Packit Service |
dff8e4 |
NULL,
|
|
Packit Service |
dff8e4 |
_get_config_ips_list_cb,
|
|
Packit Service |
dff8e4 |
iface_data);
|
|
Packit Service |
dff8e4 |
return;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
out_done:
|
|
Packit Service |
dff8e4 |
--get_config_data->n_pending;
|
|
Packit Service |
dff8e4 |
_nmcs_provider_get_config_task_maybe_return(get_config_data, g_steal_pointer(&error));
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
static void
|
|
Packit Service |
dff8e4 |
_get_net_ifaces_list_cb(GObject *source, GAsyncResult *result, gpointer user_data)
|
|
Packit Service |
dff8e4 |
{
|
|
Packit Service |
dff8e4 |
gs_unref_ptrarray GPtrArray *ifaces_arr = NULL;
|
|
Packit Service |
dff8e4 |
gs_unref_bytes GBytes *response = NULL;
|
|
Packit Service |
dff8e4 |
gs_free_error GError * error = NULL;
|
|
Packit Service |
dff8e4 |
NMCSProviderGetConfigTaskData *get_config_data;
|
|
Packit Service |
dff8e4 |
const char * response_str;
|
|
Packit Service |
dff8e4 |
gsize response_len;
|
|
Packit Service |
dff8e4 |
const char * line;
|
|
Packit Service |
dff8e4 |
gsize line_len;
|
|
Packit Service |
dff8e4 |
guint i;
|
|
Packit Service |
dff8e4 |
gssize extern_iface_idx_cnt = 0;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_http_client_poll_get_finish(NM_HTTP_CLIENT(source), result, NULL, &response, &error);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (nm_utils_error_is_cancelled(error))
|
|
Packit Service |
dff8e4 |
return;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
get_config_data = user_data;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (error) {
|
|
Packit Service |
dff8e4 |
_nmcs_provider_get_config_task_maybe_return(get_config_data, g_steal_pointer(&error));
|
|
Packit Service |
dff8e4 |
return;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
response_str = g_bytes_get_data(response, &response_len);
|
|
Packit Service |
dff8e4 |
/* NMHttpClient guarantees that there is a trailing NUL after the data. */
|
|
Packit Service |
dff8e4 |
nm_assert(response_str[response_len] == 0);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
ifaces_arr = g_ptr_array_new_with_free_func((GDestroyNotify) _gcp_iface_data_destroy);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
while (nm_utils_parse_next_line(&response_str, &response_len, &line, &line_len)) {
|
|
Packit Service |
dff8e4 |
GCPIfaceData *iface_data;
|
|
Packit Service |
dff8e4 |
gssize intern_iface_idx;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (line_len == 0)
|
|
Packit Service |
dff8e4 |
continue;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
/* Truncate the string. It's safe to do, because we own @response an it has an
|
|
Packit Service |
dff8e4 |
* extra NUL character after the buffer. */
|
|
Packit Service |
dff8e4 |
((char *) line)[line_len] = '\0';
|
|
Packit Service |
dff8e4 |
if (line[line_len - 1] == '/')
|
|
Packit Service |
dff8e4 |
((char *) line)[--line_len] = '\0';
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
intern_iface_idx = _nm_utils_ascii_str_to_int64(line, 10, 0, G_MAXSSIZE, -1);
|
|
Packit Service |
dff8e4 |
if (intern_iface_idx < 0)
|
|
Packit Service |
dff8e4 |
continue;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
iface_data = g_slice_new(GCPIfaceData);
|
|
Packit Service |
dff8e4 |
*iface_data = (GCPIfaceData){
|
|
Packit Service |
dff8e4 |
.get_config_data = get_config_data,
|
|
Packit Service |
dff8e4 |
.iface_get_config = NULL,
|
|
Packit Service |
dff8e4 |
.intern_iface_idx = intern_iface_idx,
|
|
Packit Service |
dff8e4 |
.extern_iface_idx = extern_iface_idx_cnt++,
|
|
Packit Service |
dff8e4 |
.n_fips_pending = 0,
|
|
Packit Service |
dff8e4 |
};
|
|
Packit Service |
dff8e4 |
g_ptr_array_add(ifaces_arr, iface_data);
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
_LOGI("found GCP interfaces: %u", ifaces_arr->len);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
if (ifaces_arr->len == 0) {
|
|
Packit Service |
dff8e4 |
_nmcs_provider_get_config_task_maybe_return(
|
|
Packit Service |
dff8e4 |
get_config_data,
|
|
Packit Service |
dff8e4 |
nm_utils_error_new(NM_UTILS_ERROR_UNKNOWN, "no GCP interfaces found"));
|
|
Packit Service |
dff8e4 |
return;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
for (i = 0; i < ifaces_arr->len; ++i) {
|
|
Packit Service |
dff8e4 |
GCPIfaceData * data = ifaces_arr->pdata[i];
|
|
Packit Service |
dff8e4 |
gs_free const char *uri = NULL;
|
|
Packit Service |
dff8e4 |
char sbuf[100];
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
_LOGD("GCP interface[%" G_GSSIZE_FORMAT "]: retrieving configuration",
|
|
Packit Service |
dff8e4 |
data->intern_iface_idx);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_sprintf_buf(sbuf, "%" G_GSSIZE_FORMAT "/mac", data->intern_iface_idx);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
get_config_data->n_pending++;
|
|
Packit Service |
dff8e4 |
nm_http_client_poll_get(NM_HTTP_CLIENT(source),
|
|
Packit Service |
dff8e4 |
(uri = _gcp_uri_interfaces(sbuf)),
|
|
Packit Service |
dff8e4 |
HTTP_TIMEOUT_MS,
|
|
Packit Service |
dff8e4 |
HTTP_REQ_MAX_DATA,
|
|
Packit Service |
dff8e4 |
HTTP_POLL_TIMEOUT_MS,
|
|
Packit Service |
dff8e4 |
HTTP_RATE_LIMIT_MS,
|
|
Packit Service |
dff8e4 |
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
|
Packit Service |
dff8e4 |
get_config_data->intern_cancellable,
|
|
Packit Service |
dff8e4 |
NULL,
|
|
Packit Service |
dff8e4 |
NULL,
|
|
Packit Service |
dff8e4 |
_get_config_iface_cb,
|
|
Packit Service |
dff8e4 |
data);
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
get_config_data->extra_data = g_steal_pointer(&ifaces_arr);
|
|
Packit Service |
dff8e4 |
get_config_data->extra_data_destroy = (GDestroyNotify) g_ptr_array_unref;
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
static void
|
|
Packit Service |
dff8e4 |
get_config(NMCSProvider *provider, NMCSProviderGetConfigTaskData *get_config_data)
|
|
Packit Service |
dff8e4 |
{
|
|
Packit Service |
dff8e4 |
gs_free const char *uri = NULL;
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
nm_http_client_poll_get(nmcs_provider_get_http_client(provider),
|
|
Packit Service |
dff8e4 |
(uri = _gcp_uri_interfaces()),
|
|
Packit Service |
dff8e4 |
HTTP_TIMEOUT_MS,
|
|
Packit Service |
dff8e4 |
HTTP_REQ_MAX_DATA,
|
|
Packit Service |
dff8e4 |
HTTP_POLL_TIMEOUT_MS,
|
|
Packit Service |
dff8e4 |
HTTP_RATE_LIMIT_MS,
|
|
Packit Service |
dff8e4 |
NM_MAKE_STRV(NM_GCP_METADATA_HEADER),
|
|
Packit Service |
dff8e4 |
get_config_data->intern_cancellable,
|
|
Packit Service |
dff8e4 |
NULL,
|
|
Packit Service |
dff8e4 |
NULL,
|
|
Packit Service |
dff8e4 |
_get_net_ifaces_list_cb,
|
|
Packit Service |
dff8e4 |
get_config_data);
|
|
Packit Service |
dff8e4 |
}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
/*****************************************************************************/
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
static void
|
|
Packit Service |
dff8e4 |
nmcs_provider_gcp_init(NMCSProviderGCP *self)
|
|
Packit Service |
dff8e4 |
{}
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
static void
|
|
Packit Service |
dff8e4 |
nmcs_provider_gcp_class_init(NMCSProviderGCPClass *klass)
|
|
Packit Service |
dff8e4 |
{
|
|
Packit Service |
dff8e4 |
NMCSProviderClass *provider_class = NMCS_PROVIDER_CLASS(klass);
|
|
Packit Service |
dff8e4 |
|
|
Packit Service |
dff8e4 |
provider_class->_name = "GCP";
|
|
Packit Service |
dff8e4 |
provider_class->_env_provider_enabled = NMCS_ENV_VARIABLE("NM_CLOUD_SETUP_GCP");
|
|
Packit Service |
dff8e4 |
provider_class->detect = detect;
|
|
Packit Service |
dff8e4 |
provider_class->get_config = get_config;
|
|
Packit Service |
dff8e4 |
}
|