2 * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Library 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.
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 * Library General Public License for more details.
14 * You should have received a copy of the GNU Library General Public
15 * 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.
22 #include "gstthread.h"
25 GstElementDetails gst_thread_details = {
28 "Container that creates/manages a thread",
30 "Erik Walthinsen <omega@cse.ogi.edu>",
35 /* Thread signals and args */
47 static void gst_thread_class_init (GstThreadClass *klass);
48 static void gst_thread_init (GstThread *thread);
50 static void gst_thread_set_arg (GtkObject *object,GtkArg *arg,guint id);
51 static void gst_thread_get_arg (GtkObject *object,GtkArg *arg,guint id);
53 static GstElementStateReturn gst_thread_change_state (GstElement *element);
55 static xmlNodePtr gst_thread_save_thyself (GstElement *element,xmlNodePtr parent);
56 static void gst_thread_restore_thyself (GstElement *element,xmlNodePtr parent,
57 GHashTable *elements);
59 static void gst_thread_signal_thread (GstThread *thread);
60 static void gst_thread_create_plan_dummy (GstBin *bin);
62 static void* gst_thread_main_loop (void *arg);
64 static GstBin *parent_class = NULL;
65 //static guint gst_thread_signals[LAST_SIGNAL] = { 0 };
68 gst_thread_get_type(void) {
69 static GtkType thread_type = 0;
72 static const GtkTypeInfo thread_info = {
75 sizeof(GstThreadClass),
76 (GtkClassInitFunc)gst_thread_class_init,
77 (GtkObjectInitFunc)gst_thread_init,
80 (GtkClassInitFunc)NULL,
82 thread_type = gtk_type_unique(GST_TYPE_BIN,&thread_info);
88 gst_thread_class_init (GstThreadClass *klass)
90 GtkObjectClass *gtkobject_class;
91 GstObjectClass *gstobject_class;
92 GstElementClass *gstelement_class;
93 GstBinClass *gstbin_class;
95 gtkobject_class = (GtkObjectClass*)klass;
96 gstobject_class = (GstObjectClass*)klass;
97 gstelement_class = (GstElementClass*)klass;
98 gstbin_class = (GstBinClass*)klass;
100 parent_class = gtk_type_class (GST_TYPE_BIN);
102 gtk_object_add_arg_type ("GstThread::create_thread", GTK_TYPE_BOOL,
103 GTK_ARG_READWRITE, ARG_CREATE_THREAD);
105 gstelement_class->change_state = gst_thread_change_state;
106 gstelement_class->save_thyself = gst_thread_save_thyself;
107 gstelement_class->restore_thyself = gst_thread_restore_thyself;
108 gstelement_class->elementfactory = gst_elementfactory_find("thread");
110 gstbin_class->create_plan = gst_thread_create_plan_dummy;
112 gtkobject_class->set_arg = gst_thread_set_arg;
113 gtkobject_class->get_arg = gst_thread_get_arg;
118 gst_thread_init (GstThread *thread)
120 GST_FLAG_SET (thread, GST_THREAD_CREATE);
122 thread->lock = g_mutex_new();
123 thread->cond = g_cond_new();
127 gst_thread_create_plan_dummy (GstBin *bin)
129 g_return_if_fail (GST_IS_THREAD (bin));
131 if (!GST_FLAG_IS_SET (GST_THREAD (bin), GST_THREAD_STATE_SPINNING))
132 gst_info("gstthread: create plan delayed until thread starts\n");
136 gst_thread_set_arg (GtkObject *object,
140 /* it's not null if we got it, but it might not be ours */
141 g_return_if_fail (GST_IS_THREAD (object));
144 case ARG_CREATE_THREAD:
145 if (GTK_VALUE_BOOL (*arg)) {
146 gst_info("gstthread: turning ON the creation of the thread\n");
147 GST_FLAG_SET (object, GST_THREAD_CREATE);
148 gst_info("gstthread: flags are 0x%08x\n", GST_FLAGS (object));
150 gst_info("gstthread: turning OFF the creation of the thread\n");
151 GST_FLAG_UNSET (object, GST_THREAD_CREATE);
152 gst_info("gstthread: flags are 0x%08x\n", GST_FLAGS (object));
161 gst_thread_get_arg (GtkObject *object,
165 /* it's not null if we got it, but it might not be ours */
166 g_return_if_fail (GST_IS_THREAD (object));
169 case ARG_CREATE_THREAD:
170 g_print("gstthread: query thread %d\n", GST_FLAG_IS_SET (object, GST_THREAD_CREATE));
171 GTK_VALUE_BOOL (*arg) = GST_FLAG_IS_SET (object, GST_THREAD_CREATE);
181 * @name: the name of the thread
183 * Create a new thrad with the given name
185 * Returns; The new thread
188 gst_thread_new (guchar *name)
192 thread = gtk_type_new (gst_thread_get_type ());
194 gst_element_set_name (GST_ELEMENT (thread), name);
196 GST_FLAG_UNSET (thread, GST_THREAD_STATE_REAPING);
198 return GST_ELEMENT (thread);
203 static GstElementStateReturn
204 gst_thread_change_state (GstElement *element)
207 gboolean stateset = GST_STATE_SUCCESS;
210 g_return_val_if_fail (GST_IS_THREAD(element), FALSE);
211 DEBUG_ENTER("(\"%s\")",gst_element_get_name(element));
213 thread = GST_THREAD (element);
215 gst_info("gstthread: thread \"%s\" change state %d\n",
216 gst_element_get_name (GST_ELEMENT (element)),
217 GST_STATE_PENDING (element));
219 pending = GST_STATE_PENDING (element);
221 if (pending == GST_STATE (element)) return GST_STATE_SUCCESS;
223 GST_FLAG_UNSET (thread, GST_THREAD_STATE_SPINNING);
225 if (GST_ELEMENT_CLASS (parent_class)->change_state)
226 stateset = GST_ELEMENT_CLASS (parent_class)->change_state (element);
228 gst_info("gstthread: stateset %d %d %d\n", GST_STATE (element), stateset,
229 GST_STATE_PENDING (element));
232 case GST_STATE_READY:
233 if (!stateset) return FALSE;
234 // we want to prepare our internal state for doing the iterations
235 gst_info("gstthread: preparing thread \"%s\" for iterations:\n",
236 gst_element_get_name (GST_ELEMENT (element)));
238 // set the state to idle
239 GST_FLAG_UNSET (thread, GST_THREAD_STATE_SPINNING);
240 // create the thread if that's what we're supposed to do
241 gst_info("gstthread: flags are 0x%08x\n", GST_FLAGS (thread));
243 if (GST_FLAG_IS_SET (thread, GST_THREAD_CREATE)) {
244 gst_info("gstthread: starting thread \"%s\"\n",
245 gst_element_get_name (GST_ELEMENT (element)));
247 pthread_create (&thread->thread_id, NULL,
248 gst_thread_main_loop, thread);
250 gst_info("gstthread: NOT starting thread \"%s\"\n",
251 gst_element_get_name (GST_ELEMENT (element)));
253 return GST_STATE_ASYNC;
255 case GST_STATE_PLAYING:
256 if (!stateset) return FALSE;
257 gst_info("gstthread: starting thread \"%s\"\n",
258 gst_element_get_name (GST_ELEMENT (element)));
260 GST_FLAG_SET (thread, GST_THREAD_STATE_SPINNING);
261 gst_thread_signal_thread (thread);
263 case GST_STATE_PAUSED:
264 gst_info("gstthread: pausing thread \"%s\"\n",
265 gst_element_get_name (GST_ELEMENT (element)));
267 //GST_FLAG_UNSET(thread,GST_THREAD_STATE_SPINNING);
268 gst_thread_signal_thread (thread);
271 gst_info("gstthread: stopping thread \"%s\"\n",
272 gst_element_get_name (GST_ELEMENT (element)));
274 GST_FLAG_SET (thread, GST_THREAD_STATE_REAPING);
275 gst_thread_signal_thread (thread);
285 * gst_thread_main_loop:
286 * @arg: the thread to start
288 * The main loop of the thread. The thread will iterate
289 * while the state is GST_THREAD_STATE_SPINNING
292 gst_thread_main_loop (void *arg)
294 GstThread *thread = GST_THREAD (arg);
296 gst_info("gstthread: thread \"%s\" is running with PID %d\n",
297 gst_element_get_name (GST_ELEMENT (thread)), getpid ());
299 if (GST_BIN_CLASS (parent_class)->create_plan)
300 GST_BIN_CLASS (parent_class)->create_plan (GST_BIN (thread));
302 while (!GST_FLAG_IS_SET (thread, GST_THREAD_STATE_REAPING)) {
303 if (GST_FLAG_IS_SET (thread, GST_THREAD_STATE_SPINNING))
304 gst_bin_iterate (GST_BIN (thread));
306 g_mutex_lock (thread->lock);
307 g_cond_wait (thread->cond, thread->lock);
308 g_mutex_unlock (thread->lock);
312 GST_FLAG_UNSET (thread, GST_THREAD_STATE_REAPING);
313 pthread_join (thread->thread_id, 0);
315 gst_info("gstthread: thread \"%s\" is stopped\n",
316 gst_element_get_name (GST_ELEMENT (thread)));
321 gst_thread_signal_thread (GstThread *thread)
323 g_mutex_lock (thread->lock);
324 g_cond_signal (thread->cond);
325 g_mutex_unlock (thread->lock);
329 gst_thread_restore_thyself (GstElement *element,
331 GHashTable *elements)
333 g_print("gstthread: restore\n");
335 if (GST_ELEMENT_CLASS (parent_class)->restore_thyself)
336 GST_ELEMENT_CLASS (parent_class)->restore_thyself (element,parent, elements);
340 gst_thread_save_thyself (GstElement *element,
343 if (GST_ELEMENT_CLASS (parent_class)->save_thyself)
344 GST_ELEMENT_CLASS (parent_class)->save_thyself (element,parent);