[lng-odp] [PATCH 2/4] example: ipsef_offload: port to odpthreads helpers

[Dmitry Eremin-Solenikov]

Switch from old linux-pthread API to odpthread.

Signed-off-by: Dmitry Eremin-Solenikov <dmitry.ereminsoleni...@linaro.org>
---
 example/ipsec_offload/odp_ipsec_offload.c | 21 +++++++++++----------
 1 file changed, 11 insertions(+), 10 deletions(-)

diff --git a/example/ipsec_offload/odp_ipsec_offload.c 
b/example/ipsec_offload/odp_ipsec_offload.c
index 4a494d07..001e7038 100644
--- a/example/ipsec_offload/odp_ipsec_offload.c
+++ b/example/ipsec_offload/odp_ipsec_offload.c
@@ -22,7 +22,7 @@
 #include <example_debug.h>
 
 #include <odp_api.h>
-#include <odp/helper/linux.h>
+#include <odp/helper/threads.h>
 #include <odp/helper/eth.h>
 #include <odp/helper/ip.h>
 #include <odp/helper/icmp.h>
@@ -30,6 +30,7 @@
 #include <odp/helper/ipsec.h>
 
 #include <stdbool.h>
+#include <inttypes.h>
 #include <sys/socket.h>
 #include <net/if.h>
 #include <sys/ioctl.h>
@@ -414,12 +415,12 @@ pkt_disposition_e do_ipsec_in_classify(odp_packet_t pkt)
  *  - Input interfaces (i.e. new work)
  *  - Per packet ipsec API completion queue
  *
- * @param arg  Required by "odph_linux_pthread_create", unused
+ * @param arg  Required by "odph_odpthreads_create", unused
  *
- * @return NULL (should never return)
+ * @return 0 (should never return)
  */
 static
-void *pktio_thread(void *arg EXAMPLE_UNUSED)
+int pktio_thread(void *arg EXAMPLE_UNUSED)
 {
        int thr;
        odp_packet_t pkt;
@@ -490,7 +491,7 @@ void *pktio_thread(void *arg EXAMPLE_UNUSED)
                        out_port = (odp_out_entry_t 
*)odp_packet_user_ptr(out_pkt);
                        out_queue = (odp_pktout_queue_t)out_port->pktout;
 
-                       eth = (odph_ethhdr_t *)((void *)ip - 
sizeof(odph_ethhdr_t));
+                       eth = (odph_ethhdr_t *)((uint8_t *)ip - 
sizeof(odph_ethhdr_t));
                        eth->dst = out_port->next_hop_addr;
                        eth->src = out_port->addr;
                        eth->type = odp_cpu_to_be_16(0x800);
@@ -505,7 +506,7 @@ void *pktio_thread(void *arg EXAMPLE_UNUSED)
        }
 
        /* unreachable */
-       return NULL;
+       return 0;
 }
 
 /**
@@ -514,7 +515,7 @@ void *pktio_thread(void *arg EXAMPLE_UNUSED)
 int
 main(int argc, char *argv[])
 {
-       odph_linux_pthread_t thread_tbl[MAX_WORKERS];
+       odph_odpthread_t thread_tbl[MAX_WORKERS];
        int i;
        odp_shm_t shm;
        odp_cpumask_t cpumask;
@@ -522,7 +523,7 @@ main(int argc, char *argv[])
        odp_pool_param_t params;
        odp_queue_param_t qparam;
        odp_instance_t instance;
-       odph_linux_thr_params_t thr_params;
+       odph_odpthread_params_t thr_params;
        odp_ipsec_config_t config;
        odp_ipsec_capability_t capa;
 
@@ -642,9 +643,9 @@ main(int argc, char *argv[])
        thr_params.instance = instance;
 
        /* Create and initialize worker threads */
-       odph_linux_pthread_create(thread_tbl, &cpumask,
+       odph_odpthreads_create(thread_tbl, &cpumask,
                                          &thr_params);
-       odph_linux_pthread_join(thread_tbl, num_workers);
+       odph_odpthreads_join(thread_tbl);
 
        free(args->appl.if_names);
        free(args->appl.if_str);
-- 
2.11.0