gh-105716: Fix _PyInterpreterState_IsRunningMain() For Embedders (gh-117140)

When I added _PyInterpreterState_IsRunningMain() and friends last year, I tried to accommodate applications that embed Python but don't call _PyInterpreterState_SetRunningMain() (not that they're expected to).  That mostly worked fine until my recent changes in gh-117049, where the subtleties with the fallback code led to failures; the change ended up breaking test_tools.test_freeze, which exercises a basic embedding situation.

The simplest fix is to drop the fallback code I originally added to _PyInterpreterState_IsRunningMain() (and later to _PyThreadState_IsRunningMain()).  I've kept the fallback in the _xxsubinterpreters module though.  I've also updated Py_FrozenMain() to call _PyInterpreterState_SetRunningMain().
This commit is contained in:
Eric Snow 2024-03-21 18:20:20 -06:00 committed by GitHub
parent c4bf58a14f
commit b3d25df8d3
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 39 additions and 22 deletions

View File

@ -56,6 +56,24 @@ _get_current_module(void)
} }
static int
is_running_main(PyInterpreterState *interp)
{
if (_PyInterpreterState_IsRunningMain(interp)) {
return 1;
}
// Unlike with the general C-API, we can be confident that someone
// using this module for the main interpreter is doing so through
// the main program. Thus we can make this extra check. This benefits
// applications that embed Python but haven't been updated yet
// to call_PyInterpreterState_SetRunningMain().
if (_Py_IsMainInterpreter(interp)) {
return 1;
}
return 0;
}
/* Cross-interpreter Buffer Views *******************************************/ /* Cross-interpreter Buffer Views *******************************************/
// XXX Release when the original interpreter is destroyed. // XXX Release when the original interpreter is destroyed.
@ -509,7 +527,7 @@ interp_destroy(PyObject *self, PyObject *args, PyObject *kwds)
// Ensure the interpreter isn't running. // Ensure the interpreter isn't running.
/* XXX We *could* support destroying a running interpreter but /* XXX We *could* support destroying a running interpreter but
aren't going to worry about it for now. */ aren't going to worry about it for now. */
if (_PyInterpreterState_IsRunningMain(interp)) { if (is_running_main(interp)) {
PyErr_Format(PyExc_RuntimeError, "interpreter running"); PyErr_Format(PyExc_RuntimeError, "interpreter running");
return NULL; return NULL;
} }
@ -977,7 +995,7 @@ interp_is_running(PyObject *self, PyObject *args, PyObject *kwds)
if (interp == NULL) { if (interp == NULL) {
return NULL; return NULL;
} }
if (_PyInterpreterState_IsRunningMain(interp)) { if (is_running_main(interp)) {
Py_RETURN_TRUE; Py_RETURN_TRUE;
} }
Py_RETURN_FALSE; Py_RETURN_FALSE;

View File

@ -54,6 +54,12 @@ Py_FrozenMain(int argc, char **argv)
Py_ExitStatusException(status); Py_ExitStatusException(status);
} }
PyInterpreterState *interp = PyInterpreterState_Get();
if (_PyInterpreterState_SetRunningMain(interp) < 0) {
PyErr_Print();
exit(1);
}
#ifdef MS_WINDOWS #ifdef MS_WINDOWS
PyWinFreeze_ExeInit(); PyWinFreeze_ExeInit();
#endif #endif
@ -83,6 +89,9 @@ Py_FrozenMain(int argc, char **argv)
#ifdef MS_WINDOWS #ifdef MS_WINDOWS
PyWinFreeze_ExeTerm(); PyWinFreeze_ExeTerm();
#endif #endif
_PyInterpreterState_SetNotRunningMain(interp);
if (Py_FinalizeEx() < 0) { if (Py_FinalizeEx() < 0) {
sts = 120; sts = 120;
} }

View File

@ -1042,24 +1042,15 @@ _PyInterpreterState_IsRunningMain(PyInterpreterState *interp)
if (interp->threads.main != NULL) { if (interp->threads.main != NULL) {
return 1; return 1;
} }
// For now, we assume the main interpreter is always running. // Embedders might not know to call _PyInterpreterState_SetRunningMain(),
if (_Py_IsMainInterpreter(interp)) { // so their main thread wouldn't show it is running the main interpreter's
return 1; // program. (Py_Main() doesn't have this problem.) For now this isn't
} // critical. If it were, we would need to infer "running main" from other
// information, like if it's the main interpreter. We used to do that
// but the naive approach led to some inconsistencies that caused problems.
return 0; return 0;
} }
#ifndef NDEBUG
static int
is_running_main(PyThreadState *tstate)
{
if (tstate->interp->threads.main != NULL) {
return tstate == tstate->interp->threads.main;
}
return 0;
}
#endif
int int
_PyThreadState_IsRunningMain(PyThreadState *tstate) _PyThreadState_IsRunningMain(PyThreadState *tstate)
{ {
@ -1067,9 +1058,8 @@ _PyThreadState_IsRunningMain(PyThreadState *tstate)
if (interp->threads.main != NULL) { if (interp->threads.main != NULL) {
return tstate == interp->threads.main; return tstate == interp->threads.main;
} }
if (_Py_IsMainInterpreter(interp)) { // See the note in _PyInterpreterState_IsRunningMain() about
return tstate->thread_id == interp->runtime->main_thread; // possible false negatives here for embedders.
}
return 0; return 0;
} }
@ -1571,7 +1561,7 @@ PyThreadState_Clear(PyThreadState *tstate)
{ {
assert(tstate->_status.initialized && !tstate->_status.cleared); assert(tstate->_status.initialized && !tstate->_status.cleared);
assert(current_fast_get()->interp == tstate->interp); assert(current_fast_get()->interp == tstate->interp);
assert(!is_running_main(tstate)); assert(!_PyThreadState_IsRunningMain(tstate));
// XXX assert(!tstate->_status.bound || tstate->_status.unbound); // XXX assert(!tstate->_status.bound || tstate->_status.unbound);
tstate->_status.finalizing = 1; // just in case tstate->_status.finalizing = 1; // just in case
@ -1670,7 +1660,7 @@ tstate_delete_common(PyThreadState *tstate)
assert(tstate->_status.cleared && !tstate->_status.finalized); assert(tstate->_status.cleared && !tstate->_status.finalized);
assert(tstate->state != _Py_THREAD_ATTACHED); assert(tstate->state != _Py_THREAD_ATTACHED);
tstate_verify_not_active(tstate); tstate_verify_not_active(tstate);
assert(!is_running_main(tstate)); assert(!_PyThreadState_IsRunningMain(tstate));
PyInterpreterState *interp = tstate->interp; PyInterpreterState *interp = tstate->interp;
if (interp == NULL) { if (interp == NULL) {