• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
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