Function test_multi_alloc_statistics

dpdk/app/test/test_malloc.c:268–426

}

static int
test_multi_alloc_statistics(void)
{
	int ret = -1;  /* default return is error, cleared at end on success */
	int socket = 0;
	struct rte_malloc_socket_stats pre_stats, post_stats ,first_stats, second_stats;
	size_t size = 2048;
	int align = 1024;
	int overhead = 0;
	const size_t pgsz = rte_mem_page_size();
	const size_t heap_size = (1 << 22);

	if (pgsz > heap_size) {
		printf("Page size (%zu) is bigger than heap size, skipping alloc stats test\n",
				pgsz);
		return TEST_SKIPPED;
	}
	if (heap_size % pgsz != 0) {
		printf("Heap size (%zu) is not a multiple of page size (%zu), skipping alloc stats test\n",
				heap_size, pgsz);
		return TEST_SKIPPED;
	}

	if (rte_malloc_heap_create(__func__) != 0) {
		printf("Failed to create test malloc heap\n");
		goto end;
	}

	/* Allocate some memory using malloc and add it to our test heap. */
	void *unaligned_memory = malloc(heap_size + pgsz);
	if (unaligned_memory == NULL) {
		printf("Failed to allocate memory\n");
		goto cleanup_empty_heap;
	}
	void *memory = RTE_PTR_ALIGN(unaligned_memory, pgsz);
	if (rte_malloc_heap_memory_add(__func__, memory, heap_size, NULL,
			heap_size / pgsz, pgsz) != 0) {
		printf("Failed to add memory to heap\n");
		goto cleanup_allocated_memory;
	}
	socket = rte_malloc_heap_get_socket(__func__);
	if (socket < 0) {
		printf("Failed to get socket for test malloc heap.\n");
		goto cleanup_all;
	}

	/* Dynamically calculate the overhead by allocating one cacheline and
	 * then comparing what was allocated from the heap.
	 */
	rte_malloc_get_socket_stats(socket, &pre_stats);

	void *dummy = rte_malloc_socket(NULL, RTE_CACHE_LINE_SIZE, 0, socket);
	if (dummy == NULL)
		goto cleanup_all;

	rte_malloc_get_socket_stats(socket, &post_stats);

	/* after subtracting cache line, remainder is overhead */