Commit a86ee96c authored by Matthew Brost's avatar Matthew Brost
Browse files

drm/xe: Add xe_sched_msg_lock/unlock helper

parent 549dd786
Loading
Loading
Loading
Loading
+6 −6
Original line number Diff line number Diff line
@@ -15,11 +15,11 @@ static void xe_sched_process_msg_queue_if_ready(struct xe_gpu_scheduler *sched)
{
	struct xe_sched_msg *msg;

	spin_lock(&sched->base.job_list_lock);
	xe_sched_msg_lock(sched);
	msg = list_first_entry_or_null(&sched->msgs, struct xe_sched_msg, link);
	if (msg)
		xe_sched_process_msg_queue(sched);
	spin_unlock(&sched->base.job_list_lock);
	xe_sched_msg_unlock(sched);
}

static struct xe_sched_msg *
@@ -27,12 +27,12 @@ xe_sched_get_msg(struct xe_gpu_scheduler *sched)
{
	struct xe_sched_msg *msg;

	spin_lock(&sched->base.job_list_lock);
	xe_sched_msg_lock(sched);
	msg = list_first_entry_or_null(&sched->msgs,
				       struct xe_sched_msg, link);
	if (msg)
		list_del(&msg->link);
	spin_unlock(&sched->base.job_list_lock);
	xe_sched_msg_unlock(sched);

	return msg;
}
@@ -93,9 +93,9 @@ void xe_sched_submission_stop(struct xe_gpu_scheduler *sched)
void xe_sched_add_msg(struct xe_gpu_scheduler *sched,
		      struct xe_sched_msg *msg)
{
	spin_lock(&sched->base.job_list_lock);
	xe_sched_msg_lock(sched);
	list_add_tail(&msg->link, &sched->msgs);
	spin_unlock(&sched->base.job_list_lock);
	xe_sched_msg_unlock(sched);

	xe_sched_process_msg_queue(sched);
}
+10 −0
Original line number Diff line number Diff line
@@ -25,6 +25,16 @@ void xe_sched_submission_stop(struct xe_gpu_scheduler *sched);
void xe_sched_add_msg(struct xe_gpu_scheduler *sched,
		      struct xe_sched_msg *msg);

static inline void xe_sched_msg_lock(struct xe_gpu_scheduler *sched)
{
	spin_lock(&sched->base.job_list_lock);
}

static inline void xe_sched_msg_unlock(struct xe_gpu_scheduler *sched)
{
	spin_unlock(&sched->base.job_list_lock);
}

static inline void xe_sched_stop(struct xe_gpu_scheduler *sched)
{
	drm_sched_stop(&sched->base, NULL);