[gnome-online-miners/wip/rishi/insert-share: 3/10] miner: Port gom_miner_refresh_db() to GTask
- From: Debarshi Ray <debarshir src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [gnome-online-miners/wip/rishi/insert-share: 3/10] miner: Port gom_miner_refresh_db() to GTask
- Date: Fri, 2 Sep 2016 15:07:08 +0000 (UTC)
commit 1b73797fa81fe32738b85008dd68ad847640926d
Author: Debarshi Ray <debarshir gnome org>
Date: Fri Sep 2 13:56:49 2016 +0200
miner: Port gom_miner_refresh_db() to GTask
src/gom-miner.c | 30 +++++++++++++-----------------
1 files changed, 13 insertions(+), 17 deletions(-)
---
diff --git a/src/gom-miner.c b/src/gom-miner.c
index 18979ad..3fe098d 100644
--- a/src/gom-miner.c
+++ b/src/gom-miner.c
@@ -38,7 +38,7 @@ struct _GomMinerPrivate {
GError *connection_error;
GCancellable *cancellable;
- GSimpleAsyncResult *result;
+ GTask *task;
GList *pending_jobs;
@@ -82,7 +82,7 @@ gom_miner_dispose (GObject *object)
g_clear_object (&self->priv->client);
g_clear_object (&self->priv->connection);
g_clear_object (&self->priv->cancellable);
- g_clear_object (&self->priv->result);
+ g_clear_object (&self->priv->task);
g_free (self->priv->display_name);
g_strfreev (self->priv->index_types);
@@ -173,17 +173,15 @@ static void
gom_miner_complete_error (GomMiner *self,
GError *error)
{
- g_assert (self->priv->result != NULL);
-
- g_simple_async_result_take_error (self->priv->result, error);
- g_simple_async_result_complete_in_idle (self->priv->result);
+ g_assert (self->priv->task != NULL);
+ g_task_return_error (self->priv->task, g_error_copy (error));
}
static void
gom_miner_check_pending_jobs (GomMiner *self)
{
if (g_list_length (self->priv->pending_jobs) == 0)
- g_simple_async_result_complete_in_idle (self->priv->result);
+ g_task_return_boolean (self->priv->task, TRUE);
}
static void
@@ -727,10 +725,9 @@ gom_miner_refresh_db_async (GomMiner *self,
return;
}
- self->priv->result =
- g_simple_async_result_new (G_OBJECT (self),
- callback, user_data,
- gom_miner_refresh_db_async);
+ self->priv->task = g_task_new (self, cancellable, callback, user_data);
+ g_task_set_source_tag (self->priv->task, gom_miner_refresh_db_async);
+
self->priv->cancellable =
(cancellable != NULL) ? g_object_ref (cancellable) : NULL;
@@ -742,15 +739,14 @@ gom_miner_refresh_db_finish (GomMiner *self,
GAsyncResult *res,
GError **error)
{
- GSimpleAsyncResult *simple_res = G_SIMPLE_ASYNC_RESULT (res);
+ GTask *task;
- g_assert (g_simple_async_result_is_valid (res, G_OBJECT (self),
- gom_miner_refresh_db_async));
+ g_assert (g_task_is_valid (res, self));
+ task = G_TASK (res);
- if (g_simple_async_result_propagate_error (simple_res, error))
- return FALSE;
+ g_assert (g_task_get_source_tag (task) == gom_miner_refresh_db_async);
- return TRUE;
+ return g_task_propagate_boolean (task, error);
}
void
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]