73     ClusterQueue            *queue;  member
123     ClusterQueue            queue[MAX_PRIORITY];  member
148 #define cluster_queue_lock(queue)   cluster_queue_lock_f(__FUNCTION__, queue)  argument
149 #define cluster_queue_unlock(queue) cluster_queue_unlock_f(__FUNCTION__, queue)  argument
165 static MPP_RET cluster_queue_lock_f(const char *caller, ClusterQueue *queue)  in cluster_queue_lock_f()
179 static MPP_RET cluster_queue_unlock_f(const char *caller, ClusterQueue *queue)  in cluster_queue_unlock_f()
195 MPP_RET mpp_cluster_queue_init(ClusterQueue *queue, MppCluster *cluster)  in mpp_cluster_queue_init()
211 MPP_RET mpp_cluster_queue_deinit(ClusterQueue *queue)  in mpp_cluster_queue_deinit()
222                              ClusterQueue *queue, MppNodeProc *proc)  in mpp_node_task_attach()
240     ClusterQueue *queue = task->queue;  in mpp_node_task_schedule_f()  local
424         ClusterQueue *queue = &cluster->queue[i];  in cluster_worker_get_task()  local
514             ClusterQueue *queue = task->queue;  in cluster_worker_run_task()  local
741     ClusterQueue *queue = &p->queue[priority];  in mpp_node_attach()  local