xref: /netbsd-src/external/bsd/ntp/dist/libntp/lib/isc/pthreads/thread.c (revision eabc0478de71e4e011a5b4e0392741e01d491794)
1*eabc0478Schristos /*	$NetBSD: thread.c,v 1.2 2024/08/18 20:47:15 christos Exp $	*/
2897be3a4Schristos 
3897be3a4Schristos /*
4897be3a4Schristos  * Copyright (C) 2004, 2005, 2007  Internet Systems Consortium, Inc. ("ISC")
5897be3a4Schristos  * Copyright (C) 2000, 2001, 2003  Internet Software Consortium.
6897be3a4Schristos  *
7897be3a4Schristos  * Permission to use, copy, modify, and/or distribute this software for any
8897be3a4Schristos  * purpose with or without fee is hereby granted, provided that the above
9897be3a4Schristos  * copyright notice and this permission notice appear in all copies.
10897be3a4Schristos  *
11897be3a4Schristos  * THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH
12897be3a4Schristos  * REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
13897be3a4Schristos  * AND FITNESS.  IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT,
14897be3a4Schristos  * INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
15897be3a4Schristos  * LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
16897be3a4Schristos  * OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
17897be3a4Schristos  * PERFORMANCE OF THIS SOFTWARE.
18897be3a4Schristos  */
19897be3a4Schristos 
20897be3a4Schristos /* Id: thread.c,v 1.17 2007/06/19 23:47:18 tbox Exp  */
21897be3a4Schristos 
22897be3a4Schristos /*! \file */
23897be3a4Schristos 
24897be3a4Schristos #include <config.h>
25897be3a4Schristos 
26897be3a4Schristos #include <isc/thread.h>
27897be3a4Schristos #include <isc/util.h>
28897be3a4Schristos 
29897be3a4Schristos #ifndef THREAD_MINSTACKSIZE
30897be3a4Schristos #define THREAD_MINSTACKSIZE		(64U * 1024)
31897be3a4Schristos #endif
32897be3a4Schristos 
33897be3a4Schristos isc_result_t
34897be3a4Schristos isc_thread_create(isc_threadfunc_t func, isc_threadarg_t arg,
35897be3a4Schristos 		  isc_thread_t *thread)
36897be3a4Schristos {
37897be3a4Schristos 	pthread_attr_t attr;
38897be3a4Schristos 	size_t stacksize;
39897be3a4Schristos 	int ret;
40897be3a4Schristos 
41897be3a4Schristos 	pthread_attr_init(&attr);
42897be3a4Schristos 
43897be3a4Schristos #if defined(HAVE_PTHREAD_ATTR_GETSTACKSIZE) && \
44897be3a4Schristos     defined(HAVE_PTHREAD_ATTR_SETSTACKSIZE)
45897be3a4Schristos 	ret = pthread_attr_getstacksize(&attr, &stacksize);
46897be3a4Schristos 	if (ret != 0)
47897be3a4Schristos 		return (ISC_R_UNEXPECTED);
48897be3a4Schristos 
49897be3a4Schristos 	if (stacksize < THREAD_MINSTACKSIZE) {
50897be3a4Schristos 		ret = pthread_attr_setstacksize(&attr, THREAD_MINSTACKSIZE);
51897be3a4Schristos 		if (ret != 0)
52897be3a4Schristos 			return (ISC_R_UNEXPECTED);
53897be3a4Schristos 	}
54897be3a4Schristos #endif
55897be3a4Schristos 
56897be3a4Schristos #if defined(PTHREAD_SCOPE_SYSTEM) && defined(NEED_PTHREAD_SCOPE_SYSTEM)
57897be3a4Schristos 	ret = pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM);
58897be3a4Schristos 	if (ret != 0)
59897be3a4Schristos 		return (ISC_R_UNEXPECTED);
60897be3a4Schristos #endif
61897be3a4Schristos 
62897be3a4Schristos 	ret = pthread_create(thread, &attr, func, arg);
63897be3a4Schristos 	if (ret != 0)
64897be3a4Schristos 		return (ISC_R_UNEXPECTED);
65897be3a4Schristos 
66897be3a4Schristos 	pthread_attr_destroy(&attr);
67897be3a4Schristos 
68897be3a4Schristos 	return (ISC_R_SUCCESS);
69897be3a4Schristos }
70897be3a4Schristos 
71897be3a4Schristos void
72897be3a4Schristos isc_thread_setconcurrency(unsigned int level) {
73897be3a4Schristos #if defined(CALL_PTHREAD_SETCONCURRENCY)
74897be3a4Schristos 	(void)pthread_setconcurrency(level);
75897be3a4Schristos #else
76897be3a4Schristos 	UNUSED(level);
77897be3a4Schristos #endif
78897be3a4Schristos }
79