clearlinux/uwsgi
2
0
Fork 0
mirror of https://github.com/clearlinux/uwsgi.git synced 2026-09-06 21:51:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

uniq zerg sockets

Browse Source
This commit is contained in:
roberto@precise64
2012-03-22 10:05:00 +01:00
parent af1f98131a
commit 08d9de54f0
1 changed files with 22 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
socket.c
+22 -2
View File
@@ -1254,6 +1254,21 @@ int uwsgi_is_bad_connection(int fd) {
return soopt;
}
int uwsgi_socket_uniq(struct uwsgi_socket *list, struct uwsgi_socket *item) {
int found = 0;
if (list == item) return 1;
struct uwsgi_socket *uwsgi_sock = list;
while(uwsgi_sock && uwsgi_sock != item) {
if (!strcmp(uwsgi_sock->name, item->name)) {
found = 1;
break;
}
uwsgi_sock = uwsgi_sock->next;
}
return found;
}
void uwsgi_manage_zerg(int fd, int num_sockets, int *sockets) {
struct sockaddr_un zsun;
socklen_t zsun_len = sizeof(struct sockaddr_un);
@@ -1297,11 +1312,16 @@ void uwsgi_manage_zerg(int fd, int num_sockets, int *sockets) {
if (!sockets) {
struct uwsgi_socket *uwsgi_sock = uwsgi.sockets;
int uniq_count = 0;
while (uwsgi_sock) {
memcpy(zerg_fd_ptr, &uwsgi_sock->fd, sizeof(int));
zerg_fd_ptr += sizeof(int);
if (uwsgi_socket_uniq(uwsgi.sockets, uwsgi_sock)) {
memcpy(zerg_fd_ptr, &uwsgi_sock->fd, sizeof(int));
zerg_fd_ptr += sizeof(int);
uniq_count++;
}
uwsgi_sock = uwsgi_sock->next;
}
zerg_iov[1].iov_base = &uniq_count;
}
else {
memcpy(zerg_fd_ptr, sockets, sizeof(int) * num_sockets);