diff options
author | Vijay Kumar Banerjee <vijay@rtems.org> | 2021-02-10 18:20:42 -0700 |
---|---|---|
committer | Vijay Kumar Banerjee <vijay@rtems.org> | 2021-03-02 14:29:29 -0700 |
commit | 1372fdc88fae999995d34aa0d58361f0e98a53a3 (patch) | |
tree | 2f356110ab692e5ea5caf0d25171206846afc986 /libtest | |
parent | Add nfsclient (diff) | |
download | rtems-net-legacy-1372fdc88fae999995d34aa0d58361f0e98a53a3.tar.bz2 |
Add networking01 test from RTEMS testsuites
Diffstat (limited to 'libtest')
-rw-r--r-- | libtest/testbeginend.c | 104 | ||||
-rw-r--r-- | libtest/testbusy.c | 37 | ||||
-rw-r--r-- | libtest/testextension.c | 74 | ||||
-rw-r--r-- | libtest/testparallel.c | 196 | ||||
-rw-r--r-- | libtest/testrun.c | 91 | ||||
-rw-r--r-- | libtest/testwrappers.c | 48 |
6 files changed, 550 insertions, 0 deletions
diff --git a/libtest/testbeginend.c b/libtest/testbeginend.c new file mode 100644 index 0000000..89b2468 --- /dev/null +++ b/libtest/testbeginend.c @@ -0,0 +1,104 @@ +/* + * Copyright (c) 2014, 2018 embedded brains GmbH. All rights reserved. + * + * embedded brains GmbH + * Dornierstr. 4 + * 82178 Puchheim + * Germany + * <rtems@embedded-brains.de> + * + * Copyright (c) 2017 Chris Johns <chrisj@rtems.org>. All rights reserved. + * + * The license and distribution terms for this file may be + * found in the file LICENSE in this distribution or at + * http://www.rtems.org/license/LICENSE. + */ + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include <rtems/test-info.h> +#include <rtems/bspIo.h> +#include <rtems/version.h> + +rtems_printer rtems_test_printer = { + .printer = rtems_printk_printer +}; + +static const char* const test_state_strings[] = +{ + "EXPECTED_PASS", + "EXPECTED_FAIL", + "USER_INPUT", + "INDETERMINATE", + "BENCHMARK" +}; + +int rtems_test_begin(const char* name, const RTEMS_TEST_STATE state) +{ + return rtems_printf( + &rtems_test_printer, + "\n\n*** BEGIN OF TEST %s ***\n" + "*** TEST VERSION: %s\n" + "*** TEST STATE: %s\n" + "*** TEST BUILD:" +#if RTEMS_DEBUG + " RTEMS_DEBUG" +#endif +#if RTEMS_MULTIPROCESSING + " RTEMS_MULTIPROCESSING" +#endif +#if RTEMS_NETWORKING + " RTEMS_NETWORKING" +#endif +#if RTEMS_PARAVIRT + " RTEMS_PARAVIRT" +#endif +#if RTEMS_POSIX_API + " RTEMS_POSIX_API" +#endif +#if RTEMS_PROFILING + " RTEMS_PROFILING" +#endif +#if RTEMS_SMP + " RTEMS_SMP" +#endif + "\n" + "*** TEST TOOLS: " __VERSION__ "\n", + name, + rtems_version(), + test_state_strings[state] + ); +} + +int rtems_test_end(const char* name) +{ + return rtems_printf( + &rtems_test_printer, + "\n*** END OF TEST %s ***\n\n", name + ); +} + +void rtems_test_exit(int status) +{ + (void) status; + rtems_shutdown_executive(0); +} + +int rtems_test_printf( + const char* format, + ... +) +{ + va_list ap; + int len; + va_start(ap, format); + len = rtems_vprintf( + &rtems_test_printer, + format, + ap + ); + va_end(ap); + return len; +} diff --git a/libtest/testbusy.c b/libtest/testbusy.c new file mode 100644 index 0000000..c1d4427 --- /dev/null +++ b/libtest/testbusy.c @@ -0,0 +1,37 @@ +/* + * Copyright (c) 2014, 2018 embedded brains GmbH. All rights reserved. + * + * embedded brains GmbH + * Dornierstr. 4 + * 82178 Puchheim + * Germany + * <rtems@embedded-brains.de> + * + * The license and distribution terms for this file may be + * found in the file LICENSE in this distribution or at + * http://www.rtems.org/license/LICENSE. + */ + + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include <rtems/test-info.h> +#include <rtems/score/threadimpl.h> + +void rtems_test_busy_cpu_usage( time_t seconds, long nanoseconds ) +{ + Thread_Control *executing; + Timestamp_Control busy; + Timestamp_Control start; + Timestamp_Control now; + + executing = _Thread_Get_executing(); + _Thread_Get_CPU_time_used( executing, &start ); + _Timestamp_Set( &busy, seconds, nanoseconds ); + + do { + _Thread_Get_CPU_time_used( executing, &now ); + } while ( now - start < busy ); +} diff --git a/libtest/testextension.c b/libtest/testextension.c new file mode 100644 index 0000000..ee9681a --- /dev/null +++ b/libtest/testextension.c @@ -0,0 +1,74 @@ +/* + * Copyright (c) 2014 embedded brains GmbH. All rights reserved. + * + * embedded brains GmbH + * Dornierstr. 4 + * 82178 Puchheim + * Germany + * <rtems@embedded-brains.de> + * + * The license and distribution terms for this file may be + * found in the file LICENSE in this distribution or at + * http://www.rtems.org/license/LICENSE. + */ + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include <rtems/test-info.h> +#include <rtems/profiling.h> +#include <rtems/bspIo.h> + +#if defined(RTEMS_PROFILING) +static bool report_done; + +RTEMS_INTERRUPT_LOCK_DEFINE( static, report_lock, "test report" ) +#endif + +void rtems_test_fatal_extension( + rtems_fatal_source source, + bool always_set_to_false, + rtems_fatal_code code +) +{ +#if defined(RTEMS_PROFILING) + rtems_interrupt_lock_context lock_context; + rtems_printer printer; + + rtems_print_printer_printk( &printer ); + + /* + * Ensures to report only once on SMP machines and ensures that the report is + * output completely. + */ + rtems_interrupt_lock_acquire( &report_lock, &lock_context ); + + if ( !report_done ) { + report_done = true; + + printk( + "\n*** PROFILING REPORT BEGIN %s ***\n", + rtems_test_name + ); + + rtems_profiling_report_xml( + rtems_test_name, + &printer, + 1, + " " + ); + + printk( + "*** PROFILING REPORT END %s ***\n", + rtems_test_name + ); + } + + rtems_interrupt_lock_release( &report_lock, &lock_context ); +#endif + + (void) source; + (void) always_set_to_false; + (void) code; +} diff --git a/libtest/testparallel.c b/libtest/testparallel.c new file mode 100644 index 0000000..f9845e0 --- /dev/null +++ b/libtest/testparallel.c @@ -0,0 +1,196 @@ +/* + * Copyright (c) 2013, 2016 embedded brains GmbH. All rights reserved. + * + * embedded brains GmbH + * Dornierstr. 4 + * 82178 Puchheim + * Germany + * <rtems@embedded-brains.de> + * + * The license and distribution terms for this file may be + * found in the file LICENSE in this distribution or at + * http://www.rtems.org/license/LICENSE. + */ + + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include <rtems/test-info.h> +#include <rtems/score/assert.h> +#include <rtems.h> + +static void stop_worker_timer(rtems_id timer_id, void *arg) +{ + rtems_test_parallel_context *ctx = arg; + + _Atomic_Store_ulong(&ctx->stop, 1, ATOMIC_ORDER_RELAXED); +} + +static void start_worker_stop_timer( + rtems_test_parallel_context *ctx, + rtems_interval duration +) +{ + rtems_status_code sc; + + _Atomic_Store_ulong(&ctx->stop, 0, ATOMIC_ORDER_RELEASE); + + sc = rtems_timer_fire_after( + ctx->stop_worker_timer_id, + duration, + stop_worker_timer, + ctx + ); + _Assert(sc == RTEMS_SUCCESSFUL); + (void) sc; +} + +static void run_tests( + rtems_test_parallel_context *ctx, + const rtems_test_parallel_job *jobs, + size_t job_count +) +{ + SMP_barrier_State bs = SMP_BARRIER_STATE_INITIALIZER; + size_t i; + + _SMP_barrier_Wait(&ctx->barrier, &bs, ctx->worker_count); + + for (i = 0; i < job_count; ++i) { + const rtems_test_parallel_job *job = &jobs[i]; + size_t n = rtems_scheduler_get_processor_maximum(); + size_t j = job->cascade ? 0 : rtems_scheduler_get_processor_maximum() - 1; + + while (j < n) { + size_t active_worker = j + 1; + size_t worker_index; + rtems_interrupt_level level; + + /* + * Determine worker index via the current processor index to get + * consistent job runs with respect to the cache topology. + */ + rtems_interrupt_local_disable(level); + _SMP_barrier_Wait(&ctx->barrier, &bs, ctx->worker_count); + worker_index = rtems_scheduler_get_processor(); + rtems_interrupt_local_enable(level); + + _Assert(worker_index < ctx->worker_count); + + if (rtems_test_parallel_is_master_worker(worker_index)) { + rtems_interval duration = (*job->init)(ctx, job->arg, active_worker); + + if (duration > 0) { + start_worker_stop_timer(ctx, duration); + } + } + + _SMP_barrier_Wait(&ctx->barrier, &bs, ctx->worker_count); + + if (worker_index <= j) { + (*job->body)(ctx, job->arg, active_worker, worker_index); + } + + _SMP_barrier_Wait(&ctx->barrier, &bs, ctx->worker_count); + + if (rtems_test_parallel_is_master_worker(worker_index)) { + (*job->fini)(ctx, job->arg, active_worker); + } + + _SMP_barrier_Wait(&ctx->barrier, &bs, ctx->worker_count); + + ++j; + } + } +} + +static void worker_task(rtems_task_argument arg) +{ + rtems_test_parallel_context *ctx = (rtems_test_parallel_context *) arg; + rtems_status_code sc; + + (void) sc; + + run_tests(ctx, ctx->jobs, ctx->job_count); + + while (true) { + /* Wait for delete by master worker */ + } +} + +void rtems_test_parallel( + rtems_test_parallel_context *ctx, + rtems_test_parallel_worker_setup worker_setup, + const rtems_test_parallel_job *jobs, + size_t job_count +) +{ + rtems_status_code sc; + size_t worker_index; + rtems_task_priority worker_priority; + + _Atomic_Init_ulong(&ctx->stop, 0); + _SMP_barrier_Control_initialize(&ctx->barrier); + ctx->worker_count = rtems_scheduler_get_processor_maximum(); + ctx->worker_ids[0] = rtems_task_self(); + ctx->jobs = jobs; + ctx->job_count = job_count; + + if (RTEMS_ARRAY_SIZE(ctx->worker_ids) < ctx->worker_count) { + rtems_fatal_error_occurred(0xdeadbeef); + } + + sc = rtems_task_set_priority( + RTEMS_SELF, + RTEMS_CURRENT_PRIORITY, + &worker_priority + ); + if (sc != RTEMS_SUCCESSFUL) { + rtems_fatal_error_occurred(0xdeadbeef); + } + + sc = rtems_timer_create( + rtems_build_name('S', 'T', 'O', 'P'), + &ctx->stop_worker_timer_id + ); + if (sc != RTEMS_SUCCESSFUL) { + rtems_fatal_error_occurred(0xdeadbeef); + } + + for (worker_index = 1; worker_index < ctx->worker_count; ++worker_index) { + rtems_id worker_id; + + sc = rtems_task_create( + rtems_build_name('W', 'O', 'R', 'K'), + worker_priority, + RTEMS_MINIMUM_STACK_SIZE, + RTEMS_DEFAULT_MODES, + RTEMS_DEFAULT_ATTRIBUTES, + &worker_id + ); + if (sc != RTEMS_SUCCESSFUL) { + rtems_fatal_error_occurred(0xdeadbeef); + } + + ctx->worker_ids[worker_index] = worker_id; + + if (worker_setup != NULL) { + (*worker_setup)(ctx, worker_index, worker_id); + } + + sc = rtems_task_start(worker_id, worker_task, (rtems_task_argument) ctx); + _Assert(sc == RTEMS_SUCCESSFUL); + } + + run_tests(ctx, jobs, job_count); + + for (worker_index = 1; worker_index < ctx->worker_count; ++worker_index) { + sc = rtems_task_delete(ctx->worker_ids[worker_index]); + _Assert(sc == RTEMS_SUCCESSFUL); + } + + sc = rtems_timer_delete(ctx->stop_worker_timer_id); + _Assert(sc == RTEMS_SUCCESSFUL); +} diff --git a/libtest/testrun.c b/libtest/testrun.c new file mode 100644 index 0000000..59418e8 --- /dev/null +++ b/libtest/testrun.c @@ -0,0 +1,91 @@ +/* SPDX-License-Identifier: BSD-2-Clause */ + +/** + * @file + * + * @ingroup RTEMSAPI + * + * @brief Implementation of rtems_test_run_default(). + */ + +/* + * Copyright (C) 2020 embedded brains GmbH (http://www.embedded-brains.de) + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" + * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE + * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR + * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF + * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS + * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN + * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) + * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE + * POSSIBILITY OF SUCH DAMAGE. + */ + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include <rtems/test-info.h> +#include <rtems/test.h> + +#include <stdlib.h> + +static char buffer[ 512 ]; + +static const T_action actions[] = { + T_report_hash_sha256, + T_check_task_context, + T_check_file_descriptors, + T_check_rtems_barriers, + T_check_rtems_extensions, + T_check_rtems_message_queues, + T_check_rtems_partitions, + T_check_rtems_periods, + T_check_rtems_regions, + T_check_rtems_semaphores, + T_check_rtems_tasks, + T_check_rtems_timers, + T_check_posix_keys +}; + +static const T_config config = { + .name = rtems_test_name, + .buf = buffer, + .buf_size = sizeof( buffer ), + .putchar = T_putchar_default, + .verbosity = T_VERBOSE, + .now = T_now_clock, + .allocate = malloc, + .deallocate = free, + .action_count = T_ARRAY_SIZE( actions ), + .actions = actions +}; + +void rtems_test_run( + rtems_task_argument arg, + const RTEMS_TEST_STATE state +) +{ + (void) arg; + + rtems_test_begin( rtems_test_name, state ); + T_register(); + + if ( T_main( &config ) == 0 ) { + rtems_test_end( rtems_test_name ); + } + + rtems_test_exit( 0 ); +} diff --git a/libtest/testwrappers.c b/libtest/testwrappers.c new file mode 100644 index 0000000..9679f75 --- /dev/null +++ b/libtest/testwrappers.c @@ -0,0 +1,48 @@ +/* + * Copyright (c) 2017 Chris Johns <chrisj@rtems.org>. All rights reserved. + * + * The license and distribution terms for this file may be + * found in the file LICENSE in this distribution or at + * http://www.rtems.org/license/LICENSE. + */ + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include <rtems/test-info.h> + +int __wrap_printf(const char* format, ...); +int __wrap_puts(const char *str); +int __wrap_putchar(int c); + +int __wrap_printf( + const char* format, + ... +) +{ + va_list ap; + int len; + va_start(ap, format); + len = rtems_vprintf( + &rtems_test_printer, + format, + ap + ); + va_end(ap); + return len; +} + +int __wrap_puts( + const char *str +) +{ + return rtems_test_printf( "%s\n", str ); +} + +int __wrap_putchar( + int c +) +{ + return rtems_test_printf( "%c", c ); +} |