mpp/base/mpp_cluster.c

37 typedef struct ClusterQueue_s   ClusterQueue;  typedef
73     ClusterQueue            *queue;
123     ClusterQueue            queue[MAX_PRIORITY];
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()
424         ClusterQueue *queue = &cluster->queue[i];  in cluster_worker_get_task()
514             ClusterQueue *queue = task->queue;  in cluster_worker_run_task()
741     ClusterQueue *queue = &p->queue[priority];  in mpp_node_attach()