8000 bpo-30439: Add some helpful low-level functions for subinterpreters. by ericsnowcurrently · Pull Request #1802 · python/cpython · GitHub
[go: up one dir, main page]
Skip to content

bpo-30439: Add some helpful low-level functions for subinterpreters. #1802

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.

Sign up for GitHub

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

Closed
wants to merge 28 commits into from
Closed

bpo-30439: Add some helpful low-level functions for subinterpreters. #1802

Changes from 1 commit
Commits
Show all changes
28 commits
Select commit Hold shift + click to select a range
8eb5adf
Add the _interpreters module to the stdlib.
ericsnowcurrently Dec 14, 2016
457567f
Add create() and destroy().
ericsnowcurrently Dec 29, 2016
e6af9f3
Finish nearly all the create/destroy tests.
ericsnowcurrently Jan 1, 2017
335967e
Add run_string().
ericsnowcurrently Dec 29, 2016
d2df973
Get tricky tests working.
ericsnowcurrently Jan 2, 2017
b70a496
Add a test for a still running interpreter when main exits.
ericsnowcurrently Jan 2, 2017
6f2d28f
Add run_string_unrestricted().
ericsnowcurrently Jan 4, 2017
80a931b
Exit out of the child process.
ericsnowcurrently Jan 4, 2017
6aa7d9c
Resolve several TODOs.
ericsnowcurrently Jan 4, 2017
083e13c
Set up the execution namespace before switching threads.
ericsnowcurrently Jan 4, 2017
ce081a7
Run in a copy of __main__.
ericsnowcurrently Jan 4, 2017
ec05cf5
Close stdin and stdout after the proc finishes.
ericsnowcurrently Jan 4, 2017
fe90466
Clean up a test.
ericsnowcurrently Jan 4, 2017
9082017
Chain exceptions during cleanup.
ericsnowcurrently Jan 4, 2017
21865d4
Finish the module docs.
ericsnowcurrently Jan 4, 2017
0342a4f
Fix docs.
ericsnowcurrently May 23, 2017
e9d9b04
Fix includes.
ericsnowcurrently Dec 5, 2017
722ae94
Add _interpreters.is_shareable().
ericsnowcurrently Nov 28, 2017
061ae13
Add _PyObject_CheckShareable().
ericsnowcurrently Dec 4, 2017
9a365ec
Add _PyCrossInterpreterData.
ericsnowcurrently Dec 4, 2017
8f299d4
Use the shared data in run() safely.
ericsnowcurrently Dec 7, 2017
92029a1
Do not use a copy of the __main__ ns.
ericsnowcurrently Dec 7, 2017
52c9c2f
Never return the execution namespace.
ericsnowcurrently Dec 8, 2017
a797883
Group sharing-related code.
ericsnowcurrently Dec 8, 2017
777838a
Fix a refcount.
ericsnowcurrently Dec 8, 2017
ab8f175
Add get_current() and enumerate().
ericsnowcurrently Dec 29, 2016
c50c51c
Add is_running().
ericsnowcurrently Dec 29, 2016
271d20d
Add get_main().
ericsnowcurrently Jan 4, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Set up the execution namespace before switching threads.
  • Loading branch information
@ericsnowcurrently
ericsnowcurrently committed Dec 5, 2017
commit 083e13c01f7c9a840cb8dd5a9268a41aa622f4b0
66 changes: 38 additions & 28 deletions Modules/_interpretersmodule.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -89,52 +89,62 @@ _ensure_not_running(PyInterpreterState *interp)
return 0;
}

static PyObject *
_run_string(PyInterpreterState *interp, const char *codestr, PyObject *updates)
static int
_run_string(PyInterpreterState *interp, const char *codestr, PyObject *ns)
{
if (_ensure_not_running(interp) < 0)
return NULL;

// Switch to interpreter.
PyThreadState *tstate = PyInterpreterState_ThreadHead(interp);
PyThreadState *save_tstate = PyThreadState_Swap(tstate);

// Run the string (see PyRun_SimpleStringFlags).
PyObject *exc = NULL, *value = NULL, *tb = NULL;
PyObject *ns = NULL;
// XXX Force a fresh __main__ module?
PyObject *m = PyImport_AddModule("__main__");
if (m == NULL) {
PyErr_Fetch(&exc, &value, &tb);
goto done;
}
ns = PyModule_GetDict(m);
if (ns == NULL) {
PyErr_Fetch(&exc, &value, &tb);
goto done;
}
if (updates != NULL && PyDict_Merge(ns, updates, 0) < 0) {
PyErr_Fetch(&exc, &value, &tb);
goto done;
}
PyObject *result = PyRun_StringFlags(codestr, Py_file_input, ns, ns, NULL);
if (result == NULL) {
ns = NULL;
// Get the exception from the subinterpreter.
PyErr_Fetch(&exc, &value, &tb);
goto done;
} else {
Py_DECREF(result); // We throw away the result.
}
Py_DECREF(result); // We throw away the result.
Py_INCREF(ns); // It is a borrowed reference.

done:
// Switch back.
if (save_tstate != NULL)
PyThreadState_Swap(save_tstate);

// Propagate any exception out to the caller.
PyErr_Restore(exc, value, tb);

return result == NULL ? -1 : 0;
}

static PyObject *
_run_string_in_main(PyInterpreterState *interp, const char *codestr,
PyObject *updates)
{
if (_ensure_not_running(interp) < 0)
return NULL;

// Get the namespace in which to execute.
// XXX Force a fresh __main__ module?
PyObject *m = PyMapping_GetItemString(interp->modules, "__main__");
if (m == NULL)
return NULL;
PyObject *orig = PyModule_GetDict(m); // borrowed
Py_DECREF(m);
if (orig == NULL)
return NULL;
PyObject *ns = PyDict_Copy(orig);
if (ns == NULL)
return NULL;
if (updates != NULL && PyDict_Merge(ns, updates, 0) < 0) {
Py_DECREF(ns);
return NULL;
}

if (_run_string(interp, codestr, ns) < 0) {
Py_DECREF(ns);
return NULL;
}

return ns;
}

Expand Down Expand Up @@ -277,7 +287,7 @@ interp_run_string(PyObject *self, PyObject *args)
}

// Run the code in the interpreter.
PyObject *ns = _run_string(interp, codestr, NULL);
PyObject *ns = _run_string_in_main(interp, codestr, NULL);
if (ns == NULL)
return NULL;
else
Expand Down Expand Up @@ -328,7 +338,7 @@ interp_run_string_unrestricted(PyObject *self, PyObject *args)
}

// Run the code in the interpreter.
return _run_string(interp, codestr, ns);
return _run_string_in_main(interp, codestr, ns);
}

PyDoc_STRVAR(run_string_unrestricted_doc,
Expand Down
0