reactos/wine
1
0
Fork 0
mirror of https://github.com/reactos/wine.git synced 2024-12-04 01:41:18 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

server: Introduce server-side I/O mode for named pipes.

Browse Source 
Signed-off-by: Jacek Caban <jacek@codeweavers.com>
Signed-off-by: Alexandre Julliard <julliard@winehq.org>
This commit is contained in:
Jacek Caban 2017-03-15 23:25:38 +01:00 committed by Alexandre Julliard
parent c5afc9f9b6
commit a8023d300c
1 changed files with 35 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
server/named_pipe.c
View File

@ -277,6 +277,12 @@ static const struct fd_ops named_pipe_device_fd_ops =
default_fd_reselect_async /* reselect_async */ default_fd_reselect_async /* reselect_async */
}; };
/* Returns if we handle I/O via server calls. Currently disabled. */
static int use_server_io( struct pipe_end *pipe_end )
{
return 0; /* FIXME */
}
static void named_pipe_dump( struct object *obj, int verbose ) static void named_pipe_dump( struct object *obj, int verbose )
{ {
fputs( "Named pipe\n", stderr ); fputs( "Named pipe\n", stderr );
@ -394,7 +400,8 @@ static void do_disconnect( struct pipe_server *server )
server->client->pipe_end.fd = NULL; server->client->pipe_end.fd = NULL;
} }
assert( server->pipe_end.fd ); assert( server->pipe_end.fd );
shutdown( get_unix_fd( server->pipe_end.fd ), SHUT_RDWR ); if (!use_server_io( &server->pipe_end ))
shutdown( get_unix_fd( server->pipe_end.fd ), SHUT_RDWR );
release_object( server->pipe_end.fd ); release_object( server->pipe_end.fd );
server->pipe_end.fd = NULL; server->pipe_end.fd = NULL;
} }
@ -539,6 +546,9 @@ static int pipe_data_remaining( struct pipe_server *server )
assert( server->client ); assert( server->client );
if (use_server_io( &server->pipe_end ))
return 0;
fd = get_unix_fd( server->client->pipe_end.fd ); fd = get_unix_fd( server->client->pipe_end.fd );
if (fd < 0) if (fd < 0)
return 0; return 0;
@ -590,7 +600,7 @@ static obj_handle_t pipe_server_flush( struct fd *fd, struct async *async, int b
handle = pipe_end_flush( &server->pipe_end, async, blocking ); 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 */ /* there's no unix way to be alerted when a pipe becomes empty, so resort to polling */
if (handle && !server->flush_poll) if (handle && !use_server_io( &server->pipe_end ) && !server->flush_poll)
server->flush_poll = add_timeout_user( -TICKS_PER_SEC / 10, check_flushed, server ); server->flush_poll = add_timeout_user( -TICKS_PER_SEC / 10, check_flushed, server );
return handle; return handle;
} }
@ -806,7 +816,22 @@ static struct object *named_pipe_open_file( struct object *obj, unsigned int acc
if ((client = create_pipe_client( options, pipe->flags, pipe->outsize ))) if ((client = create_pipe_client( options, pipe->flags, pipe->outsize )))
{ {
if (!socketpair( PF_UNIX, SOCK_STREAM, 0, fds )) if (use_server_io( &server->pipe_end ))
{
client->pipe_end.fd = alloc_pseudo_fd( &pipe_client_fd_ops, &client->pipe_end.obj, options );
if (client->pipe_end.fd)
{
set_fd_signaled( client->pipe_end.fd, 1 );
server->pipe_end.fd = (struct fd *)grab_object( server->ioctl_fd );
set_no_fd_status( server->ioctl_fd, STATUS_BAD_DEVICE_TYPE );
}
else
{
release_object( client );
client = NULL;
}
}
else if (!socketpair( PF_UNIX, SOCK_STREAM, 0, fds ))
{ {
assert( !server->pipe_end.fd ); assert( !server->pipe_end.fd );
@ -831,14 +856,7 @@ static struct object *named_pipe_open_file( struct object *obj, unsigned int acc
server->pipe_end.fd = create_anonymous_fd( &pipe_server_fd_ops, fds[0], &server->pipe_end.obj, server->options ); server->pipe_end.fd = create_anonymous_fd( &pipe_server_fd_ops, fds[0], &server->pipe_end.obj, server->options );
if (client->pipe_end.fd && server->pipe_end.fd) if (client->pipe_end.fd && server->pipe_end.fd)
{ {
allow_fd_caching( client->pipe_end.fd );
allow_fd_caching( server->pipe_end.fd );
fd_copy_completion( server->ioctl_fd, server->pipe_end.fd ); fd_copy_completion( server->ioctl_fd, server->pipe_end.fd );
if (server->state == ps_wait_open)
fd_async_wake_up( server->ioctl_fd, ASYNC_TYPE_WAIT, STATUS_SUCCESS );
set_server_state( server, ps_connected_server );
server->client = client;
client->server = server;
} }
else else
{ {
@ -854,6 +872,13 @@ static struct object *named_pipe_open_file( struct object *obj, unsigned int acc
} }
if (client) if (client)
{ {
allow_fd_caching( client->pipe_end.fd );
allow_fd_caching( server->pipe_end.fd );
if (server->state == ps_wait_open)
fd_async_wake_up( server->ioctl_fd, ASYNC_TYPE_WAIT, STATUS_SUCCESS );
set_server_state( server, ps_connected_server );
server->client = client;
client->server = server;
server->pipe_end.connection = &client->pipe_end; server->pipe_end.connection = &client->pipe_end;
client->pipe_end.connection = &server->pipe_end; client->pipe_end.connection = &server->pipe_end;
} }