@@ -384,7 +384,7 @@ int main(int argc, char *argv[])
}
/* Init this thread */
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_CONTROL)) {
EXAMPLE_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -599,7 +599,7 @@ int main(int argc, char *argv[])
exit(EXIT_FAILURE);
}
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_CONTROL)) {
EXAMPLE_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -1239,7 +1239,7 @@ main(int argc, char *argv[])
}
/* Init this thread */
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_CONTROL)) {
EXAMPLE_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -345,7 +345,7 @@ int main(int argc, char *argv[])
}
/* Init this thread */
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_CONTROL)) {
EXAMPLE_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -355,7 +355,7 @@ int main(int argc, char *argv[])
}
/* Init this thread. */
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_CONTROL)) {
printf("ODP local init failed.\n");
return -1;
}
@@ -58,7 +58,7 @@ static void *odp_run_start_routine(void *arg)
odp_start_args_t *start_args = arg;
/* ODP thread local init */
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_WORKER)) {
ODPH_ERR("Local init failed\n");
return NULL;
}
@@ -203,7 +203,7 @@ int odph_linux_process_fork_n(odph_linux_process_t *proc_tbl,
return -2;
}
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_WORKER)) {
ODPH_ERR("Local init failed\n");
return -2;
}
@@ -126,7 +126,7 @@ int main(int argc TEST_UNUSED, char *argv[] TEST_UNUSED)
exit(EXIT_FAILURE);
}
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_WORKER)) {
LOG_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -33,7 +33,7 @@ int main(int argc TEST_UNUSED, char *argv[] TEST_UNUSED)
exit(EXIT_FAILURE);
}
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_CONTROL)) {
LOG_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -34,7 +34,7 @@ int main(int argc TEST_UNUSED, char *argv[] TEST_UNUSED)
exit(EXIT_FAILURE);
}
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_CONTROL)) {
LOG_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -30,6 +30,7 @@ extern "C" {
#include <odp/std_types.h>
#include <odp/hints.h>
+#include <odp/thread.h>
/** @defgroup odp_initialization ODP INITIALIZATION
* Initialisation operations.
@@ -174,10 +175,12 @@ int odp_term_global(void);
* @sa odp_term_local()
* @sa odp_init_global() which must have been called prior to this.
*
+ * @param thr_type Thread type
+ *
* @retval 0 on success
* @retval <0 on failure
*/
-int odp_init_local(void);
+int odp_init_local(odp_thread_type_t thr_type);
/**
@@ -121,7 +121,7 @@ int odp_term_global(void)
return rc;
}
-int odp_init_local(void)
+int odp_init_local(odp_thread_type_t thr_type ODP_UNUSED)
{
if (odp_shm_init_local()) {
ODP_ERR("ODP shm local init failed.\n");
@@ -367,7 +367,7 @@ int main(int argc, char *argv[])
}
/* Init this thread */
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_CONTROL)) {
LOG_ERR("Error: ODP local init failed.\n");
exit(EXIT_FAILURE);
}
@@ -952,7 +952,7 @@ int main(int argc, char **argv)
if (odp_init_global(NULL, NULL) != 0)
LOG_ABORT("Failed global init.\n");
- if (odp_init_local() != 0)
+ if (odp_init_local(ODP_THREAD_CONTROL) != 0)
LOG_ABORT("Failed local init.\n");
shm = odp_shm_reserve("test_globals",
@@ -860,7 +860,7 @@ int main(int argc, char *argv[])
* Init this thread. It makes also ODP calls when
* setting up resources for worker threads.
*/
- if (odp_init_local()) {
+ if (odp_init_local(ODP_THREAD_CONTROL)) {
LOG_ERR("ODP global init failed.\n");
return -1;
}
@@ -48,7 +48,7 @@ ODP_WEAK_SYMBOL int tests_global_init(void)
fprintf(stderr, "error: odp_init_global() failed.\n");
return -1;
}
- if (0 != odp_init_local()) {
+ if (0 != odp_init_local(ODP_THREAD_CONTROL)) {
fprintf(stderr, "error: odp_init_local() failed.\n");
return -1;
}
@@ -33,7 +33,7 @@ int tests_global_init(void)
fprintf(stderr, "error: odp_init_global() failed.\n");
return -1;
}
- if (0 != odp_init_local()) {
+ if (0 != odp_init_local(ODP_THREAD_CONTROL)) {
fprintf(stderr, "error: odp_init_local() failed.\n");
return -1;
}
@@ -1061,7 +1061,7 @@ int tests_global_init(void)
fprintf(stderr, "error: odp_init_global() failed.\n");
return -1;
}
- if (0 != odp_init_local()) {
+ if (0 != odp_init_local(ODP_THREAD_CONTROL)) {
fprintf(stderr, "error: odp_init_local() failed.\n");
return -1;
}