96     MppCluster              *cluster;  member
105     MppCluster              *cluster;  member
167     MppCluster *cluster = queue->cluster;  in cluster_queue_lock_f()  local
170     cluster_dbg_lock("%s lock queue at %s start\n", cluster->name, caller);  in cluster_queue_lock_f()
174     cluster_dbg_lock("%s lock queue at %s ret %d \n", cluster->name, caller, ret);  in cluster_queue_lock_f()
181     MppCluster *cluster = queue->cluster;  in cluster_queue_unlock_f()  local
184     cluster_dbg_lock("%s unlock queue at %s start\n", cluster->name, caller);  in cluster_queue_unlock_f()
188     cluster_dbg_lock("%s unlock queue at %s ret %d \n", cluster->name, caller, ret);  in cluster_queue_unlock_f()
195 MPP_RET mpp_cluster_queue_init(ClusterQueue *queue, MppCluster *cluster)  in mpp_cluster_queue_init()  argument
204     queue->cluster = cluster;  in mpp_cluster_queue_init()
241     MppCluster *cluster = queue->cluster;  in mpp_node_task_schedule_f()  local
286         cluster_dbg_flow("%s sched task -> wq %s:%d\n", node_name, cluster->name, queue->count);  in mpp_node_task_schedule_f()
290         cluster_signal_f(caller, cluster);  in mpp_node_task_schedule_f()
294         cluster_signal_f(caller, cluster);  in mpp_node_task_schedule_f()
371 MPP_RET cluster_worker_init(ClusterWorker *p, MppCluster *cluster)  in cluster_worker_init()  argument
377     p->worker_id = cluster->worker_id++;  in cluster_worker_init()
381     p->cluster = cluster;  in cluster_worker_init()
383     snprintf(p->name, sizeof(p->name) - 1, "%d:W%d", cluster->pid, p->worker_id);  in cluster_worker_init()
384     thd = mpp_thread_create(cluster->worker_func, p, p->name);  in cluster_worker_init()
406     p->cluster = NULL;  in cluster_worker_deinit()
413     MppCluster *cluster = p->cluster;  in cluster_worker_get_task()  local
424         ClusterQueue *queue = &cluster->queue[i];  in cluster_worker_get_task()