[gnome-software] snap: Rename some internal functions
- From: Richard Hughes <rhughes src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [gnome-software] snap: Rename some internal functions
- Date: Tue, 4 Apr 2017 09:57:35 +0000 (UTC)
commit 58930e790a92e364992ca26101810cc5a7143bb7
Author: Richard Hughes <richard hughsie com>
Date: Tue Apr 4 10:30:49 2017 +0100
snap: Rename some internal functions
Give the private functions a 'gs_' prefix to indicate the domain of error they
are supposed to return.
plugins/snap/gs-snapd.c | 121 ++++++++++++++++++++++++-----------------------
1 files changed, 61 insertions(+), 60 deletions(-)
---
diff --git a/plugins/snap/gs-snapd.c b/plugins/snap/gs-snapd.c
index 81f223e..05cac5a 100644
--- a/plugins/snap/gs-snapd.c
+++ b/plugins/snap/gs-snapd.c
@@ -42,7 +42,7 @@ gs_snapd_exists (void)
}
static GSocket *
-open_snapd_socket (GCancellable *cancellable, GError **error)
+gs_snapd_socket_open (GCancellable *cancellable, GError **error)
{
GSocket *socket;
g_autoptr(GSocketAddress) address = NULL;
@@ -75,12 +75,12 @@ open_snapd_socket (GCancellable *cancellable, GError **error)
}
static gboolean
-read_from_snapd (GSocket *socket,
- GByteArray *buffer,
- gsize *read_offset,
- gsize size,
- GCancellable *cancellable,
- GError **error)
+gs_snapd_socket_read (GSocket *socket,
+ GByteArray *buffer,
+ gsize *read_offset,
+ gsize size,
+ GCancellable *cancellable,
+ GError **error)
{
gssize n_read;
@@ -102,18 +102,18 @@ read_from_snapd (GSocket *socket,
}
static gboolean
-send_request (const gchar *method,
- const gchar *path,
- const gchar *content,
- const gchar *macaroon,
- gchar **discharges,
- guint *status_code,
- gchar **reason_phrase,
- gchar **response_type,
- gchar **response,
- gsize *response_length,
- GCancellable *cancellable,
- GError **error)
+gs_snapd_send_request (const gchar *method,
+ const gchar *path,
+ const gchar *content,
+ const gchar *macaroon,
+ gchar **discharges,
+ guint *status_code,
+ gchar **reason_phrase,
+ gchar **response_type,
+ gchar **response,
+ gsize *response_length,
+ GCancellable *cancellable,
+ GError **error)
{
g_autoptr (GSocket) socket = NULL;
g_autoptr (GString) request = NULL;
@@ -129,7 +129,7 @@ send_request (const gchar *method,
// NOTE: Would love to use libsoup but it doesn't support unix sockets
// https://bugzilla.gnome.org/show_bug.cgi?id=727563
- socket = open_snapd_socket (cancellable, error);
+ socket = gs_snapd_socket_open (cancellable, error);
if (socket == NULL)
return FALSE;
@@ -162,7 +162,7 @@ send_request (const gchar *method,
/* read HTTP headers */
buffer = g_byte_array_new ();
while (body == NULL) {
- if (!read_from_snapd (socket,
+ if (!gs_snapd_socket_read (socket,
buffer,
&data_length,
1024,
@@ -202,7 +202,7 @@ send_request (const gchar *method,
case SOUP_ENCODING_EOF:
while (TRUE) {
gsize n_read = data_length;
- if (!read_from_snapd (socket,
+ if (!gs_snapd_socket_read (socket,
buffer,
&data_length,
1024,
@@ -220,7 +220,7 @@ send_request (const gchar *method,
chunk_start = strstr (body, "\r\n");
if (chunk_start)
break;
- if (!read_from_snapd (socket,
+ if (!gs_snapd_socket_read (socket,
buffer,
&data_length,
1024,
@@ -242,7 +242,7 @@ send_request (const gchar *method,
/* check if enough space to read chunk */
n_required = (chunk_start - buffer->data) + chunk_length;
while (data_length < n_required)
- if (!read_from_snapd (socket,
+ if (!gs_snapd_socket_read (socket,
buffer,
&data_length,
n_required - data_length,
@@ -255,12 +255,12 @@ send_request (const gchar *method,
chunk_start = body;
n_required = header_length + chunk_length;
while (data_length < n_required) {
- if (!read_from_snapd (socket,
- buffer,
- &data_length,
- n_required - data_length,
- cancellable,
- error))
+ if (!gs_snapd_socket_read (socket,
+ buffer,
+ &data_length,
+ n_required - data_length,
+ cancellable,
+ error))
return FALSE;
}
break;
@@ -288,11 +288,12 @@ send_request (const gchar *method,
}
static JsonParser *
-parse_result (const gchar *response, const gchar *response_type, GError **error)
+gs_snapd_parse_result (const gchar *response, const gchar *response_type, GError **error)
{
g_autoptr(JsonParser) parser = NULL;
g_autoptr(GError) error_local = NULL;
+ g_warning ("trying to parse %s: %s", response_type, response);
if (response_type == NULL) {
g_set_error_literal (error,
GS_PLUGIN_ERROR,
@@ -342,7 +343,7 @@ gs_snapd_list_one (const gchar *macaroon, gchar **discharges,
JsonObject *root, *result;
path = g_strdup_printf ("/v2/snaps/%s", name);
- if (!send_request ("GET", path, NULL,
+ if (!gs_snapd_send_request ("GET", path, NULL,
macaroon, discharges,
&status_code, &reason_phrase,
&response_type, &response, NULL,
@@ -358,7 +359,7 @@ gs_snapd_list_one (const gchar *macaroon, gchar **discharges,
return NULL;
}
- parser = parse_result (response, response_type, error);
+ parser = gs_snapd_parse_result (response, response_type, error);
if (parser == NULL)
return NULL;
root = json_node_get_object (json_parser_get_root (parser));
@@ -386,7 +387,7 @@ gs_snapd_list (const gchar *macaroon, gchar **discharges,
JsonObject *root;
JsonArray *result;
- if (!send_request ("GET", "/v2/snaps", NULL,
+ if (!gs_snapd_send_request ("GET", "/v2/snaps", NULL,
macaroon, discharges,
&status_code, &reason_phrase,
&response_type, &response, NULL,
@@ -402,7 +403,7 @@ gs_snapd_list (const gchar *macaroon, gchar **discharges,
return NULL;
}
- parser = parse_result (response, response_type, error);
+ parser = gs_snapd_parse_result (response, response_type, error);
if (parser == NULL)
return NULL;
root = json_node_get_object (json_parser_get_root (parser));
@@ -438,7 +439,7 @@ gs_snapd_find (const gchar *macaroon, gchar **discharges,
query = g_strjoinv (" ", values);
escaped = soup_uri_encode (query, NULL);
g_string_append (path, escaped);
- if (!send_request ("GET", path->str, NULL,
+ if (!gs_snapd_send_request ("GET", path->str, NULL,
macaroon, discharges,
&status_code, &reason_phrase,
&response_type, &response, NULL,
@@ -454,7 +455,7 @@ gs_snapd_find (const gchar *macaroon, gchar **discharges,
return NULL;
}
- parser = parse_result (response, response_type, error);
+ parser = gs_snapd_parse_result (response, response_type, error);
if (parser == NULL)
return NULL;
root = json_node_get_object (json_parser_get_root (parser));
@@ -487,7 +488,7 @@ gs_snapd_find_name (const gchar *macaroon, gchar **discharges,
escaped = soup_uri_encode (name, NULL);
path = g_strdup_printf ("/v2/find?name=%s", escaped);
- if (!send_request ("GET", path, NULL,
+ if (!gs_snapd_send_request ("GET", path, NULL,
macaroon, discharges,
&status_code, &reason_phrase,
&response_type, &response, NULL,
@@ -503,7 +504,7 @@ gs_snapd_find_name (const gchar *macaroon, gchar **discharges,
return NULL;
}
- parser = parse_result (response, response_type, error);
+ parser = gs_snapd_parse_result (response, response_type, error);
if (parser == NULL)
return NULL;
root = json_node_get_object (json_parser_get_root (parser));
@@ -530,7 +531,7 @@ gs_snapd_get_interfaces (const gchar *macaroon, gchar **discharges, GCancellable
JsonObject *root;
JsonObject *result;
- if (!send_request ("GET", "/v2/interfaces", NULL,
+ if (!gs_snapd_send_request ("GET", "/v2/interfaces", NULL,
macaroon, discharges,
&status_code, &reason_phrase,
&response_type, &response, NULL,
@@ -546,7 +547,7 @@ gs_snapd_get_interfaces (const gchar *macaroon, gchar **discharges, GCancellable
return NULL;
}
- parser = parse_result (response, response_type, error);
+ parser = gs_snapd_parse_result (response, response_type, error);
if (parser == NULL)
return NULL;
root = json_node_get_object (json_parser_get_root (parser));
@@ -563,9 +564,9 @@ gs_snapd_get_interfaces (const gchar *macaroon, gchar **discharges, GCancellable
}
static JsonObject *
-get_changes (const gchar *macaroon, gchar **discharges,
- const gchar *change_id,
- GCancellable *cancellable, GError **error)
+gs_snapd_get_changes (const gchar *macaroon, gchar **discharges,
+ const gchar *change_id,
+ GCancellable *cancellable, GError **error)
{
g_autofree gchar *path = NULL;
guint status_code;
@@ -576,7 +577,7 @@ get_changes (const gchar *macaroon, gchar **discharges,
JsonObject *root, *result;
path = g_strdup_printf ("/v2/changes/%s", change_id);
- if (!send_request ("GET", path, NULL,
+ if (!gs_snapd_send_request ("GET", path, NULL,
macaroon, discharges,
&status_code, &reason_phrase,
&response_type, &response, NULL,
@@ -592,7 +593,7 @@ get_changes (const gchar *macaroon, gchar **discharges,
return NULL;
}
- parser = parse_result (response, response_type, error);
+ parser = gs_snapd_parse_result (response, response_type, error);
if (parser == NULL)
return NULL;
root = json_node_get_object (json_parser_get_root (parser));
@@ -609,14 +610,14 @@ get_changes (const gchar *macaroon, gchar **discharges,
}
static gboolean
-send_package_action (const gchar *macaroon,
- gchar **discharges,
- const gchar *name,
- const gchar *action,
- GsSnapdProgressCallback callback,
- gpointer user_data,
- GCancellable *cancellable,
- GError **error)
+gs_snapd_send_package_action (const gchar *macaroon,
+ gchar **discharges,
+ const gchar *name,
+ const gchar *action,
+ GsSnapdProgressCallback callback,
+ gpointer user_data,
+ GCancellable *cancellable,
+ GError **error)
{
g_autofree gchar *content = NULL, *path = NULL;
guint status_code;
@@ -630,7 +631,7 @@ send_package_action (const gchar *macaroon,
content = g_strdup_printf ("{\"action\": \"%s\"}", action);
path = g_strdup_printf ("/v2/snaps/%s", name);
- if (!send_request ("POST", path, content,
+ if (!gs_snapd_send_request ("POST", path, content,
macaroon, discharges,
&status_code, &reason_phrase,
&response_type, &response, NULL,
@@ -654,7 +655,7 @@ send_package_action (const gchar *macaroon,
return FALSE;
}
- parser = parse_result (response, response_type, error);
+ parser = gs_snapd_parse_result (response, response_type, error);
if (parser == NULL)
return FALSE;
@@ -670,7 +671,7 @@ send_package_action (const gchar *macaroon,
/* Wait for a little bit before polling */
g_usleep (100 * 1000);
- result = get_changes (macaroon, discharges, change_id, cancellable, error);
+ result = gs_snapd_get_changes (macaroon, discharges, change_id, cancellable, error);
if (result == NULL)
return FALSE;
@@ -701,7 +702,7 @@ gs_snapd_install (const gchar *macaroon, gchar **discharges,
GCancellable *cancellable,
GError **error)
{
- return send_package_action (macaroon, discharges, name, "install", callback, user_data, cancellable,
error);
+ return gs_snapd_send_package_action (macaroon, discharges, name, "install", callback, user_data,
cancellable, error);
}
gboolean
@@ -710,7 +711,7 @@ gs_snapd_remove (const gchar *macaroon, gchar **discharges,
GsSnapdProgressCallback callback, gpointer user_data,
GCancellable *cancellable, GError **error)
{
- return send_package_action (macaroon, discharges, name, "remove", callback, user_data, cancellable,
error);
+ return gs_snapd_send_package_action (macaroon, discharges, name, "remove", callback, user_data,
cancellable, error);
}
gchar *
@@ -724,7 +725,7 @@ gs_snapd_get_resource (const gchar *macaroon, gchar **discharges,
g_autofree gchar *response_type = NULL;
g_autofree gchar *data = NULL;
- if (!send_request ("GET", path, NULL,
+ if (!gs_snapd_send_request ("GET", path, NULL,
macaroon, discharges,
&status_code, &reason_phrase,
NULL, &data, data_length,
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]