mirror of
https://github.com/clearlinux/uwsgi.git
synced 2026-09-01 11:15:57 +00:00
preliminary refactoring for multithreaded fastrouter/removed fastfuncs support
This commit is contained in:
@@ -98,11 +98,6 @@ void uwsgi_python_pthread_child(void) {
|
||||
pthread_mutex_init(&up.lock_pyloaders, NULL);
|
||||
}
|
||||
|
||||
// fake method
|
||||
PyMethodDef null_methods[] = {
|
||||
{NULL, NULL},
|
||||
};
|
||||
|
||||
PyMethodDef uwsgi_spit_method[] = { {"uwsgi_spit", py_uwsgi_spit, METH_VARARGS, ""} };
|
||||
PyMethodDef uwsgi_write_method[] = { {"uwsgi_write", py_uwsgi_write, METH_VARARGS, ""} };
|
||||
|
||||
@@ -412,20 +407,22 @@ void init_uwsgi_vars() {
|
||||
|
||||
|
||||
|
||||
PyDoc_STRVAR(uwsgi_py_doc, "uWSGI api module.");
|
||||
|
||||
|
||||
#ifdef PYTHREE
|
||||
static PyModuleDef uwsgi_module3 = {
|
||||
PyModuleDef_HEAD_INIT,
|
||||
"uwsgi",
|
||||
NULL,
|
||||
uwsgi_py_doc,
|
||||
-1,
|
||||
null_methods,
|
||||
NULL,
|
||||
};
|
||||
PyObject *init_uwsgi3(void) {
|
||||
return PyModule_Create(&uwsgi_module3);
|
||||
}
|
||||
#endif
|
||||
|
||||
|
||||
#ifdef UWSGI_EMBEDDED
|
||||
void init_uwsgi_embedded_module() {
|
||||
PyObject *new_uwsgi_module, *zero;
|
||||
@@ -442,18 +439,19 @@ void init_uwsgi_embedded_module() {
|
||||
}
|
||||
|
||||
|
||||
|
||||
#ifdef PYTHREE
|
||||
PyImport_AppendInittab("uwsgi", init_uwsgi3);
|
||||
new_uwsgi_module = PyImport_AddModule("uwsgi");
|
||||
#else
|
||||
new_uwsgi_module = Py_InitModule("uwsgi", null_methods);
|
||||
new_uwsgi_module = Py_InitModule3("uwsgi", NULL, uwsgi_py_doc);
|
||||
#endif
|
||||
if (new_uwsgi_module == NULL) {
|
||||
uwsgi_log("could not initialize the uwsgi python module\n");
|
||||
exit(1);
|
||||
}
|
||||
|
||||
|
||||
|
||||
Py_INCREF((PyObject *) &uwsgi_InputType);
|
||||
|
||||
up.embedded_dict = PyModule_GetDict(new_uwsgi_module);
|
||||
@@ -484,6 +482,7 @@ void init_uwsgi_embedded_module() {
|
||||
}
|
||||
|
||||
|
||||
|
||||
if (PyDict_SetItemString(up.embedded_dict, "hostname", PyString_FromStringAndSize(uwsgi.hostname, uwsgi.hostname_len))) {
|
||||
PyErr_Print();
|
||||
exit(1);
|
||||
@@ -528,6 +527,7 @@ void init_uwsgi_embedded_module() {
|
||||
#endif
|
||||
|
||||
|
||||
|
||||
if (PyDict_SetItemString(up.embedded_dict, "SPOOL_RETRY", PyInt_FromLong(-1))) {
|
||||
PyErr_Print();
|
||||
exit(1);
|
||||
@@ -646,11 +646,6 @@ void init_uwsgi_embedded_module() {
|
||||
exit(1);
|
||||
}
|
||||
|
||||
if (PyDict_SetItemString(up.embedded_dict, "fastfuncs", PyList_New(256))) {
|
||||
PyErr_Print();
|
||||
exit(1);
|
||||
}
|
||||
|
||||
|
||||
if (PyDict_SetItemString(up.embedded_dict, "applications", Py_None)) {
|
||||
PyErr_Print();
|
||||
@@ -681,12 +676,6 @@ void init_uwsgi_embedded_module() {
|
||||
exit(1);
|
||||
}
|
||||
|
||||
up.fastfuncslist = PyDict_GetItemString(up.embedded_dict, "fastfuncs");
|
||||
if (!up.fastfuncslist) {
|
||||
PyErr_Print();
|
||||
exit(1);
|
||||
}
|
||||
|
||||
init_uwsgi_module_advanced(new_uwsgi_module);
|
||||
|
||||
#ifdef UWSGI_SPOOLER
|
||||
|
||||
Reference in New Issue
Block a user