Lines Matching defs:pool
90 pa_mempool *pool;
109 pa_mempool *pool;
130 * Any block allocation from the pool itself, or even just imported from
135 * the pool, or just to attached ones, can still be lingering around when
174 pa_assert(b->pool);
176 pa_atomic_inc(&b->pool->stat.n_allocated);
177 pa_atomic_add(&b->pool->stat.allocated_size, (int) b->length);
179 pa_atomic_inc(&b->pool->stat.n_accumulated);
180 pa_atomic_add(&b->pool->stat.accumulated_size, (int) b->length);
183 pa_atomic_inc(&b->pool->stat.n_imported);
184 pa_atomic_add(&b->pool->stat.imported_size, (int) b->length);
187 pa_atomic_inc(&b->pool->stat.n_allocated_by_type[b->type]);
188 pa_atomic_inc(&b->pool->stat.n_accumulated_by_type[b->type]);
194 pa_assert(b->pool);
196 pa_assert(pa_atomic_load(&b->pool->stat.n_allocated) > 0);
197 pa_assert(pa_atomic_load(&b->pool->stat.allocated_size) >= (int) b->length);
199 pa_atomic_dec(&b->pool->stat.n_allocated);
200 pa_atomic_sub(&b->pool->stat.allocated_size, (int) b->length);
203 pa_assert(pa_atomic_load(&b->pool->stat.n_imported) > 0);
204 pa_assert(pa_atomic_load(&b->pool->stat.imported_size) >= (int) b->length);
206 pa_atomic_dec(&b->pool->stat.n_imported);
207 pa_atomic_sub(&b->pool->stat.imported_size, (int) b->length);
210 pa_atomic_dec(&b->pool->stat.n_allocated_by_type[b->type]);
242 b->pool = p;
243 pa_mempool_ref(b->pool);
367 pa_log_debug("Memory block too large for pool: %lu > %lu",
374 b->pool = p;
375 pa_mempool_ref(b->pool);
398 b->pool = p;
399 pa_mempool_ref(b->pool);
432 b->pool = p;
433 pa_mempool_ref(b->pool);
519 pa_semaphore_post(b->pool->semaphore);
529 /* Note! Always unref the returned pool after use */
533 pa_assert(b->pool);
535 pa_mempool_ref(b->pool);
536 return b->pool;
549 pa_mempool *pool;
552 pa_assert(b->pool);
555 pool = b->pool;
610 pa_assert_se(slot = mempool_slot_by_ptr(b->pool, pa_atomic_ptr_load(&b->data)));
616 /* VALGRIND_FREELIKE_BLOCK(slot, b->pool->block_size); */
623 while (pa_flist_push(b->pool->free_slots, slot) < 0)
638 pa_mempool_unref(pool);
664 pa_semaphore_wait(b->pool->semaphore);
674 pa_atomic_dec(&b->pool->stat.n_allocated_by_type[b->type]);
676 if (b->length <= b->pool->block_size) {
679 if ((slot = mempool_allocate_slot(b->pool))) {
681 /* We can move it into a local pool, perfect! */
694 /* Humm, not enough space in the pool, so lets allocate the memory with malloc() */
703 pa_atomic_inc(&b->pool->stat.n_allocated_by_type[b->type]);
704 pa_atomic_inc(&b->pool->stat.n_accumulated_by_type[b->type]);
742 pa_assert(pa_atomic_load(&b->pool->stat.n_imported) > 0);
743 pa_assert(pa_atomic_load(&b->pool->stat.imported_size) >= (int) b->length);
744 pa_atomic_dec(&b->pool->stat.n_imported);
745 pa_atomic_sub(&b->pool->stat.imported_size, (int) b->length);
786 * for the pool's fd to be always open :-(
817 pa_log_debug("Using %s memory pool with %u slots of size %s each, total size is"
894 pa_log_error("Memory pool destroyed but not all memory blocks freed! %u remain.",
1060 i->pool = p;
1061 pa_mempool_ref(i->pool);
1142 pa_mutex_lock(i->pool->mutex);
1145 for (e = i->pool->exports; e; e = e->next)
1148 PA_LLIST_REMOVE(pa_memimport, i->pool->imports, i);
1150 pa_mutex_unlock(i->pool->mutex);
1152 pa_mempool_unref(i->pool);
1216 pa_log_error("Did the other PA endpoint forget registering its memfd pool?");
1237 b->pool = i->pool;
1238 pa_mempool_ref(b->pool);
1295 e->pool = p;
1296 pa_mempool_ref(e->pool);
1320 pa_mutex_lock(e->pool->mutex);
1321 PA_LLIST_REMOVE(pa_memexport, e->pool->exports, e);
1322 pa_mutex_unlock(e->pool->mutex);
1324 pa_mempool_unref(e->pool);
1357 pa_assert(pa_atomic_load(&e->pool->stat.n_exported) > 0);
1358 pa_assert(pa_atomic_load(&e->pool->stat.exported_size) >= (int) b->length);
1360 pa_atomic_dec(&e->pool->stat.n_exported);
1361 pa_atomic_sub(&e->pool->stat.exported_size, (int) b->length);
1407 pa_assert(b->pool == p);
1432 pa_assert(b->pool == e->pool);
1434 if (!(b = memblock_shared_copy(e->pool, b)))
1464 pa_assert(b->pool);
1465 pa_assert(pa_mempool_is_shared(b->pool));
1466 memory = &b->pool->memory;
1479 pa_atomic_inc(&e->pool->stat.n_exported);
1480 pa_atomic_add(&e->pool->stat.exported_size, (int) b->length);