Signed-off-by: Mike Holmes <mike.hol...@linaro.org>
---
example/example_debug.h | 88 +++++++++++++++++++++++++++++++++++++++
example/generator/Makefile.am | 1 +
example/generator/odp_generator.c | 44 +++++++++++---------
example/ipsec/Makefile.am | 1 +
example/ipsec/odp_ipsec.c | 47 ++++++++++++---------
example/ipsec/odp_ipsec_cache.c | 4 +-
example/ipsec/odp_ipsec_fwd_db.c | 4 +-
example/ipsec/odp_ipsec_loop_db.c | 4 +-
example/ipsec/odp_ipsec_sa_db.c | 4 +-
example/ipsec/odp_ipsec_sp_db.c | 4 +-
example/ipsec/odp_ipsec_stream.c | 9 ++--
example/l2fwd/Makefile.am | 1 +
example/l2fwd/odp_l2fwd.c | 47 +++++++++++----------
example/odp_example/Makefile.am | 1 +
example/odp_example/odp_example.c | 75 +++++++++++++++++----------------
example/packet/Makefile.am | 1 +
example/packet/odp_pktio.c | 34 ++++++++-------
example/timer/Makefile.am | 1 +
example/timer/odp_timer_test.c | 22 +++++-----
19 files changed, 262 insertions(+), 130 deletions(-)
create mode 100644 example/example_debug.h
diff --git a/example/example_debug.h b/example/example_debug.h
new file mode 100644
index 0000000..b83667c
--- /dev/null
+++ b/example/example_debug.h
@@ -0,0 +1,88 @@
+/* Copyright (c) 2014, Linaro Limited
+ * All rights reserved.
+ *
+ * SPDX-License-Identifier: BSD-3-Clause
+ */
+/**
+ * @file
+ *
+ * example debug
+ */
+
+#ifndef EXAMPLE_DEBUG_H_
+#define EXAMPLE_DEBUG_H_
+
+#include <stdio.h>
+#include <stdlib.h>
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+#ifndef EXAMPLE_DEBUG_PRINT
+#define EXAMPLE_DEBUG_PRINT 1
+#endif
+
+/**
+ * log level.
+ */
+typedef enum example_log_level {
+ EXAMPLE_LOG_DBG,
+ EXAMPLE_LOG_ERR,
+ EXAMPLE_LOG_ABORT
+} example_log_level_e;
+
+/**
+ * default LOG macro.
+ */
+#define EXAMPLE_LOG(level, fmt, ...) \
+do { \
+ switch (level) { \
+ case EXAMPLE_LOG_ERR: \
+ fprintf(stderr, "%s:%d:%s():" fmt, __FILE__, \
+ __LINE__, __func__, ##__VA_ARGS__); \
+ break; \
+ case EXAMPLE_LOG_DBG: \
+ if (EXAMPLE_DEBUG_PRINT == 1) \
+ fprintf(stderr, "%s:%d:%s():" fmt, __FILE__, \
+ __LINE__, __func__, ##__VA_ARGS__); \
+ break; \
+ case EXAMPLE_LOG_ABORT: \
+ fprintf(stderr, "%s:%d:%s(): " fmt, __FILE__, \
+ __LINE__, __func__, ##__VA_ARGS__); \
+ abort(); \
+ break; \
+ default: \
+ fprintf(stderr, "Unknown LOG level"); \
+ break;\
+ } \
+} while (0)
+
+/**
+ * Debug printing macro, which prints output when DEBUG flag is set.
+ */
+#define EXAMPLE_DBG(fmt, ...) \
+ EXAMPLE_LOG(EXAMPLE_LOG_DBG, fmt, ##__VA_ARGS__)
+
+/**
+ * Print output to stderr (file, line and function).
+ */
+#define EXAMPLE_ERR(fmt, ...) \
+ EXAMPLE_LOG(EXAMPLE_LOG_ERR, fmt, ##__VA_ARGS__)
+
+/**
+ * Print output to stderr (file, line and function),
+ * then abort.
+ */
+#define EXAMPLE_ABORT(fmt, ...) \
+ EXAMPLE_LOG(EXAMPLE_LOG_ABORT, fmt, ##__VA_ARGS__)
+
+/**
+ * @}
+ */
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif
diff --git a/example/generator/Makefile.am b/example/generator/Makefile.am
index 5b3d55a..394985f 100644
--- a/example/generator/Makefile.am
+++ b/example/generator/Makefile.am
@@ -2,5 +2,6 @@ include $(top_srcdir)/example/Makefile.inc
bin_PROGRAMS = odp_generator
odp_generator_LDFLAGS = $(AM_LDFLAGS) -static
+odp_generator_CFLAGS = $(AM_CFLAGS) -I../
dist_odp_generator_SOURCES = odp_generator.c
diff --git a/example/generator/odp_generator.c
b/example/generator/odp_generator.c
index ffa5e62..e2e0ba4 100644
--- a/example/generator/odp_generator.c
+++ b/example/generator/odp_generator.c
@@ -16,6 +16,8 @@
#include <unistd.h>
#include <sys/time.h>
+#include <example_debug.h>
+
#include <odp.h>
#include <odph_linux.h>
@@ -55,7 +57,8 @@ typedef struct {
int number; /**< packets number to be sent */
int payload; /**< data len */
int timeout; /**< wait time */
- int interval; /**< wait interval ms between sending each
packet */
+ int interval; /**< wait interval ms between sending
+ each packet */
} appl_args_t;
/**
@@ -303,13 +306,13 @@ static void *gen_send_thread(void *arg)
/* Open a packet IO instance for this thread */
pktio = odp_pktio_open(thr_args->pktio_dev, thr_args->pool);
if (pktio == ODP_PKTIO_INVALID) {
- ODP_ERR(" [%02i] Error: pktio create failed\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: pktio create failed\n", thr);
return NULL;
}
outq_def = odp_pktio_outq_getdef(pktio);
if (outq_def == ODP_QUEUE_INVALID) {
- ODP_ERR(" [%02i] Error: def output-Q query\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: def output-Q query\n", thr);
return NULL;
}
@@ -318,7 +321,7 @@ static void *gen_send_thread(void *arg)
int err;
buf = odp_buffer_alloc(thr_args->pool);
if (!odp_buffer_is_valid(buf)) {
- ODP_ERR(" [%2i] alloc_single failed\n", thr);
+ EXAMPLE_ERR(" [%2i] alloc_single failed\n", thr);
return NULL;
}
@@ -329,7 +332,7 @@ static void *gen_send_thread(void *arg)
err = odp_queue_enq(outq_def, buf);
if (err != 0) {
- ODP_ERR(" [%02i] send pkt err!\n", thr);
+ EXAMPLE_ERR(" [%02i] send pkt err!\n", thr);
return NULL;
}
@@ -463,7 +466,7 @@ static void *gen_recv_thread(void *arg)
/* Open a packet IO instance for this thread */
pktio = odp_pktio_open(thr_args->pktio_dev, thr_args->pool);
if (pktio == ODP_PKTIO_INVALID) {
- ODP_ERR(" [%02i] Error: pktio create failed\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: pktio create failed\n", thr);
return NULL;
}
@@ -475,13 +478,14 @@ static void *gen_recv_thread(void *arg)
inq_name[ODP_QUEUE_NAME_LEN - 1] = '\0';
inq_def = odp_queue_create(inq_name, ODP_QUEUE_TYPE_PKTIN, &qparam);
if (inq_def == ODP_QUEUE_INVALID) {
- ODP_ERR(" [%02i] Error: pktio queue creation failed\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: pktio queue creation failed\n",
+ thr);
return NULL;
}
ret = odp_pktio_inq_setdef(pktio, inq_def);
if (ret != 0) {
- ODP_ERR(" [%02i] Error: default input-Q setup\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: default input-Q setup\n", thr);
return NULL;
}
@@ -520,12 +524,12 @@ int main(int argc, char *argv[])
/* Init ODP before calling anything else */
if (odp_init_global(NULL, NULL)) {
- ODP_ERR("Error: ODP global init failed.\n");
+ EXAMPLE_ERR("Error: ODP global init failed.\n");
exit(EXIT_FAILURE);
}
if (odp_init_local()) {
- ODP_ERR("Error: ODP local init failed.\n");
+ EXAMPLE_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -541,7 +545,7 @@ int main(int argc, char *argv[])
args = odp_shm_addr(shm);
if (args == NULL) {
- ODP_ERR("Error: shared mem alloc failed.\n");
+ EXAMPLE_ERR("Error: shared mem alloc failed.\n");
exit(EXIT_FAILURE);
}
memset(args, 0, sizeof(*args));
@@ -584,7 +588,7 @@ int main(int argc, char *argv[])
pool_base = odp_shm_addr(shm);
if (pool_base == NULL) {
- ODP_ERR("Error: packet pool mem alloc failed.\n");
+ EXAMPLE_ERR("Error: packet pool mem alloc failed.\n");
exit(EXIT_FAILURE);
}
@@ -594,7 +598,7 @@ int main(int argc, char *argv[])
ODP_CACHE_LINE_SIZE,
ODP_BUFFER_TYPE_PACKET);
if (pool == ODP_BUFFER_POOL_INVALID) {
- ODP_ERR("Error: packet pool create failed.\n");
+ EXAMPLE_ERR("Error: packet pool create failed.\n");
exit(EXIT_FAILURE);
}
odp_buffer_pool_print(pool);
@@ -636,7 +640,7 @@ int main(int argc, char *argv[])
} else if (args->appl.mode == APPL_MODE_RCV) {
thr_run_func = gen_recv_thread;
} else {
- ODP_ERR("ERR MODE\n");
+ EXAMPLE_ERR("ERR MODE\n");
exit(EXIT_FAILURE);
}
/*
@@ -754,35 +758,35 @@ static void parse_args(int argc, char *argv[],
appl_args_t *appl_args)
} else if (optarg[0] == 'r') {
appl_args->mode = APPL_MODE_RCV;
} else {
- ODP_ERR("wrong mode!\n");
+ EXAMPLE_ERR("wrong mode!\n");
exit(EXIT_FAILURE);
}
break;
case 'a':
if (scan_mac(optarg, &appl_args->srcmac) != 1) {
- ODP_ERR("wrong src mac:%s\n", optarg);
+ EXAMPLE_ERR("wrong src mac:%s\n", optarg);
exit(EXIT_FAILURE);
}
break;
case 'b':
if (scan_mac(optarg, &appl_args->dstmac) != 1) {
- ODP_ERR("wrong dst mac:%s\n", optarg);
+ EXAMPLE_ERR("wrong dst mac:%s\n", optarg);
exit(EXIT_FAILURE);
}
break;
case 'c':
if (scan_ip(optarg, &appl_args->srcip) != 1) {
- ODP_ERR("wrong src ip:%s\n", optarg);
+ EXAMPLE_ERR("wrong src ip:%s\n", optarg);
exit(EXIT_FAILURE);
}
break;
case 'd':
if (scan_ip(optarg, &appl_args->dstip) != 1) {
- ODP_ERR("wrong dst ip:%s\n", optarg);
+ EXAMPLE_ERR("wrong dst ip:%s\n", optarg);
exit(EXIT_FAILURE);
}
break;
@@ -802,7 +806,7 @@ static void parse_args(int argc, char *argv[], appl_args_t
*appl_args)
case 'i':
appl_args->interval = atoi(optarg);
if (appl_args->interval <= 200 && geteuid() != 0) {
- ODP_ERR("should be root user\n");
+ EXAMPLE_ERR("should be root user\n");
exit(EXIT_FAILURE);
}
break;
diff --git a/example/ipsec/Makefile.am b/example/ipsec/Makefile.am
index ac0949e..b4ef0cb 100644
--- a/example/ipsec/Makefile.am
+++ b/example/ipsec/Makefile.am
@@ -2,6 +2,7 @@ include $(top_srcdir)/example/Makefile.inc
bin_PROGRAMS = odp_ipsec
odp_ipsec_LDFLAGS = $(AM_LDFLAGS) -static
+odp_ipsec_CFLAGS = $(AM_CFLAGS) -I../
dist_odp_ipsec_SOURCES = odp_ipsec.c \
odp_ipsec_sa_db.c \
diff --git a/example/ipsec/odp_ipsec.c b/example/ipsec/odp_ipsec.c
index da6c48e..709855c 100644
--- a/example/ipsec/odp_ipsec.c
+++ b/example/ipsec/odp_ipsec.c
@@ -15,6 +15,8 @@
#include <getopt.h>
#include <unistd.h>
+#include <example_debug.h>
+
#include <odp.h>
#include <odph_linux.h>
@@ -234,7 +236,7 @@ int query_mac_address(char *intf, uint8_t *src_mac)
/* Get a socket descriptor */
sd = socket(PF_PACKET, SOCK_RAW, htons(ETH_P_ALL));
if (sd < 0) {
- ODP_ERR("Error: socket() failed for %s\n", intf);
+ EXAMPLE_ERR("Error: socket() failed for %s\n", intf);
return -1;
}
@@ -243,7 +245,7 @@ int query_mac_address(char *intf, uint8_t *src_mac)
snprintf(ifr.ifr_name, sizeof(ifr.ifr_name), "%s", intf);
if (ioctl(sd, SIOCGIFHWADDR, &ifr) < 0) {
close(sd);
- ODP_ERR("Error: ioctl() failed for %s\n", intf);
+ EXAMPLE_ERR("Error: ioctl() failed for %s\n", intf);
return -1;
}
memcpy(src_mac, ifr.ifr_hwaddr.sa_data, ODPH_ETHADDR_LEN);
@@ -382,7 +384,7 @@ void ipsec_init_pre(void)
ODP_QUEUE_TYPE_SCHED,
&qparam);
if (ODP_QUEUE_INVALID == completionq) {
- ODP_ERR("Error: completion queue creation failed\n");
+ EXAMPLE_ERR("Error: completion queue creation failed\n");
exit(EXIT_FAILURE);
}
@@ -394,7 +396,7 @@ void ipsec_init_pre(void)
ODP_QUEUE_TYPE_SCHED,
&qparam);
if (ODP_QUEUE_INVALID == seqnumq) {
- ODP_ERR("Error: sequence number queue creation failed\n");
+ EXAMPLE_ERR("Error: sequence number queue creation failed\n");
exit(EXIT_FAILURE);
}
@@ -411,7 +413,7 @@ void ipsec_init_pre(void)
ODP_BUFFER_TYPE_PACKET);
if (ODP_BUFFER_POOL_INVALID == out_pool) {
- ODP_ERR("Error: message pool create failed.\n");
+ EXAMPLE_ERR("Error: message pool create failed.\n");
exit(EXIT_FAILURE);
}
@@ -454,7 +456,8 @@ void ipsec_init_post(crypto_api_mode_e api_mode)
entry->input,
completionq,
out_pool)) {
- ODP_ERR("Error: IPSec cache entry failed.\n");
+ EXAMPLE_ERR("Error: IPSec cache entry failed.\n"
+ );
exit(EXIT_FAILURE);
}
} else {
@@ -487,7 +490,7 @@ void initialize_loop(char *intf)
/* Derive loopback interface index */
idx = loop_if_index(intf);
if (idx < 0) {
- ODP_ERR("Error: loopback \"%s\" invalid\n", intf);
+ EXAMPLE_ERR("Error: loopback \"%s\" invalid\n", intf);
exit(EXIT_FAILURE);
}
@@ -500,7 +503,8 @@ void initialize_loop(char *intf)
inq_def = QUEUE_CREATE(queue_name, ODP_QUEUE_TYPE_SCHED, &qparam);
if (ODP_QUEUE_INVALID == inq_def) {
- ODP_ERR("Error: input queue creation failed for %s\n", intf);
+ EXAMPLE_ERR("Error: input queue creation failed for %s\n",
+ intf);
exit(EXIT_FAILURE);
}
/* Create output queue */
@@ -512,7 +516,8 @@ void initialize_loop(char *intf)
outq_def = QUEUE_CREATE(queue_name, ODP_QUEUE_TYPE_POLL, &qparam);
if (ODP_QUEUE_INVALID == outq_def) {
- ODP_ERR("Error: output queue creation failed for %s\n", intf);
+ EXAMPLE_ERR("Error: output queue creation failed for %s\n",
+ intf);
exit(EXIT_FAILURE);
}
@@ -556,7 +561,7 @@ void initialize_intf(char *intf)
*/
pktio = odp_pktio_open(intf, pkt_pool);
if (ODP_PKTIO_INVALID == pktio) {
- ODP_ERR("Error: pktio create failed for %s\n", intf);
+ EXAMPLE_ERR("Error: pktio create failed for %s\n", intf);
exit(EXIT_FAILURE);
}
outq_def = odp_pktio_outq_getdef(pktio);
@@ -573,13 +578,14 @@ void initialize_intf(char *intf)
inq_def = QUEUE_CREATE(inq_name, ODP_QUEUE_TYPE_PKTIN, &qparam);
if (ODP_QUEUE_INVALID == inq_def) {
- ODP_ERR("Error: pktio queue creation failed for %s\n", intf);
+ EXAMPLE_ERR("Error: pktio queue creation failed for %s\n",
+ intf);
exit(EXIT_FAILURE);
}
ret = odp_pktio_inq_setdef(pktio, inq_def);
if (ret) {
- ODP_ERR("Error: default input-Q setup for %s\n", intf);
+ EXAMPLE_ERR("Error: default input-Q setup for %s\n", intf);
exit(EXIT_FAILURE);
}
@@ -590,7 +596,8 @@ void initialize_intf(char *intf)
ret = odp_pktio_get_mac_addr(pktio, src_mac);
#endif
if (ret) {
- ODP_ERR("Error: failed during MAC address get for %s\n", intf);
+ EXAMPLE_ERR("Error: failed during MAC address get for %s\n",
+ intf);
exit(EXIT_FAILURE);
}
@@ -1176,13 +1183,13 @@ main(int argc, char *argv[])
/* Init ODP before calling anything else */
if (odp_init_global(NULL, NULL)) {
- ODP_ERR("Error: ODP global init failed.\n");
+ EXAMPLE_ERR("Error: ODP global init failed.\n");
exit(EXIT_FAILURE);
}
/* Init this thread */
if (odp_init_local()) {
- ODP_ERR("Error: ODP local init failed.\n");
+ EXAMPLE_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -1193,7 +1200,7 @@ main(int argc, char *argv[])
args = odp_shm_addr(shm);
if (NULL == args) {
- ODP_ERR("Error: shared mem alloc failed.\n");
+ EXAMPLE_ERR("Error: shared mem alloc failed.\n");
exit(EXIT_FAILURE);
}
memset(args, 0, sizeof(*args));
@@ -1238,7 +1245,7 @@ main(int argc, char *argv[])
pool_base = odp_shm_addr(shm);
if (NULL == pool_base) {
- ODP_ERR("Error: packet pool mem alloc failed.\n");
+ EXAMPLE_ERR("Error: packet pool mem alloc failed.\n");
exit(EXIT_FAILURE);
}
@@ -1248,7 +1255,7 @@ main(int argc, char *argv[])
ODP_CACHE_LINE_SIZE,
ODP_BUFFER_TYPE_PACKET);
if (ODP_BUFFER_POOL_INVALID == pkt_pool) {
- ODP_ERR("Error: packet pool create failed.\n");
+ EXAMPLE_ERR("Error: packet pool create failed.\n");
exit(EXIT_FAILURE);
}
@@ -1259,7 +1266,7 @@ main(int argc, char *argv[])
pool_base = odp_shm_addr(shm);
if (NULL == pool_base) {
- ODP_ERR("Error: context pool mem alloc failed.\n");
+ EXAMPLE_ERR("Error: context pool mem alloc failed.\n");
exit(EXIT_FAILURE);
}
@@ -1269,7 +1276,7 @@ main(int argc, char *argv[])
ODP_CACHE_LINE_SIZE,
ODP_BUFFER_TYPE_RAW);
if (ODP_BUFFER_POOL_INVALID == ctx_pool) {
- ODP_ERR("Error: context pool create failed.\n");
+ EXAMPLE_ERR("Error: context pool create failed.\n");
exit(EXIT_FAILURE);
}
diff --git a/example/ipsec/odp_ipsec_cache.c b/example/ipsec/odp_ipsec_cache.c
index 1397d77..fb53bb6 100644
--- a/example/ipsec/odp_ipsec_cache.c
+++ b/example/ipsec/odp_ipsec_cache.c
@@ -7,6 +7,8 @@
#include <stdlib.h>
#include <string.h>
+#include <example_debug.h>
+
#include <odp.h>
#include <odph_ipsec.h>
@@ -28,7 +30,7 @@ void init_ipsec_cache(void)
ipsec_cache = odp_shm_addr(shm);
if (ipsec_cache == NULL) {
- ODP_ERR("Error: shared mem alloc failed.\n");
+ EXAMPLE_ERR("Error: shared mem alloc failed.\n");
exit(EXIT_FAILURE);
}
memset(ipsec_cache, 0, sizeof(*ipsec_cache));
diff --git a/example/ipsec/odp_ipsec_fwd_db.c b/example/ipsec/odp_ipsec_fwd_db.c
index e067db9..4168420 100644
--- a/example/ipsec/odp_ipsec_fwd_db.c
+++ b/example/ipsec/odp_ipsec_fwd_db.c
@@ -7,6 +7,8 @@
#include <stdlib.h>
#include <string.h>
+#include <example_debug.h>
+
#include <odp.h>
#include <odp_ipsec_fwd_db.h>
@@ -26,7 +28,7 @@ void init_fwd_db(void)
fwd_db = odp_shm_addr(shm);
if (fwd_db == NULL) {
- ODP_ERR("Error: shared mem alloc failed.\n");
+ EXAMPLE_ERR("Error: shared mem alloc failed.\n");
exit(EXIT_FAILURE);
}
memset(fwd_db, 0, sizeof(*fwd_db));
diff --git a/example/ipsec/odp_ipsec_loop_db.c
b/example/ipsec/odp_ipsec_loop_db.c
index af4590a..d213bb3 100644
--- a/example/ipsec/odp_ipsec_loop_db.c
+++ b/example/ipsec/odp_ipsec_loop_db.c
@@ -7,6 +7,8 @@
#include <stdlib.h>
#include <string.h>
+#include <example_debug.h>
+
#include <odp.h>
#include <odp_ipsec_loop_db.h>
@@ -26,7 +28,7 @@ void init_loopback_db(void)
loopback_db = odp_shm_addr(shm);
if (loopback_db == NULL) {
- ODP_ERR("Error: shared mem alloc failed.\n");
+ EXAMPLE_ERR("Error: shared mem alloc failed.\n");
exit(EXIT_FAILURE);
}
memset(loopback_db, 0, sizeof(*loopback_db));
diff --git a/example/ipsec/odp_ipsec_sa_db.c b/example/ipsec/odp_ipsec_sa_db.c
index e8679db..384c0ce 100644
--- a/example/ipsec/odp_ipsec_sa_db.c
+++ b/example/ipsec/odp_ipsec_sa_db.c
@@ -7,6 +7,8 @@
#include <stdlib.h>
#include <string.h>
+#include <example_debug.h>
+
#include <odp.h>
#include <odp_ipsec_sa_db.h>
@@ -26,7 +28,7 @@ void init_sa_db(void)
sa_db = odp_shm_addr(shm);
if (sa_db == NULL) {
- ODP_ERR("Error: shared mem alloc failed.\n");
+ EXAMPLE_ERR("Error: shared mem alloc failed.\n");
exit(EXIT_FAILURE);
}
memset(sa_db, 0, sizeof(*sa_db));
diff --git a/example/ipsec/odp_ipsec_sp_db.c b/example/ipsec/odp_ipsec_sp_db.c
index f288dfe..b0f4480 100644
--- a/example/ipsec/odp_ipsec_sp_db.c
+++ b/example/ipsec/odp_ipsec_sp_db.c
@@ -7,6 +7,8 @@
#include <stdlib.h>
#include <string.h>
+#include <example_debug.h>
+
#include <odp.h>
#include <odp_align.h>
#include <odp_crypto.h>
@@ -28,7 +30,7 @@ void init_sp_db(void)
sp_db = odp_shm_addr(shm);
if (sp_db == NULL) {
- ODP_ERR("Error: shared mem alloc failed.\n");
+ EXAMPLE_ERR("Error: shared mem alloc failed.\n");
exit(EXIT_FAILURE);
}
memset(sp_db, 0, sizeof(*sp_db));
diff --git a/example/ipsec/odp_ipsec_stream.c b/example/ipsec/odp_ipsec_stream.c
index fa9aba8..139d00e 100644
--- a/example/ipsec/odp_ipsec_stream.c
+++ b/example/ipsec/odp_ipsec_stream.c
@@ -12,6 +12,8 @@
#include <openssl/hmac.h>
#include <openssl/evp.h>
+#include <example_debug.h>
+
#include <odp.h>
#include <odph_packet.h>
@@ -56,7 +58,7 @@ void init_stream_db(void)
stream_db = odp_shm_addr(shm);
if (stream_db == NULL) {
- ODP_ERR("Error: shared mem alloc failed.\n");
+ EXAMPLE_ERR("Error: shared mem alloc failed.\n");
exit(EXIT_FAILURE);
}
memset(stream_db, 0, sizeof(*stream_db));
@@ -100,7 +102,8 @@ int create_stream_db_entry(char *input)
case 2:
entry->input.loop = loop_if_index(token);
if (entry->input.loop < 0) {
- ODP_ERR("Error: stream must have input loop\n");
+ EXAMPLE_ERR("Error: stream must have input"
+ " loop\n");
exit(EXIT_FAILURE);
}
break;
@@ -479,7 +482,7 @@ int create_stream_db_inputs(void)
/* Lookup the packet pool */
pkt_pool = odp_buffer_pool_lookup("packet_pool");
if (pkt_pool == ODP_BUFFER_POOL_INVALID) {
- ODP_ERR("Error: pkt_pool not found\n");
+ EXAMPLE_ERR("Error: pkt_pool not found\n");
exit(EXIT_FAILURE);
}
diff --git a/example/l2fwd/Makefile.am b/example/l2fwd/Makefile.am
index a83e757..d57a159 100644
--- a/example/l2fwd/Makefile.am
+++ b/example/l2fwd/Makefile.am
@@ -2,5 +2,6 @@ include $(top_srcdir)/example/Makefile.inc
bin_PROGRAMS = odp_l2fwd
odp_l2fwd_LDFLAGS = $(AM_LDFLAGS) -static
+odp_l2fwd_CFLAGS = $(AM_CFLAGS) -I../
dist_odp_l2fwd_SOURCES = odp_l2fwd.c
diff --git a/example/l2fwd/odp_l2fwd.c b/example/l2fwd/odp_l2fwd.c
index 57037cd..ebac8c5 100644
--- a/example/l2fwd/odp_l2fwd.c
+++ b/example/l2fwd/odp_l2fwd.c
@@ -15,6 +15,8 @@
#include <getopt.h>
#include <unistd.h>
+#include <example_debug.h>
+
#include <odp.h>
#include <odph_linux.h>
#include <odph_packet.h>
@@ -128,7 +130,7 @@ static odp_pktio_t burst_mode_init_params(void *arg,
odp_buffer_pool_t pool)
/* Open a packet IO instance for this thread */
pktio = odp_pktio_open(args->srcif, pool);
if (pktio == ODP_PKTIO_INVALID)
- ODP_ERR(" Error: pktio create failed");
+ EXAMPLE_ERR(" Error: pktio create failed");
return pktio;
}
@@ -167,13 +169,13 @@ static odp_pktio_t queue_mode_init_params(void *arg,
odp_buffer_pool_t pool)
inq_def = odp_queue_create(inq_name, ODP_QUEUE_TYPE_PKTIN, &qparam);
if (inq_def == ODP_QUEUE_INVALID) {
- ODP_ERR(" Error: pktio queue creation failed");
+ EXAMPLE_ERR(" Error: pktio queue creation failed");
return ODP_PKTIO_INVALID;
}
ret = odp_pktio_inq_setdef(pktio, inq_def);
if (ret != 0) {
- ODP_ERR(" Error: default input-Q setup");
+ EXAMPLE_ERR(" Error: default input-Q setup");
return ODP_PKTIO_INVALID;
}
@@ -200,8 +202,8 @@ static void *pktio_queue_thread(void *arg)
thr_args = arg;
if (thr_args->srcpktio == 0 || thr_args->dstpktio == 0) {
- ODP_ERR("Invalid srcpktio:%d dstpktio:%d\n",
- thr_args->srcpktio, thr_args->dstpktio);
+ EXAMPLE_ERR("Invalid srcpktio:%d dstpktio:%d\n",
+ thr_args->srcpktio, thr_args->dstpktio);
return NULL;
}
printf("[%02i] srcif:%s dstif:%s spktio:%02i dpktio:%02i QUEUE mode\n",
@@ -224,14 +226,15 @@ static void *pktio_queue_thread(void *arg)
pkt = odp_packet_from_buffer(buf);
/* Drop packets with errors */
if (odp_unlikely(drop_err_pkts(&pkt, 1) == 0)) {
- ODP_ERR("Drop frame - err_cnt:%lu\n", ++err_cnt);
+ EXAMPLE_ERR("Drop frame - err_cnt:%lu\n", ++err_cnt);
continue;
}
pktio_tmp = odp_pktio_get_input(pkt);
outq_def = odp_pktio_outq_getdef(dstpktio[pktio_tmp]);
if (outq_def == ODP_QUEUE_INVALID) {
- ODP_ERR(" [%02i] Error: def output-Q query\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: def output-Q query\n",
+ thr);
return NULL;
}
@@ -267,8 +270,8 @@ static void *pktio_ifburst_thread(void *arg)
thr_args = arg;
if (thr_args->srcpktio == 0 || thr_args->dstpktio == 0) {
- ODP_ERR("Invalid srcpktio:%d dstpktio:%d\n",
- thr_args->srcpktio, thr_args->dstpktio);
+ EXAMPLE_ERR("Invalid srcpktio:%d dstpktio:%d\n",
+ thr_args->srcpktio, thr_args->dstpktio);
return NULL;
}
printf("[%02i] srcif:%s dstif:%s spktio:%02i dpktio:%02i BURST mode\n",
@@ -286,8 +289,8 @@ static void *pktio_ifburst_thread(void *arg)
odp_pktio_send(thr_args->dstpktio, pkt_tbl,
pkts_ok);
if (odp_unlikely(pkts_ok != pkts))
- ODP_ERR("Dropped frames:%u - err_cnt:%lu\n",
- pkts-pkts_ok, ++err_cnt);
+ EXAMPLE_ERR("Dropped frames:%u - err_cnt:%lu\n",
+ pkts-pkts_ok, ++err_cnt);
/* Print packet counts every once in a while */
tmp += pkts_ok;
@@ -320,13 +323,13 @@ int main(int argc, char *argv[])
/* Init ODP before calling anything else */
if (odp_init_global(NULL, NULL)) {
- ODP_ERR("Error: ODP global init failed.\n");
+ EXAMPLE_ERR("Error: ODP global init failed.\n");
exit(EXIT_FAILURE);
}
/* Init this thread */
if (odp_init_local()) {
- ODP_ERR("Error: ODP local init failed.\n");
+ EXAMPLE_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -336,7 +339,7 @@ int main(int argc, char *argv[])
gbl_args = odp_shm_addr(shm);
if (gbl_args == NULL) {
- ODP_ERR("Error: shared mem alloc failed.\n");
+ EXAMPLE_ERR("Error: shared mem alloc failed.\n");
exit(EXIT_FAILURE);
}
memset(gbl_args, 0, sizeof(*gbl_args));
@@ -359,13 +362,13 @@ int main(int argc, char *argv[])
printf("Num worker threads: %i\n", num_workers);
if (num_workers < gbl_args->appl.if_count) {
- ODP_ERR("Error: core count %d is less than interface count\n",
- num_workers);
+ EXAMPLE_ERR("Error: core count %d is less than interface "
+ "count\n", num_workers);
exit(EXIT_FAILURE);
}
if (gbl_args->appl.if_count % 2 != 0) {
- ODP_ERR("Error: interface count %d is odd in fwd appl.\n",
- gbl_args->appl.if_count);
+ EXAMPLE_ERR("Error: interface count %d is odd in fwd appl.\n",
+ gbl_args->appl.if_count);
exit(EXIT_FAILURE);
}
/*
@@ -385,7 +388,7 @@ int main(int argc, char *argv[])
pool_base = odp_shm_addr(shm);
if (pool_base == NULL) {
- ODP_ERR("Error: packet pool mem alloc failed.\n");
+ EXAMPLE_ERR("Error: packet pool mem alloc failed.\n");
exit(EXIT_FAILURE);
}
@@ -395,7 +398,7 @@ int main(int argc, char *argv[])
ODP_CACHE_LINE_SIZE,
ODP_BUFFER_TYPE_PACKET);
if (pool == ODP_BUFFER_POOL_INVALID) {
- ODP_ERR("Error: packet pool create failed.\n");
+ EXAMPLE_ERR("Error: packet pool create failed.\n");
exit(EXIT_FAILURE);
}
odp_buffer_pool_print(pool);
@@ -418,13 +421,13 @@ int main(int argc, char *argv[])
if (gbl_args->appl.mode == APPL_MODE_PKT_BURST) {
pktio = burst_mode_init_params(&gbl_args->thread[i],
pool);
if (pktio == ODP_PKTIO_INVALID) {
- ODP_ERR(" for thread:%02i\n", i);
+ EXAMPLE_ERR(" for thread:%02i\n", i);
exit(EXIT_FAILURE);
}
} else { /* APPL_MODE_PKT_QUEUE */
pktio = queue_mode_init_params(&gbl_args->thread[i],
pool);
if (pktio == ODP_PKTIO_INVALID) {
- ODP_ERR(" for thread:%02i\n", i);
+ EXAMPLE_ERR(" for thread:%02i\n", i);
exit(EXIT_FAILURE);
}
}
diff --git a/example/odp_example/Makefile.am b/example/odp_example/Makefile.am
index e6f23d0..95136e7 100644
--- a/example/odp_example/Makefile.am
+++ b/example/odp_example/Makefile.am
@@ -2,5 +2,6 @@ include $(top_srcdir)/example/Makefile.inc
bin_PROGRAMS = odp_example
odp_example_LDFLAGS = $(AM_LDFLAGS) -static
+odp_example_CFLAGS = $(AM_CFLAGS) -I../
dist_odp_example_SOURCES = odp_example.c
diff --git a/example/odp_example/odp_example.c
b/example/odp_example/odp_example.c
index 1ed4a0b..a674b77 100644
--- a/example/odp_example/odp_example.c
+++ b/example/odp_example/odp_example.c
@@ -13,6 +13,8 @@
#include <string.h>
#include <stdlib.h>
+#include <example_debug.h>
+
/* ODP main header */
#include <odp.h>
@@ -93,7 +95,7 @@ static int create_queue(int thr, odp_buffer_pool_t msg_pool, int prio)
buf = odp_buffer_alloc(msg_pool);
if (!odp_buffer_is_valid(buf)) {
- ODP_ERR(" [%i] msg_pool alloc failed\n", thr);
+ EXAMPLE_ERR(" [%i] msg_pool alloc failed\n", thr);
return -1;
}
@@ -103,12 +105,12 @@ static int create_queue(int thr, odp_buffer_pool_t msg_pool, int prio)
queue = odp_queue_lookup(name);
if (queue == ODP_QUEUE_INVALID) {
- ODP_ERR(" [%i] Queue %s lookup failed.\n", thr, name);
+ EXAMPLE_ERR(" [%i] Queue %s lookup failed.\n", thr, name);
return -1;
}
if (odp_queue_enq(queue, buf)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
@@ -142,19 +144,20 @@ static int create_queues(int thr, odp_buffer_pool_t msg_pool, int prio)
queue = odp_queue_lookup(name);
if (queue == ODP_QUEUE_INVALID) {
- ODP_ERR(" [%i] Queue %s lookup failed.\n", thr, name);
+ EXAMPLE_ERR(" [%i] Queue %s lookup failed.\n", thr,
+ name);
return -1;
}
buf = odp_buffer_alloc(msg_pool);
if (!odp_buffer_is_valid(buf)) {
- ODP_ERR(" [%i] msg_pool alloc failed\n", thr);
+ EXAMPLE_ERR(" [%i] msg_pool alloc failed\n", thr);
return -1;
}
if (odp_queue_enq(queue, buf)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
}
@@ -183,7 +186,7 @@ static int test_alloc_single(int thr, odp_buffer_pool_t
pool)
temp_buf = odp_buffer_alloc(pool);
if (!odp_buffer_is_valid(temp_buf)) {
- ODP_ERR(" [%i] alloc_single failed\n", thr);
+ EXAMPLE_ERR(" [%i] alloc_single failed\n", thr);
return -1;
}
@@ -221,7 +224,7 @@ static int test_alloc_multi(int thr, odp_buffer_pool_t pool)
temp_buf[j] = odp_buffer_alloc(pool);
if (!odp_buffer_is_valid(temp_buf[j])) {
- ODP_ERR(" [%i] alloc_multi failed\n", thr);
+ EXAMPLE_ERR(" [%i] alloc_multi failed\n", thr);
return -1;
}
}
@@ -263,7 +266,7 @@ static int test_poll_queue(int thr, odp_buffer_pool_t
msg_pool)
buf = odp_buffer_alloc(msg_pool);
if (!odp_buffer_is_valid(buf)) {
- ODP_ERR(" [%i] msg_pool alloc failed\n", thr);
+ EXAMPLE_ERR(" [%i] msg_pool alloc failed\n", thr);
return -1;
}
@@ -284,14 +287,14 @@ static int test_poll_queue(int thr, odp_buffer_pool_t msg_pool)
for (i = 0; i < QUEUE_ROUNDS; i++) {
if (odp_queue_enq(queue, buf)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
buf = odp_queue_deq(queue);
if (!odp_buffer_is_valid(buf)) {
- ODP_ERR(" [%i] Queue empty.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue empty.\n", thr);
return -1;
}
}
@@ -339,7 +342,7 @@ static int test_schedule_one_single(const char *str, int
thr,
buf = odp_schedule_one(&queue, ODP_SCHED_WAIT);
if (odp_queue_enq(queue, buf)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
}
@@ -399,7 +402,7 @@ static int test_schedule_one_many(const char *str, int thr,
buf = odp_schedule_one(&queue, ODP_SCHED_WAIT);
if (odp_queue_enq(queue, buf)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
}
@@ -456,7 +459,7 @@ static int test_schedule_single(const char *str, int thr,
buf = odp_schedule(&queue, ODP_SCHED_WAIT);
if (odp_queue_enq(queue, buf)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
}
@@ -475,7 +478,7 @@ static int test_schedule_single(const char *str, int thr,
tot++;
if (odp_queue_enq(queue, buf)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
}
@@ -534,7 +537,7 @@ static int test_schedule_many(const char *str, int thr,
buf = odp_schedule(&queue, ODP_SCHED_WAIT);
if (odp_queue_enq(queue, buf)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
}
@@ -553,7 +556,7 @@ static int test_schedule_many(const char *str, int thr,
tot++;
if (odp_queue_enq(queue, buf)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
}
@@ -611,7 +614,8 @@ static int test_schedule_multi(const char *str, int thr,
queue = odp_queue_lookup(name);
if (queue == ODP_QUEUE_INVALID) {
- ODP_ERR(" [%i] Queue %s lookup failed.\n", thr, name);
+ EXAMPLE_ERR(" [%i] Queue %s lookup failed.\n", thr,
+ name);
return -1;
}
@@ -619,13 +623,14 @@ static int test_schedule_multi(const char *str, int thr,
buf[j] = odp_buffer_alloc(msg_pool);
if (!odp_buffer_is_valid(buf[j])) {
- ODP_ERR(" [%i] msg_pool alloc failed\n", thr);
+ EXAMPLE_ERR(" [%i] msg_pool alloc failed\n",
+ thr);
return -1;
}
}
if (odp_queue_enq_multi(queue, buf, MULTI_BUFS_MAX)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
}
@@ -640,7 +645,7 @@ static int test_schedule_multi(const char *str, int thr,
tot += num;
if (odp_queue_enq_multi(queue, buf, num)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
}
@@ -658,7 +663,7 @@ static int test_schedule_multi(const char *str, int thr,
tot += num;
if (odp_queue_enq_multi(queue, buf, num)) {
- ODP_ERR(" [%i] Queue enqueue failed.\n", thr);
+ EXAMPLE_ERR(" [%i] Queue enqueue failed.\n", thr);
return -1;
}
}
@@ -710,7 +715,7 @@ static void *run_thread(void *arg)
globals = odp_shm_addr(shm);
if (globals == NULL) {
- ODP_ERR("Shared mem lookup failed\n");
+ EXAMPLE_ERR("Shared mem lookup failed\n");
return NULL;
}
@@ -730,7 +735,7 @@ static void *run_thread(void *arg)
msg_pool = odp_buffer_pool_lookup("msg_pool");
if (msg_pool == ODP_BUFFER_POOL_INVALID) {
- ODP_ERR(" [%i] msg_pool not found\n", thr);
+ EXAMPLE_ERR(" [%i] msg_pool not found\n", thr);
return NULL;
}
@@ -830,7 +835,7 @@ static void test_time(void)
double err;
if (clock_gettime(CLOCK_MONOTONIC, &tp2)) {
- ODP_ERR("clock_gettime failed.\n");
+ EXAMPLE_ERR("clock_gettime failed.\n");
return;
}
@@ -838,7 +843,7 @@ static void test_time(void)
do {
if (clock_gettime(CLOCK_MONOTONIC, &tp1)) {
- ODP_ERR("clock_gettime failed.\n");
+ EXAMPLE_ERR("clock_gettime failed.\n");
return;
}
@@ -848,7 +853,7 @@ static void test_time(void)
do {
if (clock_gettime(CLOCK_MONOTONIC, &tp2)) {
- ODP_ERR("clock_gettime failed.\n");
+ EXAMPLE_ERR("clock_gettime failed.\n");
return;
}
@@ -966,7 +971,7 @@ int main(int argc, char *argv[])
/* ODP global init */
if (odp_init_global(NULL, NULL)) {
- ODP_ERR("ODP global init failed.\n");
+ EXAMPLE_ERR("ODP global init failed.\n");
return -1;
}
@@ -975,7 +980,7 @@ int main(int argc, char *argv[])
* setting up resources for worker threads.
*/
if (odp_init_local()) {
- ODP_ERR("ODP global init failed.\n");
+ EXAMPLE_ERR("ODP global init failed.\n");
return -1;
}
@@ -1023,7 +1028,7 @@ int main(int argc, char *argv[])
globals = odp_shm_addr(shm);
if (globals == NULL) {
- ODP_ERR("Shared memory reserve failed.\n");
+ EXAMPLE_ERR("Shared memory reserve failed.\n");
return -1;
}
@@ -1038,7 +1043,7 @@ int main(int argc, char *argv[])
pool_base = odp_shm_addr(shm);
if (pool_base == NULL) {
- ODP_ERR("Shared memory reserve failed.\n");
+ EXAMPLE_ERR("Shared memory reserve failed.\n");
return -1;
}
@@ -1047,7 +1052,7 @@ int main(int argc, char *argv[])
ODP_CACHE_LINE_SIZE, ODP_BUFFER_TYPE_RAW);
if (pool == ODP_BUFFER_POOL_INVALID) {
- ODP_ERR("Pool create failed.\n");
+ EXAMPLE_ERR("Pool create failed.\n");
return -1;
}
@@ -1059,7 +1064,7 @@ int main(int argc, char *argv[])
queue = odp_queue_create("poll_queue", ODP_QUEUE_TYPE_POLL, NULL);
if (queue == ODP_QUEUE_INVALID) {
- ODP_ERR("Poll queue create failed.\n");
+ EXAMPLE_ERR("Poll queue create failed.\n");
return -1;
}
@@ -1091,7 +1096,7 @@ int main(int argc, char *argv[])
¶m);
if (queue == ODP_QUEUE_INVALID) {
- ODP_ERR("Schedule queue create failed.\n");
+ EXAMPLE_ERR("Schedule queue create failed.\n");
return -1;
}
}
@@ -1111,7 +1116,7 @@ int main(int argc, char *argv[])
first_core);
if (ret < 0) {
- ODP_ERR("Fork workers failed %i\n", ret);
+ EXAMPLE_ERR("Fork workers failed %i\n", ret);
return -1;
}
diff --git a/example/packet/Makefile.am b/example/packet/Makefile.am
index 603a1ab..da5fc45 100644
--- a/example/packet/Makefile.am
+++ b/example/packet/Makefile.am
@@ -2,5 +2,6 @@ include $(top_srcdir)/example/Makefile.inc
bin_PROGRAMS = odp_pktio
odp_pktio_LDFLAGS = $(AM_LDFLAGS) -static
+odp_pktio_CFLAGS = $(AM_CFLAGS) -I../
dist_odp_pktio_SOURCES = odp_pktio.c
diff --git a/example/packet/odp_pktio.c b/example/packet/odp_pktio.c
index 2cf3f0d..3e08b34 100644
--- a/example/packet/odp_pktio.c
+++ b/example/packet/odp_pktio.c
@@ -15,6 +15,8 @@
#include <getopt.h>
#include <unistd.h>
+#include <example_debug.h>
+
#include <odp.h>
#include <odph_linux.h>
#include <odph_packet.h>
@@ -130,14 +132,14 @@ static void *pktio_queue_thread(void *arg)
/* Lookup the packet pool */
pkt_pool = odp_buffer_pool_lookup("packet_pool");
if (pkt_pool == ODP_BUFFER_POOL_INVALID || pkt_pool != thr_args->pool) {
- ODP_ERR(" [%02i] Error: pkt_pool not found\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: pkt_pool not found\n", thr);
return NULL;
}
/* Open a packet IO instance for this thread */
pktio = odp_pktio_open(thr_args->pktio_dev, pkt_pool);
if (pktio == ODP_PKTIO_INVALID) {
- ODP_ERR(" [%02i] Error: pktio create failed\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: pktio create failed\n", thr);
return NULL;
}
@@ -153,13 +155,14 @@ static void *pktio_queue_thread(void *arg)
inq_def = odp_queue_create(inq_name, ODP_QUEUE_TYPE_PKTIN, &qparam);
if (inq_def == ODP_QUEUE_INVALID) {
- ODP_ERR(" [%02i] Error: pktio queue creation failed\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: pktio queue creation failed\n",
+ thr);
return NULL;
}
ret = odp_pktio_inq_setdef(pktio, inq_def);
if (ret != 0) {
- ODP_ERR(" [%02i] Error: default input-Q setup\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: default input-Q setup\n", thr);
return NULL;
}
@@ -185,7 +188,7 @@ static void *pktio_queue_thread(void *arg)
/* Drop packets with errors */
if (odp_unlikely(drop_err_pkts(&pkt, 1) == 0)) {
- ODP_ERR("Drop frame - err_cnt:%lu\n", ++err_cnt);
+ EXAMPLE_ERR("Drop frame - err_cnt:%lu\n", ++err_cnt);
continue;
}
@@ -193,7 +196,8 @@ static void *pktio_queue_thread(void *arg)
outq_def = odp_pktio_outq_getdef(pktio_tmp);
if (outq_def == ODP_QUEUE_INVALID) {
- ODP_ERR(" [%02i] Error: def output-Q query\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: def output-Q query\n",
+ thr);
return NULL;
}
@@ -239,14 +243,14 @@ static void *pktio_ifburst_thread(void *arg)
/* Lookup the packet pool */
pkt_pool = odp_buffer_pool_lookup("packet_pool");
if (pkt_pool == ODP_BUFFER_POOL_INVALID || pkt_pool != thr_args->pool) {
- ODP_ERR(" [%02i] Error: pkt_pool not found\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: pkt_pool not found\n", thr);
return NULL;
}
/* Open a packet IO instance for this thread */
pktio = odp_pktio_open(thr_args->pktio_dev, pkt_pool);
if (pktio == ODP_PKTIO_INVALID) {
- ODP_ERR(" [%02i] Error: pktio create failed.\n", thr);
+ EXAMPLE_ERR(" [%02i] Error: pktio create failed.\n", thr);
return NULL;
}
@@ -266,8 +270,8 @@ static void *pktio_ifburst_thread(void *arg)
}
if (odp_unlikely(pkts_ok != pkts))
- ODP_ERR("Dropped frames:%u - err_cnt:%lu\n",
- pkts-pkts_ok, ++err_cnt);
+ EXAMPLE_ERR("Dropped frames:%u - err_cnt:%lu\n",
+ pkts-pkts_ok, ++err_cnt);
/* Print packet counts every once in a while */
tmp += pkts_ok;
@@ -300,13 +304,13 @@ int main(int argc, char *argv[])
/* Init ODP before calling anything else */
if (odp_init_global(NULL, NULL)) {
- ODP_ERR("Error: ODP global init failed.\n");
+ EXAMPLE_ERR("Error: ODP global init failed.\n");
exit(EXIT_FAILURE);
}
/* Init this thread */
if (odp_init_local()) {
- ODP_ERR("Error: ODP local init failed.\n");
+ EXAMPLE_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -316,7 +320,7 @@ int main(int argc, char *argv[])
args = odp_shm_addr(shm);
if (args == NULL) {
- ODP_ERR("Error: shared mem alloc failed.\n");
+ EXAMPLE_ERR("Error: shared mem alloc failed.\n");
exit(EXIT_FAILURE);
}
memset(args, 0, sizeof(*args));
@@ -355,7 +359,7 @@ int main(int argc, char *argv[])
pool_base = odp_shm_addr(shm);
if (pool_base == NULL) {
- ODP_ERR("Error: packet pool mem alloc failed.\n");
+ EXAMPLE_ERR("Error: packet pool mem alloc failed.\n");
exit(EXIT_FAILURE);
}
@@ -365,7 +369,7 @@ int main(int argc, char *argv[])
ODP_CACHE_LINE_SIZE,
ODP_BUFFER_TYPE_PACKET);
if (pool == ODP_BUFFER_POOL_INVALID) {
- ODP_ERR("Error: packet pool create failed.\n");
+ EXAMPLE_ERR("Error: packet pool create failed.\n");
exit(EXIT_FAILURE);
}
odp_buffer_pool_print(pool);
diff --git a/example/timer/Makefile.am b/example/timer/Makefile.am
index 6229f13..dffd4eb 100644
--- a/example/timer/Makefile.am
+++ b/example/timer/Makefile.am
@@ -2,5 +2,6 @@ include $(top_srcdir)/example/Makefile.inc
bin_PROGRAMS = odp_timer_test
odp_timer_test_LDFLAGS = $(AM_LDFLAGS) -static
+odp_timer_test_CFLAGS = $(AM_CFLAGS) -I../
dist_odp_timer_test_SOURCES = odp_timer_test.c
diff --git a/example/timer/odp_timer_test.c b/example/timer/odp_timer_test.c
index 78b2ae2..04b4d89 100644
--- a/example/timer/odp_timer_test.c
+++ b/example/timer/odp_timer_test.c
@@ -13,6 +13,8 @@
#include <string.h>
#include <stdlib.h>
+#include <example_debug.h>
+
/* ODP main header */
#include <odp.h>
@@ -55,25 +57,25 @@ static void test_abs_timeouts(int thr, test_args_t *args)
odp_buffer_t buf;
int num;
- ODP_DBG(" [%i] test_timeouts\n", thr);
+ EXAMPLE_DBG(" [%i] test_timeouts\n", thr);
queue = odp_queue_lookup("timer_queue");
period_ns = args->period_us*ODP_TIME_USEC;
period = odp_timer_ns_to_tick(test_timer, period_ns);
- ODP_DBG(" [%i] period %"PRIu64" ticks, %"PRIu64" ns\n", thr,
- period, period_ns);
+ EXAMPLE_DBG(" [%i] period %"PRIu64" ticks, %"PRIu64" ns\n", thr,
+ period, period_ns);
tick = odp_timer_current_tick(test_timer);
- ODP_DBG(" [%i] current tick %"PRIu64"\n", thr, tick);
+ EXAMPLE_DBG(" [%i] current tick %"PRIu64"\n", thr, tick);
tick += period;
if (odp_timer_absolute_tmo(test_timer, tick, queue, ODP_BUFFER_INVALID)
== ODP_TIMER_TMO_INVALID){
- ODP_DBG("Timeout request failed\n");
+ EXAMPLE_DBG("Timeout request failed\n");
return;
}
@@ -87,7 +89,7 @@ static void test_abs_timeouts(int thr, test_args_t *args)
tmo = odp_timeout_from_buffer(buf);
tick = odp_timeout_tick(tmo);
- ODP_DBG(" [%i] timeout, tick %"PRIu64"\n", thr, tick);
+ EXAMPLE_DBG(" [%i] timeout, tick %"PRIu64"\n", thr, tick);
odp_buffer_free(buf);
@@ -131,7 +133,7 @@ static void *run_thread(void *ptr)
msg_pool = odp_buffer_pool_lookup("msg_pool");
if (msg_pool == ODP_BUFFER_POOL_INVALID) {
- ODP_ERR(" [%i] msg_pool not found\n", thr);
+ EXAMPLE_ERR(" [%i] msg_pool not found\n", thr);
return NULL;
}
@@ -319,7 +321,7 @@ int main(int argc, char *argv[])
ODP_BUFFER_TYPE_TIMEOUT);
if (pool == ODP_BUFFER_POOL_INVALID) {
- ODP_ERR("Pool create failed.\n");
+ EXAMPLE_ERR("Pool create failed.\n");
return -1;
}
@@ -334,7 +336,7 @@ int main(int argc, char *argv[])
queue = odp_queue_create("timer_queue", ODP_QUEUE_TYPE_SCHED, ¶m);
if (queue == ODP_QUEUE_INVALID) {
- ODP_ERR("Timer queue create failed.\n");
+ EXAMPLE_ERR("Timer queue create failed.\n");
return -1;
}
@@ -344,7 +346,7 @@ int main(int argc, char *argv[])
args.max_us*ODP_TIME_USEC);
if (test_timer == ODP_TIMER_INVALID) {
- ODP_ERR("Timer create failed.\n");
+ EXAMPLE_ERR("Timer create failed.\n");
return -1;
}
