From f449f278dd3c70e479a035f50a9bb817a9b433ba Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 7 Apr 2024 17:24:08 +0200 Subject: Adding upstream version 3.2.6. Signed-off-by: Daniel Baumann --- tests/contrib/test_spinlock.c | 78 +++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 78 insertions(+) create mode 100644 tests/contrib/test_spinlock.c (limited to 'tests/contrib/test_spinlock.c') diff --git a/tests/contrib/test_spinlock.c b/tests/contrib/test_spinlock.c new file mode 100644 index 0000000..0d5122b --- /dev/null +++ b/tests/contrib/test_spinlock.c @@ -0,0 +1,78 @@ +/* Copyright (C) 2021 CZ.NIC, z.s.p.o. + + This program is free software: you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation, either version 3 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program. If not, see . + */ + +#include +#include + +#include "knot/server/dthreads.h" +#include "contrib/spinlock.h" + +#define THREADS 8 +#define CYCLES 100000 + +static volatile int counter = 0; +static volatile int tens_counter = 0; +static knot_spin_t spinlock; + +static int thread(struct dthread *thread) +{ + volatile int i, j, k; + + for (i = 0; i < CYCLES; i++) { + knot_spin_lock(&spinlock); + j = counter; + k = tens_counter; + if (++j % 10 == 0) { + k++; + } + tens_counter = k; + counter = j; + knot_spin_unlock(&spinlock); + } + + return 0; +} + +// Signal handler +static void interrupt_handle(int s) +{ +} + +int main(int argc, char *argv[]) +{ + plan_lazy(); + + // Register service and signal handler + struct sigaction sa; + sa.sa_handler = interrupt_handle; + sigemptyset(&sa.sa_mask); + sa.sa_flags = 0; + sigaction(SIGALRM, &sa, NULL); // Interrupt + + knot_spin_init(&spinlock); + + dt_unit_t *unit = dt_create(THREADS, thread, NULL, NULL); + dt_start(unit); + dt_join(unit); + dt_delete(&unit); + + knot_spin_destroy(&spinlock); + + is_int(THREADS * CYCLES, counter, "spinlock: protected counter one"); + is_int(THREADS * CYCLES / 10, tens_counter, "spinlock: protected counter two"); + + return 0; +} -- cgit v1.2.3