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

winhttp: Factor out receive_close_status() function. 

Signed-off-by: Paul Gofman <pgofman@codeweavers.com>
Signed-off-by: Hans Leidekker <hans@codeweavers.com>
Signed-off-by: Alexandre Julliard <julliard@winehq.org>
This commit is contained in:
Paul Gofman 2022-01-25 03:08:01 +03:00 committed by Alexandre Julliard
parent 07639a02d3
commit d5fb34ebdb
1 changed files with 17 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
dlls/winhttp/request.c
View File

@ -3505,6 +3505,22 @@ static DWORD socket_drain( struct socket *socket )
return ERROR_SUCCESS; return ERROR_SUCCESS;
} }
static DWORD receive_close_status( struct socket *socket, unsigned int len )
{
DWORD reason_len, ret;
if ((len && (len < sizeof(socket->status) || len > sizeof(socket->status) + sizeof(socket->reason))))
return ERROR_WINHTTP_INVALID_SERVER_RESPONSE;
if (!len) return ERROR_SUCCESS;
reason_len = len - sizeof(socket->status);
if ((ret = receive_bytes( socket, (char *)&socket->status, sizeof(socket->status), &len, TRUE )))
return ret;
socket->status = RtlUshortByteSwap( socket->status );
return receive_bytes( socket, socket->reason, reason_len, &socket->reason_len, TRUE );
}
static DWORD handle_control_frame( struct socket *socket ) static DWORD handle_control_frame( struct socket *socket )
{ {
switch (socket->opcode) switch (socket->opcode)
@ -3749,19 +3765,8 @@ static DWORD socket_close( struct socket *socket )
if ((ret = socket_drain( socket ))) return ret; if ((ret = socket_drain( socket ))) return ret;
} }
if ((count && (count < sizeof(socket->status) || count > sizeof(socket->status) + sizeof(socket->reason))))
return ERROR_WINHTTP_INVALID_SERVER_RESPONSE;
if (count)
{
DWORD reason_len = count - sizeof(socket->status);
if ((ret = receive_bytes( socket, (char *)&socket->status, sizeof(socket->status), &count, TRUE ))) return ret;
socket->status = RtlUshortByteSwap( socket->status );
if ((ret = receive_bytes( socket, socket->reason, reason_len, &socket->reason_len, TRUE ))) return ret;
}
socket->state = SOCKET_STATE_CLOSED; socket->state = SOCKET_STATE_CLOSED;
return receive_close_status( socket, count );
return ERROR_SUCCESS;
} }
static void CALLBACK task_socket_close( TP_CALLBACK_INSTANCE *instance, void *ctx, TP_WORK *work ) static void CALLBACK task_socket_close( TP_CALLBACK_INSTANCE *instance, void *ctx, TP_WORK *work )