fixed mule socketpair

This commit is contained in:
roberto@colossus
2011-10-06 18:37:24 +02:00
parent d6a6b65338
commit f7150d1b41
2 changed files with 5 additions and 5 deletions
-5
View File
@@ -16,11 +16,6 @@ void uwsgi_mule(int id) {
int i;
// create the socket pipe
if (socketpair(AF_UNIX, SOCK_STREAM, 0, uwsgi.mules[id-1].signal_pipe)) {
uwsgi_error("socketpair()\n");
}
pid_t pid = fork();
if (pid == 0) {
uwsgi.muleid = id;
+5
View File
@@ -2169,6 +2169,11 @@ skipzero:
}
for(i=0;i<uwsgi.mules_cnt;i++) {
// create the socket pipe
if (socketpair(AF_UNIX, SOCK_STREAM, 0, uwsgi.mules[i].signal_pipe)) {
uwsgi_error("socketpair()\n");
}
if (socketpair(AF_UNIX, SOCK_DGRAM, 0, uwsgi.mules[i].queue_pipe)) {
uwsgi_error("socketpair()");
exit(1);