Jacek Caban : server: Added support for flushing client pipe.
Alexandre Julliard
julliard at winehq.org
Mon Mar 27 15:26:08 CDT 2017
Module: wine
Branch: master
Commit: 975c5381ede8f797b6f60a3e8fded712804c1c68
URL: http://source.winehq.org/git/wine.git/?a=commit;h=975c5381ede8f797b6f60a3e8fded712804c1c68
Author: Jacek Caban <jacek at codeweavers.com>
Date: Sun Mar 26 12:52:50 2017 +0200
server: Added support for flushing client pipe.
Signed-off-by: Jacek Caban <jacek at codeweavers.com>
Signed-off-by: Alexandre Julliard <julliard at winehq.org>
---
dlls/kernel32/tests/pipe.c | 7 +++++++
server/named_pipe.c | 8 ++++++--
2 files changed, 13 insertions(+), 2 deletions(-)
diff --git a/dlls/kernel32/tests/pipe.c b/dlls/kernel32/tests/pipe.c
index 58bad06..cf2a3a3 100644
--- a/dlls/kernel32/tests/pipe.c
+++ b/dlls/kernel32/tests/pipe.c
@@ -2853,6 +2853,9 @@ static void test_overlapped_transport(BOOL msg_mode, BOOL msg_read_mode)
trace("testing %s, %s server->client writes...\n",
msg_mode ? "message mode" : "byte mode", msg_read_mode ? "message read" : "byte read");
test_blocking_rw(server, client, 5000, msg_mode, msg_read_mode);
+ trace("testing %s, %s client->server writes...\n",
+ msg_mode ? "message mode" : "byte mode", msg_read_mode ? "message read" : "byte read");
+ test_blocking_rw(client, server, 6000, msg_mode, msg_read_mode);
CloseHandle(client);
CloseHandle(server);
@@ -2869,18 +2872,22 @@ static void test_overlapped_transport(BOOL msg_mode, BOOL msg_read_mode)
/* close server with pending writes */
create_overlapped_pipe(create_flags, &client, &server);
overlapped_write_async(client, buf, 7000, &overlapped);
+ flush = test_flush_async(client, ERROR_BROKEN_PIPE);
CloseHandle(server);
test_overlapped_failure(client, &overlapped, ERROR_BROKEN_PIPE);
+ test_flush_done(flush);
CloseHandle(client);
/* disconnect with pending writes */
create_overlapped_pipe(create_flags, &client, &server);
overlapped_write_async(client, buf, 7000, &overlapped);
overlapped_write_async(server, buf, 7000, &overlapped2);
+ flush = test_flush_async(client, ERROR_PIPE_NOT_CONNECTED);
res = DisconnectNamedPipe(server);
ok(res, "DisconnectNamedPipe failed: %u\n", GetLastError());
test_overlapped_failure(client, &overlapped, ERROR_PIPE_NOT_CONNECTED);
test_overlapped_failure(client, &overlapped2, ERROR_PIPE_NOT_CONNECTED);
+ test_flush_done(flush);
CloseHandle(server);
CloseHandle(client);
}
diff --git a/server/named_pipe.c b/server/named_pipe.c
index e5b6dd1..bbdf3bc 100644
--- a/server/named_pipe.c
+++ b/server/named_pipe.c
@@ -656,6 +656,9 @@ static obj_handle_t pipe_end_flush( struct pipe_end *pipe_end, struct async *asy
{
obj_handle_t handle = 0;
+ if (use_server_io( pipe_end ) && (!pipe_end->connection || list_empty( &pipe_end->connection->message_queue )))
+ return 0;
+
if (!fd_queue_async( pipe_end->fd, async, ASYNC_TYPE_WAIT )) return 0;
if (!blocking || (handle = alloc_handle( current->process, async, SYNCHRONIZE, 0 )))
@@ -682,8 +685,9 @@ static obj_handle_t pipe_server_flush( struct fd *fd, struct async *async, int b
static obj_handle_t pipe_client_flush( struct fd *fd, struct async *async, int blocking )
{
- /* FIXME: what do we have to do for this? */
- return 0;
+ struct pipe_end *pipe_end = get_fd_user( fd );
+ /* FIXME: Support byte mode. */
+ return use_server_io( pipe_end ) ? pipe_end_flush( pipe_end, async, blocking ) : 0;
}
static void message_queue_read( struct pipe_end *pipe_end, struct iosb *iosb )
More information about the wine-cvs
mailing list