mirror of
https://github.com/fluencelabs/redis
synced 2025-07-30 07:51:55 +00:00
deps
hiredis
jemalloc
bin
doc
include
src
test
include
integration
src
unit
SFMT.c
bitmap.c
ckh.c
hash.c
junk.c
mallctl.c
math.c
mq.c
mtx.c
prof_accum.c
prof_accum.h
prof_accum_a.c
prof_accum_b.c
prof_gdump.c
prof_idump.c
ql.c
qr.c
quarantine.c
rb.c
rtree.c
stats.c
tsd.c
util.c
zero.c
test.sh.in
.gitignore
COPYING
ChangeLog
INSTALL
Makefile.in
README
VERSION
autogen.sh
config.guess
config.stamp.in
config.sub
configure
configure.ac
coverage.sh
install-sh
linenoise
lua
Makefile
update-jemalloc.sh
src
tests
utils
.gitignore
00-RELEASENOTES
BUGS
CONTRIBUTING
COPYING
INSTALL
MANIFESTO
Makefile
README
redis.conf
runtest
runtest-sentinel
sentinel.conf
249 lines
5.1 KiB
C
249 lines
5.1 KiB
C
![]() |
#include "test/jemalloc_test.h"
|
||
|
|
||
|
/* Number of ring entries, in [2..26]. */
|
||
|
#define NENTRIES 9
|
||
|
/* Split index, in [1..NENTRIES). */
|
||
|
#define SPLIT_INDEX 5
|
||
|
|
||
|
typedef struct ring_s ring_t;
|
||
|
|
||
|
struct ring_s {
|
||
|
qr(ring_t) link;
|
||
|
char id;
|
||
|
};
|
||
|
|
||
|
static void
|
||
|
init_entries(ring_t *entries)
|
||
|
{
|
||
|
unsigned i;
|
||
|
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
qr_new(&entries[i], link);
|
||
|
entries[i].id = 'a' + i;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
static void
|
||
|
test_independent_entries(ring_t *entries)
|
||
|
{
|
||
|
ring_t *t;
|
||
|
unsigned i, j;
|
||
|
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
j = 0;
|
||
|
qr_foreach(t, &entries[i], link) {
|
||
|
j++;
|
||
|
}
|
||
|
assert_u_eq(j, 1,
|
||
|
"Iteration over single-element ring should visit precisely "
|
||
|
"one element");
|
||
|
}
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
j = 0;
|
||
|
qr_reverse_foreach(t, &entries[i], link) {
|
||
|
j++;
|
||
|
}
|
||
|
assert_u_eq(j, 1,
|
||
|
"Iteration over single-element ring should visit precisely "
|
||
|
"one element");
|
||
|
}
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
t = qr_next(&entries[i], link);
|
||
|
assert_ptr_eq(t, &entries[i],
|
||
|
"Next element in single-element ring should be same as "
|
||
|
"current element");
|
||
|
}
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
t = qr_prev(&entries[i], link);
|
||
|
assert_ptr_eq(t, &entries[i],
|
||
|
"Previous element in single-element ring should be same as "
|
||
|
"current element");
|
||
|
}
|
||
|
}
|
||
|
|
||
|
TEST_BEGIN(test_qr_one)
|
||
|
{
|
||
|
ring_t entries[NENTRIES];
|
||
|
|
||
|
init_entries(entries);
|
||
|
test_independent_entries(entries);
|
||
|
}
|
||
|
TEST_END
|
||
|
|
||
|
static void
|
||
|
test_entries_ring(ring_t *entries)
|
||
|
{
|
||
|
ring_t *t;
|
||
|
unsigned i, j;
|
||
|
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
j = 0;
|
||
|
qr_foreach(t, &entries[i], link) {
|
||
|
assert_c_eq(t->id, entries[(i+j) % NENTRIES].id,
|
||
|
"Element id mismatch");
|
||
|
j++;
|
||
|
}
|
||
|
}
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
j = 0;
|
||
|
qr_reverse_foreach(t, &entries[i], link) {
|
||
|
assert_c_eq(t->id, entries[(NENTRIES+i-j-1) %
|
||
|
NENTRIES].id, "Element id mismatch");
|
||
|
j++;
|
||
|
}
|
||
|
}
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
t = qr_next(&entries[i], link);
|
||
|
assert_c_eq(t->id, entries[(i+1) % NENTRIES].id,
|
||
|
"Element id mismatch");
|
||
|
}
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
t = qr_prev(&entries[i], link);
|
||
|
assert_c_eq(t->id, entries[(NENTRIES+i-1) % NENTRIES].id,
|
||
|
"Element id mismatch");
|
||
|
}
|
||
|
}
|
||
|
|
||
|
TEST_BEGIN(test_qr_after_insert)
|
||
|
{
|
||
|
ring_t entries[NENTRIES];
|
||
|
unsigned i;
|
||
|
|
||
|
init_entries(entries);
|
||
|
for (i = 1; i < NENTRIES; i++)
|
||
|
qr_after_insert(&entries[i - 1], &entries[i], link);
|
||
|
test_entries_ring(entries);
|
||
|
}
|
||
|
TEST_END
|
||
|
|
||
|
TEST_BEGIN(test_qr_remove)
|
||
|
{
|
||
|
ring_t entries[NENTRIES];
|
||
|
ring_t *t;
|
||
|
unsigned i, j;
|
||
|
|
||
|
init_entries(entries);
|
||
|
for (i = 1; i < NENTRIES; i++)
|
||
|
qr_after_insert(&entries[i - 1], &entries[i], link);
|
||
|
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
j = 0;
|
||
|
qr_foreach(t, &entries[i], link) {
|
||
|
assert_c_eq(t->id, entries[i+j].id,
|
||
|
"Element id mismatch");
|
||
|
j++;
|
||
|
}
|
||
|
j = 0;
|
||
|
qr_reverse_foreach(t, &entries[i], link) {
|
||
|
assert_c_eq(t->id, entries[NENTRIES - 1 - j].id,
|
||
|
"Element id mismatch");
|
||
|
j++;
|
||
|
}
|
||
|
qr_remove(&entries[i], link);
|
||
|
}
|
||
|
test_independent_entries(entries);
|
||
|
}
|
||
|
TEST_END
|
||
|
|
||
|
TEST_BEGIN(test_qr_before_insert)
|
||
|
{
|
||
|
ring_t entries[NENTRIES];
|
||
|
ring_t *t;
|
||
|
unsigned i, j;
|
||
|
|
||
|
init_entries(entries);
|
||
|
for (i = 1; i < NENTRIES; i++)
|
||
|
qr_before_insert(&entries[i - 1], &entries[i], link);
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
j = 0;
|
||
|
qr_foreach(t, &entries[i], link) {
|
||
|
assert_c_eq(t->id, entries[(NENTRIES+i-j) %
|
||
|
NENTRIES].id, "Element id mismatch");
|
||
|
j++;
|
||
|
}
|
||
|
}
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
j = 0;
|
||
|
qr_reverse_foreach(t, &entries[i], link) {
|
||
|
assert_c_eq(t->id, entries[(i+j+1) % NENTRIES].id,
|
||
|
"Element id mismatch");
|
||
|
j++;
|
||
|
}
|
||
|
}
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
t = qr_next(&entries[i], link);
|
||
|
assert_c_eq(t->id, entries[(NENTRIES+i-1) % NENTRIES].id,
|
||
|
"Element id mismatch");
|
||
|
}
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
t = qr_prev(&entries[i], link);
|
||
|
assert_c_eq(t->id, entries[(i+1) % NENTRIES].id,
|
||
|
"Element id mismatch");
|
||
|
}
|
||
|
}
|
||
|
TEST_END
|
||
|
|
||
|
static void
|
||
|
test_split_entries(ring_t *entries)
|
||
|
{
|
||
|
ring_t *t;
|
||
|
unsigned i, j;
|
||
|
|
||
|
for (i = 0; i < NENTRIES; i++) {
|
||
|
j = 0;
|
||
|
qr_foreach(t, &entries[i], link) {
|
||
|
if (i < SPLIT_INDEX) {
|
||
|
assert_c_eq(t->id,
|
||
|
entries[(i+j) % SPLIT_INDEX].id,
|
||
|
"Element id mismatch");
|
||
|
} else {
|
||
|
assert_c_eq(t->id, entries[(i+j-SPLIT_INDEX) %
|
||
|
(NENTRIES-SPLIT_INDEX) + SPLIT_INDEX].id,
|
||
|
"Element id mismatch");
|
||
|
}
|
||
|
j++;
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
|
TEST_BEGIN(test_qr_meld_split)
|
||
|
{
|
||
|
ring_t entries[NENTRIES];
|
||
|
unsigned i;
|
||
|
|
||
|
init_entries(entries);
|
||
|
for (i = 1; i < NENTRIES; i++)
|
||
|
qr_after_insert(&entries[i - 1], &entries[i], link);
|
||
|
|
||
|
qr_split(&entries[0], &entries[SPLIT_INDEX], link);
|
||
|
test_split_entries(entries);
|
||
|
|
||
|
qr_meld(&entries[0], &entries[SPLIT_INDEX], link);
|
||
|
test_entries_ring(entries);
|
||
|
|
||
|
qr_meld(&entries[0], &entries[SPLIT_INDEX], link);
|
||
|
test_split_entries(entries);
|
||
|
|
||
|
qr_split(&entries[0], &entries[SPLIT_INDEX], link);
|
||
|
test_entries_ring(entries);
|
||
|
|
||
|
qr_split(&entries[0], &entries[0], link);
|
||
|
test_entries_ring(entries);
|
||
|
|
||
|
qr_meld(&entries[0], &entries[0], link);
|
||
|
test_entries_ring(entries);
|
||
|
}
|
||
|
TEST_END
|
||
|
|
||
|
int
|
||
|
main(void)
|
||
|
{
|
||
|
|
||
|
return (test(
|
||
|
test_qr_one,
|
||
|
test_qr_after_insert,
|
||
|
test_qr_remove,
|
||
|
test_qr_before_insert,
|
||
|
test_qr_meld_split));
|
||
|
}
|