mirror of https://github.com/python/cpython
[3.13] gh-117657: Fix QSBR race condition (GH-118843) (#118905)
`_Py_qsbr_unregister` is called when the PyThreadState is already
detached, so the access to `tstate->qsbr` isn't safe without locking the
shared mutex. Grab the `struct _qsbr_shared` from the interpreter
instead.
(cherry picked from commit 33d20199af
)
Co-authored-by: Alex Turner <alexturner@meta.com>
This commit is contained in:
parent
0874a400a8
commit
0becae366c
|
@ -140,7 +140,7 @@ _Py_qsbr_register(struct _PyThreadStateImpl *tstate,
|
|||
|
||||
// Disassociates a PyThreadState from the QSBR state and frees the QSBR state.
|
||||
extern void
|
||||
_Py_qsbr_unregister(struct _PyThreadStateImpl *tstate);
|
||||
_Py_qsbr_unregister(PyThreadState *tstate);
|
||||
|
||||
extern void
|
||||
_Py_qsbr_fini(PyInterpreterState *interp);
|
||||
|
|
|
@ -1794,7 +1794,7 @@ tstate_delete_common(PyThreadState *tstate)
|
|||
HEAD_UNLOCK(runtime);
|
||||
|
||||
#ifdef Py_GIL_DISABLED
|
||||
_Py_qsbr_unregister((_PyThreadStateImpl *)tstate);
|
||||
_Py_qsbr_unregister(tstate);
|
||||
#endif
|
||||
|
||||
// XXX Unbind in PyThreadState_Clear(), or earlier
|
||||
|
|
|
@ -231,20 +231,21 @@ _Py_qsbr_register(_PyThreadStateImpl *tstate, PyInterpreterState *interp,
|
|||
}
|
||||
|
||||
void
|
||||
_Py_qsbr_unregister(_PyThreadStateImpl *tstate)
|
||||
_Py_qsbr_unregister(PyThreadState *tstate)
|
||||
{
|
||||
struct _qsbr_shared *shared = tstate->qsbr->shared;
|
||||
struct _qsbr_shared *shared = &tstate->interp->qsbr;
|
||||
struct _PyThreadStateImpl *tstate_imp = (_PyThreadStateImpl*) tstate;
|
||||
|
||||
PyMutex_Lock(&shared->mutex);
|
||||
// NOTE: we must load (or reload) the thread state's qbsr inside the mutex
|
||||
// because the array may have been resized (changing tstate->qsbr) while
|
||||
// we waited to acquire the mutex.
|
||||
struct _qsbr_thread_state *qsbr = tstate->qsbr;
|
||||
struct _qsbr_thread_state *qsbr = tstate_imp->qsbr;
|
||||
|
||||
assert(qsbr->seq == 0 && "thread state must be detached");
|
||||
assert(qsbr->allocated && qsbr->tstate == (PyThreadState *)tstate);
|
||||
assert(qsbr->allocated && qsbr->tstate == tstate);
|
||||
|
||||
tstate->qsbr = NULL;
|
||||
tstate_imp->qsbr = NULL;
|
||||
qsbr->tstate = NULL;
|
||||
qsbr->allocated = false;
|
||||
qsbr->freelist_next = shared->freelist;
|
||||
|
|
|
@ -38,7 +38,6 @@ race_top:_PyParkingLot_Park
|
|||
race_top:_PyType_HasFeature
|
||||
race_top:assign_version_tag
|
||||
race_top:gc_restore_tid
|
||||
race_top:initialize_new_array
|
||||
race_top:insertdict
|
||||
race_top:lookup_tp_dict
|
||||
race_top:mi_heap_visit_pages
|
||||
|
|
Loading…
Reference in New Issue