gpointer thr_user_data;
GDestroyNotify thr_notify;
- gboolean prio_set;
- GThreadPriority priority;
-
/* configured pool */
GstTaskPool *pool;
task->lock = NULL;
g_cond_init (&task->cond);
SET_TASK_STATE (task, GST_TASK_STOPPED);
- task->priv->prio_set = FALSE;
/* use the default klass pool for this task, users can
* override this later */
if (G_UNLIKELY (lock == NULL))
goto no_lock;
task->thread = tself;
- /* only update the priority when it was changed */
- if (priv->prio_set) {
- GST_INFO_OBJECT (task, "Thread priorities no longer have any effect");
- }
GST_OBJECT_UNLOCK (task);
/* fire the enter_thread callback when we need to */
}
/**
- * gst_task_set_priority:
- * @task: a #GstTask
- * @priority: a new priority for @task
- *
- * Changes the priority of @task to @priority.
- *
- * Note: try not to depend on task priorities.
- *
- * MT safe.
- *
- * Since: 0.10.24
- */
-/* FIXME 0.11: remove gst_task_set_priority() */
-void
-gst_task_set_priority (GstTask * task, GThreadPriority priority)
-{
- GstTaskPrivate *priv;
- GThread *thread;
-
- g_return_if_fail (GST_IS_TASK (task));
-
- priv = task->priv;
-
- GST_OBJECT_LOCK (task);
- priv->prio_set = TRUE;
- priv->priority = priority;
- thread = task->thread;
- if (thread != NULL) {
- /* if this task already has a thread, we can configure the priority right
- * away, else we do that when we assign a thread to the task. */
- GST_INFO_OBJECT (task, "Thread priorities no longer have any effect");
- }
- GST_OBJECT_UNLOCK (task);
-}
-
-/**
* gst_task_get_pool:
* @task: a #GstTask
*
GstTask* gst_task_new (GstTaskFunction func, gpointer data);
void gst_task_set_lock (GstTask *task, GRecMutex *mutex);
-void gst_task_set_priority (GstTask *task, GThreadPriority priority);
GstTaskPool * gst_task_get_pool (GstTask *task);
void gst_task_set_pool (GstTask *task, GstTaskPool *pool);
break;
case GST_STREAM_STATUS_TYPE_ENTER:
if (task) {
- g_message ("raising task priority for %p", task);
- gst_task_set_priority (task, G_THREAD_PRIORITY_HIGH);
+ /* g_message ("raising task priority for %p", task); */
+ /* FIXME: do something here */
}
break;
case GST_STREAM_STATUS_TYPE_LEAVE: