summaryrefslogtreecommitdiff
path: root/logview/src/logview-log.c
diff options
context:
space:
mode:
authorzhuyaliang <zhuyaliang@[email protected]>2023-02-07 20:49:48 +0800
committerLuke from DC <[email protected]>2023-03-15 22:41:02 +0000
commit8b1b227abd0c3a1a32a1c37c5d3ec50d73ed60c9 (patch)
tree93463abc752afb069895de539ff29cf5be95284c /logview/src/logview-log.c
parente5df9110bedd48dace417491285bfa3ceeb45d4a (diff)
downloadmate-utils-8b1b227abd0c3a1a32a1c37c5d3ec50d73ed60c9.tar.bz2
mate-utils-8b1b227abd0c3a1a32a1c37c5d3ec50d73ed60c9.tar.xz
logview: Replace deprecated functions fix compilation warnings
Diffstat (limited to 'logview/src/logview-log.c')
-rw-r--r--logview/src/logview-log.c101
1 files changed, 46 insertions, 55 deletions
diff --git a/logview/src/logview-log.c b/logview/src/logview-log.c
index 6ff92904..1e236c52 100644
--- a/logview/src/logview-log.c
+++ b/logview/src/logview-log.c
@@ -64,17 +64,14 @@ struct _LogviewLogPrivate {
typedef struct {
LogviewLog *log;
- GError *err;
LogviewCreateCallback callback;
gpointer user_data;
} LoadJob;
typedef struct {
LogviewLog *log;
- GError *err;
const char **lines;
GSList *new_days;
- GCancellable *cancellable;
LogviewNewLinesCallback callback;
gpointer user_data;
} NewLinesJob;
@@ -237,34 +234,35 @@ add_new_days_to_cache (LogviewLog *log, const char **new_lines, guint lines_offs
return new_days;
}
-static gboolean
-new_lines_job_done (gpointer data)
+static void
+new_lines_job_done (GObject *source_object,
+ GAsyncResult *res,
+ gpointer user_data)
{
- NewLinesJob *job = data;
+ NewLinesJob *job = user_data;
+ g_autoptr(GError) error = NULL;
+ gboolean ret;
- if (job->err) {
- job->callback (job->log, NULL, NULL, job->err, job->user_data);
- g_error_free (job->err);
+ ret = g_task_propagate_boolean (G_TASK (res), &error);
+ if (!ret) {
+ job->callback (job->log, NULL, NULL, error, job->user_data);
} else {
- job->callback (job->log, job->lines, job->new_days, job->err, job->user_data);
+ job->callback (job->log, job->lines, job->new_days, error, job->user_data);
}
- g_clear_object (&job->cancellable);
-
g_slist_free_full (job->new_days, (GDestroyNotify) logview_utils_day_free);
/* drop the reference we acquired before */
g_object_unref (job->log);
g_slice_free (NewLinesJob, job);
-
- return FALSE;
}
-static gboolean
-do_read_new_lines (GIOSchedulerJob *io_job,
- GCancellable *cancellable,
- gpointer user_data)
+static void
+do_read_new_lines (GTask *task,
+ gpointer source_object,
+ gpointer user_data,
+ GCancellable *cancellable)
{
/* this runs in a separate thread */
NewLinesJob *job = user_data;
@@ -287,7 +285,7 @@ do_read_new_lines (GIOSchedulerJob *io_job,
g_ptr_array_remove_index (lines, lines->len - 1);
while ((line = g_data_input_stream_read_line (log->priv->stream, NULL,
- job->cancellable, &err)) != NULL)
+ cancellable, &err)) != NULL)
{
g_ptr_array_add (lines, (gpointer) line);
}
@@ -296,8 +294,7 @@ do_read_new_lines (GIOSchedulerJob *io_job,
g_ptr_array_add (lines, NULL);
if (err) {
- job->err = err;
- goto out;
+ g_task_return_error (task, err);
}
log->priv->has_new_lines = FALSE;
@@ -309,23 +306,23 @@ do_read_new_lines (GIOSchedulerJob *io_job,
job->new_days = add_new_days_to_cache (log, job->lines, log->priv->lines_no);
log->priv->lines_no = (lines->len - 1);
-out:
- g_io_scheduler_job_send_to_mainloop_async (io_job,
- new_lines_job_done,
- job, NULL);
- return FALSE;
+ g_task_return_boolean (task, TRUE);
}
-static gboolean
-log_load_done (gpointer user_data)
+static void
+log_load_done (GObject *source_object,
+ GAsyncResult *res,
+ gpointer user_data)
{
LoadJob *job = user_data;
+ g_autoptr(GError) error = NULL;
+ gboolean ret;
- if (job->err) {
- /* the callback will have NULL as log, and the error set */
+ ret = g_task_propagate_boolean (G_TASK (res), &error);
+
+ if (!ret) {
g_object_unref (job->log);
- job->callback (NULL, job->err, job->user_data);
- g_error_free (job->err);
+ job->callback (NULL, error, job->user_data);
} else {
job->callback (job->log, NULL, job->user_data);
setup_file_monitor (job->log);
@@ -333,7 +330,6 @@ log_load_done (gpointer user_data)
g_slice_free (LoadJob, job);
- return FALSE;
}
#ifdef HAVE_ZLIB
@@ -592,11 +588,11 @@ create_zlib_error (void)
}
#endif /* HAVE_ZLIB */
-
-static gboolean
-log_load (GIOSchedulerJob *io_job,
- GCancellable *cancellable,
- gpointer user_data)
+static void
+log_load (GTask *task,
+ gpointer source_object,
+ gpointer user_data,
+ GCancellable *cancellable)
{
/* this runs in a separate i/o thread */
LoadJob *job = user_data;
@@ -772,13 +768,10 @@ log_load (GIOSchedulerJob *io_job,
out:
if (err) {
- job->err = err;
+ g_task_return_error (task, err);
}
- g_io_scheduler_job_send_to_mainloop_async (io_job,
- log_load_done,
- job, NULL);
- return FALSE;
+ g_task_return_boolean (task, TRUE);
}
static void
@@ -786,17 +779,17 @@ log_setup_load (LogviewLog *log, LogviewCreateCallback callback,
gpointer user_data)
{
LoadJob *job;
+ GTask *task;
job = g_slice_new0 (LoadJob);
job->callback = callback;
job->user_data = user_data;
job->log = log;
- job->err = NULL;
- /* push the loading job into another thread */
- g_io_scheduler_push_job (log_load,
- job,
- NULL, 0, NULL);
+ task = g_task_new (log, NULL, log_load_done, job);
+ g_task_set_task_data (task, job, NULL);
+ g_task_run_in_thread (task, log_load);
+ g_object_unref (task);
}
/* public methods */
@@ -808,22 +801,20 @@ logview_log_read_new_lines (LogviewLog *log,
gpointer user_data)
{
NewLinesJob *job;
+ GTask *task;
/* initialize the job struct with sensible values */
job = g_slice_new0 (NewLinesJob);
job->callback = callback;
job->user_data = user_data;
- job->cancellable = (cancellable != NULL) ? g_object_ref (cancellable) : NULL;
job->log = g_object_ref (log);
- job->err = NULL;
job->lines = NULL;
job->new_days = NULL;
- /* push the fetching job into another thread */
- g_io_scheduler_push_job (do_read_new_lines,
- job,
- NULL, 0,
- job->cancellable);
+ task = g_task_new (log, cancellable, new_lines_job_done, job);
+ g_task_set_task_data (task, job, NULL);
+ g_task_run_in_thread (task, do_read_new_lines);
+ g_object_unref (task);
}
void