mirror of
https://gitlab.gnome.org/GNOME/glib.git
synced 2024-11-05 08:56:16 +01:00
1ce415b45b
The point of g_source_set_closure() is getting memory management right, including handling closures disappearing from the outside (for example because a runtime they refer to is being shutdown). This means that sources with an associated closure should remove themselves from the main loop and free memory when the closure is invalidated. https://bugzilla.gnome.org/show_bug.cgi?id=692034
240 lines
6.7 KiB
C
240 lines
6.7 KiB
C
/* GObject - GLib Type, Object, Parameter and Signal Library
|
|
* Copyright (C) 2001 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, write to the
|
|
* Free Software Foundation, Inc., 59 Temple Place, Suite 330,
|
|
* Boston, MA 02111-1307, USA.
|
|
*/
|
|
|
|
#include "config.h"
|
|
|
|
#include "gsourceclosure.h"
|
|
#include "gboxed.h"
|
|
#include "genums.h"
|
|
#include "gmarshal.h"
|
|
#include "gvalue.h"
|
|
#include "gvaluetypes.h"
|
|
|
|
G_DEFINE_BOXED_TYPE (GIOChannel, g_io_channel, g_io_channel_ref, g_io_channel_unref)
|
|
|
|
GType
|
|
g_io_condition_get_type (void)
|
|
{
|
|
static GType etype = 0;
|
|
if (etype == 0)
|
|
{
|
|
static const GFlagsValue values[] = {
|
|
{ G_IO_IN, "G_IO_IN", "in" },
|
|
{ G_IO_OUT, "G_IO_OUT", "out" },
|
|
{ G_IO_PRI, "G_IO_PRI", "pri" },
|
|
{ G_IO_ERR, "G_IO_ERR", "err" },
|
|
{ G_IO_HUP, "G_IO_HUP", "hup" },
|
|
{ G_IO_NVAL, "G_IO_NVAL", "nval" },
|
|
{ 0, NULL, NULL }
|
|
};
|
|
etype = g_flags_register_static ("GIOCondition", values);
|
|
}
|
|
return etype;
|
|
}
|
|
|
|
/* We need to hand-write this marshaler, since it doesn't have an
|
|
* instance object.
|
|
*/
|
|
static void
|
|
source_closure_marshal_BOOLEAN__VOID (GClosure *closure,
|
|
GValue *return_value,
|
|
guint n_param_values,
|
|
const GValue *param_values,
|
|
gpointer invocation_hint,
|
|
gpointer marshal_data)
|
|
{
|
|
GSourceFunc callback;
|
|
GCClosure *cc = (GCClosure*) closure;
|
|
gboolean v_return;
|
|
|
|
g_return_if_fail (return_value != NULL);
|
|
g_return_if_fail (n_param_values == 0);
|
|
|
|
callback = (GSourceFunc) (marshal_data ? marshal_data : cc->callback);
|
|
|
|
v_return = callback (closure->data);
|
|
|
|
g_value_set_boolean (return_value, v_return);
|
|
}
|
|
|
|
static gboolean
|
|
io_watch_closure_callback (GIOChannel *channel,
|
|
GIOCondition condition,
|
|
gpointer data)
|
|
{
|
|
GClosure *closure = data;
|
|
|
|
GValue params[2] = { G_VALUE_INIT, G_VALUE_INIT };
|
|
GValue result_value = G_VALUE_INIT;
|
|
gboolean result;
|
|
|
|
g_value_init (&result_value, G_TYPE_BOOLEAN);
|
|
g_value_init (¶ms[0], G_TYPE_IO_CHANNEL);
|
|
g_value_set_boxed (¶ms[0], channel);
|
|
|
|
g_value_init (¶ms[1], G_TYPE_IO_CONDITION);
|
|
g_value_set_flags (¶ms[1], condition);
|
|
|
|
g_closure_invoke (closure, &result_value, 2, params, NULL);
|
|
|
|
result = g_value_get_boolean (&result_value);
|
|
g_value_unset (&result_value);
|
|
g_value_unset (¶ms[0]);
|
|
g_value_unset (¶ms[1]);
|
|
|
|
return result;
|
|
}
|
|
|
|
static gboolean
|
|
source_closure_callback (gpointer data)
|
|
{
|
|
GClosure *closure = data;
|
|
GValue result_value = G_VALUE_INIT;
|
|
gboolean result;
|
|
|
|
g_value_init (&result_value, G_TYPE_BOOLEAN);
|
|
|
|
g_closure_invoke (closure, &result_value, 0, NULL, NULL);
|
|
|
|
result = g_value_get_boolean (&result_value);
|
|
g_value_unset (&result_value);
|
|
|
|
return result;
|
|
}
|
|
|
|
static void
|
|
closure_callback_get (gpointer cb_data,
|
|
GSource *source,
|
|
GSourceFunc *func,
|
|
gpointer *data)
|
|
{
|
|
GSourceFunc closure_callback = source->source_funcs->closure_callback;
|
|
|
|
if (!closure_callback)
|
|
{
|
|
if (source->source_funcs == &g_io_watch_funcs)
|
|
closure_callback = (GSourceFunc)io_watch_closure_callback;
|
|
else if (source->source_funcs == &g_timeout_funcs ||
|
|
source->source_funcs == &g_idle_funcs)
|
|
closure_callback = source_closure_callback;
|
|
}
|
|
|
|
*func = closure_callback;
|
|
*data = cb_data;
|
|
}
|
|
|
|
static GSourceCallbackFuncs closure_callback_funcs = {
|
|
(void (*) (gpointer)) g_closure_ref,
|
|
(void (*) (gpointer)) g_closure_unref,
|
|
closure_callback_get
|
|
};
|
|
|
|
static void
|
|
closure_invalidated (gpointer user_data,
|
|
GClosure *closure)
|
|
{
|
|
g_source_destroy (user_data);
|
|
}
|
|
|
|
/**
|
|
* g_source_set_closure:
|
|
* @source: the source
|
|
* @closure: a #GClosure
|
|
*
|
|
* Set the callback for a source as a #GClosure.
|
|
*
|
|
* If the source is not one of the standard GLib types, the @closure_callback
|
|
* and @closure_marshal fields of the #GSourceFuncs structure must have been
|
|
* filled in with pointers to appropriate functions.
|
|
*/
|
|
void
|
|
g_source_set_closure (GSource *source,
|
|
GClosure *closure)
|
|
{
|
|
g_return_if_fail (source != NULL);
|
|
g_return_if_fail (closure != NULL);
|
|
|
|
if (!source->source_funcs->closure_callback &&
|
|
source->source_funcs != &g_io_watch_funcs &&
|
|
source->source_funcs != &g_timeout_funcs &&
|
|
source->source_funcs != &g_idle_funcs)
|
|
{
|
|
g_critical (G_STRLOC ": closure can not be set on closure without GSourceFuncs::closure_callback\n");
|
|
return;
|
|
}
|
|
|
|
g_closure_ref (closure);
|
|
g_closure_sink (closure);
|
|
g_source_set_callback_indirect (source, closure, &closure_callback_funcs);
|
|
|
|
g_closure_add_invalidate_notifier (closure, source, closure_invalidated);
|
|
|
|
if (G_CLOSURE_NEEDS_MARSHAL (closure))
|
|
{
|
|
GClosureMarshal marshal = (GClosureMarshal)source->source_funcs->closure_marshal;
|
|
if (!marshal)
|
|
{
|
|
if (source->source_funcs == &g_idle_funcs ||
|
|
source->source_funcs == &g_timeout_funcs)
|
|
marshal = source_closure_marshal_BOOLEAN__VOID;
|
|
else if (source->source_funcs == &g_io_watch_funcs)
|
|
marshal = g_cclosure_marshal_BOOLEAN__FLAGS;
|
|
}
|
|
if (marshal)
|
|
g_closure_set_marshal (closure, marshal);
|
|
}
|
|
}
|
|
|
|
static void
|
|
dummy_closure_marshal (GClosure *closure,
|
|
GValue *return_value,
|
|
guint n_param_values,
|
|
const GValue *param_values,
|
|
gpointer invocation_hint,
|
|
gpointer marshal_data)
|
|
{
|
|
if (G_VALUE_HOLDS_BOOLEAN (return_value))
|
|
g_value_set_boolean (return_value, TRUE);
|
|
}
|
|
|
|
/**
|
|
* g_source_set_dummy_callback:
|
|
* @source: the source
|
|
*
|
|
* Sets a dummy callback for @source. The callback will do nothing, and
|
|
* if the source expects a #gboolean return value, it will return %TRUE.
|
|
* (If the source expects any other type of return value, it will return
|
|
* a 0/%NULL value; whatever g_value_init() initializes a #GValue to for
|
|
* that type.)
|
|
*
|
|
* If the source is not one of the standard GLib types, the
|
|
* @closure_callback and @closure_marshal fields of the #GSourceFuncs
|
|
* structure must have been filled in with pointers to appropriate
|
|
* functions.
|
|
*/
|
|
void
|
|
g_source_set_dummy_callback (GSource *source)
|
|
{
|
|
GClosure *closure;
|
|
|
|
closure = g_closure_new_simple (sizeof (GClosure), NULL);
|
|
g_closure_set_meta_marshal (closure, NULL, dummy_closure_marshal);
|
|
g_source_set_closure (source, closure);
|
|
}
|