clearlinux/uwsgi
2
0
Fork 0
mirror of https://github.com/clearlinux/uwsgi.git synced 2026-09-08 14:41:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

improved multi-mule support

Browse Source
This commit is contained in:
roberto@debian32
2011-10-25 17:35:52 +02:00
parent b3107d9a25
commit 4fb5a84378
5 changed files with 18 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/python/uwsgi_pymodule.c
+5 -1
View File
@@ -1153,7 +1153,7 @@ PyObject *py_uwsgi_mule_msg(PyObject * self, PyObject * args) {
char *message = NULL;
Py_ssize_t message_len = 0;
int mule_id = 1;
int mule_id = 0;
ssize_t len;
if (!PyArg_ParseTuple(args, "s#|i:mule_msg", &message, &message_len, &mule_id)) {
@@ -1161,6 +1161,10 @@ PyObject *py_uwsgi_mule_msg(PyObject * self, PyObject * args) {
}
if (mule_id == 0) {
len = write(uwsgi.shared->mule_queue_pipe[0], message, message_len);
if (len <= 0) {
uwsgi_error("write()");
}
}
else if (mule_id > 0 && mule_id <= uwsgi.mules_cnt) {
len = write(uwsgi.mules[mule_id-1].queue_pipe[0], message, message_len);