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()  argument
167     MppCluster *cluster = queue->cluster;  in cluster_queue_lock_f()
172     ret = pthread_mutex_lock(&queue->lock);  in cluster_queue_lock_f()
179 static MPP_RET cluster_queue_unlock_f(const char *caller, ClusterQueue *queue)  in cluster_queue_unlock_f()  argument
181     MppCluster *cluster = queue->cluster;  in cluster_queue_unlock_f()
186     ret = pthread_mutex_unlock(&queue->lock);  in cluster_queue_unlock_f()
195 MPP_RET mpp_cluster_queue_init(ClusterQueue *queue, MppCluster *cluster)  in mpp_cluster_queue_init()  argument
201     pthread_mutex_init(&queue->lock, &attr);  in mpp_cluster_queue_init()
204     queue->cluster = cluster;  in mpp_cluster_queue_init()
205     INIT_LIST_HEAD(&queue->list);  in mpp_cluster_queue_init()
206     queue->count = 0;  in mpp_cluster_queue_init()
211 MPP_RET mpp_cluster_queue_deinit(ClusterQueue *queue)  in mpp_cluster_queue_deinit()  argument
213     mpp_assert(!queue->count);  in mpp_cluster_queue_deinit()
214     mpp_assert(list_empty(&queue->list));  in mpp_cluster_queue_deinit()
216     pthread_mutex_destroy(&queue->lock);  in mpp_cluster_queue_deinit()
222                              ClusterQueue *queue, MppNodeProc *proc)  in mpp_node_task_attach()  argument
229     task->queue = queue;  in mpp_node_task_attach()
240     ClusterQueue *queue = task->queue;  in mpp_node_task_schedule_f()  local
241     MppCluster *cluster = queue->cluster;  in mpp_node_task_schedule_f()
250                      node_name, caller, node->state, proc->run_count, queue->count);  in mpp_node_task_schedule_f()
282         cluster_queue_lock(queue);  in mpp_node_task_schedule_f()
284         list_add_tail(&task->list_sched, &queue->list);  in mpp_node_task_schedule_f()
285         queue->count++;  in mpp_node_task_schedule_f()
286         cluster_dbg_flow("%s sched task -> wq %s:%d\n", node_name, cluster->name, queue->count);  in mpp_node_task_schedule_f()
287         cluster_queue_unlock(queue);  in mpp_node_task_schedule_f()
299                      node_name, caller, node->state, proc->run_count, queue->count);  in mpp_node_task_schedule_f()
424         ClusterQueue *queue = &cluster->queue[i];  in cluster_worker_get_task()  local
429             cluster_queue_lock(queue);  in cluster_worker_get_task()
431             if (list_empty(&queue->list)) {  in cluster_worker_get_task()
432                 mpp_assert(queue->count == 0);  in cluster_worker_get_task()
434                 cluster_queue_unlock(queue);  in cluster_worker_get_task()
438             mpp_assert(queue->count);  in cluster_worker_get_task()
439             task = list_first_entry(&queue->list, MppNodeTask, list_sched);  in cluster_worker_get_task()
443             queue->count--;  in cluster_worker_get_task()
459             cluster_queue_unlock(queue);  in cluster_worker_get_task()
514             ClusterQueue *queue = task->queue;  in cluster_worker_run_task()  local
527             cluster_queue_lock(queue);  in cluster_worker_run_task()
528             list_add_tail(&task->list_sched, &queue->list);  in cluster_worker_run_task()
529             queue->count++;  in cluster_worker_run_task()
530             cluster_queue_unlock(queue);  in cluster_worker_run_task()
669                 mpp_cluster_queue_init(&p->queue[i], p);  in MPP_SINGLETON()
723         mpp_cluster_queue_deinit(&p->queue[i]);  in cluster_server_put()
741     ClusterQueue *queue = &p->queue[priority];  in mpp_node_attach()  local
750     mpp_node_task_attach(&impl->task, impl, queue, &impl->work);  in mpp_node_attach()