Code Review
/
deb_dpdk.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Update patchwork link in patches
[deb_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
6c547ca
..
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)
@@
-134,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)
@@
-188,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);