Index: lib/libthr/thread/thr_setschedparam.c =================================================================== --- lib/libthr/thread/thr_setschedparam.c (revision 238413) +++ lib/libthr/thread/thr_setschedparam.c (working copy) @@ -53,42 +53,25 @@ struct pthread *curthread = _get_curthread(); int ret; - if (pthread == curthread) { + if (pthread == curthread) THR_LOCK(curthread); - if (curthread->attr.sched_policy == policy && - (policy == SCHED_OTHER || - curthread->attr.prio == param->sched_priority)) { - pthread->attr.prio = param->sched_priority; - THR_UNLOCK(curthread); - return (0); - } - ret = _thr_setscheduler(curthread->tid, policy, param); - if (ret == -1) - ret = errno; - else { - curthread->attr.sched_policy = policy; - curthread->attr.prio = param->sched_priority; - } - THR_UNLOCK(curthread); - } else if ((ret = _thr_ref_add(curthread, pthread, /*include dead*/0)) - == 0) { - THR_THREAD_LOCK(curthread, pthread); - if (pthread->attr.sched_policy == policy && - (policy == SCHED_OTHER || - pthread->attr.prio == param->sched_priority)) { - pthread->attr.prio = param->sched_priority; - THR_THREAD_UNLOCK(curthread, pthread); - return (0); - } - ret = _thr_setscheduler(pthread->tid, policy, param); - if (ret == -1) - ret = errno; - else { - pthread->attr.sched_policy = policy; - pthread->attr.prio = param->sched_priority; - } + else if ((ret = _thr_find_thread(curthread, pthread, + /*include dead*/0)) != 0) + return (ret); + if (pthread->attr.sched_policy == policy && + (policy == SCHED_OTHER || + pthread->attr.prio == param->sched_priority)) { + pthread->attr.prio = param->sched_priority; THR_THREAD_UNLOCK(curthread, pthread); - _thr_ref_delete(curthread, pthread); + return (0); } + ret = _thr_setscheduler(pthread->tid, policy, param); + if (ret == -1) + ret = errno; + else { + pthread->attr.sched_policy = policy; + pthread->attr.prio = param->sched_priority; + } + THR_THREAD_UNLOCK(curthread, pthread); return (ret); } Property changes on: lib/libthr/thread/thr_setschedparam.c ___________________________________________________________________ Added: svn:mergeinfo Merged /head/lib/libthr/thread/thr_setschedparam.c:r226702,227006,227604,228536,230430,231106,231503,231619,231906,233103,233516,233912,234424,236135,238637,238640,238642 Merged /vendor/resolver/dist/lib/libthr/thread/thr_setschedparam.c:r1540-186085 Merged /projects/largeSMP/lib/libthr/thread/thr_setschedparam.c:r221273-222812,222815-223757 Merged /projects/quota64/lib/libthr/thread/thr_setschedparam.c:r184125-207707 Index: lib/libthr/thread/thr_setprio.c =================================================================== --- lib/libthr/thread/thr_setprio.c (revision 238413) +++ lib/libthr/thread/thr_setprio.c (working copy) @@ -45,38 +45,22 @@ int ret; param.sched_priority = prio; - if (pthread == curthread) { + if (pthread == curthread) THR_LOCK(curthread); - if (curthread->attr.sched_policy == SCHED_OTHER || - curthread->attr.prio == prio) { - curthread->attr.prio = prio; - ret = 0; - } else { - ret = _thr_setscheduler(curthread->tid, - curthread->attr.sched_policy, ¶m); - if (ret == -1) - ret = errno; - else - curthread->attr.prio = prio; - } - THR_UNLOCK(curthread); - } else if ((ret = _thr_ref_add(curthread, pthread, /*include dead*/0)) - == 0) { - THR_THREAD_LOCK(curthread, pthread); - if (pthread->attr.sched_policy == SCHED_OTHER || - pthread->attr.prio == prio) { + else if ((ret = _thr_find_thread(curthread, pthread, /*include dead*/0))) + return (ret); + if (pthread->attr.sched_policy == SCHED_OTHER || + pthread->attr.prio == prio) { + pthread->attr.prio = prio; + ret = 0; + } else { + ret = _thr_setscheduler(pthread->tid, + pthread->attr.sched_policy, ¶m); + if (ret == -1) + ret = errno; + else pthread->attr.prio = prio; - ret = 0; - } else { - ret = _thr_setscheduler(pthread->tid, - curthread->attr.sched_policy, ¶m); - if (ret == -1) - ret = errno; - else - pthread->attr.prio = prio; - } - THR_THREAD_UNLOCK(curthread, pthread); - _thr_ref_delete(curthread, pthread); } + THR_THREAD_UNLOCK(curthread, pthread); return (ret); } Property changes on: lib/libthr/thread/thr_setprio.c ___________________________________________________________________ Added: svn:mergeinfo Merged /projects/quota64/lib/libthr/thread/thr_setprio.c:r184125-207707 Merged /head/lib/libthr/thread/thr_setprio.c:r226702,227006,227604,228536,230430,231106,231503,231619,231906,233103,233516,233912,234424,236135,238641-238642 Merged /vendor/resolver/dist/lib/libthr/thread/thr_setprio.c:r1540-186085 Merged /projects/largeSMP/lib/libthr/thread/thr_setprio.c:r221273-222812,222815-223757