}\
}G_STMT_END
-#define do_cothread_reset(cothread, context, func, argc, argv) \
+#define do_cothread_setfunc(cothread, context, func, argc, argv) \
cothread_setfunc ((cothread), (func), (argc), (argv))
#define do_cothread_destroy(cothread) cothread_free(cothread)
new_thread = cothread_create ((func), 0, (void**) (argv), (context)); \
}G_STMT_END
-#define do_cothread_reset(cothread, context, func, argc, argv) \
- cothread_reset ((cothread), (func), (argc), (void **) (argv), (context))
+#define do_cothread_setfunc(cothread, context, func, argc, argv) \
+ cothread_setfunc ((cothread), (func), (argc), (void **) (argv), (context))
#define do_cothread_destroy(cothread) cothread_destroy(cothread)
GST_ELEMENT_THREADSTATE (element),
GST_ELEMENT_NAME (element));
} else {
- do_cothread_reset (GST_ELEMENT_THREADSTATE (element), chain->sched->context,
- wrapper_function, 0, (char **) element);
+ /* set the cothread wrapper function */
+ do_cothread_setfunc (GST_ELEMENT_THREADSTATE (element), chain->sched->context,
+ wrapper_function, 0, (char **) element);
GST_DEBUG (GST_CAT_SCHEDULING, "set wrapper function for '%s' to &%s",
GST_ELEMENT_NAME (element), GST_DEBUG_FUNCPTR_NAME (wrapper_function));
}
GST_ELEMENT_NAME (element), GST_DEBUG_FUNCPTR_NAME (wrapper_function));
}
} else {
- do_cothread_reset (GST_ELEMENT_THREADSTATE (element), sched->context, wrapper_function, 0, (char **) element);
+ do_cothread_setfunc (GST_ELEMENT_THREADSTATE (element), sched->context, wrapper_function, 0, (char **) element);
GST_DEBUG (GST_CAT_SCHEDULING, "set wrapper function for '%s' to &%s\n",
GST_ELEMENT_NAME (element), GST_DEBUG_FUNCPTR_NAME (wrapper_function));
}