Lines Matching refs:pool
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()
168 static inline void free_cell(struct snd_seq_pool *pool, in free_cell() argument
171 cell->next = pool->free; in free_cell()
172 pool->free = cell; in free_cell()
173 atomic_dec(&pool->counter); in free_cell()
179 struct snd_seq_pool *pool; in snd_seq_cell_free() local
183 pool = cell->pool; in snd_seq_cell_free()
184 if (snd_BUG_ON(!pool)) in snd_seq_cell_free()
187 spin_lock_irqsave(&pool->lock, flags); in snd_seq_cell_free()
188 free_cell(pool, cell); in snd_seq_cell_free()
195 curp->next = pool->free; in snd_seq_cell_free()
196 free_cell(pool, curp); in snd_seq_cell_free()
200 if (waitqueue_active(&pool->output_sleep)) { in snd_seq_cell_free()
202 if (snd_seq_output_ok(pool)) in snd_seq_cell_free()
203 wake_up(&pool->output_sleep); in snd_seq_cell_free()
205 spin_unlock_irqrestore(&pool->lock, flags); in snd_seq_cell_free()
212 static int snd_seq_cell_alloc(struct snd_seq_pool *pool, in snd_seq_cell_alloc() argument
222 if (pool == NULL) in snd_seq_cell_alloc()
228 spin_lock_irqsave(&pool->lock, flags); in snd_seq_cell_alloc()
229 if (pool->ptr == NULL) { /* not initialized */ in snd_seq_cell_alloc()
234 while (pool->free == NULL && ! nonblock && ! pool->closing) { in snd_seq_cell_alloc()
237 add_wait_queue(&pool->output_sleep, &wait); in snd_seq_cell_alloc()
238 spin_unlock_irqrestore(&pool->lock, flags); in snd_seq_cell_alloc()
244 spin_lock_irqsave(&pool->lock, flags); in snd_seq_cell_alloc()
245 remove_wait_queue(&pool->output_sleep, &wait); in snd_seq_cell_alloc()
252 if (pool->closing) { /* closing.. */ in snd_seq_cell_alloc()
257 cell = pool->free; in snd_seq_cell_alloc()
260 pool->free = cell->next; in snd_seq_cell_alloc()
261 atomic_inc(&pool->counter); in snd_seq_cell_alloc()
262 used = atomic_read(&pool->counter); in snd_seq_cell_alloc()
263 if (pool->max_used < used) in snd_seq_cell_alloc()
264 pool->max_used = used; in snd_seq_cell_alloc()
265 pool->event_alloc_success++; in snd_seq_cell_alloc()
270 pool->event_alloc_failures++; in snd_seq_cell_alloc()
274 spin_unlock_irqrestore(&pool->lock, flags); in snd_seq_cell_alloc()
284 int snd_seq_event_dup(struct snd_seq_pool *pool, struct snd_seq_event *event, in snd_seq_event_dup() argument
300 if (ncells >= pool->total_elements) in snd_seq_event_dup()
303 err = snd_seq_cell_alloc(pool, &cell, nonblock, file, mutexp); in snd_seq_event_dup()
329 err = snd_seq_cell_alloc(pool, &tmp, nonblock, file, in snd_seq_event_dup()
365 int snd_seq_pool_poll_wait(struct snd_seq_pool *pool, struct file *file, in snd_seq_pool_poll_wait() argument
368 poll_wait(file, &pool->output_sleep, wait); in snd_seq_pool_poll_wait()
369 return snd_seq_output_ok(pool); in snd_seq_pool_poll_wait()
374 int snd_seq_pool_init(struct snd_seq_pool *pool) in snd_seq_pool_init() argument
379 if (snd_BUG_ON(!pool)) in snd_seq_pool_init()
382 cellptr = kvmalloc_array(sizeof(struct snd_seq_event_cell), pool->size, in snd_seq_pool_init()
388 spin_lock_irq(&pool->lock); in snd_seq_pool_init()
389 if (pool->ptr) { in snd_seq_pool_init()
390 spin_unlock_irq(&pool->lock); in snd_seq_pool_init()
395 pool->ptr = cellptr; in snd_seq_pool_init()
396 pool->free = NULL; in snd_seq_pool_init()
398 for (cell = 0; cell < pool->size; cell++) { in snd_seq_pool_init()
399 cellptr = pool->ptr + cell; in snd_seq_pool_init()
400 cellptr->pool = pool; in snd_seq_pool_init()
401 cellptr->next = pool->free; in snd_seq_pool_init()
402 pool->free = cellptr; in snd_seq_pool_init()
404 pool->room = (pool->size + 1) / 2; in snd_seq_pool_init()
407 pool->max_used = 0; in snd_seq_pool_init()
408 pool->total_elements = pool->size; in snd_seq_pool_init()
409 spin_unlock_irq(&pool->lock); in snd_seq_pool_init()
414 void snd_seq_pool_mark_closing(struct snd_seq_pool *pool) in snd_seq_pool_mark_closing() argument
418 if (snd_BUG_ON(!pool)) in snd_seq_pool_mark_closing()
420 spin_lock_irqsave(&pool->lock, flags); in snd_seq_pool_mark_closing()
421 pool->closing = 1; in snd_seq_pool_mark_closing()
422 spin_unlock_irqrestore(&pool->lock, flags); in snd_seq_pool_mark_closing()
426 int snd_seq_pool_done(struct snd_seq_pool *pool) in snd_seq_pool_done() argument
430 if (snd_BUG_ON(!pool)) in snd_seq_pool_done()
434 if (waitqueue_active(&pool->output_sleep)) in snd_seq_pool_done()
435 wake_up(&pool->output_sleep); in snd_seq_pool_done()
437 while (atomic_read(&pool->counter) > 0) in snd_seq_pool_done()
441 spin_lock_irq(&pool->lock); in snd_seq_pool_done()
442 ptr = pool->ptr; in snd_seq_pool_done()
443 pool->ptr = NULL; in snd_seq_pool_done()
444 pool->free = NULL; in snd_seq_pool_done()
445 pool->total_elements = 0; in snd_seq_pool_done()
446 spin_unlock_irq(&pool->lock); in snd_seq_pool_done()
450 spin_lock_irq(&pool->lock); in snd_seq_pool_done()
451 pool->closing = 0; in snd_seq_pool_done()
452 spin_unlock_irq(&pool->lock); in snd_seq_pool_done()
461 struct snd_seq_pool *pool; in snd_seq_pool_new() local
464 pool = kzalloc(sizeof(*pool), GFP_KERNEL); in snd_seq_pool_new()
465 if (!pool) in snd_seq_pool_new()
467 spin_lock_init(&pool->lock); in snd_seq_pool_new()
468 pool->ptr = NULL; in snd_seq_pool_new()
469 pool->free = NULL; in snd_seq_pool_new()
470 pool->total_elements = 0; in snd_seq_pool_new()
471 atomic_set(&pool->counter, 0); in snd_seq_pool_new()
472 pool->closing = 0; in snd_seq_pool_new()
473 init_waitqueue_head(&pool->output_sleep); in snd_seq_pool_new()
475 pool->size = poolsize; in snd_seq_pool_new()
478 pool->max_used = 0; in snd_seq_pool_new()
479 return pool; in snd_seq_pool_new()
485 struct snd_seq_pool *pool = *ppool; in snd_seq_pool_delete() local
488 if (pool == NULL) in snd_seq_pool_delete()
490 snd_seq_pool_mark_closing(pool); in snd_seq_pool_delete()
491 snd_seq_pool_done(pool); in snd_seq_pool_delete()
492 kfree(pool); in snd_seq_pool_delete()
498 struct snd_seq_pool *pool, char *space) in snd_seq_info_pool() argument
500 if (pool == NULL) in snd_seq_info_pool()
502 snd_iprintf(buffer, "%sPool size : %d\n", space, pool->total_elements); in snd_seq_info_pool()
503 snd_iprintf(buffer, "%sCells in use : %d\n", space, atomic_read(&pool->counter)); in snd_seq_info_pool()
504 snd_iprintf(buffer, "%sPeak cells in use : %d\n", space, pool->max_used); in snd_seq_info_pool()
505 snd_iprintf(buffer, "%sAlloc success : %d\n", space, pool->event_alloc_success); in snd_seq_info_pool()
506 snd_iprintf(buffer, "%sAlloc failures : %d\n", space, pool->event_alloc_failures); in snd_seq_info_pool()