summaryrefslogtreecommitdiffstats
path: root/libhb/taskset.h
diff options
context:
space:
mode:
authorjstebbins <[email protected]>2012-05-18 06:54:25 +0000
committerjstebbins <[email protected]>2012-05-18 06:54:25 +0000
commit6a31263baa876f3cf0eba0aa88a7dbc69239b8ab (patch)
treeb08444c845d3cb2a9e4961f11f2f80969542b1f4 /libhb/taskset.h
parent5a0673d1572fdfcd00063cfa9dffba907c808056 (diff)
Forgot to svn add some taskset files
git-svn-id: svn://svn.handbrake.fr/HandBrake/trunk@4686 b64f7644-9d1e-0410-96f1-a4d463321fa5
Diffstat (limited to 'libhb/taskset.h')
-rw-r--r--libhb/taskset.h52
1 files changed, 52 insertions, 0 deletions
diff --git a/libhb/taskset.h b/libhb/taskset.h
new file mode 100644
index 000000000..b482c0bef
--- /dev/null
+++ b/libhb/taskset.h
@@ -0,0 +1,52 @@
+/* $Id$
+
+ This file is part of the HandBrake source code.
+ Homepage: <http://handbrake.fr/>.
+ It may be used under the terms of the GNU General Public License. */
+
+#ifndef HB_TASKSET_H
+#define HB_TASKSET_H
+
+#define TASKSET_POSIX_COMPLIANT 1
+
+#include "bits.h"
+
+typedef struct hb_taskset_s {
+ int thread_count;
+ int arg_size;
+ int bitmap_elements;
+ hb_thread_t ** task_threads;
+ uint8_t * task_threads_args;
+ uint32_t * task_begin_bitmap; // Threads can begin
+ uint32_t * task_complete_bitmap; // Threads have completed
+ uint32_t * task_stop_bitmap; // Threads should exit
+ hb_lock_t * task_cond_lock; // Held during condition tests
+ hb_cond_t * task_begin; // Threads can begin work
+ hb_cond_t * task_complete; // Threads have finished work.
+} taskset_t;
+
+int taskset_init( taskset_t *, int /*thread_count*/, size_t /*user_arg_size*/ );
+void taskset_cycle( taskset_t * );
+void taskset_fini( taskset_t * );
+
+int taskset_thread_spawn( taskset_t *, int /*thr_idx*/, const char * /*descr*/,
+ thread_func_t *, int /*priority*/ );
+void taskset_thread_wait4start( taskset_t *, int );
+void taskset_thread_complete( taskset_t *, int );
+
+static inline void *taskset_thread_args( taskset_t *, int );
+static inline int taskset_thread_stop( taskset_t *, int );
+
+static inline void *
+taskset_thread_args( taskset_t *ts, int thr_idx )
+{
+ return( ts->task_threads_args + ( ts->arg_size * thr_idx ) );
+}
+
+static inline int
+taskset_thread_stop( taskset_t *ts, int thr_idx )
+{
+ return bit_is_set( ts->task_stop_bitmap, thr_idx );
+}
+
+#endif /* HB_TASKSET_H */