Lines Matching refs:waiter
33 * add a waiter to a waiter queue, sorted by threshold
36 static bool add_waiter_to_queue(struct host1x_waitlist *waiter,
40 u32 thresh = waiter->thresh;
44 list_add(&waiter->list, &pos->list);
48 list_add(&waiter->list, queue);
53 * run through a waiter queue for a single sync point ID
60 struct host1x_waitlist *waiter, *next, *prev;
62 list_for_each_entry_safe(waiter, next, head, list) {
63 if ((s32)(waiter->thresh - sync) > 0)
66 dest = completed + waiter->action;
69 if (waiter->action == HOST1X_INTR_ACTION_SUBMIT_COMPLETE &&
73 if (prev->data == waiter->data) {
80 if (atomic_inc_return(&waiter->state) == WLS_HANDLED || !dest) {
81 list_del(&waiter->list);
82 kref_put(&waiter->refcount, waiter_release);
84 list_move_tail(&waiter->list, dest);
99 static void action_submit_complete(struct host1x_waitlist *waiter)
101 struct host1x_channel *channel = waiter->data;
107 waiter->count, waiter->thresh);
110 static void action_wakeup(struct host1x_waitlist *waiter)
112 wait_queue_head_t *wq = waiter->data;
117 static void action_wakeup_interruptible(struct host1x_waitlist *waiter)
119 wait_queue_head_t *wq = waiter->data;
124 typedef void (*action_handler)(struct host1x_waitlist *waiter);
139 struct host1x_waitlist *waiter, *next;
141 list_for_each_entry_safe(waiter, next, head, list) {
142 list_del(&waiter->list);
143 handler(waiter);
144 WARN_ON(atomic_xchg(&waiter->state, WLS_HANDLED) !=
146 kref_put(&waiter->refcount, waiter_release);
204 void *data, struct host1x_waitlist *waiter,
209 if (waiter == NULL) {
210 pr_warn("%s: NULL waiter\n", __func__);
214 /* initialize a new waiter */
215 INIT_LIST_HEAD(&waiter->list);
216 kref_init(&waiter->refcount);
218 kref_get(&waiter->refcount);
219 waiter->thresh = thresh;
220 waiter->action = action;
221 atomic_set(&waiter->state, WLS_PENDING);
222 waiter->data = data;
223 waiter->count = 1;
229 if (add_waiter_to_queue(waiter, &syncpt->intr.wait_head)) {
233 /* added as first waiter - enable interrupt */
241 *ref = waiter;
247 struct host1x_waitlist *waiter = ref;
250 while (atomic_cmpxchg(&waiter->state, WLS_PENDING, WLS_CANCELLED) ==
258 kref_put(&waiter->refcount, waiter_release);
315 struct host1x_waitlist *waiter, *next;
317 list_for_each_entry_safe(waiter, next,
319 if (atomic_cmpxchg(&waiter->state,
321 list_del(&waiter->list);
322 kref_put(&waiter->refcount, waiter_release);