| /rockchip-linux_mpp/osal/ |
| H A D | mpp_thread.c | 66 if (0 == pthread_create(&thread->thd, &attr, thread->func, thread->ctx)) { in mpp_thread_start()
67 int ret = pthread_setname_np(thread->thd, thread->name); in mpp_thread_start()
93 pthread_join(thread->thd, &dummy); in mpp_thread_stop()
305 pthread_t thd; member
333 static rk_s32 check_sthd(const char *name, MppSThdImpl *thd) in check_sthd() argument
335 if (!thd) { in check_sthd()
340 if (thd->ctx.thd != thd) { in check_sthd()
341 mpp_err("mpp_sthd check %p:%p mismatch at %s\n", thd->ctx.thd, thd, name); in check_sthd()
348 #define CHECK_STHD(thd) check_sthd(__FUNCTION__, (MppSThdImpl *)(thd)) argument
350 static void mpp_sthd_init(MppSThdImpl *thd, rk_s32 idx) in mpp_sthd_init() argument
[all …]
|
| H A D | mpp_time.c | 197 MppThread *thd; member
218 MppThread *thd = impl->thd; in mpp_timer_thread() local
240 if (MPP_THREAD_RUNNING != mpp_thread_get_status(thd, THREAD_WORK)) in mpp_timer_thread()
367 if (!impl->enabled && !impl->thd) { in mpp_timer_set_enable()
368 MppThread *thd = mpp_thread_create(mpp_timer_thread, impl, impl->name); in mpp_timer_set_enable() local
370 if (thd) { in mpp_timer_set_enable()
371 impl->thd = thd; in mpp_timer_set_enable()
373 mpp_thread_start(impl->thd); in mpp_timer_set_enable()
377 if (impl->enabled && impl->thd) { in mpp_timer_set_enable()
378 mpp_thread_stop(impl->thd); in mpp_timer_set_enable()
[all …]
|
| /rockchip-linux_mpp/osal/inc/ |
| H A D | mpp_thread.h | 66 pthread_t thd; member
148 MppSThd thd; member
155 void mpp_sthd_put(MppSThd thd);
157 MppSThdStatus mpp_sthd_get_status(MppSThd thd);
158 const char* mpp_sthd_get_name(MppSThd thd);
159 rk_s32 mpp_sthd_get_idx(MppSThd thd);
160 rk_s32 mpp_sthd_check(MppSThd thd);
162 void mpp_sthd_setup(MppSThd thd, MppSThdFunc func, void *ctx);
164 void mpp_sthd_start(MppSThd thd);
165 void mpp_sthd_stop(MppSThd thd);
[all …]
|
| /rockchip-linux_mpp/mpp/base/ |
| H A D | mpp_cluster.c | 108 MppThread *thd; member
373 MppThread *thd = NULL; in cluster_worker_init() local
384 thd = mpp_thread_create(cluster->worker_func, p, p->name); in cluster_worker_init()
385 if (thd) { in cluster_worker_init()
386 p->thd = thd; in cluster_worker_init()
387 mpp_thread_start(thd); in cluster_worker_init()
396 if (p->thd) { in cluster_worker_deinit()
397 mpp_thread_stop(p->thd); in cluster_worker_deinit()
398 mpp_thread_destroy(p->thd); in cluster_worker_deinit()
399 p->thd = NULL; in cluster_worker_deinit()
[all …]
|
| /rockchip-linux_mpp/mpp/vproc/ |
| H A D | mpp_dec_vproc.c | 76 MppThread *thd; member
840 MppThread *thd = ctx->thd; in dec_vproc_thread() local
854 mpp_thread_lock(thd, THREAD_WORK); in dec_vproc_thread()
855 if (MPP_THREAD_RUNNING != mpp_thread_get_status(thd, THREAD_WORK)) { in dec_vproc_thread()
856 mpp_thread_unlock(thd, THREAD_WORK); in dec_vproc_thread()
862 mpp_thread_wait(thd, THREAD_WORK); in dec_vproc_thread()
864 mpp_thread_unlock(thd, THREAD_WORK); in dec_vproc_thread()
874 mpp_thread_lock(thd, THREAD_CONTROL); in dec_vproc_thread()
876 mpp_thread_unlock(thd, THREAD_CONTROL); in dec_vproc_thread()
1002 p->thd = mpp_thread_create(dec_vproc_thread, p, "mpp_dec_vproc"); in dec_vproc_init()
[all …]
|
| /rockchip-linux_mpp/mpp/codec/ |
| H A D | mpp_enc_v2.c | 309 MppThread *thd; in mpp_enc_reset_v2() local
318 thd = enc->thread_enc; in mpp_enc_reset_v2()
320 mpp_thread_lock(thd, THREAD_CONTROL); in mpp_enc_reset_v2()
323 mpp_thread_unlock(thd, THREAD_CONTROL); in mpp_enc_reset_v2()
334 MppThread *thd = enc->thread_enc; in mpp_enc_notify_v2() local
338 mpp_thread_lock(thd, THREAD_WORK); in mpp_enc_notify_v2()
343 mpp_thread_signal(thd, THREAD_WORK); in mpp_enc_notify_v2()
352 mpp_thread_signal(thd, THREAD_WORK); in mpp_enc_notify_v2()
355 mpp_thread_unlock(thd, THREAD_WORK); in mpp_enc_notify_v2()
|
| /rockchip-linux_mpp/mpp/vproc/vdpp/test/ |
| H A D | hwpq_test.c | 63 pthread_t thd; // thread for for each instance member
276 ret = pthread_create(&ctxs[i].thd, NULL, multi_vdpp, &ctxs[i]); in main()
285 pthread_join(ctxs[i].thd, NULL); in main()
|
| /rockchip-linux_mpp/test/ |
| H A D | mpi_dec_nt_test.c | 325 pthread_t thd; in dec_nt_decode() local
418 ret = pthread_create(&thd, &attr, thread_decode, &data); in dec_nt_decode()
434 pthread_join(thd, NULL); in dec_nt_decode()
|
| H A D | mpi_dec_multi_test.c | 62 pthread_t thd; // thread for for each instance member
609 ret = pthread_create(&ctxs[i].thd, NULL, multi_dec_decode, &ctxs[i]); in main()
628 pthread_join(ctxs[i].thd, NULL); in main()
|
| H A D | mpi_dec_test.c | 430 pthread_t thd; in dec_decode() local
553 ret = pthread_create(&thd, &attr, thread_decode, &data); in dec_decode()
569 pthread_join(thd, NULL); in dec_decode()
|
| H A D | mpi_enc_test.c | 178 pthread_t thd; // thread for for each instance member
1318 ret = pthread_create(&ctxs[i].thd, NULL, enc_test, &ctxs[i]); in enc_test_multi()
1337 pthread_join(ctxs[i].thd, NULL); in enc_test_multi()
|
| /rockchip-linux_mpp/utils/ |
| H A D | mpi_dec_utils.c | 65 pthread_t thd; member
403 pthread_create(&impl->thd, NULL, reader_worker, impl); in reader_start()
410 pthread_join(impl->thd, NULL); in reader_sync()
419 pthread_join(impl->thd, NULL); in reader_stop()
|