anv/allocator: Add the capability to allocate blocks of different sizes

Reviewed-by: Juan A. Suarez Romero <jasuarez@igalia.com>
This commit is contained in:
Jason Ekstrand
2017-04-26 00:49:40 -07:00
parent 01170df262
commit 12043ca696
2 changed files with 13 additions and 15 deletions

View File

@@ -432,8 +432,7 @@ anv_block_pool_expand_range(struct anv_block_pool *pool,
* the pool and a 4K CPU page. * the pool and a 4K CPU page.
*/ */
static uint32_t static uint32_t
anv_block_pool_grow(struct anv_block_pool *pool, struct anv_block_state *state, anv_block_pool_grow(struct anv_block_pool *pool, struct anv_block_state *state)
uint32_t block_size)
{ {
VkResult result = VK_SUCCESS; VkResult result = VK_SUCCESS;
@@ -508,10 +507,8 @@ anv_block_pool_grow(struct anv_block_pool *pool, struct anv_block_state *state,
*/ */
center_bo_offset = ((uint64_t)size * back_used) / total_used; center_bo_offset = ((uint64_t)size * back_used) / total_used;
/* Align down to a multiple of both the block size and page size */ /* Align down to a multiple of the page size */
uint32_t granularity = MAX2(block_size, PAGE_SIZE); center_bo_offset &= ~(PAGE_SIZE - 1);
assert(util_is_power_of_two(granularity));
center_bo_offset &= ~(granularity - 1);
assert(center_bo_offset >= back_used); assert(center_bo_offset >= back_used);
@@ -524,7 +521,6 @@ anv_block_pool_grow(struct anv_block_pool *pool, struct anv_block_state *state,
center_bo_offset = size - pool->state.end; center_bo_offset = size - pool->state.end;
} }
assert(center_bo_offset % block_size == 0);
assert(center_bo_offset % PAGE_SIZE == 0); assert(center_bo_offset % PAGE_SIZE == 0);
result = anv_block_pool_expand_range(pool, center_bo_offset, size); result = anv_block_pool_expand_range(pool, center_bo_offset, size);
@@ -558,21 +554,22 @@ anv_block_pool_alloc_new(struct anv_block_pool *pool,
{ {
struct anv_block_state state, old, new; struct anv_block_state state, old, new;
assert(util_is_power_of_two(block_size));
while (1) { while (1) {
state.u64 = __sync_fetch_and_add(&pool_state->u64, block_size); state.u64 = __sync_fetch_and_add(&pool_state->u64, block_size);
if (state.next < state.end) { if (state.next + block_size <= state.end) {
assert(pool->map); assert(pool->map);
return state.next; return state.next;
} else if (state.next == state.end) { } else if (state.next <= state.end) {
/* We allocated the first block outside the pool so we have to grow /* We allocated the first block outside the pool so we have to grow
* the pool. pool_state->next acts a mutex: threads who try to * the pool. pool_state->next acts a mutex: threads who try to
* allocate now will get block indexes above the current limit and * allocate now will get block indexes above the current limit and
* hit futex_wait below. * hit futex_wait below.
*/ */
new.next = state.next + block_size; new.next = state.next + block_size;
new.end = anv_block_pool_grow(pool, pool_state, block_size); do {
new.end = anv_block_pool_grow(pool, pool_state);
} while (new.end < new.next);
old.u64 = __sync_lock_test_and_set(&pool_state->u64, new.u64); old.u64 = __sync_lock_test_and_set(&pool_state->u64, new.u64);
if (old.next != state.next) if (old.next != state.next)
futex_wake(&pool_state->end, INT_MAX); futex_wake(&pool_state->end, INT_MAX);

View File

@@ -25,7 +25,6 @@
#include "anv_private.h" #include "anv_private.h"
#define BLOCK_SIZE 16
#define NUM_THREADS 16 #define NUM_THREADS 16
#define BLOCKS_PER_THREAD 1024 #define BLOCKS_PER_THREAD 1024
#define NUM_RUNS 64 #define NUM_RUNS 64
@@ -42,16 +41,18 @@ struct job {
static void *alloc_blocks(void *_job) static void *alloc_blocks(void *_job)
{ {
struct job *job = _job; struct job *job = _job;
uint32_t job_id = job - jobs;
uint32_t block_size = 16 * ((job_id % 4) + 1);
int32_t block, *data; int32_t block, *data;
for (unsigned i = 0; i < BLOCKS_PER_THREAD; i++) { for (unsigned i = 0; i < BLOCKS_PER_THREAD; i++) {
block = anv_block_pool_alloc(job->pool, BLOCK_SIZE); block = anv_block_pool_alloc(job->pool, block_size);
data = job->pool->map + block; data = job->pool->map + block;
*data = block; *data = block;
assert(block >= 0); assert(block >= 0);
job->blocks[i] = block; job->blocks[i] = block;
block = anv_block_pool_alloc_back(job->pool, BLOCK_SIZE); block = anv_block_pool_alloc_back(job->pool, block_size);
data = job->pool->map + block; data = job->pool->map + block;
*data = block; *data = block;
assert(block < 0); assert(block < 0);