1258945Sroberto/*
2258945Sroberto * Copyright (C) 2004, 2005, 2007  Internet Systems Consortium, Inc. ("ISC")
3258945Sroberto * Copyright (C) 2000, 2001, 2003  Internet Software Consortium.
4258945Sroberto *
5258945Sroberto * Permission to use, copy, modify, and/or distribute this software for any
6258945Sroberto * purpose with or without fee is hereby granted, provided that the above
7258945Sroberto * copyright notice and this permission notice appear in all copies.
8258945Sroberto *
9258945Sroberto * THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH
10258945Sroberto * REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
11258945Sroberto * AND FITNESS.  IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT,
12258945Sroberto * INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
13258945Sroberto * LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
14258945Sroberto * OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
15258945Sroberto * PERFORMANCE OF THIS SOFTWARE.
16258945Sroberto */
17258945Sroberto
18258945Sroberto/* $Id: thread.c,v 1.17 2007/06/19 23:47:18 tbox Exp $ */
19258945Sroberto
20258945Sroberto/*! \file */
21258945Sroberto
22258945Sroberto#include <config.h>
23258945Sroberto
24258945Sroberto#include <isc/thread.h>
25258945Sroberto#include <isc/util.h>
26258945Sroberto
27258945Sroberto#ifndef THREAD_MINSTACKSIZE
28258945Sroberto#define THREAD_MINSTACKSIZE		(64U * 1024)
29258945Sroberto#endif
30258945Sroberto
31258945Srobertoisc_result_t
32258945Srobertoisc_thread_create(isc_threadfunc_t func, isc_threadarg_t arg,
33258945Sroberto		  isc_thread_t *thread)
34258945Sroberto{
35258945Sroberto	pthread_attr_t attr;
36258945Sroberto	size_t stacksize;
37258945Sroberto	int ret;
38258945Sroberto
39258945Sroberto	pthread_attr_init(&attr);
40258945Sroberto
41258945Sroberto#if defined(HAVE_PTHREAD_ATTR_GETSTACKSIZE) && \
42258945Sroberto    defined(HAVE_PTHREAD_ATTR_SETSTACKSIZE)
43258945Sroberto	ret = pthread_attr_getstacksize(&attr, &stacksize);
44258945Sroberto	if (ret != 0)
45258945Sroberto		return (ISC_R_UNEXPECTED);
46258945Sroberto
47258945Sroberto	if (stacksize < THREAD_MINSTACKSIZE) {
48258945Sroberto		ret = pthread_attr_setstacksize(&attr, THREAD_MINSTACKSIZE);
49258945Sroberto		if (ret != 0)
50258945Sroberto			return (ISC_R_UNEXPECTED);
51258945Sroberto	}
52258945Sroberto#endif
53258945Sroberto
54258945Sroberto#if defined(PTHREAD_SCOPE_SYSTEM) && defined(NEED_PTHREAD_SCOPE_SYSTEM)
55258945Sroberto	ret = pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM);
56258945Sroberto	if (ret != 0)
57258945Sroberto		return (ISC_R_UNEXPECTED);
58258945Sroberto#endif
59258945Sroberto
60258945Sroberto	ret = pthread_create(thread, &attr, func, arg);
61258945Sroberto	if (ret != 0)
62258945Sroberto		return (ISC_R_UNEXPECTED);
63258945Sroberto
64258945Sroberto	pthread_attr_destroy(&attr);
65258945Sroberto
66258945Sroberto	return (ISC_R_SUCCESS);
67258945Sroberto}
68258945Sroberto
69258945Srobertovoid
70258945Srobertoisc_thread_setconcurrency(unsigned int level) {
71258945Sroberto#if defined(CALL_PTHREAD_SETCONCURRENCY)
72258945Sroberto	(void)pthread_setconcurrency(level);
73258945Sroberto#else
74258945Sroberto	UNUSED(level);
75258945Sroberto#endif
76258945Sroberto}
77