1135446Strhodes/* 2254402Serwin * Copyright (C) 2004, 2005, 2007, 2013 Internet Systems Consortium, Inc. ("ISC") 3135446Strhodes * Copyright (C) 2000, 2001, 2003 Internet Software Consortium. 4135446Strhodes * 5193149Sdougb * Permission to use, copy, modify, and/or distribute this software for any 6135446Strhodes * purpose with or without fee is hereby granted, provided that the above 7135446Strhodes * copyright notice and this permission notice appear in all copies. 8135446Strhodes * 9135446Strhodes * THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH 10135446Strhodes * REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY 11135446Strhodes * AND FITNESS. IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT, 12135446Strhodes * INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM 13135446Strhodes * LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE 14135446Strhodes * OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR 15135446Strhodes * PERFORMANCE OF THIS SOFTWARE. 16135446Strhodes */ 17135446Strhodes 18234010Sdougb/* $Id: thread.c,v 1.17 2007/06/19 23:47:18 tbox Exp $ */ 19135446Strhodes 20170222Sdougb/*! \file */ 21170222Sdougb 22135446Strhodes#include <config.h> 23135446Strhodes 24262706Serwin#if defined(HAVE_SCHED_H) 25262706Serwin#include <sched.h> 26262706Serwin#endif 27262706Serwin 28135446Strhodes#include <isc/thread.h> 29135446Strhodes#include <isc/util.h> 30135446Strhodes 31135446Strhodes#ifndef THREAD_MINSTACKSIZE 32254402Serwin#define THREAD_MINSTACKSIZE (1024U * 1024) 33135446Strhodes#endif 34135446Strhodes 35135446Strhodesisc_result_t 36135446Strhodesisc_thread_create(isc_threadfunc_t func, isc_threadarg_t arg, 37135446Strhodes isc_thread_t *thread) 38135446Strhodes{ 39135446Strhodes pthread_attr_t attr; 40135446Strhodes size_t stacksize; 41135446Strhodes int ret; 42135446Strhodes 43135446Strhodes pthread_attr_init(&attr); 44135446Strhodes 45135446Strhodes#if defined(HAVE_PTHREAD_ATTR_GETSTACKSIZE) && \ 46135446Strhodes defined(HAVE_PTHREAD_ATTR_SETSTACKSIZE) 47135446Strhodes ret = pthread_attr_getstacksize(&attr, &stacksize); 48135446Strhodes if (ret != 0) 49135446Strhodes return (ISC_R_UNEXPECTED); 50135446Strhodes 51135446Strhodes if (stacksize < THREAD_MINSTACKSIZE) { 52135446Strhodes ret = pthread_attr_setstacksize(&attr, THREAD_MINSTACKSIZE); 53135446Strhodes if (ret != 0) 54135446Strhodes return (ISC_R_UNEXPECTED); 55135446Strhodes } 56135446Strhodes#endif 57135446Strhodes 58143731Sdougb#if defined(PTHREAD_SCOPE_SYSTEM) && defined(NEED_PTHREAD_SCOPE_SYSTEM) 59143731Sdougb ret = pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM); 60143731Sdougb if (ret != 0) 61143731Sdougb return (ISC_R_UNEXPECTED); 62143731Sdougb#endif 63143731Sdougb 64135446Strhodes ret = pthread_create(thread, &attr, func, arg); 65135446Strhodes if (ret != 0) 66135446Strhodes return (ISC_R_UNEXPECTED); 67135446Strhodes 68135446Strhodes pthread_attr_destroy(&attr); 69135446Strhodes 70135446Strhodes return (ISC_R_SUCCESS); 71135446Strhodes} 72135446Strhodes 73135446Strhodesvoid 74135446Strhodesisc_thread_setconcurrency(unsigned int level) { 75135446Strhodes#if defined(CALL_PTHREAD_SETCONCURRENCY) 76135446Strhodes (void)pthread_setconcurrency(level); 77135446Strhodes#else 78135446Strhodes UNUSED(level); 79135446Strhodes#endif 80135446Strhodes} 81262706Serwin 82262706Serwinvoid 83262706Serwinisc_thread_yield(void) { 84262706Serwin#if defined(HAVE_SCHED_YIELD) 85262706Serwin sched_yield(); 86262706Serwin#elif defined( HAVE_PTHREAD_YIELD) 87262706Serwin pthread_yield(); 88262706Serwin#elif defined( HAVE_PTHREAD_YIELD_NP) 89262706Serwin pthread_yield_np(); 90262706Serwin#endif 91262706Serwin} 92