bus/pci: use SPDX tags in 6WIND copyrighted files

[dpdk.git] / examples / ip_pipeline / thread_fe.c

diff --git a/examples/ip_pipeline/thread_fe.c b/examples/ip_pipeline/thread_fe.c
index d1b72b4..4590c2b 100644 (file)
--- a/examples/ip_pipeline/thread_fe.c
+++ b/examples/ip_pipeline/thread_fe.c
@@ -70,8 +70,7 @@ app_pipeline_enable(struct app_params *app,
                        core_id,
                        hyper_th_id);
 
-       if ((thread_id < 0) ||
-               ((app->core_mask & (1LLU << thread_id)) == 0))
+       if ((thread_id < 0) || !app_core_is_enabled(app, thread_id))
                return -1;
 
        if (app_pipeline_data(app, pipeline_id) == NULL)
@@ -81,6 +80,9 @@ app_pipeline_enable(struct app_params *app,
        p_params = &app->pipeline_params[pipeline_id];
        p_type = app_pipeline_type_find(app, p_params->type);
 
+       if (p_type == NULL)
+               return -1;
+
        if (p->enabled == 1)
                return -1;
 
@@ -131,8 +133,7 @@ app_pipeline_disable(struct app_params *app,
                        core_id,
                        hyper_th_id);
 
-       if ((thread_id < 0) ||
-               ((app->core_mask & (1LLU << thread_id)) == 0))
+       if ((thread_id < 0) || !app_core_is_enabled(app, thread_id))
                return -1;
 
        if (app_pipeline_data(app, pipeline_id) == NULL)
@@ -185,8 +186,7 @@ app_thread_headroom(struct app_params *app,
                        core_id,
                        hyper_th_id);
 
-       if ((thread_id < 0) ||
-               ((app->core_mask & (1LLU << thread_id)) == 0))
+       if ((thread_id < 0) || !app_core_is_enabled(app, thread_id))
                return -1;
 
        req = app_msg_alloc(app);