d/freebsd-dev
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Make various posix4 system calls MPSAFE (will fixup syscalls.master later)

Browse Source 
sched_setparam()
    sched_getparam()
    sched_setscheduler()
    sched_getscheduler()
    sched_yield()
    sched_get_priority_max()
    sched_get_priority_min()
    sched_rr_get_interval()
This commit is contained in:
Matthew Dillon 2001-08-31 22:34:40 +00:00
parent 0cf9956f3f
commit 2afac34da3
Notes: svn2git 2020-12-20 02:59:44 +00:00 
svn path=/head/; revision=82701
2 changed files with 190 additions and 84 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

137
sys/kern/p1003_1b.c
View File

@ -102,36 +102,46 @@ static int sched_attach(void)
return ret;
}
/*
* MPSAFE
*/
int sched_setparam(struct proc *p,
struct sched_setparam_args *uap)
{
struct proc *targetp;
int e;
struct sched_param sched_param;
e = copyin(uap->param, &sched_param, sizeof(sched_param));
if (e)
return (e);
mtx_lock(&Giant);
if (uap->pid == 0) {
targetp = p;
PROC_LOCK(targetp);
} else {
targetp = pfind(uap->pid);
if (targetp == NULL)
return (ESRCH);
if (targetp == NULL) {
e = ESRCH;
goto done2;
}
}
e = p_cansched(p, targetp);
PROC_UNLOCK(targetp);
if (e)
return (e);
e = ksched_setparam(&p->p_retval[0], ksched, targetp,
(const struct sched_param *)&sched_param);
if (e == 0) {
e = ksched_setparam(&p->p_retval[0], ksched, targetp,
(const struct sched_param *)&sched_param);
}
done2:
mtx_unlock(&Giant);
return (e);
}
/*
* MPSAFE
*/
int sched_getparam(struct proc *p,
struct sched_getparam_args *uap)
{
@ -139,27 +149,33 @@ int sched_getparam(struct proc *p,
struct sched_param sched_param;
struct proc *targetp;
mtx_lock(&Giant);
if (uap->pid == 0) {
targetp = p;
PROC_LOCK(targetp);
} else {
targetp = pfind(uap->pid);
if (targetp == NULL)
return (ESRCH);
if (targetp == NULL) {
e = ESRCH;
goto done2;
}
}
e = p_cansee(p, targetp);
PROC_UNLOCK(targetp);
if (e)
return (e);
goto done2;
e = ksched_getparam(&p->p_retval[0], ksched, targetp, &sched_param);
if (e)
return (e);
e = copyout(&sched_param, uap->param, sizeof(sched_param));
if (e == 0)
e = copyout(&sched_param, uap->param, sizeof(sched_param));
done2:
mtx_unlock(&Giant);
return (e);
}
/*
* MPSAFE
*/
int sched_setscheduler(struct proc *p,
struct sched_setscheduler_args *uap)
{
@ -171,89 +187,126 @@ int sched_setscheduler(struct proc *p,
if (e)
return (e);
mtx_lock(&Giant);
if (uap->pid == 0) {
targetp = p;
PROC_LOCK(targetp);
} else {
targetp = pfind(uap->pid);
if (targetp == NULL)
return (ESRCH);
if (targetp == NULL) {
e = ESRCH;
goto done2;
}
}
e = p_cansched(p, targetp);
PROC_UNLOCK(targetp);
if (e)
return (e);
e = ksched_setscheduler(&p->p_retval[0], ksched, targetp, uap->policy,
(const struct sched_param *)&sched_param);
if (e == 0) {
e = ksched_setscheduler(&p->p_retval[0], ksched,
targetp, uap->policy,
(const struct sched_param *)&sched_param);
}
done2:
mtx_unlock(&Giant);
return (e);
}
/*
* MPSAFE
*/
int sched_getscheduler(struct proc *p,
struct sched_getscheduler_args *uap)
{
int e;
struct proc *targetp;
mtx_lock(&Giant);
if (uap->pid == 0) {
targetp = p;
PROC_LOCK(targetp);
} else {
targetp = pfind(uap->pid);
if (targetp == NULL)
return (ESRCH);
if (targetp == NULL) {
e = ESRCH;
goto done2;
}
}
e = p_cansee(p, targetp);
PROC_UNLOCK(targetp);
if (e)
return (e);
e = ksched_getscheduler(&p->p_retval[0], ksched, targetp);
if (e == 0)
e = ksched_getscheduler(&p->p_retval[0], ksched, targetp);
done2:
mtx_unlock(&Giant);
return (e);
}
/*
* MPSAFE
*/
int sched_yield(struct proc *p,
struct sched_yield_args *uap)
{
return ksched_yield(&p->p_retval[0], ksched);
int error;
mtx_lock(&Giant);
error = ksched_yield(&p->p_retval[0], ksched);
mtx_unlock(&Giant);
return (error);
}
/*
* MPSAFE
*/
int sched_get_priority_max(struct proc *p,
struct sched_get_priority_max_args *uap)
{
return ksched_get_priority_max(&p->p_retval[0],
ksched, uap->policy);
int error;
mtx_lock(&Giant);
error = ksched_get_priority_max(&p->p_retval[0], ksched, uap->policy);
mtx_unlock(&Giant);
return (error);
}
/*
* MPSAFE
*/
int sched_get_priority_min(struct proc *p,
struct sched_get_priority_min_args *uap)
{
return ksched_get_priority_min(&p->p_retval[0],
ksched, uap->policy);
int error;
mtx_lock(&Giant);
error = ksched_get_priority_min(&p->p_retval[0], ksched, uap->policy);
mtx_unlock(&Giant);
return (error);
}
/*
* MPSAFE
*/
int sched_rr_get_interval(struct proc *p,
struct sched_rr_get_interval_args *uap)
{
int e;
struct proc *targetp;
mtx_lock(&Giant);
if (uap->pid == 0) {
targetp = p;
PROC_LOCK(targetp);
} else {
targetp = pfind(uap->pid);
if (targetp == NULL)
return (ESRCH);
if (targetp == NULL) {
e = ESRCH;
goto done2;
}
}
e = p_cansee(p, targetp);
PROC_UNLOCK(targetp);
if (e)
return (e);
e = ksched_rr_get_interval(&p->p_retval[0], ksched, targetp,
uap->interval);
if (e == 0) {
e = ksched_rr_get_interval(&p->p_retval[0], ksched, targetp,
uap->interval);
}
done2:
mtx_unlock(&Giant);
return (e);
}

137
sys/posix4/p1003_1b.c
View File

@ -102,36 +102,46 @@ static int sched_attach(void)
return ret;
}
/*
* MPSAFE
*/
int sched_setparam(struct proc *p,
struct sched_setparam_args *uap)
{
struct proc *targetp;
int e;
struct sched_param sched_param;
e = copyin(uap->param, &sched_param, sizeof(sched_param));
if (e)
return (e);
mtx_lock(&Giant);
if (uap->pid == 0) {
targetp = p;
PROC_LOCK(targetp);
} else {
targetp = pfind(uap->pid);
if (targetp == NULL)
return (ESRCH);
if (targetp == NULL) {
e = ESRCH;
goto done2;
}
}
e = p_cansched(p, targetp);
PROC_UNLOCK(targetp);
if (e)
return (e);
e = ksched_setparam(&p->p_retval[0], ksched, targetp,
(const struct sched_param *)&sched_param);
if (e == 0) {
e = ksched_setparam(&p->p_retval[0], ksched, targetp,
(const struct sched_param *)&sched_param);
}
done2:
mtx_unlock(&Giant);
return (e);
}
/*
* MPSAFE
*/
int sched_getparam(struct proc *p,
struct sched_getparam_args *uap)
{
@ -139,27 +149,33 @@ int sched_getparam(struct proc *p,
struct sched_param sched_param;
struct proc *targetp;
mtx_lock(&Giant);
if (uap->pid == 0) {
targetp = p;
PROC_LOCK(targetp);
} else {
targetp = pfind(uap->pid);
if (targetp == NULL)
return (ESRCH);
if (targetp == NULL) {
e = ESRCH;
goto done2;
}
}
e = p_cansee(p, targetp);
PROC_UNLOCK(targetp);
if (e)
return (e);
goto done2;
e = ksched_getparam(&p->p_retval[0], ksched, targetp, &sched_param);
if (e)
return (e);
e = copyout(&sched_param, uap->param, sizeof(sched_param));
if (e == 0)
e = copyout(&sched_param, uap->param, sizeof(sched_param));
done2:
mtx_unlock(&Giant);
return (e);
}
/*
* MPSAFE
*/
int sched_setscheduler(struct proc *p,
struct sched_setscheduler_args *uap)
{
@ -171,89 +187,126 @@ int sched_setscheduler(struct proc *p,
if (e)
return (e);
mtx_lock(&Giant);
if (uap->pid == 0) {
targetp = p;
PROC_LOCK(targetp);
} else {
targetp = pfind(uap->pid);
if (targetp == NULL)
return (ESRCH);
if (targetp == NULL) {
e = ESRCH;
goto done2;
}
}
e = p_cansched(p, targetp);
PROC_UNLOCK(targetp);
if (e)
return (e);
e = ksched_setscheduler(&p->p_retval[0], ksched, targetp, uap->policy,
(const struct sched_param *)&sched_param);
if (e == 0) {
e = ksched_setscheduler(&p->p_retval[0], ksched,
targetp, uap->policy,
(const struct sched_param *)&sched_param);
}
done2:
mtx_unlock(&Giant);
return (e);
}
/*
* MPSAFE
*/
int sched_getscheduler(struct proc *p,
struct sched_getscheduler_args *uap)
{
int e;
struct proc *targetp;
mtx_lock(&Giant);
if (uap->pid == 0) {
targetp = p;
PROC_LOCK(targetp);
} else {
targetp = pfind(uap->pid);
if (targetp == NULL)
return (ESRCH);
if (targetp == NULL) {
e = ESRCH;
goto done2;
}
}
e = p_cansee(p, targetp);
PROC_UNLOCK(targetp);
if (e)
return (e);
e = ksched_getscheduler(&p->p_retval[0], ksched, targetp);
if (e == 0)
e = ksched_getscheduler(&p->p_retval[0], ksched, targetp);
done2:
mtx_unlock(&Giant);
return (e);
}
/*
* MPSAFE
*/
int sched_yield(struct proc *p,
struct sched_yield_args *uap)
{
return ksched_yield(&p->p_retval[0], ksched);
int error;
mtx_lock(&Giant);
error = ksched_yield(&p->p_retval[0], ksched);
mtx_unlock(&Giant);
return (error);
}
/*
* MPSAFE
*/
int sched_get_priority_max(struct proc *p,
struct sched_get_priority_max_args *uap)
{
return ksched_get_priority_max(&p->p_retval[0],
ksched, uap->policy);
int error;
mtx_lock(&Giant);
error = ksched_get_priority_max(&p->p_retval[0], ksched, uap->policy);
mtx_unlock(&Giant);
return (error);
}
/*
* MPSAFE
*/
int sched_get_priority_min(struct proc *p,
struct sched_get_priority_min_args *uap)
{
return ksched_get_priority_min(&p->p_retval[0],
ksched, uap->policy);
int error;
mtx_lock(&Giant);
error = ksched_get_priority_min(&p->p_retval[0], ksched, uap->policy);
mtx_unlock(&Giant);
return (error);
}
/*
* MPSAFE
*/
int sched_rr_get_interval(struct proc *p,
struct sched_rr_get_interval_args *uap)
{
int e;
struct proc *targetp;
mtx_lock(&Giant);
if (uap->pid == 0) {
targetp = p;
PROC_LOCK(targetp);
} else {
targetp = pfind(uap->pid);
if (targetp == NULL)
return (ESRCH);
if (targetp == NULL) {
e = ESRCH;
goto done2;
}
}
e = p_cansee(p, targetp);
PROC_UNLOCK(targetp);
if (e)
return (e);
e = ksched_rr_get_interval(&p->p_retval[0], ksched, targetp,
uap->interval);
if (e == 0) {
e = ksched_rr_get_interval(&p->p_retval[0], ksched, targetp,
uap->interval);
}
done2:
mtx_unlock(&Giant);
return (e);
}