Lines Matching refs:rtask
615 uint8_t rtask;
620 rtask = GKI_get_taskid();
621 GKI_TRACE_3("GKI_wait %d %x %d", rtask, flag, timeout);
622 if (rtask >= GKI_MAX_TASKS) {
627 gki_pthread_info_t* p_pthread_info = &gki_pthread_info[rtask];
630 GKI_TRACE_3("GKI_wait task=%i, pCond/pMutex = %x/%x", rtask,
638 gki_cb.com.OSWaitForEvt[rtask] = flag;
640 /* protect OSWaitEvt[rtask] from modification from an other thread */
641 pthread_mutex_lock(&gki_cb.os.thread_evt_mutex[rtask]);
645 /* Check if anything in any of the mailboxes. There is a potential race condition where OSTaskQFirst[rtask]
648 if (gki_cb.com.OSTaskQFirst[rtask][0])
649 gki_cb.com.OSWaitEvt[rtask] |= TASK_MBOX_0_EVT_MASK;
650 if (gki_cb.com.OSTaskQFirst[rtask][1])
651 gki_cb.com.OSWaitEvt[rtask] |= TASK_MBOX_1_EVT_MASK;
652 if (gki_cb.com.OSTaskQFirst[rtask][2])
653 gki_cb.com.OSWaitEvt[rtask] |= TASK_MBOX_2_EVT_MASK;
654 if (gki_cb.com.OSTaskQFirst[rtask][3])
655 gki_cb.com.OSWaitEvt[rtask] |= TASK_MBOX_3_EVT_MASK;
658 if (!(gki_cb.com.OSWaitEvt[rtask] & flag)) {
680 pthread_cond_timedwait(&gki_cb.os.thread_evt_cond[rtask],
681 &gki_cb.os.thread_evt_mutex[rtask], &abstime);
684 pthread_cond_wait(&gki_cb.os.thread_evt_cond[rtask],
685 &gki_cb.os.thread_evt_mutex[rtask]);
696 if (gki_cb.com.OSTaskQFirst[rtask][0])
697 gki_cb.com.OSWaitEvt[rtask] |= TASK_MBOX_0_EVT_MASK;
698 if (gki_cb.com.OSTaskQFirst[rtask][1])
699 gki_cb.com.OSWaitEvt[rtask] |= TASK_MBOX_1_EVT_MASK;
700 if (gki_cb.com.OSTaskQFirst[rtask][2])
701 gki_cb.com.OSWaitEvt[rtask] |= TASK_MBOX_2_EVT_MASK;
702 if (gki_cb.com.OSTaskQFirst[rtask][3])
703 gki_cb.com.OSWaitEvt[rtask] |= TASK_MBOX_3_EVT_MASK;
705 if (gki_cb.com.OSRdyTbl[rtask] == TASK_DEAD) {
706 gki_cb.com.OSWaitEvt[rtask] = 0;
709 pthread_mutex_unlock(&gki_cb.os.thread_evt_mutex[rtask]);
710 GKI_TRACE_1("GKI TASK_DEAD received. exit thread %d...", rtask);
712 gki_cb.os.thread_id[rtask] = 0;
719 gki_cb.com.OSWaitForEvt[rtask] = 0;
722 evt = gki_cb.com.OSWaitEvt[rtask] & flag;
725 gki_cb.com.OSWaitEvt[rtask] &= ~flag;
729 pthread_mutex_unlock(&gki_cb.os.thread_evt_mutex[rtask]);
730 GKI_TRACE_4("GKI_wait %d %x %d %x resumed", rtask, flag, timeout, evt);
750 uint8_t rtask = GKI_get_taskid();
754 GKI_TRACE_2("GKI_delay %d %d", rtask, timeout);
770 if (rtask && gki_cb.com.OSRdyTbl[rtask] == TASK_DEAD) {
773 GKI_TRACE_2("GKI_delay %d %d done", rtask, timeout);
