git.droids-corp.org
/
dpdk.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
event/sw: use dynamically-sized IQs
[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);
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)
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);
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;
if (p->enabled == 1)
return -1;
@@
-131,8
+133,7
@@
app_pipeline_disable(struct app_params *app,
core_id,
hyper_th_id);
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)
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);
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);
return -1;
req = app_msg_alloc(app);