mirror of
https://gitlab.gnome.org/GNOME/glib.git
synced 2024-11-10 03:16:17 +01:00
18a33f72db
If we have an input parameter (or return value) we need to use (nullable). However, if it is an (inout) or (out) parameter, (optional) is sufficient. It looks like (nullable) could be used for everything according to the Annotation documentation, but (optional) is more specific.
326 lines
8.8 KiB
C
326 lines
8.8 KiB
C
/* GIO - GLib Input, Output and Streaming Library
|
|
*
|
|
* Copyright (C) 2006-2007 Red Hat, Inc.
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 2 of the License, or (at your option) any later version.
|
|
*
|
|
* This library is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General
|
|
* Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
* Author: Alexander Larsson <alexl@redhat.com>
|
|
*/
|
|
|
|
#include "config.h"
|
|
|
|
#include "gioscheduler.h"
|
|
#include "gcancellable.h"
|
|
#include "gtask.h"
|
|
|
|
/**
|
|
* SECTION:gioscheduler
|
|
* @short_description: I/O Scheduler
|
|
* @include: gio/gio.h
|
|
*
|
|
* As of GLib 2.36, #GIOScheduler is deprecated in favor of
|
|
* #GThreadPool and #GTask.
|
|
*
|
|
* Schedules asynchronous I/O operations. #GIOScheduler integrates
|
|
* into the main event loop (#GMainLoop) and uses threads.
|
|
*/
|
|
|
|
struct _GIOSchedulerJob {
|
|
GList *active_link;
|
|
GTask *task;
|
|
|
|
GIOSchedulerJobFunc job_func;
|
|
gpointer data;
|
|
GDestroyNotify destroy_notify;
|
|
|
|
GCancellable *cancellable;
|
|
gulong cancellable_id;
|
|
GMainContext *context;
|
|
};
|
|
|
|
G_LOCK_DEFINE_STATIC(active_jobs);
|
|
static GList *active_jobs = NULL;
|
|
|
|
static void
|
|
g_io_job_free (GIOSchedulerJob *job)
|
|
{
|
|
if (job->destroy_notify)
|
|
job->destroy_notify (job->data);
|
|
|
|
G_LOCK (active_jobs);
|
|
active_jobs = g_list_delete_link (active_jobs, job->active_link);
|
|
G_UNLOCK (active_jobs);
|
|
|
|
if (job->cancellable)
|
|
g_object_unref (job->cancellable);
|
|
g_main_context_unref (job->context);
|
|
g_slice_free (GIOSchedulerJob, job);
|
|
}
|
|
|
|
static void
|
|
io_job_thread (GTask *task,
|
|
gpointer source_object,
|
|
gpointer task_data,
|
|
GCancellable *cancellable)
|
|
{
|
|
GIOSchedulerJob *job = task_data;
|
|
gboolean result;
|
|
|
|
if (job->cancellable)
|
|
g_cancellable_push_current (job->cancellable);
|
|
|
|
do
|
|
{
|
|
result = job->job_func (job, job->cancellable, job->data);
|
|
}
|
|
while (result);
|
|
|
|
if (job->cancellable)
|
|
g_cancellable_pop_current (job->cancellable);
|
|
}
|
|
|
|
/**
|
|
* g_io_scheduler_push_job:
|
|
* @job_func: a #GIOSchedulerJobFunc.
|
|
* @user_data: data to pass to @job_func
|
|
* @notify: (nullable): a #GDestroyNotify for @user_data, or %NULL
|
|
* @io_priority: the [I/O priority][io-priority]
|
|
* of the request.
|
|
* @cancellable: optional #GCancellable object, %NULL to ignore.
|
|
*
|
|
* Schedules the I/O job to run in another thread.
|
|
*
|
|
* @notify will be called on @user_data after @job_func has returned,
|
|
* regardless whether the job was cancelled or has run to completion.
|
|
*
|
|
* If @cancellable is not %NULL, it can be used to cancel the I/O job
|
|
* by calling g_cancellable_cancel() or by calling
|
|
* g_io_scheduler_cancel_all_jobs().
|
|
*
|
|
* Deprecated: use #GThreadPool or g_task_run_in_thread()
|
|
**/
|
|
void
|
|
g_io_scheduler_push_job (GIOSchedulerJobFunc job_func,
|
|
gpointer user_data,
|
|
GDestroyNotify notify,
|
|
gint io_priority,
|
|
GCancellable *cancellable)
|
|
{
|
|
GIOSchedulerJob *job;
|
|
GTask *task;
|
|
|
|
g_return_if_fail (job_func != NULL);
|
|
|
|
job = g_slice_new0 (GIOSchedulerJob);
|
|
job->job_func = job_func;
|
|
job->data = user_data;
|
|
job->destroy_notify = notify;
|
|
|
|
if (cancellable)
|
|
job->cancellable = g_object_ref (cancellable);
|
|
|
|
job->context = g_main_context_ref_thread_default ();
|
|
|
|
G_LOCK (active_jobs);
|
|
active_jobs = g_list_prepend (active_jobs, job);
|
|
job->active_link = active_jobs;
|
|
G_UNLOCK (active_jobs);
|
|
|
|
task = g_task_new (NULL, cancellable, NULL, NULL);
|
|
G_GNUC_BEGIN_IGNORE_DEPRECATIONS
|
|
g_task_set_source_tag (task, g_io_scheduler_push_job);
|
|
G_GNUC_END_IGNORE_DEPRECATIONS
|
|
g_task_set_task_data (task, job, (GDestroyNotify)g_io_job_free);
|
|
g_task_set_priority (task, io_priority);
|
|
g_task_run_in_thread (task, io_job_thread);
|
|
g_object_unref (task);
|
|
}
|
|
|
|
/**
|
|
* g_io_scheduler_cancel_all_jobs:
|
|
*
|
|
* Cancels all cancellable I/O jobs.
|
|
*
|
|
* A job is cancellable if a #GCancellable was passed into
|
|
* g_io_scheduler_push_job().
|
|
*
|
|
* Deprecated: You should never call this function, since you don't
|
|
* know how other libraries in your program might be making use of
|
|
* gioscheduler.
|
|
**/
|
|
void
|
|
g_io_scheduler_cancel_all_jobs (void)
|
|
{
|
|
GList *cancellable_list, *l;
|
|
|
|
G_LOCK (active_jobs);
|
|
cancellable_list = NULL;
|
|
for (l = active_jobs; l != NULL; l = l->next)
|
|
{
|
|
GIOSchedulerJob *job = l->data;
|
|
if (job->cancellable)
|
|
cancellable_list = g_list_prepend (cancellable_list,
|
|
g_object_ref (job->cancellable));
|
|
}
|
|
G_UNLOCK (active_jobs);
|
|
|
|
for (l = cancellable_list; l != NULL; l = l->next)
|
|
{
|
|
GCancellable *c = l->data;
|
|
g_cancellable_cancel (c);
|
|
g_object_unref (c);
|
|
}
|
|
g_list_free (cancellable_list);
|
|
}
|
|
|
|
typedef struct {
|
|
GSourceFunc func;
|
|
gboolean ret_val;
|
|
gpointer data;
|
|
GDestroyNotify notify;
|
|
|
|
GMutex ack_lock;
|
|
GCond ack_condition;
|
|
gboolean ack;
|
|
} MainLoopProxy;
|
|
|
|
static gboolean
|
|
mainloop_proxy_func (gpointer data)
|
|
{
|
|
MainLoopProxy *proxy = data;
|
|
|
|
proxy->ret_val = proxy->func (proxy->data);
|
|
|
|
if (proxy->notify)
|
|
proxy->notify (proxy->data);
|
|
|
|
g_mutex_lock (&proxy->ack_lock);
|
|
proxy->ack = TRUE;
|
|
g_cond_signal (&proxy->ack_condition);
|
|
g_mutex_unlock (&proxy->ack_lock);
|
|
|
|
return FALSE;
|
|
}
|
|
|
|
static void
|
|
mainloop_proxy_free (MainLoopProxy *proxy)
|
|
{
|
|
g_mutex_clear (&proxy->ack_lock);
|
|
g_cond_clear (&proxy->ack_condition);
|
|
g_free (proxy);
|
|
}
|
|
|
|
/**
|
|
* g_io_scheduler_job_send_to_mainloop:
|
|
* @job: a #GIOSchedulerJob
|
|
* @func: a #GSourceFunc callback that will be called in the original thread
|
|
* @user_data: data to pass to @func
|
|
* @notify: (nullable): a #GDestroyNotify for @user_data, or %NULL
|
|
*
|
|
* Used from an I/O job to send a callback to be run in the thread
|
|
* that the job was started from, waiting for the result (and thus
|
|
* blocking the I/O job).
|
|
*
|
|
* Returns: The return value of @func
|
|
*
|
|
* Deprecated: Use g_main_context_invoke().
|
|
**/
|
|
gboolean
|
|
g_io_scheduler_job_send_to_mainloop (GIOSchedulerJob *job,
|
|
GSourceFunc func,
|
|
gpointer user_data,
|
|
GDestroyNotify notify)
|
|
{
|
|
GSource *source;
|
|
MainLoopProxy *proxy;
|
|
gboolean ret_val;
|
|
|
|
g_return_val_if_fail (job != NULL, FALSE);
|
|
g_return_val_if_fail (func != NULL, FALSE);
|
|
|
|
proxy = g_new0 (MainLoopProxy, 1);
|
|
proxy->func = func;
|
|
proxy->data = user_data;
|
|
proxy->notify = notify;
|
|
g_mutex_init (&proxy->ack_lock);
|
|
g_cond_init (&proxy->ack_condition);
|
|
g_mutex_lock (&proxy->ack_lock);
|
|
|
|
source = g_idle_source_new ();
|
|
g_source_set_priority (source, G_PRIORITY_DEFAULT);
|
|
g_source_set_callback (source, mainloop_proxy_func, proxy,
|
|
NULL);
|
|
g_source_set_name (source, "[gio] mainloop_proxy_func");
|
|
|
|
g_source_attach (source, job->context);
|
|
g_source_unref (source);
|
|
|
|
while (!proxy->ack)
|
|
g_cond_wait (&proxy->ack_condition, &proxy->ack_lock);
|
|
g_mutex_unlock (&proxy->ack_lock);
|
|
|
|
ret_val = proxy->ret_val;
|
|
mainloop_proxy_free (proxy);
|
|
|
|
return ret_val;
|
|
}
|
|
|
|
/**
|
|
* g_io_scheduler_job_send_to_mainloop_async:
|
|
* @job: a #GIOSchedulerJob
|
|
* @func: a #GSourceFunc callback that will be called in the original thread
|
|
* @user_data: data to pass to @func
|
|
* @notify: (nullable): a #GDestroyNotify for @user_data, or %NULL
|
|
*
|
|
* Used from an I/O job to send a callback to be run asynchronously in
|
|
* the thread that the job was started from. The callback will be run
|
|
* when the main loop is available, but at that time the I/O job might
|
|
* have finished. The return value from the callback is ignored.
|
|
*
|
|
* Note that if you are passing the @user_data from g_io_scheduler_push_job()
|
|
* on to this function you have to ensure that it is not freed before
|
|
* @func is called, either by passing %NULL as @notify to
|
|
* g_io_scheduler_push_job() or by using refcounting for @user_data.
|
|
*
|
|
* Deprecated: Use g_main_context_invoke().
|
|
**/
|
|
void
|
|
g_io_scheduler_job_send_to_mainloop_async (GIOSchedulerJob *job,
|
|
GSourceFunc func,
|
|
gpointer user_data,
|
|
GDestroyNotify notify)
|
|
{
|
|
GSource *source;
|
|
MainLoopProxy *proxy;
|
|
|
|
g_return_if_fail (job != NULL);
|
|
g_return_if_fail (func != NULL);
|
|
|
|
proxy = g_new0 (MainLoopProxy, 1);
|
|
proxy->func = func;
|
|
proxy->data = user_data;
|
|
proxy->notify = notify;
|
|
g_mutex_init (&proxy->ack_lock);
|
|
g_cond_init (&proxy->ack_condition);
|
|
|
|
source = g_idle_source_new ();
|
|
g_source_set_priority (source, G_PRIORITY_DEFAULT);
|
|
g_source_set_callback (source, mainloop_proxy_func, proxy,
|
|
(GDestroyNotify)mainloop_proxy_free);
|
|
g_source_set_name (source, "[gio] mainloop_proxy_func");
|
|
|
|
g_source_attach (source, job->context);
|
|
g_source_unref (source);
|
|
}
|