Lines Matching refs:thd
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()
556 MppThread *thd = p->thd; in cluster_worker() local
563 mpp_thread_lock(thd, THREAD_WORK); in cluster_worker()
566 if (MPP_THREAD_RUNNING != mpp_thread_get_status(thd, THREAD_WORK)) { in cluster_worker()
567 mpp_thread_unlock(thd, THREAD_WORK); in cluster_worker()
574 mpp_thread_wait(thd, THREAD_WORK); in cluster_worker()
577 mpp_thread_unlock(thd, THREAD_WORK); in cluster_worker()
594 MppThread *thd = worker->thd; in cluster_signal_f() local
596 mpp_thread_lock(thd, THREAD_WORK); in cluster_signal_f()
599 mpp_thread_signal(thd, THREAD_WORK); in cluster_signal_f()
601 mpp_thread_unlock(thd, THREAD_WORK); in cluster_signal_f()
605 mpp_thread_unlock(thd, THREAD_WORK); in cluster_signal_f()