8000 bpo-1635741: port multiprocessing to multiphase init by koubaa · Pull Request #21378 · python/cpython · GitHub
[go: up one dir, main page]
Skip to content

bpo-1635741: port multiprocessing to multiphase init #21378

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

Merged
merged 6 commits into from
Aug 11, 2020
Merged

bpo-1635741: port multiprocessing to multiphase init #21378

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
1c0c832
port multiprocessing to multiphase init
koubaa Jul 7, 2020
b31425d
fix issues
Jul 8, 2020
d196df9
update based on review
koubaa Jul 9, 2020
e2a12af
update based on review
koubaa Jul 9, 2020
08aa12b
fix macro
koubaa Jul 9, 2020
064d8e0
fix refcount issue
koubaa Aug 10, 2020
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
Next Next commit
port multiprocessing to multiphase init
  • Loading branch information
@koubaa
koubaa committed Jul 7, 2020
commit 1c0c832b20015e0c17043d53ff6d29bb8ee20d52
1 change: 1 addition & 0 deletions Misc/NEWS.d/next/Core and Builtins/2020-07-07-16-10-52.bpo-1635741.zU-H_n.rst
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
Port :mod:`multiprocessing` to multi-phase initialization
53 changes: 26 additions & 27 deletions Modules/_multiprocessing/multiprocessing.c
View file
Open in desktop
Original fil 8000 e line number Diff line number Diff line change
Expand Up @@ -139,34 +139,15 @@ static PyMethodDef module_methods[] = {
* Initialize
*/

static struct PyModuleDef multiprocessing_module = {
PyModuleDef_HEAD_INIT,
"_multiprocessing",
NULL,
-1,
module_methods,
NULL,
NULL,
NULL,
NULL
};


PyMODINIT_FUNC
PyInit__multiprocessing(void)
int multiprocessing_exec(PyObject *module)
{
PyObject *module, *temp, *value = NULL;

/* Initialize module */
module = PyModule_Create(&multiprocessing_module);
if (!module)
return NULL;
PyObject *value = NULL;

#if defined(MS_WINDOWS) || \
(defined(HAVE_SEM_OPEN) && !defined(POSIX_SEMAPHORES_NOT_ENABLED))
/* Add _PyMp_SemLock type to module */
if (PyType_Ready(&_PyMp_SemLockType) < 0)
return NULL;
return -1;
Py_INCREF(&_PyMp_SemLockType);
{
PyObject *py_sem_value_max;
Expand All @@ -180,17 +161,17 @@ PyInit__multiprocessing(void)
else
py_sem_value_max = PyLong_FromLong(SEM_VALUE_MAX);
if (py_sem_value_max == NULL)
return NULL;
return -1;
PyDict_SetItemString(_PyMp_SemLockType.tp_dict, "SEM_VALUE_MAX",
py_sem_value_max);
}
PyModule_AddObject(module, "SemLock", (PyObject*)&_PyMp_SemLockType);
#endif

/* Add configuration macros */
temp = PyDict_New();
PyObject *temp = PyDict_New();
if (!temp)
return NULL;
return -1;

#define ADD_FLAG(name) \
value = Py_BuildValue("i", name); \
Expand All @@ -213,7 +194,25 @@ PyInit__multiprocessing(void)
#endif

if (PyModule_AddObject(module, "flags", temp) < 0)
return NULL;
return -1;

return module;
return 0;
}

static PyModuleDef_Slot multiprocessing_slots[] = {
{Py_mod_exec, multiprocessing_exec},
{0, NULL}
};

static struct PyModuleDef multiprocessing_module = {
PyModuleDef_HEAD_INIT,
.m_name = "_multiprocessing",
.m_methods = module_methods,
.m_slots = multiprocessing_slots,
};

PyMODINIT_FUNC
PyInit__multiprocessing(void)
{
return PyModuleDef_Init(&multiprocessing_module);
}
0