Lines Matching defs:t
84 return (EBUSY); /* don't remove RT for now */
331 * values. The rt_globpri member is read-only so we don't
355 rt_enterclass(kthread_t *t, id_t cid, void *parmsp, cred_t *reqpcredp,
366 * hasn't and we check it here.
410 rtpp->rt_tp = t;
414 thread_lock(t);
415 t->t_clfuncs = &(sclass[cid].cl_funcs->thread);
416 t->t_cid = cid;
417 t->t_cldata = (void *)rtpp;
418 t->t_schedflag &= ~TS_RUNQMATCH;
419 rt_change_priority(t, rtpp);
420 thread_unlock(t);
456 rt_fork(kthread_t *t, kthread_t *ct, void *bufp)
461 ASSERT(MUTEX_HELD(&ttoproc(t)->p_lock));
468 prtpp = (rtproc_t *)t->t_cldata;
469 thread_lock(t);
476 thread_unlock(t);
498 rt_forkret(kthread_t *t, kthread_t *ct)
500 proc_t *pp = ttoproc(t);
503 ASSERT(t == curthread);
555 rt_canexit(kthread_t *t, cred_t *cred)
568 rt_parmsget(kthread_t *t, void *parmsp)
570 rtproc_t *rtprocp = (rtproc_t *)t->t_cldata;
868 * passes us a credential structure we assume it hasn't and
902 rt_preempt(kthread_t *t)
904 rtproc_t *rtpp = (rtproc_t *)(t->t_cldata);
907 ASSERT(THREAD_LOCK_HELD(t));
910 * If the state is user I allow swapping because I know I won't
914 t->t_schedflag &= ~TS_DONT_SWAP;
918 setbackdq(t);
920 setfrontdq(t);
928 rt_globpri(kthread_t *t)
930 rtproc_t *rtprocp = (rtproc_t *)t->t_cldata;
935 rt_setrun(kthread_t *t)
937 rtproc_t *rtpp = (rtproc_t *)(t->t_cldata);
939 ASSERT(THREAD_LOCK_HELD(t));
943 setbackdq(t);
950 * FX and RT threads are designed so that they don't swapout; however, it
959 rt_swapin(kthread_t *t, int flags)
963 ASSERT(THREAD_LOCK_HELD(t));
965 if (t->t_state == TS_RUN && (t->t_schedflag & TS_LOAD) == 0) {
977 rt_swapout(kthread_t *t, int flags)
979 ASSERT(THREAD_LOCK_HELD(t));
990 rt_tick(kthread_t *t)
992 rtproc_t *rtpp = (rtproc_t *)(t->t_cldata);
994 ASSERT(MUTEX_HELD(&(ttoproc(t))->p_lock));
996 thread_lock(t);
998 (t->t_state == TS_ONPROC && DISP_MUST_SURRENDER(t))) {
1000 thread_unlock(t);
1001 sigtoproc(ttoproc(t), t, rtpp->rt_tqsignal);
1002 thread_lock(t);
1005 cpu_surrender(t);
1007 thread_unlock(t);
1015 rt_wakeup(kthread_t *t)
1017 rtproc_t *rtpp = (rtproc_t *)(t->t_cldata);
1019 ASSERT(THREAD_LOCK_HELD(t));
1023 setbackdq(t);
1027 rt_yield(kthread_t *t)
1029 rtproc_t *rtpp = (rtproc_t *)(t->t_cldata);
1031 ASSERT(t == curthread);
1032 ASSERT(THREAD_LOCK_HELD(t));
1035 setbackdq(t);
1040 rt_donice(kthread_t *t, cred_t *cr, int incr, int *retvalp)
1050 rt_doprio(kthread_t *t, cred_t *cr, int incr, int *retvalp)
1053 rtproc_t *rtpp = (rtproc_t *)(t->t_cldata);
1071 return (rt_parmsset(t, &rtkparms, rt_cid, cr));
1095 rt_change_priority(kthread_t *t, rtproc_t *rtpp)
1099 ASSERT(THREAD_LOCK_HELD(t));
1103 t->t_cpri = rtpp->rt_pri;
1104 if (t == curthread || t->t_state == TS_ONPROC) {
1105 cpu_t *cp = t->t_disp_queue->disp_cpu;
1106 THREAD_CHANGE_PRI(t, new_pri);
1107 if (t == cp->cpu_dispthread)
1108 cp->cpu_dispatch_pri = DISP_PRIO(t);
1109 if (DISP_MUST_SURRENDER(t)) {
1111 cpu_surrender(t);
1122 if (thread_change_pri(t, new_pri, 0)) {