be1883d978
Builds under clang fail with the following:
utils/ftl_mempool.c:45:1: error: unused function 'is_element_valid'
[-Werror,-Wunused-function]
is_element_valid(struct ftl_mempool *mpool, void *element)
^
1 error generated.
Signed-off-by: Michal Berger <michal.berger@intel.com>
Change-Id: Ic776f3f226e9ea6ed9d0bbd0a3d8e2a0661e0d11
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/13844
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: Konrad Sztyber <konrad.sztyber@intel.com>
Reviewed-by: Aleksey Marchuk <alexeymar@nvidia.com>
Reviewed-by: Dong Yi <dongx.yi@intel.com>
Reviewed-by: Kamil Godzwon <kamilx.godzwon@intel.com>
Community-CI: Mellanox Build Bot
150 lines
2.7 KiB
C
150 lines
2.7 KiB
C
/* SPDX-License-Identifier: BSD-3-Clause
|
|
* Copyright (c) Intel Corporation.
|
|
* All rights reserved.
|
|
*/
|
|
|
|
#include "spdk/stdinc.h"
|
|
#include "spdk/queue.h"
|
|
#include "spdk/util.h"
|
|
#include "spdk/env.h"
|
|
#include "spdk/likely.h"
|
|
|
|
#include "ftl_mempool.h"
|
|
|
|
struct ftl_mempool_element {
|
|
SLIST_ENTRY(ftl_mempool_element) entry;
|
|
};
|
|
|
|
struct ftl_mempool {
|
|
SLIST_HEAD(, ftl_mempool_element) list;
|
|
size_t element_size;
|
|
void *buffer;
|
|
size_t buffer_size;
|
|
size_t count;
|
|
size_t alignment;
|
|
int socket_id;
|
|
};
|
|
|
|
static inline bool is_element_valid(struct ftl_mempool *mpool,
|
|
void *element) __attribute__((unused));
|
|
|
|
static size_t
|
|
element_size_aligned(size_t size, size_t alignment)
|
|
{
|
|
if (!alignment) {
|
|
return size;
|
|
}
|
|
|
|
if (size % alignment) {
|
|
return (size / alignment + 1) * alignment;
|
|
}
|
|
|
|
return size;
|
|
}
|
|
|
|
static inline bool
|
|
is_element_valid(struct ftl_mempool *mpool, void *element)
|
|
{
|
|
if (element < mpool->buffer) {
|
|
return false;
|
|
}
|
|
|
|
if (element + mpool->element_size > mpool->buffer + mpool->buffer_size) {
|
|
return false;
|
|
}
|
|
|
|
if (!mpool->alignment) {
|
|
return true;
|
|
}
|
|
|
|
if ((size_t)element % mpool->alignment) {
|
|
return false;
|
|
}
|
|
|
|
if ((element - mpool->buffer) % mpool->element_size != 0) {
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
struct ftl_mempool *ftl_mempool_create(size_t count, size_t size,
|
|
size_t alignment, int socket_id)
|
|
{
|
|
struct ftl_mempool *mp;
|
|
void *buffer;
|
|
size_t i;
|
|
|
|
assert(count > 0);
|
|
assert(size > 0);
|
|
|
|
if (!spdk_u64_is_pow2(alignment)) {
|
|
return NULL;
|
|
}
|
|
|
|
mp = calloc(1, sizeof(*mp));
|
|
if (!mp) {
|
|
return NULL;
|
|
}
|
|
|
|
size = spdk_max(size, sizeof(struct ftl_mempool_element));
|
|
|
|
mp->count = count;
|
|
mp->element_size = element_size_aligned(size, alignment);
|
|
mp->alignment = alignment;
|
|
mp->socket_id = socket_id;
|
|
SLIST_INIT(&mp->list);
|
|
|
|
mp->buffer_size = mp->element_size * mp->count;
|
|
mp->buffer = spdk_dma_malloc_socket(mp->buffer_size, mp->alignment,
|
|
NULL, socket_id);
|
|
if (!mp->buffer) {
|
|
free(mp);
|
|
return NULL;
|
|
}
|
|
|
|
buffer = mp->buffer;
|
|
for (i = 0; i < count; i++, buffer += mp->element_size) {
|
|
struct ftl_mempool_element *el = buffer;
|
|
assert(is_element_valid(mp, el));
|
|
SLIST_INSERT_HEAD(&mp->list, el, entry);
|
|
}
|
|
|
|
return mp;
|
|
}
|
|
|
|
void
|
|
ftl_mempool_destroy(struct ftl_mempool *mpool)
|
|
{
|
|
if (!mpool) {
|
|
return;
|
|
}
|
|
|
|
spdk_dma_free(mpool->buffer);
|
|
free(mpool);
|
|
}
|
|
|
|
void *
|
|
ftl_mempool_get(struct ftl_mempool *mpool)
|
|
{
|
|
struct ftl_mempool_element *el;
|
|
|
|
if (spdk_unlikely(SLIST_EMPTY(&mpool->list))) {
|
|
return NULL;
|
|
}
|
|
|
|
el = SLIST_FIRST(&mpool->list);
|
|
SLIST_REMOVE_HEAD(&mpool->list, entry);
|
|
|
|
return el;
|
|
}
|
|
|
|
void
|
|
ftl_mempool_put(struct ftl_mempool *mpool, void *element)
|
|
{
|
|
struct ftl_mempool_element *el = element;
|
|
|
|
assert(is_element_valid(mpool, element));
|
|
SLIST_INSERT_HEAD(&mpool->list, el, entry);
|
|
}
|