avoid double-close fds that were either collected or disconnected

cloudwu · Apr 10, 2012 · 3954dd2 · 3954dd2
1 parent 5d2bba5
commit 3954dd2
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/mread.c b/mread.c
@@ -25,6 +25,8 @@
 #define SOCKET_READ 3
 #define SOCKET_POLLIN 4
 
+#define SOCKET_ALIVE	SOCKET_SUSPEND
+
 struct socket {
 	int fd;
 	struct ringbuffer_block * node;
@@ -144,7 +146,7 @@ mread_close(struct mread_pool *self) {
 	int i;
 	struct socket * s = self->sockets;
 	for (i=0;i<self->max_connection;i++) {
-		if (s[i].status != SOCKET_INVALID) {
+		if (s[i].status >= SOCKET_ALIVE) {
 			close(s[i].fd);
 		}
 	}