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

server: Moved server-independent parts of pipe_server_flush into separated function. 

Signed-off-by: Jacek Caban <jacek@codeweavers.com>
Signed-off-by: Alexandre Julliard <julliard@winehq.org>
This commit is contained in:
Jacek Caban 2017-02-22 14:51:17 +01:00 committed by Alexandre Julliard
parent 8989867544
commit e50d49c17a
1 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
server/named_pipe.c
View File

@ -548,23 +548,31 @@ static void check_flushed( void *arg )
}
}
static obj_handle_t pipe_end_flush( struct pipe_end *pipe_end, struct async *async, int blocking )
{
obj_handle_t handle = 0;
if (!fd_queue_async( pipe_end->fd, async, ASYNC_TYPE_WAIT )) return 0;
if (!blocking || (handle = alloc_handle( current->process, async, SYNCHRONIZE, 0 )))
set_error( STATUS_PENDING );
return handle;
}
static obj_handle_t pipe_server_flush( struct fd *fd, struct async *async, int blocking )
{
struct pipe_server *server = get_fd_user( fd );
obj_handle_t handle = 0;
obj_handle_t handle;
if (!server || server->state != ps_connected_server) return 0;
if (!pipe_data_remaining( server )) return 0;
if (fd_queue_async( server->pipe_end.fd, async, ASYNC_TYPE_WAIT ))
{
/* there's no unix way to be alerted when a pipe becomes empty, so resort to polling */
if (!server->flush_poll)
server->flush_poll = add_timeout_user( -TICKS_PER_SEC / 10, check_flushed, server );
if (blocking) handle = alloc_handle( current->process, async, SYNCHRONIZE, 0 );
set_error( STATUS_PENDING );
}
handle = pipe_end_flush( &server->pipe_end, async, blocking );
/* there's no unix way to be alerted when a pipe becomes empty, so resort to polling */
if (handle && !server->flush_poll)
server->flush_poll = add_timeout_user( -TICKS_PER_SEC / 10, check_flushed, server );
return handle;
}