-
-
Notifications
You must be signed in to change notification settings - Fork 33.3k
gh-138004: Encode thread names on Solaris-based platforms as ASCII and fix main/worker threading test #138017
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Changes from 15 commits
d97417d
1db08a7
0606968
b556774
38a75d3
31731b1
83fe205
aadf7f3
612a0a4
1fa51f8
d24d0bb
95d289f
d7a47bf
1970a00
6395323
241e097
66c058b
f817412
3349464
ac3d3dd
1ab9ecd
d9ba9e8
d7025f5
3689044
246f880
407b1e9
dc43fc4
7aa256c
b4934a2
ae5ac4b
4fc368d
392aa5a
84daea4
d5e9399
105d4e6
c67e93d
508f24d
25085bf
cd26833
dc86a29
c9f554d
c0f672e
69796ff
15c8481
99f13ec
8fc613b
5e5effb
9690eee
338593c
e642264
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -2360,6 +2360,9 @@ def work(): | |
| thread = threading.Thread(target=work, name=name) | ||
| thread.start() | ||
| thread.join() | ||
| # If the name is non-ASCII and the result is empty, skip (platform limitation) | ||
| if any(ord(c) > 127 for c in name) and (not work_name or work_name == ""): | ||
|
||
| self.skipTest(f"Platform does not support non-ASCII thread names: got empty name for {name!r}") | ||
| self.assertEqual(work_name, expected, | ||
| f"{len(work_name)=} and {len(expected)=}") | ||
|
|
||
|
|
||
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1 @@ | ||
| _thread.set_name() now retries with an ASCII fallback if pthread_setname_np() rejects UTF-8 names on some POSIX-compliant platforms. | ||
jadonduff marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -17,6 +17,10 @@ | |
| #ifdef HAVE_SIGNAL_H | ||
| # include <signal.h> // SIGINT | ||
| #endif | ||
| #ifdef HAVE_PTHREAD_H | ||
| # include <pthread.h> | ||
| #endif | ||
| #include <errno.h> | ||
|
|
||
| // ThreadError is just an alias to PyExc_RuntimeError | ||
| #define ThreadError PyExc_RuntimeError | ||
|
|
@@ -71,6 +75,51 @@ get_thread_state_by_cls(PyTypeObject *cls) | |
| return get_thread_state(module); | ||
| } | ||
|
|
||
| // Helper to set the thread name using platform-specific APIs | ||
| static int | ||
| set_native_thread_name(const char *name) | ||
| { | ||
| #ifdef __APPLE__ | ||
| return pthread_setname_np(name); | ||
| #elif defined(__NetBSD__) | ||
| pthread_t thread = pthread_self(); | ||
| return pthread_setname_np(thread, "%s", (void *)name); | ||
| #elif defined(HAVE_PTHREAD_SETNAME_NP) | ||
| pthread_t thread = pthread_self(); | ||
| return pthread_setname_np(thread, name); | ||
| #elif defined(HAVE_PTHREAD_SET_NAME_NP) | ||
| pthread_t thread = pthread_self(); | ||
| pthread_set_name_np(thread, name); | ||
| return 0; /* pthread_set_name_np() returns void */ | ||
| #else | ||
| return 0; | ||
| #endif | ||
jadonduff marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| } | ||
|
|
||
| // Helper to encode and truncate thread name | ||
| static PyObject * | ||
| encode_thread_name(PyObject *name_obj, const char *encoding) | ||
| { | ||
| #ifdef __sun | ||
| // Solaris always uses UTF-8 | ||
| encoding = "utf-8"; | ||
| #endif | ||
| PyObject *name_encoded = PyUnicode_AsEncodedString(name_obj, encoding, "replace"); | ||
| if (name_encoded == NULL) { | ||
| return NULL; | ||
| } | ||
| #ifdef _PYTHREAD_NAME_MAXLEN | ||
| if (PyBytes_GET_SIZE(name_encoded) > _PYTHREAD_NAME_MAXLEN) { | ||
| PyObject *truncated = PyBytes_FromStringAndSize(PyBytes_AS_STRING(name_encoded), _PYTHREAD_NAME_MAXLEN); | ||
| if (truncated == NULL) { | ||
| Py_DECREF(name_encoded); | ||
| return NULL; | ||
| } | ||
| Py_SETREF(name_encoded, truncated); | ||
| } | ||
jadonduff marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| #endif | ||
| return name_encoded; | ||
| } | ||
|
|
||
| #ifdef MS_WINDOWS | ||
| typedef HRESULT (WINAPI *PF_GET_THREAD_DESCRIPTION)(HANDLE, PCWSTR*); | ||
|
|
@@ -2581,65 +2630,47 @@ _thread_set_name_impl(PyObject *module, PyObject *name_obj) | |
| /*[clinic end generated code: output=402b0c68e0c0daed input=7e7acd98261be82f]*/ | ||
| { | ||
| #ifndef MS_WINDOWS | ||
| #ifdef __sun | ||
| // Solaris always uses UTF-8 | ||
jadonduff marked this conversation as resolved.
Show resolved
Hide resolved
|
||
| const char *encoding = "utf-8"; | ||
| #else | ||
| // Encode the thread name to the filesystem encoding using the "replace" | ||
| // error handler | ||
|
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Why remove all this? There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. moved to encode_thread_name |
||
| PyInterpreterState *interp = _PyInterpreterState_GET(); | ||
| const char *encoding = interp->unicode.fs_codec.encoding; | ||
| #endif | ||
| PyObject *name_encoded; | ||
| name_encoded = PyUnicode_AsEncodedString(name_obj, encoding, "replace"); | ||
| PyObject *name_encoded = encode_thread_name(name_obj, encoding); | ||
| if (name_encoded == NULL) { | ||
| return NULL; | ||
| } | ||
|
|
||
| #ifdef _PYTHREAD_NAME_MAXLEN | ||
| // Truncate to _PYTHREAD_NAME_MAXLEN bytes + the NUL byte if needed | ||
| if (PyBytes_GET_SIZE(name_encoded) > _PYTHREAD_NAME_MAXLEN) { | ||
| PyObject *truncated; | ||
| truncated = PyBytes_FromStringAndSize(PyBytes_AS_STRING(name_encoded), | ||
| _PYTHREAD_NAME_MAXLEN); | ||
| if (truncated == NULL) { | ||
| Py_DECREF(name_encoded); | ||
| return NULL; | ||
| } | ||
| Py_SETREF(name_encoded, truncated); | ||
| } | ||
| #endif | ||
|
|
||
| const char *name = PyBytes_AS_STRING(name_encoded); | ||
| #ifdef __APPLE__ | ||
| int rc = pthread_setname_np(name); | ||
| #elif defined(__NetBSD__) | ||
| pthread_t thread = pthread_self(); | ||
| int rc = pthread_setname_np(thread, "%s", (void *)name); | ||
| #elif defined(HAVE_PTHREAD_SETNAME_NP) | ||
| pthread_t thread = pthread_self(); | ||
| int rc = pthread_setname_np(thread, name); | ||
| #else /* defined(HAVE_PTHREAD_SET_NAME_NP) */ | ||
| pthread_t thread = pthread_self(); | ||
| int rc = 0; /* pthread_set_name_np() returns void */ | ||
| pthread_set_name_np(thread, name); | ||
| #endif | ||
| Py_DECREF(name_encoded); | ||
| int rc = set_native_thread_name(name); | ||
| if (rc) { | ||
| errno = rc; | ||
| int err = rc; | ||
|
||
| Py_DECREF(name_encoded); | ||
| if (err == EINVAL && strcmp(encoding, "ascii") != 0) { | ||
| // Retry with ASCII encoding and 'replace' if not already ASCII | ||
| name_encoded = encode_thread_name(name_obj, "ascii"); | ||
| if (name_encoded == NULL) { | ||
| return NULL; | ||
| } | ||
| name = PyBytes_AS_STRING(name_encoded); | ||
| rc = set_native_thread_name(name); | ||
|
||
| if (rc) { | ||
| err = rc; | ||
| Py_DECREF(name_encoded); | ||
| errno = err; | ||
| return PyErr_SetFromErrno(PyExc_OSError); | ||
| } | ||
| Py_DECREF(name_encoded); | ||
| Py_RETURN_NONE; | ||
| } | ||
| errno = err; | ||
| return PyErr_SetFromErrno(PyExc_OSError); | ||
| } | ||
| Py_DECREF(name_encoded); | ||
| Py_RETURN_NONE; | ||
| #else | ||
| // Windows implementation | ||
| assert(pSetThreadDescription != NULL); | ||
|
|
||
|
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Those blank lines could be kept as this part of the code is not touched. |
||
| Py_ssize_t len; | ||
| wchar_t *name = PyUnicode_AsWideCharString(name_obj, &len); | ||
| if (name == NULL) { | ||
| return NULL; | ||
| } | ||
|
|
||
| if (len > _PYTHREAD_NAME_MAXLEN) { | ||
| // Truncate the name | ||
| Py_UCS4 ch = name[_PYTHREAD_NAME_MAXLEN-1]; | ||
|
|
@@ -2650,7 +2681,6 @@ _thread_set_name_impl(PyObject *module, PyObject *name_obj) | |
| name[_PYTHREAD_NAME_MAXLEN] = 0; | ||
| } | ||
| } | ||
|
|
||
| HRESULT hr = pSetThreadDescription(GetCurrentThread(), name); | ||
| PyMem_Free(name); | ||
| if (FAILED(hr)) { | ||
|
|
@@ -2894,4 +2924,4 @@ PyMODINIT_FUNC | |
| PyInit__thread(void) | ||
| { | ||
| return PyModuleDef_Init(&thread_module); | ||
| } | ||
| } | ||
|
||
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do not repeat the code in a comment.