msg_queue_test.c File Reference

Test: parallel message queue. More...

#include <test.h>
#include <test_rng.h>
#include <datatypes/msg_queue.h>
#include <lp/lp.h>
#include <memory.h>
#include <stdatomic.h>
#include <stdint.h>
#include <stdlib.h>

Include dependency graph for msg_queue_test.c:

Go to the source code of this file.

Macros
#define	THREAD_CNT   6
#define	THREAD_REPS   100000

Functions
void	msg_allocator_free (struct lp_msg *msg)
static int	msg_queue_test_init (void)
static int	msg_queue_test_fini (void)
static int	msg_queue_test (void)

Variables
uint64_t	n_lps_node = 64
	The total number of LPs hosted in the node.
static __thread test_rng_state	rng_state
static struct lp_ctx	lps_m [6]
static atomic_uint	msg_missing = 100000 * 6
static atomic_uint	msg_to_free = 6
struct lp_ctx *	lps = lps_m
const struct test_config	test_config
	The test configuration object, must be defined by the test sources. More...

Detailed Description

Test: parallel message queue.

Copyright

Copyright (C) 2008-2021 HPDCS Group https://hpdcs.github.io

Definition in file msg_queue_test.c.

Variable Documentation

test_config

const struct test_config test_config

Initial value:

= {
        .threads_count =  6 ,
        .test_init_fnc = msg_queue_test_init,
        .test_fini_fnc = msg_queue_test_fini,
        .test_fnc = msg_queue_test
}

The test configuration object, must be defined by the test sources.

Definition at line 92 of file msg_queue_test.c.