/dports/devel/embb/embb-1.0.0/mtapi_c/src/ |
H A D | embb_mtapi_task_queue_t.c | 42 assert(MTAPI_NULL != that); in embb_mtapi_task_queue_initialize() 44 that->front = MTAPI_NULL; in embb_mtapi_task_queue_initialize() 45 that->back = MTAPI_NULL; in embb_mtapi_task_queue_initialize() 51 that->front = MTAPI_NULL; in embb_mtapi_task_queue_finalize() 52 that->back = MTAPI_NULL; in embb_mtapi_task_queue_finalize() 60 assert(MTAPI_NULL != that); in embb_mtapi_task_queue_pop_front() 67 that->back = MTAPI_NULL; in embb_mtapi_task_queue_pop_front() 83 assert(MTAPI_NULL != that); in embb_mtapi_task_queue_push_back() 86 task->next = MTAPI_NULL; in embb_mtapi_task_queue_push_back() 105 assert(MTAPI_NULL != that); in embb_mtapi_task_queue_push_front() [all …]
|
H A D | embb_mtapi_scheduler_t.c | 54 assert(MTAPI_NULL != that); in embb_mtapi_scheduler_get_private_task_from_context() 70 assert(MTAPI_NULL != that); in embb_mtapi_scheduler_get_public_task_from_context() 84 assert(MTAPI_NULL != that); in embb_mtapi_scheduler_get_next_task_vhpf() 85 assert(MTAPI_NULL != node); in embb_mtapi_scheduler_get_next_task_vhpf() 94 if (MTAPI_NULL == task) { in embb_mtapi_scheduler_get_next_task_vhpf() 127 assert(MTAPI_NULL != that); in embb_mtapi_scheduler_get_next_task_lf() 128 assert(MTAPI_NULL != node); in embb_mtapi_scheduler_get_next_task_lf() 244 if (MTAPI_NULL != queue) { in embb_mtapi_scheduler_finalize_task() 257 if (MTAPI_NULL != group) { in embb_mtapi_scheduler_finalize_task() 614 if (MTAPI_NULL != that) { in embb_mtapi_scheduler_new() [all …]
|
H A D | embb_mtapi_node_t.c | 79 if (MTAPI_NULL != mtapi_info) { in mtapi_initialize() 96 if (MTAPI_NULL != attributes) { in mtapi_initialize() 149 mtapi_finalize(MTAPI_NULL); in mtapi_initialize() 172 if (MTAPI_NULL != node->scheduler) { in mtapi_finalize() 174 node->scheduler = MTAPI_NULL; in mtapi_finalize() 180 node->queue_pool = MTAPI_NULL; in mtapi_finalize() 185 node->task_pool = MTAPI_NULL; in mtapi_finalize() 190 node->group_pool = MTAPI_NULL; in mtapi_finalize() 195 node->action_pool = MTAPI_NULL; in mtapi_finalize() 198 if (MTAPI_NULL != node->job_list) { in mtapi_finalize() [all …]
|
H A D | embb_mtapi_job_t.c | 66 node->job_list = MTAPI_NULL; in embb_mtapi_job_finalize_list() 75 assert(MTAPI_NULL != node); in embb_mtapi_job_is_handle_valid() 85 assert(MTAPI_NULL != node); in embb_mtapi_job_get_storage_for_handle() 94 assert(MTAPI_NULL != node); in embb_mtapi_job_is_id_valid() 102 assert(MTAPI_NULL != node); in embb_mtapi_job_get_storage_for_id() 113 assert(MTAPI_NULL != that); in embb_mtapi_job_initialize() 135 assert(MTAPI_NULL != that); in embb_mtapi_job_finalize() 152 assert(MTAPI_NULL != that); in embb_mtapi_job_add_action() 153 assert(MTAPI_NULL != action); in embb_mtapi_job_add_action() 171 assert(MTAPI_NULL != that); in embb_mtapi_job_remove_action() [all …]
|
H A D | embb_mtapi_task_context_t.c | 47 assert(MTAPI_NULL != that); in embb_mtapi_task_context_initialize_with_thread_context_and_task() 49 assert(MTAPI_NULL != task); in embb_mtapi_task_context_initialize_with_thread_context_and_task() 59 assert(MTAPI_NULL != that); in embb_mtapi_task_context_finalize() 63 that->task = MTAPI_NULL; in embb_mtapi_task_context_finalize() 64 that->thread_context = MTAPI_NULL; in embb_mtapi_task_context_finalize() 78 if (MTAPI_NULL != task_context) { in mtapi_context_status_set() 160 if (MTAPI_NULL != task_context) { in mtapi_context_runtime_notify() 184 if (MTAPI_NULL != task_context) { in mtapi_context_taskstate_get() 213 if (MTAPI_NULL != task_context) { in mtapi_context_instnum_get() 241 if (MTAPI_NULL != task_context) { in mtapi_context_numinst_get() [all …]
|
H A D | embb_mtapi_queue_t.c | 57 assert(MTAPI_NULL != that); in embb_mtapi_pool_implementation() 74 assert(MTAPI_NULL != that); in embb_mtapi_queue_initialize_with_attributes_and_job() 75 assert(MTAPI_NULL != attributes); in embb_mtapi_queue_initialize_with_attributes_and_job() 88 assert(MTAPI_NULL != that); in embb_mtapi_queue_finalize() 101 assert(MTAPI_NULL != that); in embb_mtapi_queue_task_started() 106 assert(MTAPI_NULL != that); in embb_mtapi_queue_task_finished() 127 assert(MTAPI_NULL != queue); in embb_mtapi_queue_delete_visitor() 128 assert(MTAPI_NULL != task); in embb_mtapi_queue_delete_visitor() 148 assert(MTAPI_NULL != queue); in embb_mtapi_queue_disable_visitor() 149 assert(MTAPI_NULL != task); in embb_mtapi_queue_disable_visitor() [all …]
|
H A D | embb_mtapi_thread_context_t.c | 50 assert(MTAPI_NULL != that); in embb_mtapi_thread_context_initialize() 51 assert(MTAPI_NULL != node); in embb_mtapi_thread_context_initialize() 117 assert(MTAPI_NULL != that); in embb_mtapi_thread_context_start() 118 assert(MTAPI_NULL != scheduler); in embb_mtapi_thread_context_start() 174 assert(MTAPI_NULL != that); in embb_mtapi_thread_context_finalize() 191 that->queue[ii] = MTAPI_NULL; in embb_mtapi_thread_context_finalize() 195 that->queue = MTAPI_NULL; in embb_mtapi_thread_context_finalize() 207 that->private_queue = MTAPI_NULL; in embb_mtapi_thread_context_finalize() 216 that->node = MTAPI_NULL; in embb_mtapi_thread_context_finalize() 226 assert(MTAPI_NULL != that); in embb_mtapi_thread_context_process_tasks() [all …]
|
H A D | embb_mtapi_pool_template-inl.h | 44 if (MTAPI_NULL != that) { \ 51 assert(MTAPI_NULL != that); \ 60 assert(MTAPI_NULL != that); \ 78 assert(MTAPI_NULL != that); \ 88 that->storage = MTAPI_NULL; \ 98 return MTAPI_NULL; \ 114 assert(MTAPI_NULL != that); \ 124 assert(MTAPI_NULL != that); \
|
H A D | embb_mtapi_task_t.c | 57 assert(MTAPI_NULL != pool); in embb_mtapi_pool_implementation() 60 if (MTAPI_NULL != that) { in embb_mtapi_pool_implementation() 70 assert(MTAPI_NULL != that); in embb_mtapi_task_delete() 71 assert(MTAPI_NULL != pool); in embb_mtapi_task_delete() 78 assert(MTAPI_NULL != that); in embb_mtapi_task_initialize() 87 that->next = MTAPI_NULL; in embb_mtapi_task_initialize() 93 assert(MTAPI_NULL != that); in embb_mtapi_task_finalize() 102 that->next = MTAPI_NULL; in embb_mtapi_task_finalize() 113 assert(MTAPI_NULL != that); in embb_mtapi_task_execute() 168 assert(MTAPI_NULL != that); in embb_mtapi_task_set_state() [all …]
|
H A D | embb_mtapi_group_t.c | 55 assert(MTAPI_NULL != that); in embb_mtapi_pool_implementation() 64 assert(MTAPI_NULL != that); in embb_mtapi_group_finalize() 89 if (MTAPI_NULL != group) { in mtapi_group_create() 92 if (MTAPI_NULL != attributes) { in mtapi_group_create() 167 if (MTAPI_NULL == attribute) { in mtapi_group_get_attribute() 241 while (MTAPI_NULL != local_task) { in mtapi_group_wait_all() 259 mtapi_group_delete(group, MTAPI_NULL); in mtapi_group_wait_all() 279 void* local_result = MTAPI_NULL; in mtapi_group_wait_any() 316 while (MTAPI_NULL == local_task) { in mtapi_group_wait_any() 343 if (MTAPI_NULL != local_task) { in mtapi_group_wait_any() [all …]
|
H A D | mtapi_task_attributes_t.c | 46 if (MTAPI_NULL != attributes) { in mtapi_taskattr_init() 50 attributes->complete_func = MTAPI_NULL; in mtapi_taskattr_init() 51 attributes->user_data = MTAPI_NULL; in mtapi_taskattr_init() 71 if (MTAPI_NULL != attributes) { in mtapi_taskattr_set() 73 MTAPI_NULL == attribute) { in mtapi_taskattr_set()
|
H A D | embb_mtapi_attr.c | 36 assert(MTAPI_NULL != target); \ 39 assert(MTAPI_NULL != attribute); \ 52 assert(MTAPI_NULL != source); \ 53 assert(MTAPI_NULL != attribute); \
|
H A D | embb_mtapi_action_t.c | 52 assert(MTAPI_NULL != that); in embb_mtapi_pool_implementation() 61 that->plugin_data = MTAPI_NULL; in embb_mtapi_pool_implementation() 66 assert(MTAPI_NULL != that); in embb_mtapi_action_finalize() 79 that->plugin_data = MTAPI_NULL; in embb_mtapi_action_finalize() 88 assert(MTAPI_NULL != action); in embb_mtapi_action_delete_visitor() 89 assert(MTAPI_NULL != task); in embb_mtapi_action_delete_visitor() 108 assert(MTAPI_NULL != action); in embb_mtapi_action_disable_visitor() 109 assert(MTAPI_NULL != task); in embb_mtapi_action_disable_visitor() 145 if (MTAPI_NULL != new_action) { in mtapi_action_create() 158 if (MTAPI_NULL != attributes) { in mtapi_action_create() [all …]
|
H A D | mtapi_queue_attributes_t.c | 46 if (MTAPI_NULL != node) { in mtapi_queueattr_init() 47 if (MTAPI_NULL != attributes) { in mtapi_queueattr_init() 75 if (MTAPI_NULL != attributes) { in mtapi_queueattr_set() 77 MTAPI_NULL == attribute) { in mtapi_queueattr_set()
|
H A D | mtapi_group_attributes_t.c | 44 if (MTAPI_NULL != attributes) { in mtapi_groupattr_init() 66 if (MTAPI_NULL != attributes) { in mtapi_groupattr_set() 68 MTAPI_NULL == attribute) { in mtapi_groupattr_set()
|
H A D | mtapi_action_attributes_t.c | 45 if (MTAPI_NULL != attributes) { in mtapi_actionattr_init() 66 if (MTAPI_NULL != attributes) { in mtapi_actionattr_set() 68 MTAPI_NULL == attribute) { in mtapi_actionattr_set()
|
H A D | mtapi_affinity_t.c | 50 if (MTAPI_NULL != mask) { in mtapi_affinity_init() 77 if (MTAPI_NULL != mask) { in mtapi_affinity_set() 109 if (MTAPI_NULL != mask) { in mtapi_affinity_get()
|
/dports/devel/embb/embb-1.0.0/mtapi_c/test/ |
H A D | embb_mtapi_test_error.cc | 166 0, MTAPI_NULL, 0, &status); in TestNodeNotInit() 333 MTAPI_NULL, 0, &status); in TestLimits() 351 MTAPI_NULL, 0, MTAPI_NULL, 0, in TestLimits() 361 MTAPI_NULL, 0, MTAPI_NULL, 0, in TestLimits() 379 MTAPI_NULL, 0, MTAPI_NULL, 0, in TestLimits() 386 MTAPI_NULL, 0, MTAPI_NULL, 0, in TestLimits() 483 MTAPI_NULL, 0, &status); in TestLimits() 493 MTAPI_NULL, 0, MTAPI_NULL, 0, in TestLimits() 500 MTAPI_NULL, 0, MTAPI_NULL, 0, in TestLimits() 528 MTAPI_NULL, 0, &status); in TestLimits() [all …]
|
H A D | embb_mtapi_test_queue.cc | 51 mtapi_uint_t core_num = mtapi_context_corenum_get(task_context, MTAPI_NULL); in testQueueAction() 95 MTAPI_NULL, 0, in testQueueWaitAction() 130 MTAPI_NULL, 0, MTAPI_DEFAULT_ACTION_ATTRIBUTES, &status); in TrySimple() 149 args_size, MTAPI_NULL, 0, MTAPI_DEFAULT_TASK_ATTRIBUTES, in TrySimple() 186 MTAPI_NULL, 0, MTAPI_DEFAULT_ACTION_ATTRIBUTES, &status); in TryWithWait() 191 MTAPI_NULL, 0, MTAPI_DEFAULT_ACTION_ATTRIBUTES, &status); in TryWithWait() 221 MTAPI_NULL, 0, MTAPI_DEFAULT_TASK_ATTRIBUTES, in TryWithWait()
|
H A D | embb_mtapi_test_task.cc | 143 MTAPI_NULL, in TrySimple() 161 MTAPI_NULL, in TrySimple() 215 MTAPI_NULL, in TryDetached() 239 MTAPI_NULL, in TryDetached() 266 MTAPI_NULL, in TryMultiInstance() 300 MTAPI_NULL, 0, in TryMultiInstance()
|
H A D | embb_mtapi_test_group.cc | 56 mtapi_uint_t core_num = mtapi_context_corenum_get(task_context, MTAPI_NULL); in testGroupAction() 63 if (MTAPI_NULL != result_buffer && in testGroupAction() 112 MTAPI_NULL, 0, MTAPI_DEFAULT_ACTION_ATTRIBUTES, &status); in TestBasic() 141 args_size, MTAPI_NULL, 0, &task_attributes, group, &status); in TestBasic()
|
H A D | embb_mtapi_test_plugin.cc | 204 MTAPI_NULL, in TestBasic() 205 MTAPI_NULL, in TestBasic() 222 MTAPI_NULL, 0, in TestBasic() 223 MTAPI_NULL, 0, in TestBasic()
|
/dports/devel/embb/embb-1.0.0/mtapi_cpp/test/ |
H A D | mtapi_cpp_test_error.cc | 124 node.Start(job, reinterpret_cast<void*>(MTAPI_NULL), in TestLimits() 125 reinterpret_cast<void*>(MTAPI_NULL)); in TestLimits() 138 reinterpret_cast<void*>(MTAPI_NULL)); in TestLimits() 143 node.Start(job, reinterpret_cast<void*>(MTAPI_NULL), in TestLimits() 144 reinterpret_cast<void*>(MTAPI_NULL)); in TestLimits() 194 task = queue.Enqueue(reinterpret_cast<void*>(MTAPI_NULL), in TestLimits() 195 reinterpret_cast<void*>(MTAPI_NULL)); in TestLimits() 200 queue.Enqueue(reinterpret_cast<void*>(MTAPI_NULL), in TestLimits() 201 reinterpret_cast<void*>(MTAPI_NULL)); in TestLimits() 223 queue.Enqueue(reinterpret_cast<void*>(MTAPI_NULL), in TestLimits() [all …]
|
/dports/devel/embb/embb-1.0.0/examples/mtapi/ |
H A D | mtapi_c_plugin.cc | 134 MTAPI_NULL, in RunMTAPI_C_Plugin() 144 MTAPI_NULL, in RunMTAPI_C_Plugin() 145 MTAPI_NULL, in RunMTAPI_C_Plugin() 164 MTAPI_NULL, 0, in RunMTAPI_C_Plugin() 165 MTAPI_NULL, 0, in RunMTAPI_C_Plugin()
|
H A D | mtapi_c.cc | 75 int* result = MTAPI_NULL; in fibonacciActionFunction() 76 if (result_buffer == MTAPI_NULL) { in fibonacciActionFunction() 127 MTAPI_NULL, 0, in fibonacciActionFunction() 178 MTAPI_NULL, /* no shared data */ in fibonacci()
|