mirror of https://github.com/python/cpython
Issue #7544: Preallocate thread memory before creating the thread to avoid a
fatal error in low memory condition.
This commit is contained in:
parent
2379bb664a
commit
71fb87e64c
|
@ -105,6 +105,8 @@ PyAPI_FUNC(void) PyInterpreterState_Clear(PyInterpreterState *);
|
|||
PyAPI_FUNC(void) PyInterpreterState_Delete(PyInterpreterState *);
|
||||
|
||||
PyAPI_FUNC(PyThreadState *) PyThreadState_New(PyInterpreterState *);
|
||||
PyAPI_FUNC(PyThreadState *) _PyThreadState_Prealloc(PyInterpreterState *);
|
||||
PyAPI_FUNC(void) _PyThreadState_Init(PyThreadState *);
|
||||
PyAPI_FUNC(void) PyThreadState_Clear(PyThreadState *);
|
||||
PyAPI_FUNC(void) PyThreadState_Delete(PyThreadState *);
|
||||
#ifdef WITH_THREAD
|
||||
|
|
|
@ -12,6 +12,9 @@ What's New in Python 2.7 alpha 4?
|
|||
Core and Builtins
|
||||
-----------------
|
||||
|
||||
- Issue #7544: Preallocate thread memory before creating the thread to avoid
|
||||
a fatal error in low memory condition.
|
||||
|
||||
- Issue #7820: The parser tokenizer restores all bytes in the right if
|
||||
the BOM check fails.
|
||||
|
||||
|
|
|
@ -428,6 +428,7 @@ struct bootstate {
|
|||
PyObject *func;
|
||||
PyObject *args;
|
||||
PyObject *keyw;
|
||||
PyThreadState *tstate;
|
||||
};
|
||||
|
||||
static void
|
||||
|
@ -437,8 +438,9 @@ t_bootstrap(void *boot_raw)
|
|||
PyThreadState *tstate;
|
||||
PyObject *res;
|
||||
|
||||
tstate = PyThreadState_New(boot->interp);
|
||||
|
||||
tstate = boot->tstate;
|
||||
tstate->thread_id = PyThread_get_thread_ident();
|
||||
_PyThreadState_Init(tstate);
|
||||
PyEval_AcquireThread(tstate);
|
||||
nb_threads++;
|
||||
res = PyEval_CallObjectWithKeywords(
|
||||
|
@ -503,6 +505,11 @@ thread_PyThread_start_new_thread(PyObject *self, PyObject *fargs)
|
|||
boot->func = func;
|
||||
boot->args = args;
|
||||
boot->keyw = keyw;
|
||||
boot->tstate = _PyThreadState_Prealloc(boot->interp);
|
||||
if (boot->tstate == NULL) {
|
||||
PyMem_DEL(boot);
|
||||
return PyErr_NoMemory();
|
||||
}
|
||||
Py_INCREF(func);
|
||||
Py_INCREF(args);
|
||||
Py_XINCREF(keyw);
|
||||
|
@ -513,6 +520,7 @@ thread_PyThread_start_new_thread(PyObject *self, PyObject *fargs)
|
|||
Py_DECREF(func);
|
||||
Py_DECREF(args);
|
||||
Py_XDECREF(keyw);
|
||||
PyThreadState_Clear(boot->tstate);
|
||||
PyMem_DEL(boot);
|
||||
return NULL;
|
||||
}
|
||||
|
|
|
@ -154,8 +154,8 @@ threadstate_getframe(PyThreadState *self)
|
|||
return self->frame;
|
||||
}
|
||||
|
||||
PyThreadState *
|
||||
PyThreadState_New(PyInterpreterState *interp)
|
||||
static PyThreadState *
|
||||
new_threadstate(PyInterpreterState *interp, int init)
|
||||
{
|
||||
PyThreadState *tstate = (PyThreadState *)malloc(sizeof(PyThreadState));
|
||||
|
||||
|
@ -193,9 +193,8 @@ PyThreadState_New(PyInterpreterState *interp)
|
|||
tstate->c_profileobj = NULL;
|
||||
tstate->c_traceobj = NULL;
|
||||
|
||||
#ifdef WITH_THREAD
|
||||
_PyGILState_NoteThreadState(tstate);
|
||||
#endif
|
||||
if (init)
|
||||
_PyThreadState_Init(tstate);
|
||||
|
||||
HEAD_LOCK();
|
||||
tstate->next = interp->tstate_head;
|
||||
|
@ -206,6 +205,25 @@ PyThreadState_New(PyInterpreterState *interp)
|
|||
return tstate;
|
||||
}
|
||||
|
||||
PyThreadState *
|
||||
PyThreadState_New(PyInterpreterState *interp)
|
||||
{
|
||||
return new_threadstate(interp, 1);
|
||||
}
|
||||
|
||||
PyThreadState *
|
||||
_PyThreadState_Prealloc(PyInterpreterState *interp)
|
||||
{
|
||||
return new_threadstate(interp, 0);
|
||||
}
|
||||
|
||||
void
|
||||
_PyThreadState_Init(PyThreadState *tstate)
|
||||
{
|
||||
#ifdef WITH_THREAD
|
||||
_PyGILState_NoteThreadState(tstate);
|
||||
#endif
|
||||
}
|
||||
|
||||
void
|
||||
PyThreadState_Clear(PyThreadState *tstate)
|
||||
|
|
Loading…
Reference in New Issue