IABSD.fr/src/lib/librthread/rthread_sched.c

Branch : - branch - master - tag -

• Show log

  Commit

• Author : guenther
  Date : 2017-09-05 02:40:54
  Hash : a5511fa9
  Message : Move mutex, condvar, and thread-specific data routes, pthread_once, and pthread_exit from libpthread to libc, along with low-level bits to support them. Major bump to both libc and libpthread. Requested by libressl team. Ports testing by naddy@ ok kettenis@

• lib/librthread/rthread_sched.c

• /*	$OpenBSD: rthread_sched.c,v 1.14 2017/09/05 02:40:54 guenther Exp $ */
  /*
   * Copyright (c) 2004,2005 Ted Unangst <tedu@openbsd.org>
   * All Rights Reserved.
   *
   * Permission to use, copy, modify, and distribute this software for any
   * purpose with or without fee is hereby granted, provided that the above
   * copyright notice and this permission notice appear in all copies.
   *
   * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
   * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
   * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
   * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
   * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
   * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
   * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
   */
  /*
   * scheduling routines
   */
  
  #include <unistd.h>
  #include <signal.h>
  #include <errno.h>
  
  #include <pthread.h>
  #include <pthread_np.h>
  
  #include "rthread.h"
  
  int
  pthread_getschedparam(pthread_t thread, int *policy,
      struct sched_param *param)
  {
  	if (!_threads_ready)
  		_rthread_init();
  
  	*policy = thread->attr.sched_policy;
  	if (param)
  		*param = thread->attr.sched_param;
  
  	return (0);
  }
  
  int
  pthread_setschedparam(pthread_t thread, int policy,
      const struct sched_param *param)
  {
  	if (!_threads_ready)
  		_rthread_init();
  
  	/* XXX return ENOTSUP for SCHED_{FIFO,RR}? */
  	if (policy != SCHED_OTHER && policy != SCHED_FIFO &&
  	    policy != SCHED_RR)
  		return (EINVAL);
  	thread->attr.sched_policy = policy;
  	if (param)
  		thread->attr.sched_param = *param;
  
  	return (0);
  }
  
  int
  pthread_attr_getschedparam(const pthread_attr_t *attrp,
      struct sched_param *param)
  {
  	*param = (*attrp)->sched_param;
  
  	return (0);
  }
  
  int
  pthread_attr_setschedparam(pthread_attr_t *attrp,
      const struct sched_param *param)
  {
  	(*attrp)->sched_param = *param;
  
  	return (0);
  }
  
  int
  pthread_attr_getschedpolicy(const pthread_attr_t *attrp, int *policy)
  {
  	*policy = (*attrp)->sched_policy;
  
  	return (0);
  }
  
  int
  pthread_attr_setschedpolicy(pthread_attr_t *attrp, int policy)
  {
  	/* XXX return ENOTSUP for SCHED_{FIFO,RR}? */
  	if (policy != SCHED_OTHER && policy != SCHED_FIFO &&
  	    policy != SCHED_RR)
  		return (EINVAL);
  	(*attrp)->sched_policy = policy;
  
  	return (0);
  }
  
  int
  pthread_attr_getinheritsched(const pthread_attr_t *attrp, int *inherit)
  {
  	*inherit = (*attrp)->sched_inherit;
  
  	return (0);
  }
  
  int
  pthread_attr_setinheritsched(pthread_attr_t *attrp, int inherit)
  {
  	if (inherit != PTHREAD_INHERIT_SCHED &&
  	    inherit != PTHREAD_EXPLICIT_SCHED)
  		return (EINVAL);
  	(*attrp)->sched_inherit = inherit;
  
  	return (0);
  }
  
  int
  pthread_getprio(pthread_t thread)
  {
  	if (!_threads_ready)
  		_rthread_init();
  
  	return (thread->attr.sched_param.sched_priority);
  }
  
  int
  pthread_setprio(pthread_t thread, int priority)
  {
  	if (!_threads_ready)
  		_rthread_init();
  
  	thread->attr.sched_param.sched_priority = priority;
  
  	return (0);
  }
  
  void
  pthread_yield(void)
  {
  	sched_yield();
  }