Lines Matching defs:task_id
104 UINT8 task_id; /* GKI task id */
146 gki_cb.os.thread_id[p_pthread_info->task_id] = pthread_self();
148 prctl(PR_SET_NAME, (unsigned long)gki_cb.com.OSTName[p_pthread_info->task_id], 0, 0, 0);
150 GKI_INFO("gki_task_entry task_id=%i [%s] starting\n", p_pthread_info->task_id,
151 gki_cb.com.OSTName[p_pthread_info->task_id]);
156 GKI_INFO("gki_task task_id=%i [%s] terminating\n", p_pthread_info->task_id,
157 gki_cb.com.OSTName[p_pthread_info->task_id]);
231 ** task_id - (input) Task id is mapped to priority
243 UINT8 GKI_create_task (TASKPTR task_entry, UINT8 task_id, INT8 *taskname, UINT16 *stack, UINT16 stacksize)
251 GKI_TRACE( "GKI_create_task %x %d %s %x %d", (int)task_entry, (int)task_id,
254 if (task_id >= GKI_MAX_TASKS)
261 gki_cb.com.OSRdyTbl[task_id] = TASK_READY;
262 gki_cb.com.OSTName[task_id] = taskname;
263 gki_cb.com.OSWaitTmr[task_id] = 0;
264 gki_cb.com.OSWaitEvt[task_id] = 0;
267 pthread_mutex_init(&gki_cb.os.thread_evt_mutex[task_id], NULL);
268 pthread_cond_init (&gki_cb.os.thread_evt_cond[task_id], NULL);
269 pthread_mutex_init(&gki_cb.os.thread_timeout_mutex[task_id], NULL);
270 pthread_cond_init (&gki_cb.os.thread_timeout_cond[task_id], NULL);
277 GKI_TRACE("GKI creating task %i\n", task_id);
279 GKI_TRACE("GKI creating JOINABLE task %i\n", task_id);
282 /* On Android, the new tasks starts running before 'gki_cb.os.thread_id[task_id]' is initialized */
283 /* Pass task_id to new task so it can initialize gki_cb.os.thread_id[task_id] for it calls GKI_wait */
284 gki_pthread_info[task_id].task_id = task_id;
285 gki_pthread_info[task_id].task_entry = task_entry;
286 gki_pthread_info[task_id].params = 0;
288 ret = pthread_create( &gki_cb.os.thread_id[task_id],
291 &gki_pthread_info[task_id]);
299 if(pthread_getschedparam(gki_cb.os.thread_id[task_id], &policy, ¶m)==0)
303 if (task_id == PBS_SQL_TASK)
315 param.sched_priority = GKI_LINUX_BASE_PRIORITY - task_id - 2;
318 pthread_setschedparam(gki_cb.os.thread_id[task_id], policy, ¶m);
323 (int)task_id,
324 (int)gki_cb.os.thread_id[task_id],
332 void GKI_destroy_task(UINT8 task_id)
339 if (gki_cb.com.OSRdyTbl[task_id] != TASK_DEAD)
341 gki_cb.com.OSRdyTbl[task_id] = TASK_DEAD;
344 gki_cb.com.OSWaitEvt[task_id] &= ~(TASK_MBOX_0_EVT_MASK|TASK_MBOX_1_EVT_MASK|
348 gki_cb.com.OSTaskTmr0R[task_id] = 0;
349 gki_cb.com.OSTaskTmr0 [task_id] = 0;
353 gki_cb.com.OSTaskTmr1R[task_id] = 0;
354 gki_cb.com.OSTaskTmr1 [task_id] = 0;
358 gki_cb.com.OSTaskTmr2R[task_id] = 0;
359 gki_cb.com.OSTaskTmr2 [task_id] = 0;
363 gki_cb.com.OSTaskTmr3R[task_id] = 0;
364 gki_cb.com.OSTaskTmr3 [task_id] = 0;
367 GKI_send_event(task_id, EVENT_MASK(GKI_SHUTDOWN_EVT));
372 while ((gki_cb.com.OSWaitEvt[task_id] != 0) && (++i < 10))
375 result = pthread_join( gki_cb.os.thread_id[task_id], NULL );
381 GKI_exit_task(task_id);
382 GKI_INFO( "GKI_shutdown(): task [%s] terminated\n", gki_cb.com.OSTName[task_id]);
397 ** Parameters: task_id - (input) Task id is used for sanity check to
404 void GKI_task_self_cleanup(UINT8 task_id)
408 if (task_id != my_task_id)
411 __FUNCTION__, my_task_id, task_id);
415 if (gki_cb.com.OSRdyTbl[task_id] != TASK_DEAD)
418 gki_cb.com.OSWaitEvt[task_id] &= ~(TASK_MBOX_0_EVT_MASK|TASK_MBOX_1_EVT_MASK|
422 gki_cb.com.OSTaskTmr0R[task_id] = 0;
423 gki_cb.com.OSTaskTmr0 [task_id] = 0;
427 gki_cb.com.OSTaskTmr1R[task_id] = 0;
428 gki_cb.com.OSTaskTmr1 [task_id] = 0;
432 gki_cb.com.OSTaskTmr2R[task_id] = 0;
433 gki_cb.com.OSTaskTmr2 [task_id] = 0;
437 gki_cb.com.OSTaskTmr3R[task_id] = 0;
438 gki_cb.com.OSTaskTmr3 [task_id] = 0;
441 GKI_exit_task(task_id);
447 pthread_detach(gki_cb.os.thread_id[task_id]);
466 UINT8 task_id;
479 for (task_id = GKI_MAX_TASKS; task_id > 0; task_id--)
481 if (gki_cb.com.OSRdyTbl[task_id - 1] != TASK_DEAD)
483 gki_cb.com.OSRdyTbl[task_id - 1] = TASK_DEAD;
486 gki_cb.com.OSWaitEvt[task_id-1] &= ~(TASK_MBOX_0_EVT_MASK|TASK_MBOX_1_EVT_MASK|
488 GKI_send_event(task_id - 1, EVENT_MASK(GKI_SHUTDOWN_EVT));
493 while ((gki_cb.com.OSWaitEvt[task_id - 1] != 0) && (++i < 10))
496 result = pthread_join( gki_cb.os.thread_id[task_id-1], NULL );
503 // GKI_ERROR_LOG( "GKI_shutdown(): task %s dead\n", gki_cb.com.OSTName[task_id]);
504 GKI_exit_task(task_id - 1);
875 UINT8 task_id;
880 for(task_id = 0; task_id<GKI_MAX_TASKS; task_id++)
882 if(gki_cb.com.OSRdyTbl[task_id] != TASK_DEAD)
884 GKI_exit_task(task_id);
1044 ** Parameters: task_id - (input) The id of the task to which the event has to
1053 UINT8 GKI_send_event (UINT8 task_id, UINT16 event)
1055 GKI_TRACE("GKI_send_event %d %x", task_id, event);
1058 if (task_id < GKI_MAX_TASKS)
1060 /* protect OSWaitEvt[task_id] from manipulation in GKI_wait() */
1061 pthread_mutex_lock(&gki_cb.os.thread_evt_mutex[task_id]);
1064 gki_cb.com.OSWaitEvt[task_id] |= event;
1066 pthread_cond_signal(&gki_cb.os.thread_evt_cond[task_id]);
1068 pthread_mutex_unlock(&gki_cb.os.thread_evt_mutex[task_id]);
1070 GKI_TRACE("GKI_send_event %d %x done", task_id, event);
1086 ** Parameters: task_id - (input) The destination task Id for the event.
1097 UINT8 GKI_isend_event (UINT8 task_id, UINT16 event)
1099 GKI_TRACE("GKI_isend_event %d %x", task_id, event);
1100 GKI_TRACE("GKI_isend_event %d %x done", task_id, event);
1101 return GKI_send_event(task_id, event);
1148 ** Parameters: task_id - (input) The id of the task whose name is being
1158 INT8 *GKI_map_taskname (UINT8 task_id)
1160 GKI_TRACE("GKI_map_taskname %d", task_id);
1162 if (task_id < GKI_MAX_TASKS)
1164 GKI_TRACE("GKI_map_taskname %d %s done", task_id, gki_cb.com.OSTName[task_id]);
1165 return (gki_cb.com.OSTName[task_id]);
1167 else if (task_id == GKI_MAX_TASKS )
1233 UINT8 task_id;
1238 for(task_id = 0; task_id < GKI_MAX_TASKS; task_id++)
1241 task_id,
1242 gki_cb.com.OSTName[task_id],
1243 gki_cb.com.OSRdyTbl[task_id]);
1394 ** Parameters: task_id - (input) the id of the task that has to suspended
1403 UINT8 GKI_suspend_task (UINT8 task_id)
1405 GKI_TRACE("GKI_suspend_task %d - NOT implemented", task_id);
1408 GKI_TRACE("GKI_suspend_task %d done", task_id);
1420 ** Parameters: task_id - (input) the id of the task that has to resumed
1429 UINT8 GKI_resume_task (UINT8 task_id)
1431 GKI_TRACE("GKI_resume_task %d - NOT implemented", task_id);
1434 GKI_TRACE("GKI_resume_task %d done", task_id);
1446 ** Parameters: task_id - (input) the id of the task that has to be stopped
1455 void GKI_exit_task (UINT8 task_id)
1458 gki_cb.com.OSRdyTbl[task_id] = TASK_DEAD;
1461 pthread_mutex_destroy(&gki_cb.os.thread_evt_mutex[task_id]);
1462 pthread_cond_destroy (&gki_cb.os.thread_evt_cond[task_id]);
1463 pthread_mutex_destroy(&gki_cb.os.thread_timeout_mutex[task_id]);
1464 pthread_cond_destroy (&gki_cb.os.thread_timeout_cond[task_id]);
1468 //GKI_send_event(task_id, EVENT_MASK(GKI_SHUTDOWN_EVT));
1470 GKI_INFO("GKI_exit_task %d done", task_id);
