diff --git a/mtapi_c/src/embb_mtapi_node_t.c b/mtapi_c/src/embb_mtapi_node_t.c index e695c36..a47a2fa 100644 --- a/mtapi_c/src/embb_mtapi_node_t.c +++ b/mtapi_c/src/embb_mtapi_node_t.c @@ -130,7 +130,7 @@ void mtapi_initialize( } #ifdef EMBB_HARD_REALTIME - embb_mtapi_task_queue_initialize_with_capacity( + embb_mtapi_priority_queue_initialize_with_capacity( &node->global_task_queue, node->attributes.max_tasks); #endif @@ -210,7 +210,7 @@ void mtapi_finalize(MTAPI_OUT mtapi_status_t* status) { embb_atomic_destroy_int(&node->is_scheduler_running); #ifdef EMBB_HARD_REALTIME - embb_mtapi_task_queue_finalize(&node->global_task_queue); + embb_mtapi_priority_queue_finalize(&node->global_task_queue); #endif /* free system instance */ diff --git a/mtapi_c/src/embb_mtapi_node_t.h b/mtapi_c/src/embb_mtapi_node_t.h index ba2f3e8..604eeb7 100644 --- a/mtapi_c/src/embb_mtapi_node_t.h +++ b/mtapi_c/src/embb_mtapi_node_t.h @@ -33,7 +33,7 @@ #include #ifdef EMBB_HARD_REALTIME -#include +#include #endif /*EMBB_HARD_REALTIME*/ #ifdef __cplusplus @@ -76,7 +76,7 @@ struct embb_mtapi_node_struct { embb_atomic_int is_scheduler_running; mtapi_affinity_t affinity_all; #ifdef EMBB_HARD_REALTIME - embb_mtapi_task_queue_t global_task_queue; + embb_mtapi_priority_queue_t global_task_queue; #endif /*EMBB_HARD_REALTIME*/ }; diff --git a/mtapi_c/src/embb_mtapi_scheduler_t.c b/mtapi_c/src/embb_mtapi_scheduler_t.c index 1bdeddf..2232e7d 100644 --- a/mtapi_c/src/embb_mtapi_scheduler_t.c +++ b/mtapi_c/src/embb_mtapi_scheduler_t.c @@ -38,7 +38,7 @@ #include #include #ifdef EMBB_HARD_REALTIME -#include +#include #endif /*EMBB_HARD_REALTIME*/ #include #include @@ -181,7 +181,7 @@ embb_mtapi_task_t * embb_mtapi_scheduler_get_next_task_gedf( assert(MTAPI_NULL != that); assert(MTAPI_NULL != node); - task = embb_mtapi_task_queue_pop(&node->global_task_queue); + task = embb_mtapi_priority_queue_pop(&node->global_task_queue); return task; } @@ -669,7 +669,7 @@ mtapi_boolean_t embb_mtapi_scheduler_schedule_task( /* one more task in flight for this action */ embb_atomic_fetch_and_add_int(&local_action->num_tasks, 1); - pushed = embb_mtapi_task_queue_push(&node->global_task_queue, task); + pushed = embb_mtapi_priority_queue_push(&node->global_task_queue, task); if (!pushed) { embb_atomic_fetch_and_add_int(&local_action->num_tasks, -1); }