commit ac12c67f40fc9892e27b76b74c0425b69767b95a
author Mike Kaplinskiy <mike.kaplinskiy@gmail.com> Wed May 19 01:38:29 2010 -0400
committer Alexandre Julliard <julliard@winehq.org> Wed May 19 16:57:59 2010 +0200
tree b4eeb29c3c44d915dcfe248db2599555033e3486
parent 91c7d4f909eeff585892d112f37bd5fc0e90aab8

server: Don't poll for events when there are async operations queued.

server/sock.c

diff --git a/server/sock.c b/server/sock.c
index 34ec176..0a1bb40 100644
--- a/server/sock.c
+++ b/server/sock.c
@@ -466,7 +466,8 @@
 static int sock_get_poll_events( struct fd *fd )
 {
     struct sock *sock = get_fd_user( fd );
-    unsigned int mask = sock->mask & sock->state & ~sock->hmask;
+    unsigned int mask = sock->mask & ~sock->hmask;
+    unsigned int smask = sock->state & mask;
     int ev = 0;
 
     assert( sock->obj.ops == &sock_ops );
@@ -476,15 +477,26 @@
         return POLLOUT;
     if (sock->state & FD_WINE_LISTENING)
         /* listening, wait for readable */
-        return (sock->hmask & FD_ACCEPT) ? 0 : POLLIN;
+        return (mask & FD_ACCEPT) ? POLLIN : 0;
 
-    if (mask & FD_READ  || async_waiting( sock->read_q )) ev |= POLLIN | POLLPRI;
-    if (mask & FD_WRITE || async_waiting( sock->write_q )) ev |= POLLOUT;
+    if ( async_queued( sock->read_q ) )
+    {
+        if ( async_waiting( sock->read_q ) ) ev |= POLLIN | POLLPRI;
+    }
+    else if (smask & FD_READ)
+        ev |= POLLIN | POLLPRI;
     /* We use POLLIN with 0 bytes recv() as FD_CLOSE indication for stream sockets. */
-    if ( sock->type == SOCK_STREAM && ( sock->mask & ~sock->hmask & FD_CLOSE) &&
-         !(sock->hmask & FD_READ) && sock->state & FD_READ )
+    else if ( sock->type == SOCK_STREAM && sock->state & FD_READ && mask & FD_CLOSE &&
+              !(sock->hmask & FD_READ) )
         ev |= POLLIN;
 
+    if ( async_queued( sock->write_q ) )
+    {
+        if ( async_waiting( sock->write_q ) ) ev |= POLLOUT;
+    }
+    else if (smask & FD_WRITE)
+        ev |= POLLOUT;
+
     return ev;
 }