#ifndef Py_BUILD_CORE_BUILTIN

# define Py_BUILD_CORE_MODULE 1

#include "Python.h"

#include "pycore_abstract.h" // _PyIndex_Check()

#include "pycore_crossinterp.h" // _PyXIData_t

#include "pycore_interp.h" // _PyInterpreterState_IDIncref()

#include "pycore_initconfig.h" // _PyErr_SetFromPyStatus()

#include "pycore_modsupport.h" // _PyArg_BadArgument()

#include "pycore_namespace.h" // _PyNamespace_New()

#include "pycore_pybuffer.h" // _PyBuffer_ReleaseInInterpreterAndRawFree()

#include "pycore_pyerrors.h" // _Py_excinfo

#include "pycore_pylifecycle.h" // _PyInterpreterConfig_AsDict()

#include "pycore_pystate.h" // _PyInterpreterState_SetRunningMain()

#include "marshal.h" // PyMarshal_ReadObjectFromString()

#include "_interpreters_common.h"

#define MODULE_NAME _interpreters

#define MODULE_NAME_STR Py_STRINGIFY(MODULE_NAME)

#define MODINIT_FUNC_NAME RESOLVE_MODINIT_FUNC_NAME(MODULE_NAME)

static PyInterpreterState *

_get_current_interp(void)

{

// PyInterpreterState_Get() aborts if lookup fails, so don't need

// to check the result for NULL.

return PyInterpreterState_Get();

}

#define look_up_interp _PyInterpreterState_LookUpIDObject

static PyObject *

_get_current_module(void)

{

PyObject *name = PyUnicode_FromString(MODULE_NAME_STR);

if (name == NULL) {

return NULL;

}

PyObject *mod = PyImport_GetModule(name);

Py_DECREF(name);

if (mod == NULL) {

return NULL;

}

assert(mod != Py_None);

return mod;

}

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;

}

typedef struct {

PyObject_HEAD

Py_buffer *view;

int64_t interpid;

} XIBufferViewObject;

#define XIBufferViewObject_CAST(op) ((XIBufferViewObject *)(op))

static PyObject *

xibufferview_from_xid(PyTypeObject *cls, _PyXIData_t *data)

{

assert(_PyXIData_DATA(data) != NULL);

assert(_PyXIData_OBJ(data) == NULL);

assert(_PyXIData_INTERPID(data) >= 0);

XIBufferViewObject *self = PyObject_Malloc(sizeof(XIBufferViewObject));

if (self == NULL) {

return NULL;

}

PyObject_Init((PyObject *)self, cls);

self->view = (Py_buffer *)_PyXIData_DATA(data);

self->interpid = _PyXIData_INTERPID(data);

return (PyObject *)self;

}

static void

xibufferview_dealloc(PyObject *op)

{

XIBufferViewObject *self = XIBufferViewObject_CAST(op);

PyInterpreterState *interp = _PyInterpreterState_LookUpID(self->interpid);

/* If the interpreter is no longer alive then we have problems,

assert(interp != NULL);

if (_PyBuffer_ReleaseInInterpreterAndRawFree(interp, self->view) < 0) {

// XXX Emit a warning?

PyErr_Clear();

}

PyTypeObject *tp = Py_TYPE(self);

tp->tp_free(self);

/* "Instances of heap-allocated types hold a reference to their type."

// XXX Why don't we implement Py_TPFLAGS_HAVE_GC, e.g. Py_tp_traverse,

// like we do for _abc._abc_data?

Py_DECREF(tp);

}

static int

xibufferview_getbuf(PyObject *op, Py_buffer *view, int flags)

{

/* Only PyMemoryView_FromObject() should ever call this,

XIBufferViewObject *self = XIBufferViewObject_CAST(op);

*view = *self->view;

view->obj = op;

// XXX Should we leave it alone?

view->internal = NULL;

return 0;

}

static PyType_Slot XIBufferViewType_slots[] = {

{Py_tp_dealloc, xibufferview_dealloc},

{Py_bf_getbuffer, xibufferview_getbuf},

// We don't bother with Py_bf_releasebuffer since we don't need it.

{0, NULL},

};

static PyType_Spec XIBufferViewType_spec = {

.name = MODULE_NAME_STR ".CrossInterpreterBufferView",

.basicsize = sizeof(XIBufferViewObject),

.flags = (Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE |

Py_TPFLAGS_DISALLOW_INSTANTIATION | Py_TPFLAGS_IMMUTABLETYPE),

.slots = XIBufferViewType_slots,

};

static PyTypeObject * _get_current_xibufferview_type(void);

static PyObject *

_memoryview_from_xid(_PyXIData_t *data)

{

PyTypeObject *cls = _get_current_xibufferview_type();

if (cls == NULL) {

return NULL;

}

PyObject *obj = xibufferview_from_xid(cls, data);

if (obj == NULL) {

return NULL;

}

return PyMemoryView_FromObject(obj);

}

static int

_memoryview_shared(PyThreadState *tstate, PyObject *obj, _PyXIData_t *data)

{

Py_buffer *view = PyMem_RawMalloc(sizeof(Py_buffer));

if (view == NULL) {

return -1;

}

if (PyObject_GetBuffer(obj, view, PyBUF_FULL_RO) < 0) {

PyMem_RawFree(view);

return -1;

}

_PyXIData_Init(data, tstate->interp, view, NULL, _memoryview_from_xid);

return 0;

}

static int

register_memoryview_xid(PyObject *mod, PyTypeObject **p_state)

{

// XIBufferView

assert(*p_state == NULL);

PyTypeObject *cls = (PyTypeObject *)PyType_FromModuleAndSpec(

mod, &XIBufferViewType_spec, NULL);

if (cls == NULL) {

return -1;

}

if (PyModule_AddType(mod, cls) < 0) {

Py_DECREF(cls);

return -1;

}

*p_state = cls;

// Register XID for the builtin memoryview type.

if (ensure_xid_class(&PyMemoryView_Type, _memoryview_shared) < 0) {

return -1;

}

// We don't ever bother un-registering memoryview.

return 0;

}

typedef struct {

int _notused;

/* heap types */

PyTypeObject *XIBufferViewType;

} module_state;

static inline module_state *

get_module_state(PyObject *mod)

{

assert(mod != NULL);

module_state *state = PyModule_GetState(mod);

assert(state != NULL);

return state;

}

static module_state *

_get_current_module_state(void)

{

PyObject *mod = _get_current_module();

if (mod == NULL) {

// XXX import it?

PyErr_SetString(PyExc_RuntimeError,

MODULE_NAME_STR " module not imported yet");

return NULL;

}

module_state *state = get_module_state(mod);

Py_DECREF(mod);

return state;

}

static int

traverse_module_state(module_state *state, visitproc visit, void *arg)

{

/* heap types */

Py_VISIT(state->XIBufferViewType);

return 0;

}

static int

clear_module_state(module_state *state)

{

/* heap types */

Py_CLEAR(state->XIBufferViewType);

return 0;

}

static PyTypeObject *

_get_current_xibufferview_type(void)

{

module_state *state = _get_current_module_state();

if (state == NULL) {

return NULL;

}

return state->XIBufferViewType;

}

static const char *

check_code_str(PyUnicodeObject *text)

{

assert(text != NULL);

if (PyUnicode_GET_LENGTH(text) == 0) {

return "too short";

}

// XXX Verify that it parses?

return NULL;

}

static const char *

check_code_object(PyCodeObject *code)

{

assert(code != NULL);

if (code->co_argcount > 0

|| code->co_posonlyargcount > 0

|| code->co_kwonlyargcount > 0

|| code->co_flags & (CO_VARARGS | CO_VARKEYWORDS))

{

return "arguments not supported";

}

if (code->co_ncellvars > 0) {

return "closures not supported";

}

// We trust that no code objects under co_consts have unbound cell vars.

if (_PyCode_HAS_EXECUTORS(code) || _PyCode_HAS_INSTRUMENTATION(code)) {

return "only basic functions are supported";

}

if (code->_co_monitoring != NULL) {

return "only basic functions are supported";

}

if (code->co_extra != NULL) {

return "only basic functions are supported";

}

return NULL;

}

#define RUN_TEXT 1

#define RUN_CODE 2

static const char *

get_code_str(PyObject *arg, Py_ssize_t *len_p, PyObject **bytes_p, int *flags_p)

{

const char *codestr = NULL;

Py_ssize_t len = -1;

PyObject *bytes_obj = NULL;

int flags = 0;

if (PyUnicode_Check(arg)) {

assert(PyUnicode_CheckExact(arg)

&& (check_code_str((PyUnicodeObject *)arg) == NULL));

codestr = PyUnicode_AsUTF8AndSize(arg, &len);

if (codestr == NULL) {

return NULL;

}

if (strlen(codestr) != (size_t)len) {

PyErr_SetString(PyExc_ValueError,

"source code string cannot contain null bytes");

return NULL;

}

flags = RUN_TEXT;

}

else {

assert(PyCode_Check(arg)

&& (check_code_object((PyCodeObject *)arg) == NULL));

flags = RUN_CODE;

// Serialize the code object.

bytes_obj = PyMarshal_WriteObjectToString(arg, Py_MARSHAL_VERSION);

if (bytes_obj == NULL) {

return NULL;

}

codestr = PyBytes_AS_STRING(bytes_obj);

len = PyBytes_GET_SIZE(bytes_obj);

}

*flags_p = flags;

*bytes_p = bytes_obj;

*len_p = len;

return codestr;

}

static int

init_named_config(PyInterpreterConfig *config, const char *name)

{

if (name == NULL

|| strcmp(name, "") == 0

|| strcmp(name, "default") == 0)

{

name = "isolated";

}

if (strcmp(name, "isolated") == 0) {

*config = (PyInterpreterConfig)_PyInterpreterConfig_INIT;

}

else if (strcmp(name, "legacy") == 0) {

*config = (PyInterpreterConfig)_PyInterpreterConfig_LEGACY_INIT;

}

else if (strcmp(name, "empty") == 0) {

*config = (PyInterpreterConfig){0};

}

else {

PyErr_Format(PyExc_ValueError,

"unsupported config name '%s'", name);

return -1;

}

return 0;

}

static int

config_from_object(PyObject *configobj, PyInterpreterConfig *config)

{

if (configobj == NULL || configobj == Py_None) {

if (init_named_config(config, NULL) < 0) {

return -1;

}

}

else if (PyUnicode_Check(configobj)) {

const char *utf8name = PyUnicode_AsUTF8(configobj);

if (utf8name == NULL) {

return -1;

}

if (init_named_config(config, utf8name) < 0) {

return -1;

}

}

else {

PyObject *dict = PyObject_GetAttrString(configobj, "__dict__");

if (dict == NULL) {

PyErr_Format(PyExc_TypeError, "bad config %R", configobj);

return -1;

}

int res = _PyInterpreterConfig_InitFromDict(config, dict);

Py_DECREF(dict);

if (res < 0) {

return -1;

}

}

return 0;

}

static int

_run_script(PyObject *ns, const char *codestr, Py_ssize_t codestrlen, int flags)

{

PyObject *result = NULL;

if (flags & RUN_TEXT) {

result = PyRun_StringFlags(codestr, Py_file_input, ns, ns, NULL);

}

else if (flags & RUN_CODE) {

PyObject *code = PyMarshal_ReadObjectFromString(codestr, codestrlen);

if (code != NULL) {

result = PyEval_EvalCode(code, ns, ns);

Py_DECREF(code);

}

}

else {

Py_UNREACHABLE();

}

if (result == NULL) {

return -1;

}

Py_DECREF(result); // We throw away the result.

return 0;

}

static int

_run_in_interpreter(PyInterpreterState *interp,

const char *codestr, Py_ssize_t codestrlen,

PyObject *shareables, int flags,

PyObject **p_excinfo)

{

assert(!PyErr_Occurred());

_PyXI_session session = {0};

// Prep and switch interpreters.

if (_PyXI_Enter(&session, interp, shareables) < 0) {

if (PyErr_Occurred()) {

// If an error occured at this step, it means that interp

// was not prepared and switched.

return -1;

}

// Now, apply the error from another interpreter:

PyObject *excinfo = _PyXI_ApplyError(session.error);

if (excinfo != NULL) {

*p_excinfo = excinfo;

}

assert(PyErr_Occurred());

return -1;

}

// Run the script.

int res = _run_script(session.main_ns, codestr, codestrlen, flags);

// Clean up and switch back.

_PyXI_Exit(&session);

// Propagate any exception out to the caller.

assert(!PyErr_Occurred());

if (res < 0) {

PyObject *excinfo = _PyXI_ApplyCapturedException(&session);

if (excinfo != NULL) {

*p_excinfo = excinfo;

}

}

else {

assert(!_PyXI_HasCapturedException(&session));

}

return res;

}

static long

get_whence(PyInterpreterState *interp)

{

return _PyInterpreterState_GetWhence(interp);

}

static PyInterpreterState *

resolve_interp(PyObject *idobj, int restricted, int reqready, const char *op)

{

PyInterpreterState *interp;

if (idobj == NULL) {

interp = PyInterpreterState_Get();

}

else {

interp = look_up_interp(idobj);

if (interp == NULL) {

return NULL;

}

}

if (reqready && !_PyInterpreterState_IsReady(interp)) {

if (idobj == NULL) {

PyErr_Format(PyExc_InterpreterError,

"cannot %s current interpreter (not ready)", op);

}

else {

PyErr_Format(PyExc_InterpreterError,

"cannot %s interpreter %R (not ready)", op, idobj);

}

return NULL;

}

if (restricted && get_whence(interp) != _PyInterpreterState_WHENCE_STDLIB) {

if (idobj == NULL) {

PyErr_Format(PyExc_InterpreterError,

"cannot %s unrecognized current interpreter", op);

}

else {

PyErr_Format(PyExc_InterpreterError,

"cannot %s unrecognized interpreter %R", op, idobj);

}

return NULL;

}

return interp;

}

static PyObject *

get_summary(PyInterpreterState *interp)

{

PyObject *idobj = _PyInterpreterState_GetIDObject(interp);

if (idobj == NULL) {

return NULL;

}

PyObject *whenceobj = PyLong_FromLong(

get_whence(interp));

if (whenceobj == NULL) {

Py_DECREF(idobj);

return NULL;

}

PyObject *res = PyTuple_Pack(2, idobj, whenceobj);

Py_DECREF(idobj);

Py_DECREF(whenceobj);

return res;

}

static PyObject *

interp_new_config(PyObject *self, PyObject *args, PyObject *kwds)

{

const char *name = NULL;

if (!PyArg_ParseTuple(args, "|s:" MODULE_NAME_STR ".new_config",

&name))

{

return NULL;

}

PyObject *overrides = kwds;

PyInterpreterConfig config;

if (init_named_config(&config, name) < 0) {

return NULL;

}

if (overrides != NULL && PyDict_GET_SIZE(overrides) > 0) {

if (_PyInterpreterConfig_UpdateFromDict(&config, overrides) < 0) {

return NULL;

}

}

PyObject *dict = _PyInterpreterConfig_AsDict(&config);

if (dict == NULL) {

return NULL;

}

PyObject *configobj = _PyNamespace_New(dict);

Py_DECREF(dict);

return configobj;

}

PyDoc_STRVAR(new_config_doc,

overriding the initial values.");

static PyObject *

interp_create(PyObject *self, PyObject *args, PyObject *kwds)

{

static char *kwlist[] = {"config", "reqrefs", NULL};

PyObject *configobj = NULL;

int reqrefs = 0;

if (!PyArg_ParseTupleAndKeywords(args, kwds, "|O$p:create", kwlist,

&configobj, &reqrefs)) {

return NULL;

}

PyInterpreterConfig config;

if (config_from_object(configobj, &config) < 0) {

return NULL;

}

long whence = _PyInterpreterState_WHENCE_STDLIB;

PyInterpreterState *interp = \

_PyXI_NewInterpreter(&config, &whence, NULL, NULL);

if (interp == NULL) {

// XXX Move the chained exception to interpreters.create()?

PyObject *exc = PyErr_GetRaisedException();

assert(exc != NULL);

PyErr_SetString(PyExc_InterpreterError, "interpreter creation failed");

_PyErr_ChainExceptions1(exc);

return NULL;

}

assert(_PyInterpreterState_IsReady(interp));

PyObject *idobj = _PyInterpreterState_GetIDObject(interp);

if (idobj == NULL) {

_PyXI_EndInterpreter(interp, NULL, NULL);

return NULL;

}

if (reqrefs) {

// Decref to 0 will destroy the interpreter.

_PyInterpreterState_RequireIDRef(interp, 1);

}

return idobj;

}

PyDoc_STRVAR(create_doc,

is \"isolated\".");

static PyObject *

interp_destroy(PyObject *self, PyObject *args, PyObject *kwds)

{

static char *kwlist[] = {"id", "restrict", NULL};

PyObject *id;

int restricted = 0;

// XXX Use "L" for id?

if (!PyArg_ParseTupleAndKeywords(args, kwds,

"O|$p:destroy", kwlist, &id, &restricted))

{

return NULL;

}

// Look up the interpreter.

int reqready = 0;

PyInterpreterState *interp = \

resolve_interp(id, restricted, reqready, "destroy");

if (interp == NULL) {

return NULL;

}

// Ensure we don't try to destroy the current interpreter.

PyInterpreterState *current = _get_current_interp();

if (current == NULL) {

return NULL;

}

if (interp == current) {

PyErr_SetString(PyExc_InterpreterError,

"cannot destroy the current interpreter");

return NULL;

}

// Ensure the interpreter isn't running.

/* XXX We *could* support destroying a running interpreter but

if (is_running_main(interp)) {

PyErr_Format(PyExc_InterpreterError, "interpreter running");

return NULL;

}

// Destroy the interpreter.

_PyXI_EndInterpreter(interp, NULL, NULL);

Py_RETURN_NONE;

}

PyDoc_STRVAR(destroy_doc,

So does an unrecognized ID.");

static PyObject *

interp_list_all(PyObject *self, PyObject *args, PyObject *kwargs)

{

static char *kwlist[] = {"require_ready", NULL};

int reqready = 0;

if (!PyArg_ParseTupleAndKeywords(args, kwargs,

"|$p:" MODULE_NAME_STR ".list_all",

kwlist, &reqready))

{

return NULL;

}

PyObject *ids = PyList_New(0);

if (ids == NULL) {

return NULL;

}

PyInterpreterState *interp = PyInterpreterState_Head();

while (interp != NULL) {

if (!reqready || _PyInterpreterState_IsReady(interp)) {

PyObject *item = get_summary(interp);

if (item == NULL) {

Py_DECREF(ids);

return NULL;

}

// insert at front of list

int res = PyList_Insert(ids, 0, item);

Py_DECREF(item);

if (res < 0) {

Py_DECREF(ids);

return NULL;

}

}

interp = PyInterpreterState_Next(interp);

}

return ids;

}

PyDoc_STRVAR(list_all_doc,

Return a list containing the ID of every existing interpreter.");

static PyObject *

interp_get_current(PyObject *self, PyObject *Py_UNUSED(ignored))

{

PyInterpreterState *interp =_get_current_interp();

if (interp == NULL) {

return NULL;

}

assert(_PyInterpreterState_IsReady(interp));

return get_summary(interp);

}

PyDoc_STRVAR(get_current_doc,

Return the ID of current interpreter.");

static PyObject *

interp_get_main(PyObject *self, PyObject *Py_UNUSED(ignored))

{

PyInterpreterState *interp = _PyInterpreterState_Main();

assert(_PyInterpreterState_IsReady(interp));

return get_summary(interp);

}

PyDoc_STRVAR(get_main_doc,

Return the ID of main interpreter.");

static PyObject *

interp_set___main___attrs(PyObject *self, PyObject *args, PyObject *kwargs)

{

static char *kwlist[] = {"id", "updates", "restrict", NULL};

PyObject *id, *updates;

int restricted = 0;

if (!PyArg_ParseTupleAndKeywords(args, kwargs,

"OO|$p:" MODULE_NAME_STR ".set___main___attrs",

kwlist, &id, &updates, &restricted))

{

return NULL;

}

// Look up the interpreter.

int reqready = 1;

PyInterpreterState *interp = \

resolve_interp(id, restricted, reqready, "update __main__ for");

if (interp == NULL) {

return NULL;

}

// Check the updates.

if (updates != Py_None) {

Py_ssize_t size = PyObject_Size(updates);

if (size < 0) {

return NULL;

}

if (size == 0) {

PyErr_SetString(PyExc_ValueError,

"arg 2 must be a non-empty mapping");

return NULL;

}

}

_PyXI_session session = {0};

// Prep and switch interpreters, including apply the updates.

if (_PyXI_Enter(&session, interp, updates) < 0) {

if (!PyErr_Occurred()) {

_PyXI_ApplyCapturedException(&session);

assert(PyErr_Occurred());

}

else {

assert(!_PyXI_HasCapturedException(&session));

}

return NULL;

}

// Clean up and switch back.

_PyXI_Exit(&session);

Py_RETURN_NONE;

}

PyDoc_STRVAR(set___main___attrs_doc,

Bind the given attributes in the interpreter's __main__ module.");

static PyUnicodeObject *

convert_script_arg(PyObject *arg, const char *fname, const char *displayname,

const char *expected)

{

PyUnicodeObject *str = NULL;

if (PyUnicode_CheckExact(arg)) {

str = (PyUnicodeObject *)Py_NewRef(arg);

}

else if (PyUnicode_Check(arg)) {

// XXX str = PyUnicode_FromObject(arg);

str = (PyUnicodeObject *)Py_NewRef(arg);

}

else {

_PyArg_BadArgument(fname, displayname, expected, arg);

return NULL;

}

const char *err = check_code_str(str);

if (err != NULL) {

Py_DECREF(str);

PyErr_Format(PyExc_ValueError,

"%.200s(): bad script text (%s)", fname, err);

return NULL;

}

return str;

}

static PyCodeObject *

convert_code_arg(PyObject *arg, const char *fname, const char *displayname,

const char *expected)

{

const char *kind = NULL;

PyCodeObject *code = NULL;

if (PyFunction_Check(arg)) {

if (PyFunction_GetClosure(arg) != NULL) {

PyErr_Format(PyExc_ValueError,

"%.200s(): closures not supported", fname);

return NULL;

}

code = (PyCodeObject *)PyFunction_GetCode(arg);

if (code == NULL) {

if (PyErr_Occurred()) {

// This chains.

PyErr_Format(PyExc_ValueError,

"%.200s(): bad func", fname);

}

else {

PyErr_Format(PyExc_ValueError,

"%.200s(): func.__code__ missing", fname);

}

return NULL;

}

Py_INCREF(code);

kind = "func";

}

else if (PyCode_Check(arg)) {

code = (PyCodeObject *)Py_NewRef(arg);

kind = "code object";

}

else {

_PyArg_BadArgument(fname, displayname, expected, arg);

return NULL;

}

const char *err = check_code_object(code);

if (err != NULL) {

Py_DECREF(code);

PyErr_Format(PyExc_ValueError,

"%.200s(): bad %s (%s)", fname, kind, err);

return NULL;

}

return code;

}

static int

_interp_exec(PyObject *self, PyInterpreterState *interp,

PyObject *code_arg, PyObject *shared_arg, PyObject **p_excinfo)

{

if (shared_arg != NULL && !PyDict_CheckExact(shared_arg)) {

PyErr_SetString(PyExc_TypeError, "expected 'shared' to be a dict");

return -1;

}

// Extract code.

Py_ssize_t codestrlen = -1;

PyObject *bytes_obj = NULL;

int flags = 0;

const char *codestr = get_code_str(code_arg,

&codestrlen, &bytes_obj, &flags);

if (codestr == NULL) {

return -1;

}

// Run the code in the interpreter.

int res = _run_in_interpreter(interp, codestr, codestrlen,

shared_arg, flags, p_excinfo);

Py_XDECREF(bytes_obj);

if (res < 0) {

return -1;

}

return 0;

}

static PyObject *

interp_exec(PyObject *self, PyObject *args, PyObject *kwds)

{

static char *kwlist[] = {"id", "code", "shared", "restrict", NULL};

PyObject *id, *code;

PyObject *shared = NULL;

int restricted = 0;

if (!PyArg_ParseTupleAndKeywords(args, kwds,

"OO|O$p:" MODULE_NAME_STR ".exec", kwlist,

&id, &code, &shared, &restricted))

{

return NULL;

}

int reqready = 1;

PyInterpreterState *interp = \

resolve_interp(id, restricted, reqready, "exec code for");

if (interp == NULL) {

return NULL;

}

const char *expected = "a string, a function, or a code object";

if (PyUnicode_Check(code)) {

code = (PyObject *)convert_script_arg(code, MODULE_NAME_STR ".exec",

"argument 2", expected);

}

else {