sl@0: /* GObject - GLib Type, Object, Parameter and Signal Library
sl@0:  * Copyright (C) 1998-1999, 2000-2001 Tim Janik and Red Hat, Inc.
sl@0:  *
sl@0:  * This library is free software; you can redistribute it and/or
sl@0:  * modify it under the terms of the GNU Lesser General Public
sl@0:  * License as published by the Free Software Foundation; either
sl@0:  * version 2 of the License, or (at your option) any later version.
sl@0:  *
sl@0:  * This library is distributed in the hope that it will be useful,
sl@0:  * but WITHOUT ANY WARRANTY; without even the implied warranty of
sl@0:  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
sl@0:  * Lesser General Public License for more details.
sl@0:  *
sl@0:  * You should have received a copy of the GNU Lesser General
sl@0:  * Public License along with this library; if not, write to the
sl@0:  * Free Software Foundation, Inc., 59 Temple Place, Suite 330,
sl@0:  * Boston, MA 02111-1307, USA.
sl@0:  */
sl@0: 
sl@0: #ifndef __G_OBJECT_NOTIFY_QUEUE_H__
sl@0: #define __G_OBJECT_NOTIFY_QUEUE_H__
sl@0: 
sl@0: #include <string.h> /* memset */
sl@0: 
sl@0: #include <glib-object.h>
sl@0: 
sl@0: G_BEGIN_DECLS
sl@0: 
sl@0: 
sl@0: /* --- typedefs --- */
sl@0: #if (!EMULATOR)
sl@0: typedef struct _GObjectNotifyContext          GObjectNotifyContext;
sl@0: #endif
sl@0: typedef struct _GObjectNotifyQueue            GObjectNotifyQueue;
sl@0: #if (!EMULATOR)
sl@0: typedef void (*GObjectNotifyQueueDispatcher) (GObject     *object,
sl@0: 					      guint        n_pspecs,
sl@0: 					      GParamSpec **pspecs);
sl@0: 
sl@0: 
sl@0: /* --- structures --- */
sl@0: struct _GObjectNotifyContext
sl@0: {
sl@0:   GQuark                       quark_notify_queue;
sl@0:   GObjectNotifyQueueDispatcher dispatcher;
sl@0:   GTrashStack                 *_nqueue_trash; /* unused */
sl@0: };
sl@0: #endif
sl@0: struct _GObjectNotifyQueue
sl@0: {
sl@0:   GObjectNotifyContext *context;
sl@0:   GSList               *pspecs;
sl@0:   guint16               n_pspecs;
sl@0:   guint16               freeze_count;
sl@0:   /* currently, this structure abuses the GList allocation chain and thus
sl@0:    * must be <= sizeof (GList)
sl@0:    */
sl@0: };
sl@0: 
sl@0: 
sl@0: /* --- functions --- */
sl@0: static void
sl@0: g_object_notify_queue_free (gpointer data)
sl@0: {
sl@0:   GObjectNotifyQueue *nqueue = data;
sl@0: 
sl@0:   g_slist_free (nqueue->pspecs);
sl@0:   g_list_free_1 ((void*) nqueue);
sl@0: }
sl@0: 
sl@0: static inline GObjectNotifyQueue*
sl@0: g_object_notify_queue_freeze (GObject		   *object,
sl@0: 			      GObjectNotifyContext *context)
sl@0: {
sl@0:   GObjectNotifyQueue *nqueue;
sl@0: 
sl@0:   nqueue = g_datalist_id_get_data (&object->qdata, context->quark_notify_queue);
sl@0:   if (!nqueue)
sl@0:     {
sl@0:       nqueue = (void*) g_list_alloc ();
sl@0:       memset (nqueue, 0, sizeof (*nqueue));
sl@0:       nqueue->context = context;
sl@0:       g_datalist_id_set_data_full (&object->qdata, context->quark_notify_queue,
sl@0: 				   nqueue, g_object_notify_queue_free);
sl@0:     }
sl@0: 
sl@0:   g_return_val_if_fail (nqueue->freeze_count < 65535, nqueue);
sl@0:   nqueue->freeze_count++;
sl@0: 
sl@0:   return nqueue;
sl@0: }
sl@0: 
sl@0: static inline void
sl@0: g_object_notify_queue_thaw (GObject            *object,
sl@0: 			    GObjectNotifyQueue *nqueue)
sl@0: {
sl@0:   GObjectNotifyContext *context = nqueue->context;
sl@0:   GParamSpec *pspecs_mem[16], **pspecs, **free_me = NULL;
sl@0:   GSList *slist;
sl@0:   guint n_pspecs = 0;
sl@0: 
sl@0:   g_return_if_fail (nqueue->freeze_count > 0);
sl@0: 
sl@0:   nqueue->freeze_count--;
sl@0:   if (nqueue->freeze_count)
sl@0:     return;
sl@0:   g_return_if_fail (object->ref_count > 0);
sl@0: 
sl@0:   pspecs = nqueue->n_pspecs > 16 ? free_me = g_new (GParamSpec*, nqueue->n_pspecs) : pspecs_mem;
sl@0:   /* set first entry to NULL since it's checked unconditionally */
sl@0:   pspecs[0] = NULL;
sl@0:   for (slist = nqueue->pspecs; slist; slist = slist->next)
sl@0:     {
sl@0:       GParamSpec *pspec = slist->data;
sl@0:       guint i = 0;
sl@0: 
sl@0:       /* dedup, make pspecs in the list unique */
sl@0:     redo_dedup_check:
sl@0:       if (pspecs[i] == pspec)
sl@0: 	continue;
sl@0:       if (++i < n_pspecs)
sl@0: 	goto redo_dedup_check;
sl@0: 
sl@0:       pspecs[n_pspecs++] = pspec;
sl@0:     }
sl@0:   g_datalist_id_set_data (&object->qdata, context->quark_notify_queue, NULL);
sl@0: 
sl@0:   if (n_pspecs)
sl@0:     context->dispatcher (object, n_pspecs, pspecs);
sl@0:   g_free (free_me);
sl@0: }
sl@0: 
sl@0: static inline void
sl@0: g_object_notify_queue_clear (GObject            *object,
sl@0: 			     GObjectNotifyQueue *nqueue)
sl@0: {
sl@0:   g_return_if_fail (nqueue->freeze_count > 0);
sl@0: 
sl@0:   g_slist_free (nqueue->pspecs);
sl@0:   nqueue->pspecs = NULL;
sl@0:   nqueue->n_pspecs = 0;
sl@0: }
sl@0: 
sl@0: static inline void
sl@0: g_object_notify_queue_add (GObject            *object,
sl@0: 			   GObjectNotifyQueue *nqueue,
sl@0: 			   GParamSpec	      *pspec)
sl@0: {
sl@0:   if (pspec->flags & G_PARAM_READABLE)
sl@0:     {
sl@0:       GParamSpec *redirect;
sl@0: 
sl@0:       g_return_if_fail (nqueue->n_pspecs < 65535);
sl@0: 
sl@0:       redirect = g_param_spec_get_redirect_target (pspec);
sl@0:       if (redirect)
sl@0: 	pspec = redirect;
sl@0: 	    
sl@0:       /* we do the deduping in _thaw */
sl@0:       nqueue->pspecs = g_slist_prepend (nqueue->pspecs, pspec);
sl@0:       nqueue->n_pspecs++;
sl@0:     }
sl@0: }
sl@0: 
sl@0: static inline GObjectNotifyQueue*
sl@0: g_object_notify_queue_from_object (GObject              *object,
sl@0: 				   GObjectNotifyContext *context)
sl@0: {
sl@0:   return g_datalist_id_get_data (&object->qdata, context->quark_notify_queue);
sl@0: }
sl@0: 
sl@0: 
sl@0: G_END_DECLS
sl@0: 
sl@0: #endif /* __G_OBJECT_NOTIFY_QUEUE_H__ */