/* $OpenBSD: rthread_attr.c,v 1.9 2008/10/13 05:42:46 kevlo Exp $ */ /* * Copyright (c) 2004,2005 Ted Unangst * 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. */ /* * generic attribute support */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include "rthread.h" /* * temp: these need to be added to pthread.h */ int pthread_attr_getguardsize(const pthread_attr_t *, size_t *); int pthread_attr_setguardsize(pthread_attr_t *, size_t); /* * Note: stack_size + guard_size == total stack used * * pthread_attr_init MUST be called before any other attribute function * for proper operation. * * Every call to pthread_attr_init MUST be matched with a call to * pthread_attr_destroy to avoid leaking memory. This is an implementation * requirement, not a POSIX requirement. */ int pthread_attr_init(pthread_attr_t *attrp) { pthread_attr_t attr; attr = calloc(1, sizeof(*attr)); if (!attr) return (errno); attr->stack_size = RTHREAD_STACK_SIZE_DEF; attr->guard_size = sysconf(_SC_PAGESIZE); attr->stack_size -= attr->guard_size; attr->detach_state = PTHREAD_CREATE_JOINABLE; *attrp = attr; return (0); } int pthread_attr_destroy(pthread_attr_t *attrp) { free(*attrp); *attrp = NULL; return (0); } int pthread_attr_getguardsize(const pthread_attr_t *attrp, size_t *guardsize) { *guardsize = (*attrp)->guard_size; return (0); } int pthread_attr_setguardsize(pthread_attr_t *attrp, size_t guardsize) { if ((*attrp)->guard_size != guardsize) { (*attrp)->stack_size += (*attrp)->guard_size; (*attrp)->guard_size = guardsize; (*attrp)->stack_size -= (*attrp)->guard_size; } return 0; } int pthread_attr_getdetachstate(const pthread_attr_t *attrp, int *detachstate) { *detachstate = (*attrp)->detach_state; return (0); } int pthread_attr_setdetachstate(pthread_attr_t *attrp, int detachstate) { int retval; retval = (detachstate == PTHREAD_CREATE_DETACHED || detachstate == PTHREAD_CREATE_JOINABLE) ? 0 : EINVAL; if (retval == 0) (*attrp)->detach_state = detachstate; return (retval); } int pthread_attr_getstack(const pthread_attr_t *attrp, void **stackaddr, size_t *stacksize) { *stackaddr = (*attrp)->stack_addr; *stacksize = (*attrp)->stack_size + (*attrp)->guard_size; return (0); } int pthread_attr_setstack(pthread_attr_t *attrp, void *stackaddr, size_t stacksize) { int n; if ((n = pthread_attr_setstackaddr(attrp, stackaddr))) return (n); (*attrp)->stack_size = stacksize; (*attrp)->stack_size -= (*attrp)->guard_size; return (0); } int pthread_attr_getstacksize(const pthread_attr_t *attrp, size_t *stacksize) { *stacksize = (*attrp)->stack_size + (*attrp)->guard_size; return (0); } int pthread_attr_setstacksize(pthread_attr_t *attrp, size_t stacksize) { (*attrp)->stack_size = stacksize; if ((*attrp)->stack_size > (*attrp)->guard_size) (*attrp)->stack_size -= (*attrp)->guard_size; else (*attrp)->stack_size = 0; return (0); } int pthread_attr_getstackaddr(const pthread_attr_t *attrp, void **stackaddr) { *stackaddr = (*attrp)->stack_addr; return (0); } int pthread_attr_setstackaddr(pthread_attr_t *attrp, void *stackaddr) { size_t pgsz = sysconf(_SC_PAGESIZE); if (pgsz == (size_t)-1) return EINVAL; if ((uintptr_t)stackaddr & (pgsz - 1)) return EINVAL; (*attrp)->stack_addr = stackaddr; return (0); } int pthread_attr_getscope(const pthread_attr_t *attrp, int *contentionscope) { *contentionscope = (*attrp)->contention_scope; return (0); } int pthread_attr_setscope(pthread_attr_t *attrp, int contentionscope) { /* XXX contentionscope should be validated here */ (*attrp)->contention_scope = contentionscope; return (0); } int pthread_attr_setcreatesuspend_np(pthread_attr_t *attr) { (*attr)->create_suspended = 1; return (0); }