#include "Python.h"

#include "pycore_pystate.h" // _PyInterpreterState_GET()

#include "pycore_structseq.h" // _PyStructSequence_FiniType()

#include "pycore_pythread.h"

#ifndef DONT_HAVE_STDIO_H

#include <stdio.h>

#include <stdlib.h>

static void PyThread__init_thread(void); /* Forward */

#define initialized _PyRuntime.threads.initialized

PyThread_init_thread(void)

{

if (initialized) {

return;

}

initialized = 1;

PyThread__init_thread();

}

#if defined(HAVE_PTHREAD_STUBS)

# define PYTHREAD_NAME "pthread-stubs"

# include "thread_pthread_stubs.h"

#elif defined(_USE_PTHREADS) /* AKA _PTHREADS */

# if defined(__EMSCRIPTEN__) && !defined(__EMSCRIPTEN_PTHREADS__)

# define PYTHREAD_NAME "pthread-stubs"

# define PYTHREAD_NAME "pthread"

# include "thread_pthread.h"

#elif defined(NT_THREADS)

# define PYTHREAD_NAME "nt"

# include "thread_nt.h"

# error "Require native threads. See https://bugs.python.org/issue31370"

PyThread_get_stacksize(void)

{

return _PyInterpreterState_GET()->threads.stacksize;

}

PyThread_set_stacksize(size_t size)

{

#if defined(THREAD_SET_STACKSIZE)

return THREAD_SET_STACKSIZE(size);

return -2;

}

Py_tss_t *

PyThread_tss_alloc(void)

{

Py_tss_t *new_key = (Py_tss_t *)PyMem_RawMalloc(sizeof(Py_tss_t));

if (new_key == NULL) {

return NULL;

}

new_key->_is_initialized = 0;

return new_key;

}

PyThread_tss_free(Py_tss_t *key)

{

if (key != NULL) {

PyThread_tss_delete(key);

PyMem_RawFree((void *)key);

}

}

PyThread_tss_is_created(Py_tss_t *key)

{

assert(key != NULL);

return key->_is_initialized;

}

PyDoc_STRVAR(threadinfo__doc__,

A named tuple holding information about the thread implementation.");

static PyStructSequence_Field threadinfo_fields[] = {

{"name", "name of the thread implementation"},

{"lock", "name of the lock implementation"},

{"version", "name and version of the thread library"},

{0}

};

static PyStructSequence_Desc threadinfo_desc = {

"sys.thread_info", /* name */

threadinfo__doc__, /* doc */

threadinfo_fields, /* fields */

3

};

static PyTypeObject ThreadInfoType;

PyThread_GetInfo(void)

{

PyObject *threadinfo, *value;

int pos = 0;

#if (defined(_POSIX_THREADS) && defined(HAVE_CONFSTR) \

&& defined(_CS_GNU_LIBPTHREAD_VERSION))

char buffer[255];

int len;

if (ThreadInfoType.tp_name == 0) {

if (_PyStructSequence_InitBuiltin(&ThreadInfoType,

&threadinfo_desc) < 0)

return NULL;

}

threadinfo = PyStructSequence_New(&ThreadInfoType);

if (threadinfo == NULL)

return NULL;

value = PyUnicode_FromString(PYTHREAD_NAME);

if (value == NULL) {

Py_DECREF(threadinfo);

return NULL;

}

PyStructSequence_SET_ITEM(threadinfo, pos++, value);

#ifdef HAVE_PTHREAD_STUBS

value = Py_NewRef(Py_None);

#elif defined(_POSIX_THREADS)

#ifdef USE_SEMAPHORES

value = PyUnicode_FromString("semaphore");

value = PyUnicode_FromString("mutex+cond");

if (value == NULL) {

Py_DECREF(threadinfo);

return NULL;

}

value = Py_NewRef(Py_None);

PyStructSequence_SET_ITEM(threadinfo, pos++, value);

#if (defined(_POSIX_THREADS) && defined(HAVE_CONFSTR) \

&& defined(_CS_GNU_LIBPTHREAD_VERSION))

value = NULL;

len = confstr(_CS_GNU_LIBPTHREAD_VERSION, buffer, sizeof(buffer));

if (1 < len && (size_t)len < sizeof(buffer)) {

value = PyUnicode_DecodeFSDefaultAndSize(buffer, len-1);

if (value == NULL)

PyErr_Clear();

}

if (value == NULL)

{

value = Py_NewRef(Py_None);

}

PyStructSequence_SET_ITEM(threadinfo, pos++, value);

return threadinfo;

}

_PyThread_FiniType(PyInterpreterState *interp)

{

if (!_Py_IsMainInterpreter(interp)) {

return;

}

_PyStructSequence_FiniType(&ThreadInfoType);

}