Potential Deadlock in _Py_qsbr_reserve
Nessuno ha ancora preso questa issue.
- Lingua principale
- Python
- Stelle
- 77.2k
- Fork
- 35.9k
- Metriche di merge delle PR
- Metriche PR in attesa
Descrizione
Crash report
What happened?
Hello
I don't have a good unit test for it. I'm running a server under free-threading 3.14.3t build. On a larger QPS, I see a rapid unstoppable RAM increase, while CPU load is okay.
Based on a dump of active threads, I suspect a deadlock somewhere around _Py_qsbr_reserve and Stop the World:
E.g.
- This thread successfully initiated the Stop The World event and is waiting for all other threads to acknowledge and pause (park).
stop_the_worldindicates it is the one trying to stop everything.PyEvent_WaitTimedshows it is sitting there waiting for a signal that everyone has stopped.
do_futex_wait __new_sem_wait_slow _PySemaphore_Wait _PyParkingLot_Park PyEvent_WaitTimed stop_the_world type_set_abstractmethods type_setattro PyObject_SetAttr _abc__abc_init ... etc - This thread also needed to stop the world (to grow an internal array) but got blocked because anotheer already held the master lock.
_Py_qsbr_reserveshows it was trying to reserve space in the memory management system._PyMutex_LockTimedshows it is blocked waiting for a lock inside stop_the_world. This is the lock held by Thread 1.
do_futex_wait __new_sem_wait_slow _PySemaphore_Wait _PyParkingLot_Park _PyMutex_LockTimed stop_the_world _Py_qsbr_reserve PyGILState_Ensure ... etc
I suspect a modification of _Py_qsbr_reserve could help, the server thread dump does not complain about waiting on Stop the World after this modification:
Py_ssize_t
_Py_qsbr_reserve(PyInterpreterState *interp)
{
struct _qsbr_shared *shared = &interp->qsbr;
PyMutex_Lock(&shared->mutex);
// Try allocating from our internal freelist
struct _qsbr_thread_state *qsbr = qsbr_allocate(shared);
while (qsbr == NULL) {
// Unlock before stopping the world to avoid deadlocks.
// If we hold shared->mutex while waiting for the world to stop,
// we might block a thread that needs to acquire shared->mutex to park.
PyMutex_Unlock(&shared->mutex);
_PyEval_StopTheWorld(interp);
PyMutex_Lock(&shared->mutex);
// Try allocating again, as another thread might have grown the array
// or freed an entry while we were waiting.
qsbr = qsbr_allocate(shared);
if (qsbr != NULL) {
_PyEval_StartTheWorld(interp);
break;
}
// Still NULL, we must grow it
if (grow_thread_array(shared) == 0) {
qsbr = qsbr_allocate(shared);
} else {
// Failed to grow array (e.g. OOM). Break to avoid infinite loop.
_PyEval_StartTheWorld(interp);
break;
}
_PyEval_StartTheWorld(interp);
}
// Return an index rather than the pointer because the array may be
// resized and the pointer invalidated.
Py_ssize_t index = -1;
if (qsbr != NULL) {
index = (struct _qsbr_pad *)qsbr - shared->array;
}
PyMutex_Unlock(&shared->mutex);
return index;
}
Similar issues in the past:
CPython versions tested on:
3.14
Operating systems tested on:
Linux
Output from running 'python -VV' on the command line:
3.14.3 (free-threading)
Linked PRs
- gh-149100
Guida per i contributori
Apri la guida per i contributori
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Direzione di ricerca
Inizia esaminando la PR collegata gh-149100, quindi traccia _Py_qsbr_reserve e stop_the_world usando gli stack dei thread riportati. L’issue non fornisce alcun file sorgente nominato, alcun unit test né un riproduttore affidabile; per considerare il lavoro completato sarebbe necessario confermare il meccanismo del deadlock e validare una correzione con la build free-threading.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Valutazione
- Stack tecnologico
- c
- Ambito
- operating-systems
- Tipo di issue
- Bug
- Difficoltà
- 5/5
- Tempo stimato
- Più di una settimana
- Stato di attività
- Ferma
- Chiarezza
- Da chiarire
- Idoneità per principianti
- 25/100