|
Packit Service |
ae04f2 |
/*
|
|
Packit Service |
ae04f2 |
* Copyright (C) Internet Systems Consortium, Inc. ("ISC")
|
|
Packit Service |
ae04f2 |
*
|
|
Packit Service |
ae04f2 |
* This Source Code Form is subject to the terms of the Mozilla Public
|
|
Packit Service |
ae04f2 |
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
Packit Service |
ae04f2 |
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
Packit Service |
ae04f2 |
*
|
|
Packit Service |
ae04f2 |
* See the COPYRIGHT file distributed with this work for additional
|
|
Packit Service |
ae04f2 |
* information regarding copyright ownership.
|
|
Packit Service |
ae04f2 |
*/
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
/*! \file */
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
#include <config.h>
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
#if defined(HAVE_SCHED_H)
|
|
Packit Service |
ae04f2 |
#include <sched.h>
|
|
Packit Service |
ae04f2 |
#endif
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
#include <isc/thread.h>
|
|
Packit Service |
ae04f2 |
#include <isc/util.h>
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
#ifndef THREAD_MINSTACKSIZE
|
|
Packit Service |
ae04f2 |
#define THREAD_MINSTACKSIZE (1024U * 1024)
|
|
Packit Service |
ae04f2 |
#endif
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
isc_result_t
|
|
Packit Service |
ae04f2 |
isc_thread_create(isc_threadfunc_t func, isc_threadarg_t arg,
|
|
Packit Service |
ae04f2 |
isc_thread_t *thread)
|
|
Packit Service |
ae04f2 |
{
|
|
Packit Service |
ae04f2 |
pthread_attr_t attr;
|
|
Packit Service |
ae04f2 |
#if defined(HAVE_PTHREAD_ATTR_GETSTACKSIZE) && \
|
|
Packit Service |
ae04f2 |
defined(HAVE_PTHREAD_ATTR_SETSTACKSIZE)
|
|
Packit Service |
ae04f2 |
size_t stacksize;
|
|
Packit Service |
ae04f2 |
#endif
|
|
Packit Service |
ae04f2 |
int ret;
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
pthread_attr_init(&attr);
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
#if defined(HAVE_PTHREAD_ATTR_GETSTACKSIZE) && \
|
|
Packit Service |
ae04f2 |
defined(HAVE_PTHREAD_ATTR_SETSTACKSIZE)
|
|
Packit Service |
ae04f2 |
ret = pthread_attr_getstacksize(&attr, &stacksize);
|
|
Packit Service |
ae04f2 |
if (ret != 0)
|
|
Packit Service |
ae04f2 |
return (ISC_R_UNEXPECTED);
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
if (stacksize < THREAD_MINSTACKSIZE) {
|
|
Packit Service |
ae04f2 |
ret = pthread_attr_setstacksize(&attr, THREAD_MINSTACKSIZE);
|
|
Packit Service |
ae04f2 |
if (ret != 0)
|
|
Packit Service |
ae04f2 |
return (ISC_R_UNEXPECTED);
|
|
Packit Service |
ae04f2 |
}
|
|
Packit Service |
ae04f2 |
#endif
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
#if defined(PTHREAD_SCOPE_SYSTEM) && defined(NEED_PTHREAD_SCOPE_SYSTEM)
|
|
Packit Service |
ae04f2 |
ret = pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM);
|
|
Packit Service |
ae04f2 |
if (ret != 0)
|
|
Packit Service |
ae04f2 |
return (ISC_R_UNEXPECTED);
|
|
Packit Service |
ae04f2 |
#endif
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
ret = pthread_create(thread, &attr, func, arg);
|
|
Packit Service |
ae04f2 |
if (ret != 0)
|
|
Packit Service |
ae04f2 |
return (ISC_R_UNEXPECTED);
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
pthread_attr_destroy(&attr);
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
return (ISC_R_SUCCESS);
|
|
Packit Service |
ae04f2 |
}
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
void
|
|
Packit Service |
ae04f2 |
isc_thread_setconcurrency(unsigned int level) {
|
|
Packit Service |
ae04f2 |
#if defined(CALL_PTHREAD_SETCONCURRENCY)
|
|
Packit Service |
ae04f2 |
(void)pthread_setconcurrency(level);
|
|
Packit Service |
ae04f2 |
#else
|
|
Packit Service |
ae04f2 |
UNUSED(level);
|
|
Packit Service |
ae04f2 |
#endif
|
|
Packit Service |
ae04f2 |
}
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
void
|
|
Packit Service |
ae04f2 |
isc_thread_setname(isc_thread_t thread, const char *name) {
|
|
Packit Service |
ae04f2 |
#if defined(HAVE_PTHREAD_SETNAME_NP) && defined(_GNU_SOURCE)
|
|
Packit Service |
ae04f2 |
/*
|
|
Packit Service |
ae04f2 |
* macOS has pthread_setname_np but only works on the
|
|
Packit Service |
ae04f2 |
* current thread so it's not used here
|
|
Packit Service |
ae04f2 |
*/
|
|
Packit Service |
ae04f2 |
(void)pthread_setname_np(thread, name);
|
|
Packit Service |
ae04f2 |
#elif defined(HAVE_PTHREAD_SET_NAME_NP)
|
|
Packit Service |
ae04f2 |
(void)pthread_set_name_np(thread, name);
|
|
Packit Service |
ae04f2 |
#else
|
|
Packit Service |
ae04f2 |
UNUSED(thread);
|
|
Packit Service |
ae04f2 |
UNUSED(name);
|
|
Packit Service |
ae04f2 |
#endif
|
|
Packit Service |
ae04f2 |
}
|
|
Packit Service |
ae04f2 |
|
|
Packit Service |
ae04f2 |
void
|
|
Packit Service |
ae04f2 |
isc_thread_yield(void) {
|
|
Packit Service |
ae04f2 |
#if defined(HAVE_SCHED_YIELD)
|
|
Packit Service |
ae04f2 |
sched_yield();
|
|
Packit Service |
ae04f2 |
#elif defined( HAVE_PTHREAD_YIELD)
|
|
Packit Service |
ae04f2 |
pthread_yield();
|
|
Packit Service |
ae04f2 |
#elif defined( HAVE_PTHREAD_YIELD_NP)
|
|
Packit Service |
ae04f2 |
pthread_yield_np();
|
|
Packit Service |
ae04f2 |
#endif
|
|
Packit Service |
ae04f2 |
}
|