ReceiveTempSMS/Sweden-Number
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

server: Move async activation into separate function.

Browse Source
This commit is contained in:
Mike Kaplinskiy 2010-05-19 16:14:08 -04:00 committed by Alexandre Julliard
parent b8fb1c97a1
commit ee5ee5c538
1 changed files with 19 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
server/sock.c
View File

@ -295,6 +295,23 @@ static inline int sock_error( struct fd *fd )
return optval; return optval;
} }
static void sock_dispatch_asyncs( struct sock *sock, int event )
{
if ( sock->flags & WSA_FLAG_OVERLAPPED )
{
if ( event & (POLLIN|POLLPRI|POLLERR|POLLHUP) && async_waiting( sock->read_q ))
{
if (debug_level) fprintf( stderr, "activating read queue for socket %p\n", sock );
async_wake_up( sock->read_q, STATUS_ALERTED );
}
if ( event & (POLLOUT|POLLERR|POLLHUP) && async_waiting( sock->write_q ))
{
if (debug_level) fprintf( stderr, "activating write queue for socket %p\n", sock );
async_wake_up( sock->write_q, STATUS_ALERTED );
}
}
}
static void sock_poll_event( struct fd *fd, int event ) static void sock_poll_event( struct fd *fd, int event )
{ {
struct sock *sock = get_fd_user( fd ); struct sock *sock = get_fd_user( fd );
@ -422,23 +439,11 @@ static void sock_poll_event( struct fd *fd, int event )
event |= POLLHUP; event |= POLLHUP;
} }
sock_dispatch_asyncs( sock, event );
/* wake up anyone waiting for whatever just happened */ /* wake up anyone waiting for whatever just happened */
sock_wake_up( sock ); sock_wake_up( sock );
if ( sock->flags & WSA_FLAG_OVERLAPPED )
{
if ( event & (POLLIN|POLLPRI|POLLERR|POLLHUP) && async_waiting( sock->read_q ))
{
if (debug_level) fprintf( stderr, "activating read queue for socket %p\n", sock );
async_wake_up( sock->read_q, STATUS_ALERTED );
}
if ( event & (POLLOUT|POLLERR|POLLHUP) && async_waiting( sock->write_q ))
{
if (debug_level) fprintf( stderr, "activating write queue for socket %p\n", sock );
async_wake_up( sock->write_q, STATUS_ALERTED );
}
}
/* if anyone is stupid enough to wait on the socket object itself, /* if anyone is stupid enough to wait on the socket object itself,
* maybe we should wake them up too, just in case? */ * maybe we should wake them up too, just in case? */
wake_up( &sock->obj, 0 ); wake_up( &sock->obj, 0 );