Lines Matching refs:q
50 static int queue_list_add(struct snd_seq_queue *q) in queue_list_add() argument
58 queue_list[i] = q; in queue_list_add()
59 q->queue = i; in queue_list_add()
71 struct snd_seq_queue *q; in queue_list_remove() local
75 q = queue_list[id]; in queue_list_remove()
76 if (q) { in queue_list_remove()
77 spin_lock(&q->owner_lock); in queue_list_remove()
78 if (q->owner == client) { in queue_list_remove()
80 q->klocked = 1; in queue_list_remove()
81 spin_unlock(&q->owner_lock); in queue_list_remove()
85 return q; in queue_list_remove()
87 spin_unlock(&q->owner_lock); in queue_list_remove()
98 struct snd_seq_queue *q; in queue_new() local
100 q = kzalloc(sizeof(*q), GFP_KERNEL); in queue_new()
101 if (!q) in queue_new()
104 spin_lock_init(&q->owner_lock); in queue_new()
105 spin_lock_init(&q->check_lock); in queue_new()
106 mutex_init(&q->timer_mutex); in queue_new()
107 snd_use_lock_init(&q->use_lock); in queue_new()
108 q->queue = -1; in queue_new()
110 q->tickq = snd_seq_prioq_new(); in queue_new()
111 q->timeq = snd_seq_prioq_new(); in queue_new()
112 q->timer = snd_seq_timer_new(); in queue_new()
113 if (q->tickq == NULL || q->timeq == NULL || q->timer == NULL) { in queue_new()
114 snd_seq_prioq_delete(&q->tickq); in queue_new()
115 snd_seq_prioq_delete(&q->timeq); in queue_new()
116 snd_seq_timer_delete(&q->timer); in queue_new()
117 kfree(q); in queue_new()
121 q->owner = owner; in queue_new()
122 q->locked = locked; in queue_new()
123 q->klocked = 0; in queue_new()
125 return q; in queue_new()
129 static void queue_delete(struct snd_seq_queue *q) in queue_delete() argument
132 mutex_lock(&q->timer_mutex); in queue_delete()
133 snd_seq_timer_stop(q->timer); in queue_delete()
134 snd_seq_timer_close(q); in queue_delete()
135 mutex_unlock(&q->timer_mutex); in queue_delete()
137 snd_use_lock_sync(&q->use_lock); in queue_delete()
139 snd_seq_prioq_delete(&q->tickq); in queue_delete()
140 snd_seq_prioq_delete(&q->timeq); in queue_delete()
141 snd_seq_timer_delete(&q->timer); in queue_delete()
143 kfree(q); in queue_delete()
170 struct snd_seq_queue *q; in snd_seq_queue_alloc() local
172 q = queue_new(client, locked); in snd_seq_queue_alloc()
173 if (q == NULL) in snd_seq_queue_alloc()
175 q->info_flags = info_flags; in snd_seq_queue_alloc()
176 queue_use(q, client, 1); in snd_seq_queue_alloc()
177 snd_use_lock_use(&q->use_lock); in snd_seq_queue_alloc()
178 if (queue_list_add(q) < 0) { in snd_seq_queue_alloc()
179 snd_use_lock_free(&q->use_lock); in snd_seq_queue_alloc()
180 queue_delete(q); in snd_seq_queue_alloc()
183 return q; in snd_seq_queue_alloc()
189 struct snd_seq_queue *q; in snd_seq_queue_delete() local
193 q = queue_list_remove(queueid, client); in snd_seq_queue_delete()
194 if (q == NULL) in snd_seq_queue_delete()
196 queue_delete(q); in snd_seq_queue_delete()
205 struct snd_seq_queue *q; in queueptr() local
211 q = queue_list[queueid]; in queueptr()
212 if (q) in queueptr()
213 snd_use_lock_use(&q->use_lock); in queueptr()
215 return q; in queueptr()
222 struct snd_seq_queue *q; in snd_seq_queue_find_name() local
225 q = queueptr(i); in snd_seq_queue_find_name()
226 if (q) { in snd_seq_queue_find_name()
227 if (strncmp(q->name, name, sizeof(q->name)) == 0) in snd_seq_queue_find_name()
228 return q; in snd_seq_queue_find_name()
229 queuefree(q); in snd_seq_queue_find_name()
240 void snd_seq_check_queue(struct snd_seq_queue *q, int atomic, int hop) in snd_seq_check_queue() argument
248 if (q == NULL) in snd_seq_check_queue()
252 spin_lock_irqsave(&q->check_lock, flags); in snd_seq_check_queue()
253 if (q->check_blocked) { in snd_seq_check_queue()
254 q->check_again = 1; in snd_seq_check_queue()
255 spin_unlock_irqrestore(&q->check_lock, flags); in snd_seq_check_queue()
258 q->check_blocked = 1; in snd_seq_check_queue()
259 spin_unlock_irqrestore(&q->check_lock, flags); in snd_seq_check_queue()
263 cur_tick = snd_seq_timer_get_cur_tick(q->timer); in snd_seq_check_queue()
265 cell = snd_seq_prioq_cell_out(q->tickq, &cur_tick); in snd_seq_check_queue()
274 cur_time = snd_seq_timer_get_cur_time(q->timer, false); in snd_seq_check_queue()
276 cell = snd_seq_prioq_cell_out(q->timeq, &cur_time); in snd_seq_check_queue()
286 spin_lock_irqsave(&q->check_lock, flags); in snd_seq_check_queue()
287 if (q->check_again) { in snd_seq_check_queue()
288 q->check_again = 0; in snd_seq_check_queue()
290 spin_unlock_irqrestore(&q->check_lock, flags); in snd_seq_check_queue()
294 q->check_blocked = 0; in snd_seq_check_queue()
295 spin_unlock_irqrestore(&q->check_lock, flags); in snd_seq_check_queue()
303 struct snd_seq_queue *q; in snd_seq_enqueue_event() local
308 q = queueptr(dest); in snd_seq_enqueue_event()
309 if (q == NULL) in snd_seq_enqueue_event()
315 cell->event.time.tick += q->timer->tick.cur_tick; in snd_seq_enqueue_event()
320 &q->timer->cur_time); in snd_seq_enqueue_event()
329 err = snd_seq_prioq_cell_in(q->tickq, cell); in snd_seq_enqueue_event()
334 err = snd_seq_prioq_cell_in(q->timeq, cell); in snd_seq_enqueue_event()
339 queuefree(q); /* unlock */ in snd_seq_enqueue_event()
344 snd_seq_check_queue(q, atomic, hop); in snd_seq_enqueue_event()
346 queuefree(q); /* unlock */ in snd_seq_enqueue_event()
354 static inline int check_access(struct snd_seq_queue *q, int client) in check_access() argument
356 return (q->owner == client) || (!q->locked && !q->klocked); in check_access()
362 static int queue_access_lock(struct snd_seq_queue *q, int client) in queue_access_lock() argument
367 spin_lock_irqsave(&q->owner_lock, flags); in queue_access_lock()
368 access_ok = check_access(q, client); in queue_access_lock()
370 q->klocked = 1; in queue_access_lock()
371 spin_unlock_irqrestore(&q->owner_lock, flags); in queue_access_lock()
376 static inline void queue_access_unlock(struct snd_seq_queue *q) in queue_access_unlock() argument
380 spin_lock_irqsave(&q->owner_lock, flags); in queue_access_unlock()
381 q->klocked = 0; in queue_access_unlock()
382 spin_unlock_irqrestore(&q->owner_lock, flags); in queue_access_unlock()
388 struct snd_seq_queue *q = queueptr(queueid); in snd_seq_queue_check_access() local
392 if (! q) in snd_seq_queue_check_access()
394 spin_lock_irqsave(&q->owner_lock, flags); in snd_seq_queue_check_access()
395 access_ok = check_access(q, client); in snd_seq_queue_check_access()
396 spin_unlock_irqrestore(&q->owner_lock, flags); in snd_seq_queue_check_access()
397 queuefree(q); in snd_seq_queue_check_access()
408 struct snd_seq_queue *q = queueptr(queueid); in snd_seq_queue_set_owner() local
411 if (q == NULL) in snd_seq_queue_set_owner()
414 if (! queue_access_lock(q, client)) { in snd_seq_queue_set_owner()
415 queuefree(q); in snd_seq_queue_set_owner()
419 spin_lock_irqsave(&q->owner_lock, flags); in snd_seq_queue_set_owner()
420 q->locked = locked ? 1 : 0; in snd_seq_queue_set_owner()
421 q->owner = client; in snd_seq_queue_set_owner()
422 spin_unlock_irqrestore(&q->owner_lock, flags); in snd_seq_queue_set_owner()
423 queue_access_unlock(q); in snd_seq_queue_set_owner()
424 queuefree(q); in snd_seq_queue_set_owner()
475 struct snd_seq_queue *q = queueptr(queueid); in snd_seq_queue_timer_set_tempo() local
478 if (q == NULL) in snd_seq_queue_timer_set_tempo()
480 if (! queue_access_lock(q, client)) { in snd_seq_queue_timer_set_tempo()
481 queuefree(q); in snd_seq_queue_timer_set_tempo()
485 result = snd_seq_timer_set_tempo_ppq(q->timer, info->tempo, info->ppq); in snd_seq_queue_timer_set_tempo()
487 result = snd_seq_timer_set_skew(q->timer, info->skew_value, in snd_seq_queue_timer_set_tempo()
489 queue_access_unlock(q); in snd_seq_queue_timer_set_tempo()
490 queuefree(q); in snd_seq_queue_timer_set_tempo()
538 struct snd_seq_queue *q; in snd_seq_queue_is_used() local
541 q = queueptr(queueid); in snd_seq_queue_is_used()
542 if (q == NULL) in snd_seq_queue_is_used()
544 result = test_bit(client, q->clients_bitmap) ? 1 : 0; in snd_seq_queue_is_used()
545 queuefree(q); in snd_seq_queue_is_used()
559 struct snd_seq_queue *q; in snd_seq_queue_client_leave() local
563 q = queue_list_remove(i, client); in snd_seq_queue_client_leave()
564 if (q) in snd_seq_queue_client_leave()
565 queue_delete(q); in snd_seq_queue_client_leave()
572 q = queueptr(i); in snd_seq_queue_client_leave()
573 if (!q) in snd_seq_queue_client_leave()
575 if (test_bit(client, q->clients_bitmap)) { in snd_seq_queue_client_leave()
576 snd_seq_prioq_leave(q->tickq, client, 0); in snd_seq_queue_client_leave()
577 snd_seq_prioq_leave(q->timeq, client, 0); in snd_seq_queue_client_leave()
578 snd_seq_queue_use(q->queue, client, 0); in snd_seq_queue_client_leave()
580 queuefree(q); in snd_seq_queue_client_leave()
592 struct snd_seq_queue *q; in snd_seq_queue_client_leave_cells() local
595 q = queueptr(i); in snd_seq_queue_client_leave_cells()
596 if (!q) in snd_seq_queue_client_leave_cells()
598 snd_seq_prioq_leave(q->tickq, client, 0); in snd_seq_queue_client_leave_cells()
599 snd_seq_prioq_leave(q->timeq, client, 0); in snd_seq_queue_client_leave_cells()
600 queuefree(q); in snd_seq_queue_client_leave_cells()
608 struct snd_seq_queue *q; in snd_seq_queue_remove_cells() local
611 q = queueptr(i); in snd_seq_queue_remove_cells()
612 if (!q) in snd_seq_queue_remove_cells()
614 if (test_bit(client, q->clients_bitmap) && in snd_seq_queue_remove_cells()
616 q->queue == info->queue)) { in snd_seq_queue_remove_cells()
617 snd_seq_prioq_remove_events(q->tickq, client, info); in snd_seq_queue_remove_cells()
618 snd_seq_prioq_remove_events(q->timeq, client, info); in snd_seq_queue_remove_cells()
620 queuefree(q); in snd_seq_queue_remove_cells()
629 static void queue_broadcast_event(struct snd_seq_queue *q, struct snd_seq_event *ev, in queue_broadcast_event() argument
637 sev.time.tick = q->timer->tick.cur_tick; in queue_broadcast_event()
638 sev.queue = q->queue; in queue_broadcast_event()
639 sev.data.queue.queue = q->queue; in queue_broadcast_event()
652 static void snd_seq_queue_process_event(struct snd_seq_queue *q, in snd_seq_queue_process_event() argument
658 snd_seq_prioq_leave(q->tickq, ev->source.client, 1); in snd_seq_queue_process_event()
659 snd_seq_prioq_leave(q->timeq, ev->source.client, 1); in snd_seq_queue_process_event()
660 if (! snd_seq_timer_start(q->timer)) in snd_seq_queue_process_event()
661 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
665 if (! snd_seq_timer_continue(q->timer)) in snd_seq_queue_process_event()
666 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
670 snd_seq_timer_stop(q->timer); in snd_seq_queue_process_event()
671 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
675 snd_seq_timer_set_tempo(q->timer, ev->data.queue.param.value); in snd_seq_queue_process_event()
676 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
680 if (snd_seq_timer_set_position_tick(q->timer, ev->data.queue.param.time.tick) == 0) { in snd_seq_queue_process_event()
681 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
686 if (snd_seq_timer_set_position_time(q->timer, ev->data.queue.param.time.time) == 0) { in snd_seq_queue_process_event()
687 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
691 if (snd_seq_timer_set_skew(q->timer, in snd_seq_queue_process_event()
694 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
707 struct snd_seq_queue *q; in snd_seq_control_queue() local
711 q = queueptr(ev->data.queue.queue); in snd_seq_control_queue()
713 if (q == NULL) in snd_seq_control_queue()
716 if (! queue_access_lock(q, ev->source.client)) { in snd_seq_control_queue()
717 queuefree(q); in snd_seq_control_queue()
721 snd_seq_queue_process_event(q, ev, atomic, hop); in snd_seq_control_queue()
723 queue_access_unlock(q); in snd_seq_control_queue()
724 queuefree(q); in snd_seq_control_queue()
737 struct snd_seq_queue *q; in snd_seq_info_queues_read() local
743 q = queueptr(i); in snd_seq_info_queues_read()
744 if (!q) in snd_seq_info_queues_read()
747 tmr = q->timer; in snd_seq_info_queues_read()
753 spin_lock_irq(&q->owner_lock); in snd_seq_info_queues_read()
754 locked = q->locked; in snd_seq_info_queues_read()
755 owner = q->owner; in snd_seq_info_queues_read()
756 spin_unlock_irq(&q->owner_lock); in snd_seq_info_queues_read()
758 snd_iprintf(buffer, "queue %d: [%s]\n", q->queue, q->name); in snd_seq_info_queues_read()
761 snd_iprintf(buffer, "queued time events : %d\n", snd_seq_prioq_avail(q->timeq)); in snd_seq_info_queues_read()
762 snd_iprintf(buffer, "queued tick events : %d\n", snd_seq_prioq_avail(q->tickq)); in snd_seq_info_queues_read()
770 queuefree(q); in snd_seq_info_queues_read()