Skip to content

Commit 11cfa4b

Browse files
committed
[disjoint] Set default parameters for disjoint pool
1 parent cde4cb8 commit 11cfa4b

File tree

4 files changed

+135
-6
lines changed

4 files changed

+135
-6
lines changed

include/umf/pools/pool_disjoint.h

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ umf_result_t
5252
umfDisjointPoolParamsDestroy(umf_disjoint_pool_params_handle_t hParams);
5353

5454
/// @brief Set minimum allocation size that will be requested from the memory provider.
55+
/// @details Default value for minimum size of slab's is 64KB.
5556
/// @param hParams handle to the parameters of the disjoint pool.
5657
/// @param slabMinSize minimum allocation size.
5758
/// @return UMF_RESULT_SUCCESS on success or appropriate error code on failure.
@@ -60,6 +61,7 @@ umfDisjointPoolParamsSetSlabMinSize(umf_disjoint_pool_params_handle_t hParams,
6061
size_t slabMinSize);
6162

6263
/// @brief Set size limit for allocations that are subject to pooling.
64+
/// @details Default value for maximum poolable size is 2MB.
6365
/// @param hParams handle to the parameters of the disjoint pool.
6466
/// @param maxPoolableSize maximum poolable size.
6567
/// @return UMF_RESULT_SUCCESS on success or appropriate error code on failure.
@@ -68,6 +70,7 @@ umf_result_t umfDisjointPoolParamsSetMaxPoolableSize(
6870

6971
/// @brief Set maximum capacity of each bucket. Each bucket will hold a
7072
/// max of \p maxCapacity unfreed slabs.
73+
/// @details Default value for capacity is 4.
7174
/// @param hParams handle to the parameters of the disjoint pool.
7275
/// @param maxCapacity maximum capacity of each bucket.
7376
/// @return UMF_RESULT_SUCCESS on success or appropriate error code on failure.

src/pool/pool_disjoint.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1085,9 +1085,9 @@ umfDisjointPoolParamsCreate(umf_disjoint_pool_params_handle_t *hParams) {
10851085
}
10861086

10871087
*params = (umf_disjoint_pool_params_t){
1088-
.slab_min_size = 0,
1089-
.max_poolable_size = 0,
1090-
.capacity = 0,
1088+
.slab_min_size = 64 * 1024, // 64K
1089+
.max_poolable_size = 2 * 1024 * 1024, // 2MB
1090+
.capacity = 4,
10911091
.min_bucket_size = UMF_DISJOINT_POOL_MIN_BUCKET_DEFAULT_SIZE,
10921092
.cur_pool_size = 0,
10931093
.pool_trace = 0,

src/pool/pool_disjoint_internal.h

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -110,13 +110,13 @@ typedef struct umf_disjoint_pool_shared_limits_t {
110110

111111
typedef struct umf_disjoint_pool_params_t {
112112
// Minimum allocation size that will be requested from the memory provider.
113-
size_t slab_min_size;
113+
size_t slab_min_size; // Default: 64KB
114114

115115
// Allocations up to this limit will be subject to chunking/pooling
116-
size_t max_poolable_size;
116+
size_t max_poolable_size; // Default: 2MB
117117

118118
// When pooling, each bucket will hold a max of 'capacity' unfreed slabs
119-
size_t capacity;
119+
size_t capacity; // Default: 4
120120

121121
// Holds the minimum bucket size valid for allocation of a memory type.
122122
// This value must be a power of 2.

test/pools/disjoint_pool.cpp

Lines changed: 126 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -356,6 +356,132 @@ TEST_F(test, disjointPoolName) {
356356
umfDisjointPoolParamsDestroy(params);
357357
}
358358

359+
TEST_F(test, disjointPoolDefaultParams) {
360+
// Disjoint pool defaults
361+
static constexpr size_t DefaultSlabMinSize = 64 * 1024; // 64K
362+
static constexpr size_t DefaultMaxPoolableSize = 2 * 1024 * 1024; // 2MB
363+
364+
umf_disjoint_pool_params_handle_t params = nullptr;
365+
umf_memory_pool_handle_t pool = nullptr;
366+
umf_memory_provider_handle_t provider_handle = nullptr;
367+
368+
// Create disjoint pool parameters with default settings
369+
umf_result_t res = umfDisjointPoolParamsCreate(&params);
370+
EXPECT_EQ(res, UMF_RESULT_SUCCESS);
371+
372+
int expected_free_counter = 0;
373+
static int free_counter = 0;
374+
static int last_requested_size = 0;
375+
struct memory_provider : public umf_test::provider_base_t {
376+
umf_result_t alloc(size_t size, size_t alignment, void **ptr) noexcept {
377+
*ptr = umf_ba_global_aligned_alloc(size, alignment);
378+
last_requested_size = size;
379+
return UMF_RESULT_SUCCESS;
380+
}
381+
382+
umf_result_t free(void *ptr, [[maybe_unused]] size_t size) noexcept {
383+
// do the actual free only when we expect the success
384+
umf_ba_global_free(ptr);
385+
free_counter++;
386+
return UMF_RESULT_SUCCESS;
387+
}
388+
};
389+
390+
umf_memory_provider_ops_t provider_ops =
391+
umf_test::providerMakeCOps<memory_provider, void>();
392+
393+
auto providerUnique =
394+
wrapProviderUnique(createProviderChecked(&provider_ops, nullptr));
395+
provider_handle = providerUnique.get();
396+
397+
res = umfDisjointPoolParamsSetTrace(params, 3);
398+
ASSERT_EQ(res, UMF_RESULT_SUCCESS);
399+
400+
umf_result_t ret = umfPoolCreate(umfDisjointPoolOps(), provider_handle,
401+
params, UMF_POOL_CREATE_FLAG_NONE, &pool);
402+
ASSERT_EQ(ret, UMF_RESULT_SUCCESS);
403+
404+
// Test allocation and deallocation
405+
// This will use the default disjoint pool parameters
406+
void *ptr = umfPoolMalloc(pool, DefaultSlabMinSize - 1); // Should use pool
407+
ASSERT_NE(ptr, nullptr);
408+
ASSERT_EQ(last_requested_size, DefaultSlabMinSize); // First allocated size should be at least the slab min size
409+
ret = umfPoolFree(pool, ptr);
410+
ASSERT_EQ(ret, UMF_RESULT_SUCCESS);
411+
ASSERT_EQ(free_counter, expected_free_counter);
412+
413+
// Test allocation and deallocation with a different size
414+
expected_free_counter = 1;
415+
ptr = umfPoolMalloc(pool, 2 * DefaultMaxPoolableSize); // Fallback to provider
416+
ASSERT_EQ(last_requested_size, 2 * DefaultMaxPoolableSize);
417+
ASSERT_NE(ptr, nullptr);
418+
ret = umfPoolFree(pool, ptr);
419+
ASSERT_EQ(ret, UMF_RESULT_SUCCESS);
420+
ASSERT_EQ(free_counter, expected_free_counter);
421+
422+
// Cleaning up
423+
umfPoolDestroy(pool);
424+
umfDisjointPoolParamsDestroy(params);
425+
expected_free_counter = 2;
426+
ASSERT_EQ(free_counter, expected_free_counter);
427+
}
428+
429+
TEST_F(test, disjointPoolDefaultCapacity) {
430+
// Disjoint pool defaults
431+
static constexpr size_t DefaultSlabMinSize = 64 * 1024; // 64K
432+
static constexpr size_t DefaultCapacity = 4;
433+
434+
static int last_requested_size = 0;
435+
static int free_counter = 0;
436+
437+
struct memory_provider : public umf_test::provider_base_t {
438+
umf_result_t alloc(size_t size, size_t alignment, void **ptr) noexcept {
439+
*ptr = umf_ba_global_aligned_alloc(size, alignment);
440+
last_requested_size = size;
441+
return UMF_RESULT_SUCCESS;
442+
}
443+
umf_result_t free(void *ptr, [[maybe_unused]] size_t size) noexcept {
444+
// do the actual free only when we expect the success
445+
umf_ba_global_free(ptr);
446+
free_counter++;
447+
return UMF_RESULT_SUCCESS;
448+
}
449+
};
450+
umf_memory_provider_ops_t provider_ops =
451+
umf_test::providerMakeCOps<memory_provider, void>();
452+
auto providerUnique =
453+
wrapProviderUnique(createProviderChecked(&provider_ops, nullptr));
454+
umf_memory_provider_handle_t provider_handle = providerUnique.get();
455+
umf_disjoint_pool_params_handle_t params = nullptr;
456+
umf_result_t ret = umfDisjointPoolParamsCreate(&params);
457+
ASSERT_EQ(ret, UMF_RESULT_SUCCESS);
458+
459+
umf_memory_pool_handle_t pool = nullptr;
460+
ret = umfPoolCreate(umfDisjointPoolOps(), provider_handle,
461+
params, UMF_POOL_CREATE_FLAG_NONE, &pool);
462+
ASSERT_EQ(ret, UMF_RESULT_SUCCESS);
463+
464+
// Test capacity
465+
void *ptrs[DefaultCapacity + 1];
466+
for (size_t i = 0; i < DefaultCapacity + 1; ++i) {
467+
ptrs[i] = umfPoolMalloc(pool, DefaultSlabMinSize - 1); // Should use pool
468+
ASSERT_NE(ptrs[i], nullptr);
469+
ASSERT_EQ(last_requested_size, DefaultSlabMinSize);
470+
}
471+
472+
size_t i;
473+
for (i = 0; i < DefaultCapacity + 1; ++i) {
474+
ret = umfPoolFree(pool, ptrs[i]);
475+
ASSERT_EQ(ret, UMF_RESULT_SUCCESS);
476+
}
477+
ASSERT_EQ(free_counter, i - DefaultCapacity); // only the last allocation exceeds the capacity
478+
479+
// Cleaning up
480+
umfPoolDestroy(pool);
481+
umfDisjointPoolParamsDestroy(params);
482+
ASSERT_EQ(free_counter, DefaultCapacity + 1); // +1 for the last allocation that exceeded the capacity
483+
}
484+
359485
INSTANTIATE_TEST_SUITE_P(disjointPoolTests, umfPoolTest,
360486
::testing::Values(poolCreateExtParams{
361487
umfDisjointPoolOps(), defaultDisjointPoolConfig,

0 commit comments

Comments
 (0)