1 /* GObject - GLib Type, Object, Parameter and Signal Library 2 * Copyright (C) 1998-1999, 2000-2001 Tim Janik and Red Hat, Inc. 3 * 4 * This library is free software; you can redistribute it and/or 5 * modify it under the terms of the GNU Lesser General Public 6 * License as published by the Free Software Foundation; either 7 * version 2 of the License, or (at your option) any later version. 8 * 9 * This library is distributed in the hope that it will be useful, 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of 11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 12 * Lesser General Public License for more details. 13 * 14 * You should have received a copy of the GNU Lesser General 15 * Public License along with this library; if not, write to the 16 * Free Software Foundation, Inc., 59 Temple Place, Suite 330, 17 * Boston, MA 02111-1307, USA. 18 */ 19 20 #ifndef __G_OBJECT_NOTIFY_QUEUE_H__ 21 #define __G_OBJECT_NOTIFY_QUEUE_H__ 22 23 #include <string.h> /* memset */ 24 25 #include <glib-object.h> 26 27 G_BEGIN_DECLS 28 29 30 /* --- typedefs --- */ 31 typedef struct _GObjectNotifyContext GObjectNotifyContext; 32 typedef struct _GObjectNotifyQueue GObjectNotifyQueue; 33 typedef void (*GObjectNotifyQueueDispatcher) (GObject *object, 34 guint n_pspecs, 35 GParamSpec **pspecs); 36 37 38 /* --- structures --- */ 39 struct _GObjectNotifyContext 40 { 41 GQuark quark_notify_queue; 42 GObjectNotifyQueueDispatcher dispatcher; 43 GTrashStack *_nqueue_trash; /* unused */ 44 }; 45 struct _GObjectNotifyQueue 46 { 47 GObjectNotifyContext *context; 48 GSList *pspecs; 49 guint16 n_pspecs; 50 guint16 freeze_count; 51 /* currently, this structure abuses the GList allocation chain and thus 52 * must be <= sizeof (GList) 53 */ 54 }; 55 56 57 /* --- functions --- */ 58 static void g_object_notify_queue_free(gpointer data)59 g_object_notify_queue_free (gpointer data) 60 { 61 GObjectNotifyQueue *nqueue = data; 62 63 g_slist_free (nqueue->pspecs); 64 g_list_free_1 ((void*) nqueue); 65 } 66 67 static inline GObjectNotifyQueue* g_object_notify_queue_freeze(GObject * object,GObjectNotifyContext * context)68 g_object_notify_queue_freeze (GObject *object, 69 GObjectNotifyContext *context) 70 { 71 GObjectNotifyQueue *nqueue; 72 73 nqueue = g_datalist_id_get_data (&object->qdata, context->quark_notify_queue); 74 if (!nqueue) 75 { 76 nqueue = (void*) g_list_alloc (); 77 memset (nqueue, 0, sizeof (*nqueue)); 78 nqueue->context = context; 79 g_datalist_id_set_data_full (&object->qdata, context->quark_notify_queue, 80 nqueue, g_object_notify_queue_free); 81 } 82 83 g_return_val_if_fail (nqueue->freeze_count < 65535, nqueue); 84 nqueue->freeze_count++; 85 86 return nqueue; 87 } 88 89 static inline void g_object_notify_queue_thaw(GObject * object,GObjectNotifyQueue * nqueue)90 g_object_notify_queue_thaw (GObject *object, 91 GObjectNotifyQueue *nqueue) 92 { 93 GObjectNotifyContext *context = nqueue->context; 94 GParamSpec *pspecs_mem[16], **pspecs, **free_me = NULL; 95 GSList *slist; 96 guint n_pspecs = 0; 97 98 g_return_if_fail (nqueue->freeze_count > 0); 99 100 nqueue->freeze_count--; 101 if (nqueue->freeze_count) 102 return; 103 g_return_if_fail (object->ref_count > 0); 104 105 pspecs = nqueue->n_pspecs > 16 ? free_me = g_new (GParamSpec*, nqueue->n_pspecs) : pspecs_mem; 106 /* set first entry to NULL since it's checked unconditionally */ 107 pspecs[0] = NULL; 108 for (slist = nqueue->pspecs; slist; slist = slist->next) 109 { 110 GParamSpec *pspec = slist->data; 111 guint i = 0; 112 113 /* dedup, make pspecs in the list unique */ 114 redo_dedup_check: 115 if (pspecs[i] == pspec) 116 continue; 117 if (++i < n_pspecs) 118 goto redo_dedup_check; 119 120 pspecs[n_pspecs++] = pspec; 121 } 122 g_datalist_id_set_data (&object->qdata, context->quark_notify_queue, NULL); 123 124 if (n_pspecs) 125 context->dispatcher (object, n_pspecs, pspecs); 126 g_free (free_me); 127 } 128 129 static inline void g_object_notify_queue_clear(GObject * object,GObjectNotifyQueue * nqueue)130 g_object_notify_queue_clear (GObject *object, 131 GObjectNotifyQueue *nqueue) 132 { 133 g_return_if_fail (nqueue->freeze_count > 0); 134 135 g_slist_free (nqueue->pspecs); 136 nqueue->pspecs = NULL; 137 nqueue->n_pspecs = 0; 138 } 139 140 static inline void g_object_notify_queue_add(GObject * object,GObjectNotifyQueue * nqueue,GParamSpec * pspec)141 g_object_notify_queue_add (GObject *object, 142 GObjectNotifyQueue *nqueue, 143 GParamSpec *pspec) 144 { 145 if (pspec->flags & G_PARAM_READABLE) 146 { 147 GParamSpec *redirect; 148 149 g_return_if_fail (nqueue->n_pspecs < 65535); 150 151 redirect = g_param_spec_get_redirect_target (pspec); 152 if (redirect) 153 pspec = redirect; 154 155 /* we do the deduping in _thaw */ 156 nqueue->pspecs = g_slist_prepend (nqueue->pspecs, pspec); 157 nqueue->n_pspecs++; 158 } 159 } 160 161 static inline GObjectNotifyQueue* g_object_notify_queue_from_object(GObject * object,GObjectNotifyContext * context)162 g_object_notify_queue_from_object (GObject *object, 163 GObjectNotifyContext *context) 164 { 165 return g_datalist_id_get_data (&object->qdata, context->quark_notify_queue); 166 } 167 168 169 G_END_DECLS 170 171 #endif /* __G_OBJECT_NOTIFY_QUEUE_H__ */ 172