Lines Matching defs:entity
44 * The jobs in a entity are always scheduled in the order that they were pushed.
47 * hardware, i.e. the pending queue, the entity must not be referenced anymore
48 * through the jobs entity pointer.
88 static inline void drm_sched_rq_remove_fifo_locked(struct drm_sched_entity *entity)
90 struct drm_sched_rq *rq = entity->rq;
92 if (!RB_EMPTY_NODE(&entity->rb_tree_node)) {
93 rb_erase_cached(&entity->rb_tree_node, &rq->rb_tree_root);
94 RB_CLEAR_NODE(&entity->rb_tree_node);
98 void drm_sched_rq_update_fifo(struct drm_sched_entity *entity, ktime_t ts)
101 * Both locks need to be grabbed, one to protect from entity->rq change
102 * for entity from within concurrent drm_sched_entity_select_rq and the
105 spin_lock(&entity->rq_lock);
106 spin_lock(&entity->rq->lock);
108 drm_sched_rq_remove_fifo_locked(entity);
110 entity->oldest_job_waiting = ts;
112 rb_add_cached(&entity->rb_tree_node, &entity->rq->rb_tree_root,
115 spin_unlock(&entity->rq->lock);
116 spin_unlock(&entity->rq_lock);
138 * drm_sched_rq_add_entity - add an entity
141 * @entity: scheduler entity
143 * Adds a scheduler entity to the run queue.
146 struct drm_sched_entity *entity)
148 if (!list_empty(&entity->list))
154 list_add_tail(&entity->list, &rq->entities);
160 * drm_sched_rq_remove_entity - remove an entity
163 * @entity: scheduler entity
165 * Removes a scheduler entity from the run queue.
168 struct drm_sched_entity *entity)
170 if (list_empty(&entity->list))
176 list_del_init(&entity->list);
178 if (rq->current_entity == entity)
182 drm_sched_rq_remove_fifo_locked(entity);
188 * drm_sched_rq_select_entity_rr - Select an entity which could provide a job to run
192 * Try to find a ready entity, returns NULL if none found.
197 struct drm_sched_entity *entity;
201 entity = rq->current_entity;
202 if (entity) {
203 list_for_each_entry_continue(entity, &rq->entities, list) {
204 if (drm_sched_entity_is_ready(entity)) {
205 rq->current_entity = entity;
206 reinit_completion(&entity->entity_idle);
208 return entity;
213 list_for_each_entry(entity, &rq->entities, list) {
215 if (drm_sched_entity_is_ready(entity)) {
216 rq->current_entity = entity;
217 reinit_completion(&entity->entity_idle);
219 return entity;
222 if (entity == rq->current_entity)
232 * drm_sched_rq_select_entity_fifo - Select an entity which provides a job to run
236 * Find oldest waiting ready entity, returns NULL if none found.
245 struct drm_sched_entity *entity;
247 entity = rb_entry(rb, struct drm_sched_entity, rb_tree_node);
248 if (drm_sched_entity_is_ready(entity)) {
249 rq->current_entity = entity;
250 reinit_completion(&entity->entity_idle);
615 * @entity: scheduler entity to use
625 * has died, which can mean that there's no valid runqueue for a @entity.
632 struct drm_sched_entity *entity,
635 if (!entity->rq)
638 job->entity = entity;
639 job->s_fence = drm_sched_fence_alloc(entity, owner);
667 struct drm_sched_entity *entity = job->entity;
669 BUG_ON(!entity);
670 drm_sched_entity_select_rq(entity);
671 sched = entity->rq->sched;
674 job->s_priority = entity->rq - sched->sched_rq;
677 drm_sched_fence_init(job->s_fence, job->entity);
875 * drm_sched_select_entity - Select next entity to process
879 * Returns the entity to process or NULL if none are found.
884 struct drm_sched_entity *entity;
892 entity = drm_sched_policy == DRM_SCHED_POLICY_FIFO ?
895 if (entity)
899 return entity;
1013 struct drm_sched_entity *entity = NULL;
1022 (entity = drm_sched_select_entity(sched))) ||
1028 if (!entity)
1031 sched_job = drm_sched_entity_pop_job(entity);
1034 complete_all(&entity->entity_idle);
1043 trace_drm_run_job(sched_job, entity);
1045 complete_all(&entity->entity_idle);
1172 * limit of the scheduler then the respective sched entity is marked guilty and
1179 struct drm_sched_entity *entity;
1194 list_for_each_entry_safe(entity, tmp, &rq->entities, list) {
1196 entity->fence_context) {
1197 if (entity->guilty)
1198 atomic_set(entity->guilty, 1);
1203 if (&entity->list != &rq->entities)