22 static inline int snd_seq_pool_available(struct snd_seq_pool *pool)  in snd_seq_pool_available()  argument
24 	return pool->total_elements - atomic_read(&pool->counter);  in snd_seq_pool_available()
27 static inline int snd_seq_output_ok(struct snd_seq_pool *pool)  in snd_seq_output_ok()  argument
29 	return snd_seq_pool_available(pool) >= pool->room;  in snd_seq_output_ok()
225 static inline void free_cell(struct snd_seq_pool *pool,  in free_cell()  argument
228 	cell->next = pool->free;  in free_cell()
229 	pool->free = cell;  in free_cell()
230 	atomic_dec(&pool->counter);  in free_cell()
235 	struct snd_seq_pool *pool;  in snd_seq_cell_free()  local
239 	pool = cell->pool;  in snd_seq_cell_free()
240 	if (snd_BUG_ON(!pool))  in snd_seq_cell_free()
243 	guard(spinlock_irqsave)(&pool->lock);  in snd_seq_cell_free()
244 	free_cell(pool, cell);  in snd_seq_cell_free()
251 				curp->next = pool->free;  in snd_seq_cell_free()
252 				free_cell(pool, curp);  in snd_seq_cell_free()
256 	if (waitqueue_active(&pool->output_sleep)) {  in snd_seq_cell_free()
258 		if (snd_seq_output_ok(pool))  in snd_seq_cell_free()
259 			wake_up(&pool->output_sleep);  in snd_seq_cell_free()
267 static int snd_seq_cell_alloc(struct snd_seq_pool *pool,  in snd_seq_cell_alloc()  argument
277 	if (pool == NULL)  in snd_seq_cell_alloc()
283 	spin_lock_irqsave(&pool->lock, flags);  in snd_seq_cell_alloc()
284 	if (pool->ptr == NULL) {	/* not initialized */  in snd_seq_cell_alloc()
289 	while (pool->free == NULL && ! nonblock && ! pool->closing) {  in snd_seq_cell_alloc()
292 		add_wait_queue(&pool->output_sleep, &wait);  in snd_seq_cell_alloc()
293 		spin_unlock_irqrestore(&pool->lock, flags);  in snd_seq_cell_alloc()
299 		spin_lock_irqsave(&pool->lock, flags);  in snd_seq_cell_alloc()
300 		remove_wait_queue(&pool->output_sleep, &wait);  in snd_seq_cell_alloc()
307 	if (pool->closing) { /* closing.. */  in snd_seq_cell_alloc()
312 	cell = pool->free;  in snd_seq_cell_alloc()
315 		pool->free = cell->next;  in snd_seq_cell_alloc()
316 		atomic_inc(&pool->counter);  in snd_seq_cell_alloc()
317 		used = atomic_read(&pool->counter);  in snd_seq_cell_alloc()
318 		if (pool->max_used < used)  in snd_seq_cell_alloc()
319 			pool->max_used = used;  in snd_seq_cell_alloc()
320 		pool->event_alloc_success++;  in snd_seq_cell_alloc()
325 		pool->event_alloc_failures++;  in snd_seq_cell_alloc()
329 	spin_unlock_irqrestore(&pool->lock, flags);  in snd_seq_cell_alloc()
339 int snd_seq_event_dup(struct snd_seq_pool *pool, struct snd_seq_event *event,  in snd_seq_event_dup()  argument
356 	if (ncells >= pool->total_elements)  in snd_seq_event_dup()
359 	err = snd_seq_cell_alloc(pool, &cell, nonblock, file, mutexp);  in snd_seq_event_dup()
390 			err = snd_seq_cell_alloc(pool, &tmp, nonblock, file,  in snd_seq_event_dup()
426 int snd_seq_pool_poll_wait(struct snd_seq_pool *pool, struct file *file,  in snd_seq_pool_poll_wait()  argument
429 	poll_wait(file, &pool->output_sleep, wait);  in snd_seq_pool_poll_wait()
430 	return snd_seq_output_ok(pool);  in snd_seq_pool_poll_wait()
435 int snd_seq_pool_init(struct snd_seq_pool *pool)  in snd_seq_pool_init()  argument
440 	if (snd_BUG_ON(!pool))  in snd_seq_pool_init()
443 	cellptr = kvmalloc_array(pool->size,  in snd_seq_pool_init()
450 	guard(spinlock_irq)(&pool->lock);  in snd_seq_pool_init()
451 	if (pool->ptr) {  in snd_seq_pool_init()
456 	pool->ptr = cellptr;  in snd_seq_pool_init()
457 	pool->free = NULL;  in snd_seq_pool_init()
459 	for (cell = 0; cell < pool->size; cell++) {  in snd_seq_pool_init()
460 		cellptr = pool->ptr + cell;  in snd_seq_pool_init()
461 		cellptr->pool = pool;  in snd_seq_pool_init()
462 		cellptr->next = pool->free;  in snd_seq_pool_init()
463 		pool->free = cellptr;  in snd_seq_pool_init()
465 	pool->room = (pool->size + 1) / 2;  in snd_seq_pool_init()
468 	pool->max_used = 0;  in snd_seq_pool_init()
469 	pool->total_elements = pool->size;  in snd_seq_pool_init()
474 void snd_seq_pool_mark_closing(struct snd_seq_pool *pool)  in snd_seq_pool_mark_closing()  argument
476 	if (snd_BUG_ON(!pool))  in snd_seq_pool_mark_closing()
478 	guard(spinlock_irqsave)(&pool->lock);  in snd_seq_pool_mark_closing()
479 	pool->closing = 1;  in snd_seq_pool_mark_closing()
483 int snd_seq_pool_done(struct snd_seq_pool *pool)  in snd_seq_pool_done()  argument
487 	if (snd_BUG_ON(!pool))  in snd_seq_pool_done()
491 	if (waitqueue_active(&pool->output_sleep))  in snd_seq_pool_done()
492 		wake_up(&pool->output_sleep);  in snd_seq_pool_done()
494 	while (atomic_read(&pool->counter) > 0)  in snd_seq_pool_done()
498 	scoped_guard(spinlock_irq, &pool->lock) {  in snd_seq_pool_done()
499 		ptr = pool->ptr;  in snd_seq_pool_done()
500 		pool->ptr = NULL;  in snd_seq_pool_done()
501 		pool->free = NULL;  in snd_seq_pool_done()
502 		pool->total_elements = 0;  in snd_seq_pool_done()
507 	guard(spinlock_irq)(&pool->lock);  in snd_seq_pool_done()
508 	pool->closing = 0;  in snd_seq_pool_done()
517 	struct snd_seq_pool *pool;  in snd_seq_pool_new()  local
520 	pool = kzalloc(sizeof(*pool), GFP_KERNEL);  in snd_seq_pool_new()
521 	if (!pool)  in snd_seq_pool_new()
523 	spin_lock_init(&pool->lock);  in snd_seq_pool_new()
524 	pool->ptr = NULL;  in snd_seq_pool_new()
525 	pool->free = NULL;  in snd_seq_pool_new()
526 	pool->total_elements = 0;  in snd_seq_pool_new()
527 	atomic_set(&pool->counter, 0);  in snd_seq_pool_new()
528 	pool->closing = 0;  in snd_seq_pool_new()
529 	init_waitqueue_head(&pool->output_sleep);  in snd_seq_pool_new()
531 	pool->size = poolsize;  in snd_seq_pool_new()
534 	pool->max_used = 0;  in snd_seq_pool_new()
535 	return pool;  in snd_seq_pool_new()
541 	struct snd_seq_pool *pool = *ppool;  in snd_seq_pool_delete()  local
544 	if (pool == NULL)  in snd_seq_pool_delete()
546 	snd_seq_pool_mark_closing(pool);  in snd_seq_pool_delete()
547 	snd_seq_pool_done(pool);  in snd_seq_pool_delete()
548 	kfree(pool);  in snd_seq_pool_delete()
554 		       struct snd_seq_pool *pool, char *space)  in snd_seq_info_pool()  argument
556 	if (pool == NULL)  in snd_seq_info_pool()
558 	snd_iprintf(buffer, "%sPool size          : %d\n", space, pool->total_elements);  in snd_seq_info_pool()
559 	snd_iprintf(buffer, "%sCells in use       : %d\n", space, atomic_read(&pool->counter));  in snd_seq_info_pool()
560 	snd_iprintf(buffer, "%sPeak cells in use  : %d\n", space, pool->max_used);  in snd_seq_info_pool()
561 	snd_iprintf(buffer, "%sAlloc success      : %d\n", space, pool->event_alloc_success);  in snd_seq_info_pool()
562 	snd_iprintf(buffer, "%sAlloc failures     : %d\n", space, pool->event_alloc_failures);  in snd_seq_info_pool()