]> git.ipfire.org Git - thirdparty/Python/cpython.git/commitdiff
gh-154431: Revert "gh-154431: Fix data race in `sys.audithook` (#154462)" (GH-154769)
authorPetr Viktorin <encukou@gmail.com>
Mon, 27 Jul 2026 14:00:20 +0000 (16:00 +0200)
committerGitHub <noreply@github.com>
Mon, 27 Jul 2026 14:00:20 +0000 (16:00 +0200)
This commit caused a refleak.

This reverts commit 596cd5c5d7b6ada3e50c6499447eb90a065769ad.

Include/internal/pycore_interp_structs.h
Lib/test/test_free_threading/test_sys.py
Misc/NEWS.d/next/Library/2026-07-22-12-42-53.gh-issue-154431.U2kXXZ.rst [deleted file]
Python/pystate.c
Python/sysmodule.c

index 3d577ff717cc6e1c980ec4cbb518bc06fe3fbc1b..0623adce693d4650a33f0f00d9972bc972ad3016 100644 (file)
@@ -977,7 +977,6 @@ struct _is {
     struct _obmalloc_state *obmalloc;
 
     PyObject *audit_hooks;
-    PyMutex audit_hooks_mutex;
     PyType_WatchCallback type_watchers[TYPE_MAX_WATCHERS];
     PyCode_WatchCallback code_watchers[CODE_MAX_WATCHERS];
     PyContext_WatchCallback context_watchers[CONTEXT_MAX_WATCHERS];
index b8ba933cb01adc0313ec53337ed5a3289582e1dd..271fdd13c62b668eed7cacff356e366ff64b9bef 100644 (file)
@@ -44,20 +44,6 @@ class SysModuleTest(unittest.TestCase):
         workers = [lambda: worker(i) for i in range(5)]
         threading_helper.run_concurrently(workers)
 
-    def test_sys_audit_hooks(self):
-        def _hook(*args):
-            return None
-
-        def adder():
-            for _ in range(100):
-                sys.addaudithook(_hook)
-
-        def auditor():
-            for _ in range(2000):
-                sys.audit("fusil.tsan.test")
-
-        threading_helper.run_concurrently([adder, auditor])
-
 
 if __name__ == "__main__":
     unittest.main()
diff --git a/Misc/NEWS.d/next/Library/2026-07-22-12-42-53.gh-issue-154431.U2kXXZ.rst b/Misc/NEWS.d/next/Library/2026-07-22-12-42-53.gh-issue-154431.U2kXXZ.rst
deleted file mode 100644 (file)
index a56c3b3..0000000
+++ /dev/null
@@ -1 +0,0 @@
-Fixes a data race in free-threading build in :func:`sys.addaudithook`.
index b6c34552e94337bb65d6b4a3a11eeb1670bd1391..d10b38def32911d2bab0e78209fe2ec753fa004b 100644 (file)
@@ -578,7 +578,6 @@ init_interpreter(PyInterpreterState *interp,
     llist_init(&interp->mem_free_queue.head);
     llist_init(&interp->asyncio_tasks_head);
     interp->asyncio_tasks_lock = (PyMutex){0};
-    interp->audit_hooks_mutex = (PyMutex){0};
     for (int i = 0; i < _PY_MONITORING_UNGROUPED_EVENTS; i++) {
         interp->monitors.tools[i] = 0;
     }
index 207ccbce41d71db246af2a355b04bc6c608c2f9d..9442472b53abbe1d8d5659df107462c871cb98c2 100644 (file)
@@ -236,7 +236,7 @@ should_audit(PyInterpreterState *interp)
         return 0;
     }
     return (interp->runtime->audit_hooks.head
-            || FT_ATOMIC_LOAD_PTR_ACQUIRE(interp->audit_hooks)
+            || interp->audit_hooks
             || PyDTrace_AUDIT_ENABLED());
 }
 
@@ -306,14 +306,13 @@ sys_audit_tstate(PyThreadState *ts, const char *event,
     }
 
     /* Call interpreter hooks */
-    PyObject *audit_hooks = FT_ATOMIC_LOAD_PTR_ACQUIRE(is->audit_hooks);
-    if (audit_hooks) {
+    if (is->audit_hooks) {
         eventName = PyUnicode_FromString(event);
         if (!eventName) {
             goto exit;
         }
 
-        hooks = PyObject_GetIter(audit_hooks);
+        hooks = PyObject_GetIter(is->audit_hooks);
         if (!hooks) {
             goto exit;
         }
@@ -537,29 +536,20 @@ sys_addaudithook_impl(PyObject *module, PyObject *hook)
     }
 
     PyInterpreterState *interp = tstate->interp;
-    PyMutex mutex = interp->audit_hooks_mutex;
-    PyMutex_Lock(&mutex);
-
     if (interp->audit_hooks == NULL) {
-        PyObject *new_list = PyList_New(0);
-        if (new_list == NULL) {
-            goto error;
+        interp->audit_hooks = PyList_New(0);
+        if (interp->audit_hooks == NULL) {
+            return NULL;
         }
         /* Avoid having our list of hooks show up in the GC module */
-        PyObject_GC_UnTrack(new_list);
-        FT_ATOMIC_STORE_PTR_RELEASE(interp->audit_hooks, new_list);
+        PyObject_GC_UnTrack(interp->audit_hooks);
     }
 
     if (PyList_Append(interp->audit_hooks, hook) < 0) {
-        goto error;
+        return NULL;
     }
 
-    PyMutex_Unlock(&mutex);
     Py_RETURN_NONE;
-
-error:
-    PyMutex_Unlock(&mutex);
-    return NULL;
 }
 
 /*[clinic input]