1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/ossrv/glib/gobject/gobjectnotifyqueue.c Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,175 @@
1.4 +/* GObject - GLib Type, Object, Parameter and Signal Library
1.5 + * Copyright (C) 1998-1999, 2000-2001 Tim Janik and Red Hat, Inc.
1.6 + *
1.7 + * This library is free software; you can redistribute it and/or
1.8 + * modify it under the terms of the GNU Lesser General Public
1.9 + * License as published by the Free Software Foundation; either
1.10 + * version 2 of the License, or (at your option) any later version.
1.11 + *
1.12 + * This library is distributed in the hope that it will be useful,
1.13 + * but WITHOUT ANY WARRANTY; without even the implied warranty of
1.14 + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
1.15 + * Lesser General Public License for more details.
1.16 + *
1.17 + * You should have received a copy of the GNU Lesser General
1.18 + * Public License along with this library; if not, write to the
1.19 + * Free Software Foundation, Inc., 59 Temple Place, Suite 330,
1.20 + * Boston, MA 02111-1307, USA.
1.21 + */
1.22 +
1.23 +#ifndef __G_OBJECT_NOTIFY_QUEUE_H__
1.24 +#define __G_OBJECT_NOTIFY_QUEUE_H__
1.25 +
1.26 +#include <string.h> /* memset */
1.27 +
1.28 +#include <glib-object.h>
1.29 +
1.30 +G_BEGIN_DECLS
1.31 +
1.32 +
1.33 +/* --- typedefs --- */
1.34 +#if (!EMULATOR)
1.35 +typedef struct _GObjectNotifyContext GObjectNotifyContext;
1.36 +#endif
1.37 +typedef struct _GObjectNotifyQueue GObjectNotifyQueue;
1.38 +#if (!EMULATOR)
1.39 +typedef void (*GObjectNotifyQueueDispatcher) (GObject *object,
1.40 + guint n_pspecs,
1.41 + GParamSpec **pspecs);
1.42 +
1.43 +
1.44 +/* --- structures --- */
1.45 +struct _GObjectNotifyContext
1.46 +{
1.47 + GQuark quark_notify_queue;
1.48 + GObjectNotifyQueueDispatcher dispatcher;
1.49 + GTrashStack *_nqueue_trash; /* unused */
1.50 +};
1.51 +#endif
1.52 +struct _GObjectNotifyQueue
1.53 +{
1.54 + GObjectNotifyContext *context;
1.55 + GSList *pspecs;
1.56 + guint16 n_pspecs;
1.57 + guint16 freeze_count;
1.58 + /* currently, this structure abuses the GList allocation chain and thus
1.59 + * must be <= sizeof (GList)
1.60 + */
1.61 +};
1.62 +
1.63 +
1.64 +/* --- functions --- */
1.65 +static void
1.66 +g_object_notify_queue_free (gpointer data)
1.67 +{
1.68 + GObjectNotifyQueue *nqueue = data;
1.69 +
1.70 + g_slist_free (nqueue->pspecs);
1.71 + g_list_free_1 ((void*) nqueue);
1.72 +}
1.73 +
1.74 +static inline GObjectNotifyQueue*
1.75 +g_object_notify_queue_freeze (GObject *object,
1.76 + GObjectNotifyContext *context)
1.77 +{
1.78 + GObjectNotifyQueue *nqueue;
1.79 +
1.80 + nqueue = g_datalist_id_get_data (&object->qdata, context->quark_notify_queue);
1.81 + if (!nqueue)
1.82 + {
1.83 + nqueue = (void*) g_list_alloc ();
1.84 + memset (nqueue, 0, sizeof (*nqueue));
1.85 + nqueue->context = context;
1.86 + g_datalist_id_set_data_full (&object->qdata, context->quark_notify_queue,
1.87 + nqueue, g_object_notify_queue_free);
1.88 + }
1.89 +
1.90 + g_return_val_if_fail (nqueue->freeze_count < 65535, nqueue);
1.91 + nqueue->freeze_count++;
1.92 +
1.93 + return nqueue;
1.94 +}
1.95 +
1.96 +static inline void
1.97 +g_object_notify_queue_thaw (GObject *object,
1.98 + GObjectNotifyQueue *nqueue)
1.99 +{
1.100 + GObjectNotifyContext *context = nqueue->context;
1.101 + GParamSpec *pspecs_mem[16], **pspecs, **free_me = NULL;
1.102 + GSList *slist;
1.103 + guint n_pspecs = 0;
1.104 +
1.105 + g_return_if_fail (nqueue->freeze_count > 0);
1.106 +
1.107 + nqueue->freeze_count--;
1.108 + if (nqueue->freeze_count)
1.109 + return;
1.110 + g_return_if_fail (object->ref_count > 0);
1.111 +
1.112 + pspecs = nqueue->n_pspecs > 16 ? free_me = g_new (GParamSpec*, nqueue->n_pspecs) : pspecs_mem;
1.113 + /* set first entry to NULL since it's checked unconditionally */
1.114 + pspecs[0] = NULL;
1.115 + for (slist = nqueue->pspecs; slist; slist = slist->next)
1.116 + {
1.117 + GParamSpec *pspec = slist->data;
1.118 + guint i = 0;
1.119 +
1.120 + /* dedup, make pspecs in the list unique */
1.121 + redo_dedup_check:
1.122 + if (pspecs[i] == pspec)
1.123 + continue;
1.124 + if (++i < n_pspecs)
1.125 + goto redo_dedup_check;
1.126 +
1.127 + pspecs[n_pspecs++] = pspec;
1.128 + }
1.129 + g_datalist_id_set_data (&object->qdata, context->quark_notify_queue, NULL);
1.130 +
1.131 + if (n_pspecs)
1.132 + context->dispatcher (object, n_pspecs, pspecs);
1.133 + g_free (free_me);
1.134 +}
1.135 +
1.136 +static inline void
1.137 +g_object_notify_queue_clear (GObject *object,
1.138 + GObjectNotifyQueue *nqueue)
1.139 +{
1.140 + g_return_if_fail (nqueue->freeze_count > 0);
1.141 +
1.142 + g_slist_free (nqueue->pspecs);
1.143 + nqueue->pspecs = NULL;
1.144 + nqueue->n_pspecs = 0;
1.145 +}
1.146 +
1.147 +static inline void
1.148 +g_object_notify_queue_add (GObject *object,
1.149 + GObjectNotifyQueue *nqueue,
1.150 + GParamSpec *pspec)
1.151 +{
1.152 + if (pspec->flags & G_PARAM_READABLE)
1.153 + {
1.154 + GParamSpec *redirect;
1.155 +
1.156 + g_return_if_fail (nqueue->n_pspecs < 65535);
1.157 +
1.158 + redirect = g_param_spec_get_redirect_target (pspec);
1.159 + if (redirect)
1.160 + pspec = redirect;
1.161 +
1.162 + /* we do the deduping in _thaw */
1.163 + nqueue->pspecs = g_slist_prepend (nqueue->pspecs, pspec);
1.164 + nqueue->n_pspecs++;
1.165 + }
1.166 +}
1.167 +
1.168 +static inline GObjectNotifyQueue*
1.169 +g_object_notify_queue_from_object (GObject *object,
1.170 + GObjectNotifyContext *context)
1.171 +{
1.172 + return g_datalist_id_get_data (&object->qdata, context->quark_notify_queue);
1.173 +}
1.174 +
1.175 +
1.176 +G_END_DECLS
1.177 +
1.178 +#endif /* __G_OBJECT_NOTIFY_QUEUE_H__ */