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

server: Support FSCTL_PIPE_PEEK in byte mode.

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-10-04 15:17:52 +02:00 committed by Alexandre Julliard
parent 688c7a99d2
commit f68bea526f
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
server/named_pipe.c
View File

@ -930,21 +930,33 @@ static int pipe_end_peek( struct pipe_end *pipe_end )
LIST_FOR_EACH_ENTRY( message, &pipe_end->message_queue, struct pipe_message, entry ) LIST_FOR_EACH_ENTRY( message, &pipe_end->message_queue, struct pipe_message, entry )
avail += message->iosb->in_size - message->read_pos; avail += message->iosb->in_size - message->read_pos;
reply_size = min( reply_size, avail );
if (avail) if (avail && (pipe_end->flags & NAMED_PIPE_MESSAGE_STREAM_WRITE))
{ {
message = LIST_ENTRY( list_head(&pipe_end->message_queue), struct pipe_message, entry ); message = LIST_ENTRY( list_head(&pipe_end->message_queue), struct pipe_message, entry );
message_length = message->iosb->in_size - message->read_pos; message_length = message->iosb->in_size - message->read_pos;
reply_size = min( reply_size, message_length ); reply_size = min( reply_size, message_length );
} }
else reply_size = 0;
if (!(buffer = set_reply_data_size( offsetof( FILE_PIPE_PEEK_BUFFER, Data[reply_size] )))) return 0; if (!(buffer = set_reply_data_size( offsetof( FILE_PIPE_PEEK_BUFFER, Data[reply_size] )))) return 0;
buffer->NamedPipeState = 0; /* FIXME */ buffer->NamedPipeState = 0; /* FIXME */
buffer->ReadDataAvailable = avail; buffer->ReadDataAvailable = avail;
buffer->NumberOfMessages = 0; /* FIXME */ buffer->NumberOfMessages = 0; /* FIXME */
buffer->MessageLength = message_length; buffer->MessageLength = message_length;
if (reply_size) memcpy( buffer->Data, (const char *)message->iosb->in_data + message->read_pos, reply_size );
if (reply_size)
{
data_size_t write_pos = 0, writing;
LIST_FOR_EACH_ENTRY( message, &pipe_end->message_queue, struct pipe_message, entry )
{
writing = min( reply_size - write_pos, message->iosb->in_size - message->read_pos );
memcpy( buffer->Data + write_pos, (const char *)message->iosb->in_data + message->read_pos,
writing );
write_pos += writing;
if (write_pos == reply_size) break;
}
}
return 1; return 1;
} }