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 if ((q = queueptr(i)) != NULL) { in snd_seq_queue_find_name()
226 if (strncmp(q->name, name, sizeof(q->name)) == 0) in snd_seq_queue_find_name()
227 return q; in snd_seq_queue_find_name()
228 queuefree(q); in snd_seq_queue_find_name()
237 void snd_seq_check_queue(struct snd_seq_queue *q, int atomic, int hop) in snd_seq_check_queue() argument
242 if (q == NULL) in snd_seq_check_queue()
246 spin_lock_irqsave(&q->check_lock, flags); in snd_seq_check_queue()
247 if (q->check_blocked) { in snd_seq_check_queue()
248 q->check_again = 1; in snd_seq_check_queue()
249 spin_unlock_irqrestore(&q->check_lock, flags); in snd_seq_check_queue()
252 q->check_blocked = 1; in snd_seq_check_queue()
253 spin_unlock_irqrestore(&q->check_lock, flags); in snd_seq_check_queue()
258 cell = snd_seq_prioq_cell_out(q->tickq, in snd_seq_check_queue()
259 &q->timer->tick.cur_tick); in snd_seq_check_queue()
267 cell = snd_seq_prioq_cell_out(q->timeq, &q->timer->cur_time); in snd_seq_check_queue()
274 spin_lock_irqsave(&q->check_lock, flags); in snd_seq_check_queue()
275 if (q->check_again) { in snd_seq_check_queue()
276 q->check_again = 0; in snd_seq_check_queue()
277 spin_unlock_irqrestore(&q->check_lock, flags); in snd_seq_check_queue()
280 q->check_blocked = 0; in snd_seq_check_queue()
281 spin_unlock_irqrestore(&q->check_lock, flags); in snd_seq_check_queue()
289 struct snd_seq_queue *q; in snd_seq_enqueue_event() local
294 q = queueptr(dest); in snd_seq_enqueue_event()
295 if (q == NULL) in snd_seq_enqueue_event()
301 cell->event.time.tick += q->timer->tick.cur_tick; in snd_seq_enqueue_event()
306 &q->timer->cur_time); in snd_seq_enqueue_event()
315 err = snd_seq_prioq_cell_in(q->tickq, cell); in snd_seq_enqueue_event()
320 err = snd_seq_prioq_cell_in(q->timeq, cell); in snd_seq_enqueue_event()
325 queuefree(q); /* unlock */ in snd_seq_enqueue_event()
330 snd_seq_check_queue(q, atomic, hop); in snd_seq_enqueue_event()
332 queuefree(q); /* unlock */ in snd_seq_enqueue_event()
340 static inline int check_access(struct snd_seq_queue *q, int client) in check_access() argument
342 return (q->owner == client) || (!q->locked && !q->klocked); in check_access()
348 static int queue_access_lock(struct snd_seq_queue *q, int client) in queue_access_lock() argument
353 spin_lock_irqsave(&q->owner_lock, flags); in queue_access_lock()
354 access_ok = check_access(q, client); in queue_access_lock()
356 q->klocked = 1; in queue_access_lock()
357 spin_unlock_irqrestore(&q->owner_lock, flags); in queue_access_lock()
362 static inline void queue_access_unlock(struct snd_seq_queue *q) in queue_access_unlock() argument
366 spin_lock_irqsave(&q->owner_lock, flags); in queue_access_unlock()
367 q->klocked = 0; in queue_access_unlock()
368 spin_unlock_irqrestore(&q->owner_lock, flags); in queue_access_unlock()
374 struct snd_seq_queue *q = queueptr(queueid); in snd_seq_queue_check_access() local
378 if (! q) in snd_seq_queue_check_access()
380 spin_lock_irqsave(&q->owner_lock, flags); in snd_seq_queue_check_access()
381 access_ok = check_access(q, client); in snd_seq_queue_check_access()
382 spin_unlock_irqrestore(&q->owner_lock, flags); in snd_seq_queue_check_access()
383 queuefree(q); in snd_seq_queue_check_access()
394 struct snd_seq_queue *q = queueptr(queueid); in snd_seq_queue_set_owner() local
396 if (q == NULL) in snd_seq_queue_set_owner()
399 if (! queue_access_lock(q, client)) { in snd_seq_queue_set_owner()
400 queuefree(q); in snd_seq_queue_set_owner()
404 q->locked = locked ? 1 : 0; in snd_seq_queue_set_owner()
405 q->owner = client; in snd_seq_queue_set_owner()
406 queue_access_unlock(q); in snd_seq_queue_set_owner()
407 queuefree(q); in snd_seq_queue_set_owner()
457 struct snd_seq_queue *q = queueptr(queueid); in snd_seq_queue_timer_set_tempo() local
460 if (q == NULL) in snd_seq_queue_timer_set_tempo()
462 if (! queue_access_lock(q, client)) { in snd_seq_queue_timer_set_tempo()
463 queuefree(q); in snd_seq_queue_timer_set_tempo()
467 result = snd_seq_timer_set_tempo_ppq(q->timer, info->tempo, info->ppq); in snd_seq_queue_timer_set_tempo()
469 result = snd_seq_timer_set_skew(q->timer, info->skew_value, in snd_seq_queue_timer_set_tempo()
471 queue_access_unlock(q); in snd_seq_queue_timer_set_tempo()
472 queuefree(q); in snd_seq_queue_timer_set_tempo()
520 struct snd_seq_queue *q; in snd_seq_queue_is_used() local
523 q = queueptr(queueid); in snd_seq_queue_is_used()
524 if (q == NULL) in snd_seq_queue_is_used()
526 result = test_bit(client, q->clients_bitmap) ? 1 : 0; in snd_seq_queue_is_used()
527 queuefree(q); in snd_seq_queue_is_used()
541 struct snd_seq_queue *q; in snd_seq_queue_client_termination() local
544 if ((q = queueptr(i)) == NULL) in snd_seq_queue_client_termination()
546 spin_lock_irqsave(&q->owner_lock, flags); in snd_seq_queue_client_termination()
547 if (q->owner == client) in snd_seq_queue_client_termination()
548 q->klocked = 1; in snd_seq_queue_client_termination()
549 spin_unlock_irqrestore(&q->owner_lock, flags); in snd_seq_queue_client_termination()
550 if (q->owner == client) { in snd_seq_queue_client_termination()
551 if (q->timer->running) in snd_seq_queue_client_termination()
552 snd_seq_timer_stop(q->timer); in snd_seq_queue_client_termination()
553 snd_seq_timer_reset(q->timer); in snd_seq_queue_client_termination()
555 queuefree(q); in snd_seq_queue_client_termination()
566 struct snd_seq_queue *q; in snd_seq_queue_client_leave() local
570 if ((q = queue_list_remove(i, client)) != NULL) in snd_seq_queue_client_leave()
571 queue_delete(q); in snd_seq_queue_client_leave()
578 if ((q = queueptr(i)) == NULL) in snd_seq_queue_client_leave()
580 if (test_bit(client, q->clients_bitmap)) { in snd_seq_queue_client_leave()
581 snd_seq_prioq_leave(q->tickq, client, 0); in snd_seq_queue_client_leave()
582 snd_seq_prioq_leave(q->timeq, client, 0); in snd_seq_queue_client_leave()
583 snd_seq_queue_use(q->queue, client, 0); in snd_seq_queue_client_leave()
585 queuefree(q); in snd_seq_queue_client_leave()
597 struct snd_seq_queue *q; in snd_seq_queue_client_leave_cells() local
600 if ((q = queueptr(i)) == NULL) in snd_seq_queue_client_leave_cells()
602 snd_seq_prioq_leave(q->tickq, client, 0); in snd_seq_queue_client_leave_cells()
603 snd_seq_prioq_leave(q->timeq, client, 0); in snd_seq_queue_client_leave_cells()
604 queuefree(q); in snd_seq_queue_client_leave_cells()
612 struct snd_seq_queue *q; in snd_seq_queue_remove_cells() local
615 if ((q = queueptr(i)) == NULL) in snd_seq_queue_remove_cells()
617 if (test_bit(client, q->clients_bitmap) && in snd_seq_queue_remove_cells()
619 q->queue == info->queue)) { in snd_seq_queue_remove_cells()
620 snd_seq_prioq_remove_events(q->tickq, client, info); in snd_seq_queue_remove_cells()
621 snd_seq_prioq_remove_events(q->timeq, client, info); in snd_seq_queue_remove_cells()
623 queuefree(q); in snd_seq_queue_remove_cells()
632 static void queue_broadcast_event(struct snd_seq_queue *q, struct snd_seq_event *ev, in queue_broadcast_event() argument
640 sev.time.tick = q->timer->tick.cur_tick; in queue_broadcast_event()
641 sev.queue = q->queue; in queue_broadcast_event()
642 sev.data.queue.queue = q->queue; in queue_broadcast_event()
655 static void snd_seq_queue_process_event(struct snd_seq_queue *q, in snd_seq_queue_process_event() argument
661 snd_seq_prioq_leave(q->tickq, ev->source.client, 1); in snd_seq_queue_process_event()
662 snd_seq_prioq_leave(q->timeq, ev->source.client, 1); in snd_seq_queue_process_event()
663 if (! snd_seq_timer_start(q->timer)) in snd_seq_queue_process_event()
664 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
668 if (! snd_seq_timer_continue(q->timer)) in snd_seq_queue_process_event()
669 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
673 snd_seq_timer_stop(q->timer); in snd_seq_queue_process_event()
674 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
678 snd_seq_timer_set_tempo(q->timer, ev->data.queue.param.value); in snd_seq_queue_process_event()
679 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
683 if (snd_seq_timer_set_position_tick(q->timer, ev->data.queue.param.time.tick) == 0) { in snd_seq_queue_process_event()
684 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
689 if (snd_seq_timer_set_position_time(q->timer, ev->data.queue.param.time.time) == 0) { in snd_seq_queue_process_event()
690 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
694 if (snd_seq_timer_set_skew(q->timer, in snd_seq_queue_process_event()
697 queue_broadcast_event(q, ev, atomic, hop); in snd_seq_queue_process_event()
710 struct snd_seq_queue *q; in snd_seq_control_queue() local
714 q = queueptr(ev->data.queue.queue); in snd_seq_control_queue()
716 if (q == NULL) in snd_seq_control_queue()
719 if (! queue_access_lock(q, ev->source.client)) { in snd_seq_control_queue()
720 queuefree(q); in snd_seq_control_queue()
724 snd_seq_queue_process_event(q, ev, atomic, hop); in snd_seq_control_queue()
726 queue_access_unlock(q); in snd_seq_control_queue()
727 queuefree(q); in snd_seq_control_queue()
740 struct snd_seq_queue *q; in snd_seq_info_queues_read() local
744 if ((q = queueptr(i)) == NULL) in snd_seq_info_queues_read()
747 tmr = q->timer; in snd_seq_info_queues_read()
753 snd_iprintf(buffer, "queue %d: [%s]\n", q->queue, q->name); in snd_seq_info_queues_read()
754 snd_iprintf(buffer, "owned by client : %d\n", q->owner); in snd_seq_info_queues_read()
755 snd_iprintf(buffer, "lock status : %s\n", q->locked ? "Locked" : "Free"); in snd_seq_info_queues_read()
756 snd_iprintf(buffer, "queued time events : %d\n", snd_seq_prioq_avail(q->timeq)); in snd_seq_info_queues_read()
757 snd_iprintf(buffer, "queued tick events : %d\n", snd_seq_prioq_avail(q->tickq)); in snd_seq_info_queues_read()
765 queuefree(q); in snd_seq_info_queues_read()