From patchwork Fri Jan 8 19:21:12 2016 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Ivan Khoronzhuk X-Patchwork-Id: 59385 Delivered-To: patch@linaro.org Received: by 10.112.130.2 with SMTP id oa2csp744650lbb; Fri, 8 Jan 2016 11:22:38 -0800 (PST) X-Received: by 10.55.74.14 with SMTP id x14mr13411534qka.70.1452280956552; Fri, 08 Jan 2016 11:22:36 -0800 (PST) Return-Path: Received: from lists.linaro.org (lists.linaro.org. [54.225.227.206]) by mx.google.com with ESMTP id z139si24127736qka.98.2016.01.08.11.22.36; Fri, 08 Jan 2016 11:22:36 -0800 (PST) Received-SPF: pass (google.com: domain of lng-odp-bounces@lists.linaro.org designates 54.225.227.206 as permitted sender) client-ip=54.225.227.206; Authentication-Results: mx.google.com; spf=pass (google.com: domain of lng-odp-bounces@lists.linaro.org designates 54.225.227.206 as permitted sender) smtp.mailfrom=lng-odp-bounces@lists.linaro.org; dkim=neutral (body hash did not verify) header.i=@linaro.org Received: by lists.linaro.org (Postfix, from userid 109) id D84976176A; Fri, 8 Jan 2016 19:22:35 +0000 (UTC) Authentication-Results: lists.linaro.org; dkim=fail reason="verification failed; unprotected key" header.d=linaro.org header.i=@linaro.org header.b=EQC9/Diw; dkim-adsp=none (unprotected policy); dkim-atps=neutral X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on ip-10-142-244-252 X-Spam-Level: X-Spam-Status: No, score=-2.5 required=5.0 tests=BAYES_00,DKIM_SIGNED, RCVD_IN_DNSWL_LOW, RCVD_IN_MSPIKE_H3, RCVD_IN_MSPIKE_WL, T_DKIM_INVALID, URIBL_BLOCKED autolearn=disabled version=3.4.0 Received: from [127.0.0.1] (localhost [127.0.0.1]) by lists.linaro.org (Postfix) with ESMTP id 7F8F4615E9; Fri, 8 Jan 2016 19:22:27 +0000 (UTC) X-Original-To: lng-odp@lists.linaro.org Delivered-To: lng-odp@lists.linaro.org Received: by lists.linaro.org (Postfix, from userid 109) id B7447615FA; Fri, 8 Jan 2016 19:22:24 +0000 (UTC) Received: from mail-lb0-f178.google.com (mail-lb0-f178.google.com [209.85.217.178]) by lists.linaro.org (Postfix) with ESMTPS id CFC8B615CD for ; Fri, 8 Jan 2016 19:22:22 +0000 (UTC) Received: by mail-lb0-f178.google.com with SMTP id sv6so222263377lbb.0 for ; Fri, 08 Jan 2016 11:22:22 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=linaro.org; s=google; h=from:to:cc:subject:date:message-id; bh=2Q2iEe4y9SCOBOCXp/JGwNB13+GcVeUCnT2DwuYPRjs=; b=EQC9/DiwY+3ygpEpdS1uBCesyMiX8dYcyUyXja6E/uVrUS75gkD0wmW1Vaiy01/pDj Xw9RfbZy1ri66x3KPjA7JuZZrcMfMsqBoWgNV9vYXZTqmQse5Tv+NLbe+EYztbOU9QlS vjl4X8DUMLRll9gLE2UUc6vZOv4hAFg0BVQLg= X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:from:to:cc:subject:date:message-id; bh=2Q2iEe4y9SCOBOCXp/JGwNB13+GcVeUCnT2DwuYPRjs=; b=W3ZvRrOUv9Nc4XR/8/rQIscugAMFSW5J3BYViwwy01w2JF1mYgabu6hVXjn0JxZU6O mgSgXgSI3YQnGfO84cqH/5uCTFkF0rU3ZVdf1K/lQyMcZdbgaSDKKXMR3TK4p5cUCOb0 Pftp1JK/IRyhetaaHaheuBRArVjWY1/txwatoE4r+cJYvp+dXXFrAYlGVgp3UmOGOpbu q7FRq612NKb75F6mxO5CNgxJXcOnNP9SEoybHjPFwcT22HGAdRAsks6H+1DgwVVDvIUN XYSpzo9l8mhbT6nVf5S4vLbmPNrJCXSDEKvL/pgmXXOUbjiihlOJH13wwconGYiQzJBk RLHQ== X-Gm-Message-State: ALoCoQlHAG0eRXSfR2D9c4rFWnnc7LMtYDObozWbVm0CJawE8MfSDthqc8xbXQtXpcLjtEItN0evCMnIW62cqtOBi39/3WrNKw== X-Received: by 10.112.201.67 with SMTP id jy3mr351011lbc.25.1452280941766; Fri, 08 Jan 2016 11:22:21 -0800 (PST) Received: from localhost.localdomain ([212.90.63.58]) by smtp.gmail.com with ESMTPSA id q76sm14749772lfd.41.2016.01.08.11.22.20 (version=TLS1_2 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Fri, 08 Jan 2016 11:22:20 -0800 (PST) From: Ivan Khoronzhuk To: lng-odp@lists.linaro.org Date: Fri, 8 Jan 2016 21:21:12 +0200 Message-Id: <1452280872-14172-1-git-send-email-ivan.khoronzhuk@linaro.org> X-Mailer: git-send-email 1.9.1 X-Topics: patch Subject: [lng-odp] [PATCH v5] example: time: add test of global time API on monotony X-BeenThere: lng-odp@lists.linaro.org X-Mailman-Version: 2.1.16 Precedence: list List-Id: "The OpenDataPlane \(ODP\) List" List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , MIME-Version: 1.0 Errors-To: lng-odp-bounces@lists.linaro.org Sender: "lng-odp" This test example uses linux helper functions to schedule worker threads in order to check global time monotony between the threads. Each thread receives event from it's own queue, checks global time on correctness, writes in the buffer new current global time, chooses randomly next thread queue, sends event and waits on next event on it's own queue. Using for each thread it's own queue guarantees that event is read by not the same thread that sends it. When global time source is correct the time received with event by a thread must be less than read on the moment of receiving. Signed-off-by: Ivan Khoronzhuk Reviewed-and-tested-by: Bill Fischofer --- Since v4: - convert time to ns only while printing log Since v3: - defined log entry size Since v2: -added binary to .gitignore Since v1: - replaced many includes on odp.h - corrected a little error path - increased num of iterations - rebased on ODPv1.6 configure.ac | 1 + example/Makefile.am | 2 +- example/time/.gitignore | 1 + example/time/Makefile.am | 10 ++ example/time/time_global_test.c | 353 ++++++++++++++++++++++++++++++++++++++++ 5 files changed, 366 insertions(+), 1 deletion(-) create mode 100644 example/time/.gitignore create mode 100644 example/time/Makefile.am create mode 100644 example/time/time_global_test.c diff --git a/configure.ac b/configure.ac index 2626fd7..b284384 100644 --- a/configure.ac +++ b/configure.ac @@ -338,6 +338,7 @@ AC_CONFIG_FILES([Makefile example/generator/Makefile example/ipsec/Makefile example/packet/Makefile + example/time/Makefile example/timer/Makefile helper/Makefile helper/test/Makefile diff --git a/example/Makefile.am b/example/Makefile.am index 353f397..39d9b01 100644 --- a/example/Makefile.am +++ b/example/Makefile.am @@ -1 +1 @@ -SUBDIRS = classifier generator ipsec packet timer +SUBDIRS = classifier generator ipsec packet time timer diff --git a/example/time/.gitignore b/example/time/.gitignore new file mode 100644 index 0000000..3106aea --- /dev/null +++ b/example/time/.gitignore @@ -0,0 +1 @@ +odp_time_global_test diff --git a/example/time/Makefile.am b/example/time/Makefile.am new file mode 100644 index 0000000..915593a --- /dev/null +++ b/example/time/Makefile.am @@ -0,0 +1,10 @@ +include $(top_srcdir)/example/Makefile.inc + +bin_PROGRAMS = odp_time_global_test$(EXEEXT) +odp_time_global_test_LDFLAGS = $(AM_LDFLAGS) -static +odp_time_global_test_CFLAGS = $(AM_CFLAGS) -I${top_srcdir}/example + +noinst_HEADERS = \ + $(top_srcdir)/example/example_debug.h + +dist_odp_time_global_test_SOURCES = time_global_test.c diff --git a/example/time/time_global_test.c b/example/time/time_global_test.c new file mode 100644 index 0000000..afb9bbf --- /dev/null +++ b/example/time/time_global_test.c @@ -0,0 +1,353 @@ +/* Copyright (c) 2015, Linaro Limited + * All rights reserved. + * + * SPDX-License-Identifier: BSD-3-Clause + */ + +#include +#include +#include + +#define MAX_WORKERS 32 +#define ITERATION_NUM 2048 +#define LOG_BASE 8 +#define LOG_ENTRY_SIZE 19 +#define LOG_LINE_SIZE LOG_BASE * LOG_ENTRY_SIZE + 1 + +#define QUEUE_NAME_PREFIX "thread_queue_" + +typedef struct { + odp_time_t timestamp; + int id; +} timestamp_event_t; + +typedef struct { + uint8_t thr; + uint8_t id; + odp_time_t time; +} log_entry_t; + +typedef struct { + uint32_t iteration_num; + odp_atomic_u32_t iteration_counter; + odp_atomic_u32_t id_counter; + odp_atomic_u32_t log_counter; + odp_atomic_u32_t err_counter; + odp_barrier_t start_barrier; + odp_barrier_t end_barrier; + int thread_num; + log_entry_t *log; + int log_enries_num; +} test_globals_t; + +static void print_log(test_globals_t *gbls) +{ + uint32_t err_num; + int i, j, k, pad; + char line[LOG_LINE_SIZE]; + + memset(line, '-', LOG_LINE_SIZE - 1); + line[LOG_LINE_SIZE - 1] = 0; + for (i = 1; i <= gbls->thread_num; i++) { + printf("\n==== history of %d buffer, time,ns (thread) ====\n%s\n", + i, line); + + /* print log for buffer */ + k = 0; + for (j = 0; j < gbls->log_enries_num; j++) + if (gbls->log[j].id == i) { + printf("%10" PRIu64 " (%-3d)", + odp_time_to_ns(gbls->log[j].time), + gbls->log[j].thr); + + if (!(++k % LOG_BASE)) + printf(" |\n"); + else + printf(" =>"); + } + + if ((k % LOG_BASE)) { + pad = (LOG_BASE - k % LOG_BASE) * LOG_ENTRY_SIZE - 4; + printf(" end%*c\n%s\n", pad, '|', line); + } else { + printf("%s\n", line); + } + } + + printf("\n\n"); + + err_num = odp_atomic_load_u32(&gbls->err_counter); + if (err_num) + printf("Number of errors: %u\n", err_num); +} + +static void +generate_next_queue(test_globals_t *gbls, odp_queue_t *queue, unsigned int id) +{ + int thr; + unsigned int rand_id; + char queue_name[sizeof(QUEUE_NAME_PREFIX) + 2]; + + thr = odp_thread_id(); + + /* generate next random id */ + do { + odp_random_data((uint8_t *)&rand_id, sizeof(rand_id), 1); + rand_id = rand_id % gbls->thread_num + 1; + } while (rand_id == id); + + sprintf(queue_name, QUEUE_NAME_PREFIX "%d", rand_id); + *queue = odp_queue_lookup(queue_name); + + if (ODP_QUEUE_INVALID == *queue) + EXAMPLE_ABORT("Cannot lookup thread queue \"%s\", thread %d\n", + queue_name, thr); +} + +static void test_global_timestamps(test_globals_t *gbls, + odp_queue_t queue, unsigned int id) +{ + int thr; + int log_entry; + odp_event_t ev; + odp_time_t time; + odp_buffer_t buf; + odp_queue_t queue_next; + timestamp_event_t *timestamp_ev; + + thr = odp_thread_id(); + while (odp_atomic_load_u32(&gbls->iteration_counter) < + gbls->iteration_num) { + ev = odp_queue_deq(queue); + + if (ev == ODP_EVENT_INVALID) + continue; + + buf = odp_buffer_from_event(ev); + timestamp_ev = (timestamp_event_t *)odp_buffer_addr(buf); + + time = odp_time_global(); + if (odp_time_cmp(time, timestamp_ev->timestamp) < 0) { + EXAMPLE_ERR("timestamp is less than previous time_prev=%" PRIu64 "ns, time_next=%" PRIu64 "ns, thread %d\n", + odp_time_to_ns(timestamp_ev->timestamp), + odp_time_to_ns(time), thr); + odp_atomic_inc_u32(&gbls->err_counter); + } + + /* update the log */ + log_entry = odp_atomic_fetch_inc_u32(&gbls->log_counter); + gbls->log[log_entry].time = timestamp_ev->timestamp; + gbls->log[log_entry].id = timestamp_ev->id; + gbls->log[log_entry].thr = thr; + + /* assign new current time and send */ + generate_next_queue(gbls, &queue_next, id); + timestamp_ev->timestamp = time; + if (odp_queue_enq(queue_next, ev)) + EXAMPLE_ABORT("Cannot enqueue event %" PRIu64 " on queue %" PRIu64 ", thread %d\n", + odp_event_to_u64(ev), + odp_queue_to_u64(queue_next), thr); + + odp_atomic_inc_u32(&gbls->iteration_counter); + } +} + +/** + * @internal Worker thread + * + * @param ptr Pointer to test arguments + * + * @return Pointer to exit status + */ +static void *run_thread(void *ptr) +{ + int thr; + uint32_t id; + odp_event_t ev; + odp_buffer_t buf; + test_globals_t *gbls; + odp_pool_t buffer_pool; + odp_queue_param_t qparams; + odp_queue_t queue, queue_next; + timestamp_event_t *timestamp_ev; + char queue_name[sizeof(QUEUE_NAME_PREFIX) + 2]; + + gbls = ptr; + thr = odp_thread_id(); + printf("Thread %i starts on cpu %i\n", thr, odp_cpu_id()); + + /* + * Allocate own queue for receiving timestamps. + * Own queue is needed to guarantee that next thread for receiving + * buffer is not the same thread. + */ + odp_queue_param_init(&qparams); + qparams.sched.prio = ODP_SCHED_PRIO_LOWEST; + qparams.sched.sync = ODP_SCHED_SYNC_NONE; + qparams.sched.group = ODP_SCHED_GROUP_WORKER; + + id = odp_atomic_fetch_inc_u32(&gbls->id_counter); + sprintf(queue_name, QUEUE_NAME_PREFIX "%d", id); + queue = odp_queue_create(queue_name, ODP_QUEUE_TYPE_POLL, &qparams); + if (queue == ODP_QUEUE_INVALID) + EXAMPLE_ABORT("Cannot create thread queue, thread %d", thr); + + /* allocate buffer for timestamp */ + buffer_pool = odp_pool_lookup("time buffers pool"); + if (buffer_pool == ODP_POOL_INVALID) + EXAMPLE_ABORT("Buffer pool was not found, thread %d\n", thr); + + buf = odp_buffer_alloc(buffer_pool); + if (buf == ODP_BUFFER_INVALID) + EXAMPLE_ABORT("Buffer was not allocated, thread %d\n", thr); + + /* wait all threads allocated their queues */ + odp_barrier_wait(&gbls->start_barrier); + + /* enqueue global timestamp to some queue of some other thread */ + generate_next_queue(gbls, &queue_next, id); + + /* save global timestamp and id for tracing */ + ev = odp_buffer_to_event(buf); + timestamp_ev = (timestamp_event_t *)odp_buffer_addr(buf); + timestamp_ev->id = id; + timestamp_ev->timestamp = odp_time_global(); + if (odp_queue_enq(queue_next, ev)) + EXAMPLE_ABORT("Cannot enqueue timestamp event %" PRIu64 " on queue %" PRIu64 ", thread %d", + odp_event_to_u64(ev), + odp_queue_to_u64(queue_next), thr); + + test_global_timestamps(gbls, queue, id); + + /* wait all threads are finished their jobs */ + odp_barrier_wait(&gbls->end_barrier); + + /* free all events on the allocated queue */ + while (1) { + ev = odp_queue_deq(queue); + if (ev == ODP_EVENT_INVALID) + break; + + buf = odp_buffer_from_event(ev); + odp_buffer_free(buf); + } + + /* free allocated queue */ + if (odp_queue_destroy(queue)) + EXAMPLE_ABORT("Cannot destroy queue %" PRIu64 "", + odp_queue_to_u64(queue)); + + printf("Thread %i exits\n", thr); + fflush(NULL); + return NULL; +} + +int main(void) +{ + int err = 0; + odp_pool_t pool = ODP_POOL_INVALID; + int num_workers; + test_globals_t *gbls; + odp_cpumask_t cpumask; + odp_pool_param_t params; + odp_shm_t shm_glbls = ODP_SHM_INVALID; + odp_shm_t shm_log = ODP_SHM_INVALID; + int log_size, log_enries_num; + odph_linux_pthread_t thread_tbl[MAX_WORKERS]; + + printf("\nODP global time test starts\n"); + + if (odp_init_global(NULL, NULL)) { + err = 1; + EXAMPLE_ERR("ODP global init failed.\n"); + goto end; + } + + /* Init this thread. */ + if (odp_init_local(ODP_THREAD_CONTROL)) { + err = 1; + EXAMPLE_ERR("ODP local init failed.\n"); + goto err_global; + } + + num_workers = MAX_WORKERS; + num_workers = odp_cpumask_default_worker(&cpumask, num_workers); + + shm_glbls = odp_shm_reserve("test_globals", sizeof(test_globals_t), + ODP_CACHE_LINE_SIZE, 0); + if (ODP_SHM_INVALID == shm_glbls) { + err = 1; + EXAMPLE_ERR("Error: shared mem reserve failed.\n"); + goto err; + } + + log_enries_num = num_workers * (ITERATION_NUM + num_workers); + log_size = sizeof(log_entry_t) * log_enries_num; + shm_log = odp_shm_reserve("test_log", log_size, ODP_CACHE_LINE_SIZE, 0); + if (ODP_SHM_INVALID == shm_log) { + err = 1; + EXAMPLE_ERR("Error: shared mem reserve failed.\n"); + goto err; + } + + gbls = odp_shm_addr(shm_glbls); + gbls->thread_num = num_workers; + gbls->iteration_num = ITERATION_NUM; + odp_atomic_store_u32(&gbls->iteration_counter, 0); + odp_atomic_store_u32(&gbls->id_counter, 1); + odp_atomic_store_u32(&gbls->log_counter, 0); + odp_atomic_store_u32(&gbls->err_counter, 0); + gbls->log_enries_num = log_enries_num; + gbls->log = odp_shm_addr(shm_log); + odp_barrier_init(&gbls->start_barrier, num_workers); + odp_barrier_init(&gbls->end_barrier, num_workers); + memset(gbls->log, 0, log_size); + + params.buf.size = sizeof(timestamp_event_t); + params.buf.align = ODP_CACHE_LINE_SIZE; + params.buf.num = num_workers; + params.type = ODP_POOL_BUFFER; + + pool = odp_pool_create("time buffers pool", ¶ms); + if (pool == ODP_POOL_INVALID) { + err = 1; + EXAMPLE_ERR("Pool create failed.\n"); + goto err; + } + + /* Create and launch worker threads */ + odph_linux_pthread_create(thread_tbl, &cpumask, + run_thread, gbls, ODP_THREAD_WORKER); + + /* Wait for worker threads to exit */ + odph_linux_pthread_join(thread_tbl, num_workers); + + print_log(gbls); + +err: + if (pool != ODP_POOL_INVALID) + if (odp_pool_destroy(pool)) + err = 1; + + if (shm_log != ODP_SHM_INVALID) + if (odp_shm_free(shm_log)) + err = 1; + + if (shm_glbls != ODP_SHM_INVALID) + if (odp_shm_free(shm_glbls)) + err = 1; + + if (odp_term_local()) + err = 1; +err_global: + if (odp_term_global()) + err = 1; +end: + if (err) { + EXAMPLE_ERR("Err: ODP global time test failed\n\n"); + return -1; + } + + printf("ODP global time test complete\n\n"); + return 0; +}