Searched refs:worker (Results 1 – 3 of 3) sorted by relevance
128 ClusterWorker *worker; member593 ClusterWorker *worker = &p->worker[i]; in cluster_signal_f() local594 MppThread *thd = worker->thd; in cluster_signal_f()598 if (worker->state == WORKER_IDLE) { in cluster_signal_f()681 p->worker = mpp_malloc(ClusterWorker, p->worker_count); in MPP_SINGLETON()684 cluster_worker_init(&p->worker[i], p); in MPP_SINGLETON()720 cluster_worker_deinit(&p->worker[i]); in cluster_server_put()727 MPP_FREE(p->worker); in cluster_server_put()
27 worker thread will use mpp_port_poll / mpp_port_dequeue / mpp_port_enqueue85 Input task queue connects input side external user to internal worker thread.86 Output task queue connects internal worker thread to output side external user.
2 include_directories(worker/inc)