#include "config.h"
#include "ws2tcpip.h"
#include <stdarg.h>
#include <assert.h>
#include "windef.h"
#include "winbase.h"
#include "ole2.h"
#include "initguid.h"
#include "httprequest.h"
#include "httprequestid.h"
#include "schannel.h"
#include "winhttp.h"
#include "wine/debug.h"
#include "winhttp_private.h"

Include dependency graph for request.c:

Classes
struct	winhttp_request

struct	stream

Enumerations
enum	escape_flags { ESCAPE_FLAG_NON_PRINTABLE = 0x01 , ESCAPE_FLAG_SPACE = 0x02 , ESCAPE_FLAG_PERCENT = 0x04 , ESCAPE_FLAG_UNSAFE = 0x08 , ESCAPE_FLAG_DEL = 0x10 , ESCAPE_FLAG_8BIT = 0x20 , ESCAPE_FLAG_STRIP_CRLF = 0x40 }

enum	request_state { REQUEST_STATE_INITIALIZED , REQUEST_STATE_CANCELLED , REQUEST_STATE_OPEN , REQUEST_STATE_SENT , REQUEST_STATE_RESPONSE_RECEIVED }

enum	type_id { INetFwAuthorizedApplication_tid , INetFwAuthorizedApplications_tid , INetFwMgr_tid , INetFwOpenPort_tid , INetFwOpenPorts_tid , INetFwPolicy_tid , INetFwPolicy2_tid , INetFwProfile_tid , INetFwRules_tid , IUPnPNAT_tid , last_tid , ISWbemLocator_tid , ISWbemObject_tid , ISWbemObjectSet_tid , ISWbemProperty_tid , ISWbemPropertySet_tid , ISWbemServices_tid , ISWbemSecurity_tid , last_tid , IWinHttpRequest_tid , last_tid }

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (winhttp)

static struct task_header *	dequeue_task (struct request *request)

static void CALLBACK	task_proc (TP_CALLBACK_INSTANCE instance, void ctx)

static BOOL	queue_task (struct task_header *task)

static void	free_header (struct header *header)

static BOOL	valid_token_char (WCHAR c)

static struct header *	parse_header (const WCHAR *string)

static int	get_header_index (struct request request, const WCHAR field, int requested_index, BOOL request_only)

static BOOL	insert_header (struct request request, struct header header)

static BOOL	delete_header (struct request *request, DWORD index)

BOOL	process_header (struct request request, const WCHAR field, const WCHAR *value, DWORD flags, BOOL request_only)

BOOL	add_request_headers (struct request request, const WCHAR headers, DWORD len, DWORD flags)

BOOL WINAPI	WinHttpAddRequestHeaders (HINTERNET hrequest, LPCWSTR headers, DWORD len, DWORD flags)

static WCHAR *	build_absolute_request_path (struct request request, const WCHAR *path)

static WCHAR *	build_request_string (struct request *request)

static BOOL	query_headers (struct request request, DWORD level, const WCHAR name, void buffer, DWORD buflen, DWORD *index)

BOOL WINAPI	WinHttpQueryHeaders (HINTERNET hrequest, DWORD level, LPCWSTR name, LPVOID buffer, LPDWORD buflen, LPDWORD index)

static enum auth_scheme	scheme_from_flag (DWORD flag)

static DWORD	auth_scheme_from_header (const WCHAR *header)

static BOOL	query_auth_schemes (struct request request, DWORD level, DWORD supported, DWORD *first)

BOOL WINAPI	WinHttpQueryAuthSchemes (HINTERNET hrequest, LPDWORD supported, LPDWORD first, LPDWORD target)

static UINT	encode_base64 (const char bin, unsigned int len, WCHAR base64)

static char	decode_char (WCHAR c)

static unsigned int	decode_base64 (const WCHAR base64, unsigned int len, char buf)

static struct authinfo *	alloc_authinfo (void)

void	destroy_authinfo (struct authinfo *authinfo)

static BOOL	get_authvalue (struct request request, DWORD level, DWORD scheme, WCHAR buffer, DWORD len)

static BOOL	do_authorization (struct request *request, DWORD target, DWORD scheme_flag)

static WCHAR *	build_proxy_connect_string (struct request *request)

static BOOL	read_reply (struct request *request)

static BOOL	secure_proxy_connect (struct request *request)

static WCHAR *	addr_to_str (struct sockaddr_storage *addr)

void	release_host (struct hostdata *host)

static void CALLBACK	connection_collector (TP_CALLBACK_INSTANCE instance, void ctx)

static void	cache_connection (struct netconn *netconn)

static DWORD	map_secure_protocols (DWORD mask)

static BOOL	ensure_cred_handle (struct request *request)

static BOOL	open_connection (struct request *request)

void	close_connection (struct request *request)

static BOOL	add_host_header (struct request *request, DWORD modifier)

static void	clear_response_headers (struct request *request)

static void	remove_data (struct request *request, int count)

static BOOL	read_more_data (struct request *request, int maxlen, BOOL notify)

static BOOL	discard_eol (struct request *request, BOOL notify)

static BOOL	start_next_chunk (struct request *request, BOOL notify)

static BOOL	refill_buffer (struct request *request, BOOL notify)

static void	finished_reading (struct request *request)

static DWORD	get_available_data (struct request *request)

static BOOL	end_of_read_data (struct request *request)

static BOOL	read_data (struct request request, void buffer, DWORD size, DWORD *read, BOOL async)

static void	drain_content (struct request *request)

static BOOL	need_escape (char ch, enum escape_flags flags)

static DWORD	escape_string (const char src, DWORD len, char dst, enum escape_flags flags)

static DWORD	str_to_wire (const WCHAR src, int src_len, char dst, enum escape_flags flags)

static char *	build_wire_path (struct request request, DWORD ret_len)

static char *	build_wire_request (struct request request, DWORD len)

static BOOL	send_request (struct request request, const WCHAR headers, DWORD headers_len, void *optional, DWORD optional_len, DWORD total_len, DWORD_PTR context, BOOL async)

static void	task_send_request (struct task_header *task)

BOOL WINAPI	WinHttpSendRequest (HINTERNET hrequest, LPCWSTR headers, DWORD headers_len, LPVOID optional, DWORD optional_len, DWORD total_len, DWORD_PTR context)

static BOOL	set_credentials (struct request request, DWORD target, DWORD scheme_flag, const WCHAR username, const WCHAR *password)

BOOL WINAPI	WinHttpSetCredentials (HINTERNET hrequest, DWORD target, DWORD scheme, LPCWSTR username, LPCWSTR password, LPVOID params)

static BOOL	handle_authorization (struct request *request, DWORD status)

static DWORD	set_content_length (struct request *request, DWORD status)

static BOOL	read_line (struct request request, char buffer, DWORD *len)

static void	record_cookies (struct request *request)

static WCHAR *	get_redirect_url (struct request request, DWORD len)

static BOOL	handle_redirect (struct request *request, DWORD status)

static BOOL	is_passport_request (struct request *request)

static BOOL	handle_passport_redirect (struct request *request)

static BOOL	receive_response (struct request *request, BOOL async)

static void	task_receive_response (struct task_header *task)

BOOL WINAPI	WinHttpReceiveResponse (HINTERNET hrequest, LPVOID reserved)

static BOOL	query_data_available (struct request request, DWORD available, BOOL async)

static void	task_query_data_available (struct task_header *task)

BOOL WINAPI	WinHttpQueryDataAvailable (HINTERNET hrequest, LPDWORD available)

static void	task_read_data (struct task_header *task)

BOOL WINAPI	WinHttpReadData (HINTERNET hrequest, LPVOID buffer, DWORD to_read, LPDWORD read)

static BOOL	write_data (struct request request, const void buffer, DWORD to_write, DWORD *written, BOOL async)

static void	task_write_data (struct task_header *task)

BOOL WINAPI	WinHttpWriteData (HINTERNET hrequest, LPCVOID buffer, DWORD to_write, LPDWORD written)

static struct winhttp_request *	impl_from_IWinHttpRequest (IWinHttpRequest *iface)

static ULONG WINAPI	winhttp_request_AddRef (IWinHttpRequest *iface)

static void	cancel_request (struct winhttp_request *request)

static void	free_request (struct winhttp_request *request)

static ULONG WINAPI	winhttp_request_Release (IWinHttpRequest *iface)

static HRESULT WINAPI	winhttp_request_QueryInterface (IWinHttpRequest iface, REFIID riid, void *obj)

static HRESULT WINAPI	winhttp_request_GetTypeInfoCount (IWinHttpRequest iface, UINT count)

static HRESULT	get_typeinfo (enum type_id tid, ITypeInfo **ret)

void	release_typelib (void)

static HRESULT WINAPI	winhttp_request_GetTypeInfo (IWinHttpRequest iface, UINT index, LCID lcid, ITypeInfo *info)

static HRESULT WINAPI	winhttp_request_GetIDsOfNames (IWinHttpRequest iface, REFIID riid, LPOLESTR names, UINT count, LCID lcid, DISPID *dispid)

static HRESULT WINAPI	winhttp_request_Invoke (IWinHttpRequest iface, DISPID member, REFIID riid, LCID lcid, WORD flags, DISPPARAMS params, VARIANT result, EXCEPINFO excep_info, UINT *arg_err)

static HRESULT WINAPI	winhttp_request_SetProxy (IWinHttpRequest *iface, HTTPREQUEST_PROXY_SETTING proxy_setting, VARIANT proxy_server, VARIANT bypass_list)

static HRESULT WINAPI	winhttp_request_SetCredentials (IWinHttpRequest *iface, BSTR username, BSTR password, HTTPREQUEST_SETCREDENTIALS_FLAGS flags)

static void	initialize_request (struct winhttp_request *request)

static void	reset_request (struct winhttp_request *request)

static HRESULT WINAPI	winhttp_request_Open (IWinHttpRequest *iface, BSTR method, BSTR url, VARIANT async)

static HRESULT WINAPI	winhttp_request_SetRequestHeader (IWinHttpRequest *iface, BSTR header, BSTR value)

static HRESULT WINAPI	winhttp_request_GetResponseHeader (IWinHttpRequest iface, BSTR header, BSTR value)

static HRESULT WINAPI	winhttp_request_GetAllResponseHeaders (IWinHttpRequest iface, BSTR headers)

static void CALLBACK	wait_status_callback (HINTERNET handle, DWORD_PTR context, DWORD status, LPVOID buffer, DWORD size)

static void	wait_set_status_callback (struct winhttp_request *request, DWORD status)

static DWORD	wait_for_completion (struct winhttp_request *request)

static HRESULT	request_receive (struct winhttp_request *request)

static DWORD	request_set_parameters (struct winhttp_request *request)

static void	request_set_utf8_content_type (struct winhttp_request *request)

static HRESULT	request_send (struct winhttp_request *request)

static void CALLBACK	send_and_receive_proc (TP_CALLBACK_INSTANCE instance, void ctx)

static DWORD	request_wait (struct winhttp_request *request, DWORD timeout)

static HRESULT WINAPI	winhttp_request_Send (IWinHttpRequest *iface, VARIANT body)

static HRESULT WINAPI	winhttp_request_get_Status (IWinHttpRequest iface, LONG status)

static HRESULT WINAPI	winhttp_request_get_StatusText (IWinHttpRequest iface, BSTR status)

static DWORD	request_get_codepage (struct winhttp_request request, UINT codepage)

static HRESULT WINAPI	winhttp_request_get_ResponseText (IWinHttpRequest iface, BSTR body)

static HRESULT WINAPI	winhttp_request_get_ResponseBody (IWinHttpRequest iface, VARIANT body)

static struct stream *	impl_from_IStream (IStream *iface)

static HRESULT WINAPI	stream_QueryInterface (IStream iface, REFIID riid, void *obj)

static ULONG WINAPI	stream_AddRef (IStream *iface)

static ULONG WINAPI	stream_Release (IStream *iface)

static HRESULT WINAPI	stream_Read (IStream iface, void buf, ULONG len, ULONG *read)

static HRESULT WINAPI	stream_Write (IStream iface, const void buf, ULONG len, ULONG *written)

static HRESULT WINAPI	stream_Seek (IStream iface, LARGE_INTEGER move, DWORD origin, ULARGE_INTEGER newpos)

static HRESULT WINAPI	stream_SetSize (IStream *iface, ULARGE_INTEGER newsize)

static HRESULT WINAPI	stream_CopyTo (IStream iface, IStream stream, ULARGE_INTEGER len, ULARGE_INTEGER read, ULARGE_INTEGER written)

static HRESULT WINAPI	stream_Commit (IStream *iface, DWORD flags)

static HRESULT WINAPI	stream_Revert (IStream *iface)

static HRESULT WINAPI	stream_LockRegion (IStream *iface, ULARGE_INTEGER offset, ULARGE_INTEGER len, DWORD locktype)

static HRESULT WINAPI	stream_UnlockRegion (IStream *iface, ULARGE_INTEGER offset, ULARGE_INTEGER len, DWORD locktype)

static HRESULT WINAPI	stream_Stat (IStream iface, STATSTG stg, DWORD flag)

static HRESULT WINAPI	stream_Clone (IStream iface, IStream *stream)

static HRESULT WINAPI	winhttp_request_get_ResponseStream (IWinHttpRequest iface, VARIANT body)

static HRESULT WINAPI	winhttp_request_get_Option (IWinHttpRequest iface, WinHttpRequestOption option, VARIANT value)

static HRESULT WINAPI	winhttp_request_put_Option (IWinHttpRequest *iface, WinHttpRequestOption option, VARIANT value)

static HRESULT WINAPI	winhttp_request_WaitForResponse (IWinHttpRequest iface, VARIANT timeout, VARIANT_BOOL succeeded)

static HRESULT WINAPI	winhttp_request_Abort (IWinHttpRequest *iface)

static HRESULT WINAPI	winhttp_request_SetTimeouts (IWinHttpRequest *iface, LONG resolve_timeout, LONG connect_timeout, LONG send_timeout, LONG receive_timeout)

static HRESULT WINAPI	winhttp_request_SetClientCertificate (IWinHttpRequest *iface, BSTR certificate)

static HRESULT WINAPI	winhttp_request_SetAutoLogonPolicy (IWinHttpRequest *iface, WinHttpRequestAutoLogonPolicy policy)

HRESULT	WinHttpRequest_create (void **obj)

Variables
static const WCHAR	attr_accept [] = {'A','c','c','e','p','t',0}

static const WCHAR	attr_accept_charset [] = {'A','c','c','e','p','t','-','C','h','a','r','s','e','t', 0}

static const WCHAR	attr_accept_encoding [] = {'A','c','c','e','p','t','-','E','n','c','o','d','i','n','g',0}

static const WCHAR	attr_accept_language [] = {'A','c','c','e','p','t','-','L','a','n','g','u','a','g','e',0}

static const WCHAR	attr_accept_ranges [] = {'A','c','c','e','p','t','-','R','a','n','g','e','s',0}

static const WCHAR	attr_age [] = {'A','g','e',0}

static const WCHAR	attr_allow [] = {'A','l','l','o','w',0}

static const WCHAR	attr_authorization [] = {'A','u','t','h','o','r','i','z','a','t','i','o','n',0}

static const WCHAR	attr_cache_control [] = {'C','a','c','h','e','-','C','o','n','t','r','o','l',0}

static const WCHAR	attr_connection [] = {'C','o','n','n','e','c','t','i','o','n',0}

static const WCHAR	attr_content_base [] = {'C','o','n','t','e','n','t','-','B','a','s','e',0}

static const WCHAR	attr_content_encoding [] = {'C','o','n','t','e','n','t','-','E','n','c','o','d','i','n','g',0}

static const WCHAR	attr_content_id [] = {'C','o','n','t','e','n','t','-','I','D',0}

static const WCHAR	attr_content_language [] = {'C','o','n','t','e','n','t','-','L','a','n','g','u','a','g','e',0}

static const WCHAR	attr_content_length [] = {'C','o','n','t','e','n','t','-','L','e','n','g','t','h',0}

static const WCHAR	attr_content_location [] = {'C','o','n','t','e','n','t','-','L','o','c','a','t','i','o','n',0}

static const WCHAR	attr_content_md5 [] = {'C','o','n','t','e','n','t','-','M','D','5',0}

static const WCHAR	attr_content_range [] = {'C','o','n','t','e','n','t','-','R','a','n','g','e',0}

static const WCHAR	attr_content_transfer_encoding [] = {'C','o','n','t','e','n','t','-','T','r','a','n','s','f','e','r','-','E','n','c','o','d','i','n','g',0}

static const WCHAR	attr_content_type [] = {'C','o','n','t','e','n','t','-','T','y','p','e',0}

static const WCHAR	attr_cookie [] = {'C','o','o','k','i','e',0}

static const WCHAR	attr_date [] = {'D','a','t','e',0}

static const WCHAR	attr_from [] = {'F','r','o','m',0}

static const WCHAR	attr_etag [] = {'E','T','a','g',0}

static const WCHAR	attr_expect [] = {'E','x','p','e','c','t',0}

static const WCHAR	attr_expires [] = {'E','x','p','i','r','e','s',0}

static const WCHAR	attr_host [] = {'H','o','s','t',0}

static const WCHAR	attr_if_match [] = {'I','f','-','M','a','t','c','h',0}

static const WCHAR	attr_if_modified_since [] = {'I','f','-','M','o','d','i','f','i','e','d','-','S','i','n','c','e',0}

static const WCHAR	attr_if_none_match [] = {'I','f','-','N','o','n','e','-','M','a','t','c','h',0}

static const WCHAR	attr_if_range [] = {'I','f','-','R','a','n','g','e',0}

static const WCHAR	attr_if_unmodified_since [] = {'I','f','-','U','n','m','o','d','i','f','i','e','d','-','S','i','n','c','e',0}

static const WCHAR	attr_last_modified [] = {'L','a','s','t','-','M','o','d','i','f','i','e','d',0}

static const WCHAR	attr_location [] = {'L','o','c','a','t','i','o','n',0}

static const WCHAR	attr_max_forwards [] = {'M','a','x','-','F','o','r','w','a','r','d','s',0}

static const WCHAR	attr_mime_version [] = {'M','i','m','e','-','V','e','r','s','i','o','n',0}

static const WCHAR	attr_pragma [] = {'P','r','a','g','m','a',0}

static const WCHAR	attr_proxy_authenticate [] = {'P','r','o','x','y','-','A','u','t','h','e','n','t','i','c','a','t','e',0}

static const WCHAR	attr_proxy_authorization [] = {'P','r','o','x','y','-','A','u','t','h','o','r','i','z','a','t','i','o','n',0}

static const WCHAR	attr_proxy_connection [] = {'P','r','o','x','y','-','C','o','n','n','e','c','t','i','o','n',0}

static const WCHAR	attr_public [] = {'P','u','b','l','i','c',0}

static const WCHAR	attr_range [] = {'R','a','n','g','e',0}

static const WCHAR	attr_referer [] = {'R','e','f','e','r','e','r',0}

static const WCHAR	attr_retry_after [] = {'R','e','t','r','y','-','A','f','t','e','r',0}

static const WCHAR	attr_server [] = {'S','e','r','v','e','r',0}

static const WCHAR	attr_set_cookie [] = {'S','e','t','-','C','o','o','k','i','e',0}

static const WCHAR	attr_status [] = {'S','t','a','t','u','s',0}

static const WCHAR	attr_transfer_encoding [] = {'T','r','a','n','s','f','e','r','-','E','n','c','o','d','i','n','g',0}

static const WCHAR	attr_unless_modified_since [] = {'U','n','l','e','s','s','-','M','o','d','i','f','i','e','d','-','S','i','n','c','e',0}

static const WCHAR	attr_upgrade [] = {'U','p','g','r','a','d','e',0}

static const WCHAR	attr_uri [] = {'U','R','I',0}

static const WCHAR	attr_user_agent [] = {'U','s','e','r','-','A','g','e','n','t',0}

static const WCHAR	attr_vary [] = {'V','a','r','y',0}

static const WCHAR	attr_via [] = {'V','i','a',0}

static const WCHAR	attr_warning [] = {'W','a','r','n','i','n','g',0}

static const WCHAR	attr_www_authenticate [] = {'W','W','W','-','A','u','t','h','e','n','t','i','c','a','t','e',0}

static const WCHAR *	attribute_table []

static const WCHAR	basicW [] = {'B','a','s','i','c',0}

static const WCHAR	ntlmW [] = {'N','T','L','M',0}

static const WCHAR	passportW [] = {'P','a','s','s','p','o','r','t',0}

static const WCHAR	digestW [] = {'D','i','g','e','s','t',0}

static const WCHAR	negotiateW [] = {'N','e','g','o','t','i','a','t','e',0}

struct {
const WCHAR * str

unsigned int len

DWORD scheme

}	auth_schemes []

static CRITICAL_SECTION	connection_pool_cs = { &connection_pool_debug, -1, 0, 0, 0, 0 }

static CRITICAL_SECTION_DEBUG	connection_pool_debug

static struct list	connection_pool = LIST_INIT( connection_pool )

static BOOL	connection_collector_running

static ITypeLib *	winhttp_typelib

static ITypeInfo *	winhttp_typeinfo [last_tid]

static REFIID	winhttp_tid_id []

static const IStreamVtbl	stream_vtbl

static const struct IWinHttpRequestVtbl	winhttp_request_vtbl

Macro Definition Documentation

◆ COBJMACROS

#define COBJMACROS

Definition at line 22 of file request.c.

◆ DEFAULT_KEEP_ALIVE_TIMEOUT

#define DEFAULT_KEEP_ALIVE_TIMEOUT 30000

Definition at line 46 of file request.c.

◆ ESCAPE_MASK_DEFAULT

#define ESCAPE_MASK_DEFAULT

Value:

(ESCAPE_FLAG_NON_PRINTABLE | ESCAPE_FLAG_SPACE | ESCAPE_FLAG_UNSAFE |\

ESCAPE_FLAG_DEL | ESCAPE_FLAG_8BIT)

ESCAPE_FLAG_NON_PRINTABLE

@ ESCAPE_FLAG_NON_PRINTABLE

Definition: request.c:2084

ESCAPE_FLAG_8BIT

@ ESCAPE_FLAG_8BIT

Definition: request.c:2089

ESCAPE_FLAG_DEL

@ ESCAPE_FLAG_DEL

Definition: request.c:2088

ESCAPE_FLAG_SPACE

@ ESCAPE_FLAG_SPACE

Definition: request.c:2085

ESCAPE_FLAG_UNSAFE

@ ESCAPE_FLAG_UNSAFE

Definition: request.c:2087

Definition at line 2093 of file request.c.

◆ ESCAPE_MASK_DISABLE

#define ESCAPE_MASK_DISABLE (ESCAPE_FLAG_SPACE | ESCAPE_FLAG_8BIT | ESCAPE_FLAG_STRIP_CRLF)

Definition at line 2096 of file request.c.

◆ ESCAPE_MASK_PERCENT

#define ESCAPE_MASK_PERCENT (ESCAPE_FLAG_PERCENT | ESCAPE_MASK_DEFAULT)

Definition at line 2095 of file request.c.

◆ INITIAL_HEADER_BUFFER_LEN

#define INITIAL_HEADER_BUFFER_LEN 512

Definition at line 2569 of file request.c.

◆ MAX_REPLY_LEN

#define MAX_REPLY_LEN 1460

Definition at line 2568 of file request.c.

◆ QUERY_MODIFIER_MASK

#define QUERY_MODIFIER_MASK (WINHTTP_QUERY_FLAG_REQUEST_HEADERS | WINHTTP_QUERY_FLAG_SYSTEMTIME | WINHTTP_QUERY_FLAG_NUMBER)

Definition at line 649 of file request.c.

Enumeration Type Documentation

◆ escape_flags

enum escape_flags

Enumerator
ESCAPE_FLAG_NON_PRINTABLE
ESCAPE_FLAG_SPACE
ESCAPE_FLAG_PERCENT
ESCAPE_FLAG_UNSAFE
ESCAPE_FLAG_DEL
ESCAPE_FLAG_8BIT
ESCAPE_FLAG_STRIP_CRLF

Definition at line 2082 of file request.c.

{
    ESCAPE_FLAG_NON_PRINTABLE = 0x01,
    ESCAPE_FLAG_SPACE         = 0x02,
    ESCAPE_FLAG_PERCENT       = 0x04,
    ESCAPE_FLAG_UNSAFE        = 0x08,
    ESCAPE_FLAG_DEL           = 0x10,
    ESCAPE_FLAG_8BIT          = 0x20,
    ESCAPE_FLAG_STRIP_CRLF    = 0x40,
};

◆ request_state

enum request_state

Enumerator
REQUEST_STATE_INITIALIZED
REQUEST_STATE_CANCELLED
REQUEST_STATE_OPEN
REQUEST_STATE_SENT
REQUEST_STATE_RESPONSE_RECEIVED

Definition at line 3166 of file request.c.

{
    REQUEST_STATE_INITIALIZED,
    REQUEST_STATE_CANCELLED,
    REQUEST_STATE_OPEN,
    REQUEST_STATE_SENT,
    REQUEST_STATE_RESPONSE_RECEIVED
};

◆ type_id

enum type_id

Enumerator
INetFwAuthorizedApplication_tid
INetFwAuthorizedApplications_tid
INetFwMgr_tid
INetFwOpenPort_tid
INetFwOpenPorts_tid
INetFwPolicy_tid
INetFwPolicy2_tid
INetFwProfile_tid
INetFwRules_tid
IUPnPNAT_tid
last_tid
ISWbemLocator_tid
ISWbemObject_tid
ISWbemObjectSet_tid
ISWbemProperty_tid
ISWbemPropertySet_tid
ISWbemServices_tid
ISWbemSecurity_tid
last_tid
IWinHttpRequest_tid
last_tid

Definition at line 3329 of file request.c.

{
    IWinHttpRequest_tid,
    last_tid
};

Function Documentation

◆ add_host_header()

static BOOL add_host_header	(	struct request *	request,
		DWORD	modifier
	)

static

Definition at line 1819 of file request.c.

{
    BOOL ret;
    DWORD len;
    WCHAR *host;
    static const WCHAR fmt[] = {'%','s',':','%','u',0};
    struct connect *connect = request->connect;
    INTERNET_PORT port;
 
    port = connect->hostport ? connect->hostport : (request->hdr.flags & WINHTTP_FLAG_SECURE ? 443 : 80);
 
    if (port == INTERNET_DEFAULT_HTTP_PORT || port == INTERNET_DEFAULT_HTTPS_PORT)
    {
        return process_header( request, attr_host, connect->hostname, modifier, TRUE );
    }
    len = strlenW( connect->hostname ) + 7; /* sizeof(":65335") */
    if (!(host = heap_alloc( len * sizeof(WCHAR) ))) return FALSE;
    sprintfW( host, fmt, connect->hostname, port );
    ret = process_header( request, attr_host, host, modifier, TRUE );
    heap_free( host );
    return ret;
}

Referenced by handle_redirect(), and send_request().

◆ add_request_headers()

BOOL add_request_headers	(	struct request *	request,
		const WCHAR *	headers,
		DWORD	len,
		DWORD	flags
	)

Definition at line 495 of file request.c.

{
    BOOL ret = FALSE;
    WCHAR *buffer, *p, *q;
    struct header *header;
 
    if (len == ~0u) len = strlenW( headers );
    if (!len) return TRUE;
    if (!(buffer = heap_alloc( (len + 1) * sizeof(WCHAR) ))) return FALSE;
    memcpy( buffer, headers, len * sizeof(WCHAR) );
    buffer[len] = 0;
 
    p = buffer;
    do
    {
        q = p;
        while (*q)
        {
            if (q[0] == '\n' && q[1] == '\r')
            {
                q[0] = '\r';
                q[1] = '\n';
            }
            if (q[0] == '\r' && q[1] == '\n') break;
            q++;
        }
        if (!*p) break;
        if (*q == '\r')
        {
            *q = 0;
            q += 2; /* jump over \r\n */
        }
        if ((header = parse_header( p )))
        {
            ret = process_header( request, header->field, header->value, flags, TRUE );
            free_header( header );
        }
        p = q;
    } while (ret);
 
    heap_free( buffer );
    return ret;
}

Referenced by add_cookie_headers(), send_request(), and WinHttpAddRequestHeaders().

◆ addr_to_str()

static WCHAR * addr_to_str ( struct sockaddr_storage * addr )

static

Definition at line 1462 of file request.c.

{
    char buf[INET6_ADDRSTRLEN];
    void *src;
 
    switch (addr->ss_family)
    {
    case AF_INET:
        src = &((struct sockaddr_in *)addr)->sin_addr;
        break;
    case AF_INET6:
        src = &((struct sockaddr_in6 *)addr)->sin6_addr;
        break;
    default:
        WARN("unsupported address family %d\n", addr->ss_family);
        return NULL;
    }
    if (!inet_ntop( addr->ss_family, src, buf, sizeof(buf) )) return NULL;
    return strdupAW( buf );
}

Referenced by open_connection().

◆ alloc_authinfo()

static struct authinfo * alloc_authinfo ( void )

static

Definition at line 1120 of file request.c.

{
    struct authinfo *ret;
 
    if (!(ret = heap_alloc( sizeof(*ret) ))) return NULL;
 
    SecInvalidateHandle( &ret->cred );
    SecInvalidateHandle( &ret->ctx );
    memset( &ret->exp, 0, sizeof(ret->exp) );
    ret->scheme    = 0;
    ret->attr      = 0;
    ret->max_token = 0;
    ret->data      = NULL;
    ret->data_len  = 0;
    ret->finished  = FALSE;
    return ret;
}

Referenced by do_authorization().

◆ auth_scheme_from_header()

static DWORD auth_scheme_from_header ( const WCHAR * header )

static

Definition at line 911 of file request.c.

{
    unsigned int i;
 
    for (i = 0; i < ARRAY_SIZE( auth_schemes ); i++)
    {
        if (!strncmpiW( header, auth_schemes[i].str, auth_schemes[i].len ) &&
            (header[auth_schemes[i].len] == ' ' || !header[auth_schemes[i].len])) return auth_schemes[i].scheme;
    }
    return 0;
}

Referenced by get_authvalue(), and query_auth_schemes().

◆ build_absolute_request_path()

static WCHAR * build_absolute_request_path	(	struct request *	request,
		const WCHAR **	path
	)

static

Definition at line 573 of file request.c.

{
    static const WCHAR http[] = {'h','t','t','p',0};
    static const WCHAR https[] = {'h','t','t','p','s',0};
    static const WCHAR fmt[] = {'%','s',':','/','/','%','s',0};
    const WCHAR *scheme;
    WCHAR *ret;
    int len;
 
    scheme = (request->netconn ? request->netconn->secure : (request->hdr.flags & WINHTTP_FLAG_SECURE)) ? https : http;
 
    len = strlenW( scheme ) + strlenW( request->connect->hostname ) + 4; /* '://' + nul */
    if (request->connect->hostport) len += 6; /* ':' between host and port, up to 5 for port */
 
    len += strlenW( request->path );
    if ((ret = heap_alloc( len * sizeof(WCHAR) )))
    {
        len = sprintfW( ret, fmt, scheme, request->connect->hostname );
        if (request->connect->hostport)
        {
            static const WCHAR port_fmt[] = {':','%','u',0};
            len += sprintfW( ret + len, port_fmt, request->connect->hostport );
        }
        strcpyW( ret + len, request->path );
        if (path) *path = ret + len;
    }
 
    return ret;
}

Referenced by build_request_string(), and build_wire_path().

◆ build_proxy_connect_string()

static WCHAR * build_proxy_connect_string ( struct request * request )

static

Definition at line 1392 of file request.c.

{
    static const WCHAR fmtW[] = {'%','s',':','%','u',0};
    static const WCHAR connectW[] = {'C','O','N','N','E','C','T', 0};
    static const WCHAR spaceW[] = {' ',0}, crlfW[] = {'\r','\n',0}, colonW[] = {':',' ',0};
    static const WCHAR twocrlfW[] = {'\r','\n','\r','\n',0};
    WCHAR *ret, *host;
    unsigned int i;
    int len;
 
    if (!(host = heap_alloc( (strlenW( request->connect->hostname ) + 7) * sizeof(WCHAR) ))) return NULL;
    len = sprintfW( host, fmtW, request->connect->hostname, request->connect->hostport );
 
    len += ARRAY_SIZE(connectW);
    len += ARRAY_SIZE(http1_1);
 
    for (i = 0; i < request->num_headers; i++)
    {
        if (request->headers[i].is_request)
            len += strlenW( request->headers[i].field ) + strlenW( request->headers[i].value ) + 4; /* '\r\n: ' */
    }
    len += 4; /* '\r\n\r\n' */
 
    if ((ret = heap_alloc( (len + 1) * sizeof(WCHAR) )))
    {
        strcpyW( ret, connectW );
        strcatW( ret, spaceW );
        strcatW( ret, host );
        strcatW( ret, spaceW );
        strcatW( ret, http1_1 );
 
        for (i = 0; i < request->num_headers; i++)
        {
            if (request->headers[i].is_request)
            {
                strcatW( ret, crlfW );
                strcatW( ret, request->headers[i].field );
                strcatW( ret, colonW );
                strcatW( ret, request->headers[i].value );
            }
        }
        strcatW( ret, twocrlfW );
    }
 
    heap_free( host );
    return ret;
}

Referenced by secure_proxy_connect().

◆ build_request_string()

static WCHAR * build_request_string ( struct request * request )

static

Definition at line 603 of file request.c.

{
    static const WCHAR spaceW[] = {' ',0}, crlfW[] = {'\r','\n',0}, colonW[] = {':',' ',0};
    static const WCHAR twocrlfW[] = {'\r','\n','\r','\n',0};
    WCHAR *path, *ret;
    unsigned int i, len;
 
    if (!strcmpiW( request->connect->hostname, request->connect->servername )) path = request->path;
    else if (!(path = build_absolute_request_path( request, NULL ))) return NULL;
 
    len = strlenW( request->verb ) + 1 /* ' ' */;
    len += strlenW( path ) + 1 /* ' ' */;
    len += strlenW( request->version );
 
    for (i = 0; i < request->num_headers; i++)
    {
        if (request->headers[i].is_request)
            len += strlenW( request->headers[i].field ) + strlenW( request->headers[i].value ) + 4; /* '\r\n: ' */
    }
    len += 4; /* '\r\n\r\n' */
 
    if ((ret = heap_alloc( (len + 1) * sizeof(WCHAR) )))
    {
        strcpyW( ret, request->verb );
        strcatW( ret, spaceW );
        strcatW( ret, path );
        strcatW( ret, spaceW );
        strcatW( ret, request->version );
 
        for (i = 0; i < request->num_headers; i++)
        {
            if (request->headers[i].is_request)
            {
                strcatW( ret, crlfW );
                strcatW( ret, request->headers[i].field );
                strcatW( ret, colonW );
                strcatW( ret, request->headers[i].value );
            }
        }
        strcatW( ret, twocrlfW );
    }
 
    if (path != request->path) heap_free( path );
    return ret;
}

Referenced by query_headers().

◆ build_wire_path()

static char * build_wire_path	(	struct request *	request,
		DWORD *	ret_len
	)

static

Definition at line 2159 of file request.c.

{
    WCHAR *full_path;
    const WCHAR *start, *path, *query = NULL;
    DWORD len, len_path = 0, len_query = 0;
    enum escape_flags path_flags, query_flags;
    char *ret;
 
    if (!strcmpiW( request->connect->hostname, request->connect->servername )) start = full_path = request->path;
    else if (!(full_path = build_absolute_request_path( request, &start ))) return NULL;
 
    len = strlenW( full_path );
    if ((path = strchrW( start, '/' )))
    {
        len_path = strlenW( path );
        if ((query = strchrW( path, '?' )))
        {
            len_query = strlenW( query );
            len_path -= len_query;
        }
    }
 
    if (request->hdr.flags & WINHTTP_FLAG_ESCAPE_DISABLE) path_flags = ESCAPE_MASK_DISABLE;
    else if (request->hdr.flags & WINHTTP_FLAG_ESCAPE_PERCENT) path_flags = ESCAPE_MASK_PERCENT;
    else path_flags = ESCAPE_MASK_DEFAULT;
 
    if (request->hdr.flags & WINHTTP_FLAG_ESCAPE_DISABLE_QUERY) query_flags = ESCAPE_MASK_DISABLE;
    else query_flags = path_flags;
 
    *ret_len = str_to_wire( full_path, len - len_path - len_query, NULL, 0 );
    if (path) *ret_len += str_to_wire( path, len_path, NULL, path_flags );
    if (query) *ret_len += str_to_wire( query, len_query, NULL, query_flags );
 
    if ((ret = heap_alloc( *ret_len + 1 )))
    {
        len = str_to_wire( full_path, len - len_path - len_query, ret, 0 );
        if (path) len += str_to_wire( path, len_path, ret + len, path_flags );
        if (query) str_to_wire( query, len_query, ret + len, query_flags );
    }
 
    if (full_path != request->path) heap_free( full_path );
    return ret;
}

Referenced by build_wire_request().

◆ build_wire_request()

static char * build_wire_request	(	struct request *	request,
		DWORD *	len
	)

static

Definition at line 2203 of file request.c.

{
    char *path, *ptr, *ret;
    DWORD i, len_path;
 
    if (!(path = build_wire_path( request, &len_path ))) return NULL;
 
    *len = str_to_wire( request->verb, -1, NULL, 0 ) + 1; /* ' ' */
    *len += len_path + 1; /* ' ' */
    *len += str_to_wire( request->version, -1, NULL, 0 );
 
    for (i = 0; i < request->num_headers; i++)
    {
        if (request->headers[i].is_request)
        {
            *len += str_to_wire( request->headers[i].field, -1, NULL, 0 ) + 2; /* ': ' */
            *len += str_to_wire( request->headers[i].value, -1, NULL, 0 ) + 2; /* '\r\n' */
        }
    }
    *len += 4; /* '\r\n\r\n' */
 
    if ((ret = ptr = heap_alloc( *len + 1 )))
    {
        ptr += str_to_wire( request->verb, -1, ptr, 0 );
        *ptr++ = ' ';
        memcpy( ptr, path, len_path );
        ptr += len_path;
        *ptr++ = ' ';
        ptr += str_to_wire( request->version, -1, ptr, 0 );
 
        for (i = 0; i < request->num_headers; i++)
        {
            if (request->headers[i].is_request)
            {
                *ptr++ = '\r';
                *ptr++ = '\n';
                ptr += str_to_wire( request->headers[i].field, -1, ptr, 0 );
                *ptr++ = ':';
                *ptr++ = ' ';
                ptr += str_to_wire( request->headers[i].value, -1, ptr, 0 );
            }
        }
        memcpy( ptr, "\r\n\r\n", sizeof("\r\n\r\n") );
    }
 
    heap_free( path );
    return ret;
}

Referenced by send_request().

◆ cache_connection()

static void cache_connection ( struct netconn * netconn )

static

Definition at line 1556 of file request.c.

{
    TRACE( "caching connection %p\n", netconn );
 
    EnterCriticalSection( &connection_pool_cs );
 
    netconn->keep_until = GetTickCount64() + DEFAULT_KEEP_ALIVE_TIMEOUT;
    list_add_head( &netconn->host->connections, &netconn->entry );
 
    if (!connection_collector_running)
    {
        HMODULE module;
#ifdef __REACTOS__
        HANDLE thread;
#endif
 
        GetModuleHandleExW( GET_MODULE_HANDLE_EX_FLAG_FROM_ADDRESS, (const WCHAR *)winhttp_instance, &module );
 
#ifdef __REACTOS__
        thread = CreateThread(NULL, 0, connection_collector, NULL, 0, NULL);
        if (thread)
        {
            CloseHandle( thread );
            connection_collector_running = TRUE;
        }
        else
        {
            FreeLibrary( winhttp_instance );
        }
#else
        if (TrySubmitThreadpoolCallback( connection_collector, NULL, NULL )) connection_collector_running = TRUE;
        else FreeLibrary( winhttp_instance );
#endif
    }
 
    LeaveCriticalSection( &connection_pool_cs );
}

Referenced by finished_reading().

◆ cancel_request()

static void cancel_request ( struct winhttp_request * request )

static

Definition at line 3225 of file request.c.

{
    if (request->state <= REQUEST_STATE_CANCELLED) return;
 
#ifdef __REACTOS__
    SetEvent( request->cancel );
    LeaveCriticalSection( &request->cs );
    WaitForSingleObject( request->thread, INFINITE );
    EnterCriticalSection( &request->cs );
 
    request->state = REQUEST_STATE_CANCELLED;
 
    CloseHandle( request->thread );
    request->thread = NULL;
#else
    if (request->proc_running)
    {
        SetEvent( request->cancel );
        LeaveCriticalSection( &request->cs );
 
        WaitForSingleObject( request->done, INFINITE );
 
        EnterCriticalSection( &request->cs );
    }
    request->state = REQUEST_STATE_CANCELLED;
#endif
}

Referenced by reset_request(), winhttp_request_Abort(), and winhttp_request_Release().

◆ clear_response_headers()

static void clear_response_headers ( struct request * request )

static

Definition at line 1842 of file request.c.

{
    unsigned int i;
 
    for (i = 0; i < request->num_headers; i++)
    {
        if (!request->headers[i].field) continue;
        if (!request->headers[i].value) continue;
        if (request->headers[i].is_request) continue;
        delete_header( request, i );
        i--;
    }
}

Referenced by send_request().

◆ close_connection()

void close_connection ( struct request * request )

Definition at line 1809 of file request.c.

{
    if (!request->netconn) return;
 
    send_callback( &request->hdr, WINHTTP_CALLBACK_STATUS_CLOSING_CONNECTION, 0, 0 );
    netconn_close( request->netconn );
    request->netconn = NULL;
    send_callback( &request->hdr, WINHTTP_CALLBACK_STATUS_CONNECTION_CLOSED, 0, 0 );
}

◆ connection_collector()

static void CALLBACK connection_collector	(	TP_CALLBACK_INSTANCE *	instance,
		void *	ctx
	)

static

Definition at line 1513 of file request.c.

{
    unsigned int remaining_connections;
    struct netconn *netconn, *next_netconn;
    struct hostdata *host, *next_host;
    ULONGLONG now;
 
    do
    {
        /* FIXME: Use more sophisticated method */
        Sleep(5000);
        remaining_connections = 0;
        now = GetTickCount64();
 
        EnterCriticalSection(&connection_pool_cs);
 
        LIST_FOR_EACH_ENTRY_SAFE(host, next_host, &connection_pool, struct hostdata, entry)
        {
            LIST_FOR_EACH_ENTRY_SAFE(netconn, next_netconn, &host->connections, struct netconn, entry)
            {
                if (netconn->keep_until < now)
                {
                    TRACE("freeing %p\n", netconn);
                    list_remove(&netconn->entry);
                    netconn_close(netconn);
                }
                else remaining_connections++;
            }
        }
 
        if (!remaining_connections) connection_collector_running = FALSE;
 
        LeaveCriticalSection(&connection_pool_cs);
    } while(remaining_connections);
 
#ifdef __REACTOS__
    FreeLibraryAndExitThread( winhttp_instance, 0 );
#else
    FreeLibraryWhenCallbackReturns( instance, winhttp_instance );
#endif
}

Referenced by cache_connection().

◆ decode_base64()

static unsigned int decode_base64	(	const WCHAR *	base64,
		unsigned int	len,
		char *	buf
	)

static

Definition at line 1058 of file request.c.

{
    unsigned int i = 0;
    char c0, c1, c2, c3;
    const WCHAR *p = base64;
 
    while (len > 4)
    {
        if ((c0 = decode_char( p[0] )) > 63) return 0;
        if ((c1 = decode_char( p[1] )) > 63) return 0;
        if ((c2 = decode_char( p[2] )) > 63) return 0;
        if ((c3 = decode_char( p[3] )) > 63) return 0;
 
        if (buf)
        {
            buf[i + 0] = (c0 << 2) | (c1 >> 4);
            buf[i + 1] = (c1 << 4) | (c2 >> 2);
            buf[i + 2] = (c2 << 6) |  c3;
        }
        len -= 4;
        i += 3;
        p += 4;
    }
    if (p[2] == '=')
    {
        if ((c0 = decode_char( p[0] )) > 63) return 0;
        if ((c1 = decode_char( p[1] )) > 63) return 0;
 
        if (buf) buf[i] = (c0 << 2) | (c1 >> 4);
        i++;
    }
    else if (p[3] == '=')
    {
        if ((c0 = decode_char( p[0] )) > 63) return 0;
        if ((c1 = decode_char( p[1] )) > 63) return 0;
        if ((c2 = decode_char( p[2] )) > 63) return 0;
 
        if (buf)
        {
            buf[i + 0] = (c0 << 2) | (c1 >> 4);
            buf[i + 1] = (c1 << 4) | (c2 >> 2);
        }
        i += 2;
    }
    else
    {
        if ((c0 = decode_char( p[0] )) > 63) return 0;
        if ((c1 = decode_char( p[1] )) > 63) return 0;
        if ((c2 = decode_char( p[2] )) > 63) return 0;
        if ((c3 = decode_char( p[3] )) > 63) return 0;
 
        if (buf)
        {
            buf[i + 0] = (c0 << 2) | (c1 >> 4);
            buf[i + 1] = (c1 << 4) | (c2 >> 2);
            buf[i + 2] = (c2 << 6) |  c3;
        }
        i += 3;
    }
    return i;
}

Referenced by do_authorization().

◆ decode_char()

static char decode_char ( WCHAR c )

inlinestatic

Definition at line 1048 of file request.c.

{
    if (c >= 'A' && c <= 'Z') return c - 'A';
    if (c >= 'a' && c <= 'z') return c - 'a' + 26;
    if (c >= '0' && c <= '9') return c - '0' + 52;
    if (c == '+') return 62;
    if (c == '/') return 63;
    return 64;
}

Referenced by decode_base64().

◆ delete_header()

static BOOL delete_header	(	struct request *	request,
		DWORD	index
	)

static

Definition at line 415 of file request.c.

{
    if (!request->num_headers) return FALSE;
    if (index >= request->num_headers) return FALSE;
    request->num_headers--;
 
    heap_free( request->headers[index].field );
    heap_free( request->headers[index].value );
 
    memmove( &request->headers[index], &request->headers[index + 1],
             (request->num_headers - index) * sizeof(struct header) );
    memset( &request->headers[request->num_headers], 0, sizeof(struct header) );
    return TRUE;
}

Referenced by clear_response_headers(), handle_redirect(), and process_header().

◆ dequeue_task()

static struct task_header * dequeue_task ( struct request * request )

static

Definition at line 184 of file request.c.

{
    struct task_header *task;
 
    EnterCriticalSection( &request->task_cs );
    TRACE("%u tasks queued\n", list_count( &request->task_queue ));
    task = LIST_ENTRY( list_head( &request->task_queue ), struct task_header, entry );
    if (task) list_remove( &task->entry );
    LeaveCriticalSection( &request->task_cs );
 
    TRACE("returning task %p\n", task);
    return task;
}

Referenced by task_proc().

◆ destroy_authinfo()

void destroy_authinfo ( struct authinfo * authinfo )

Definition at line 1138 of file request.c.

{
    if (!authinfo) return;
 
    if (SecIsValidHandle( &authinfo->ctx ))
        DeleteSecurityContext( &authinfo->ctx );
    if (SecIsValidHandle( &authinfo->cred ))
        FreeCredentialsHandle( &authinfo->cred );
 
    heap_free( authinfo->data );
    heap_free( authinfo );
}

Referenced by do_authorization().

◆ discard_eol()

static BOOL discard_eol	(	struct request *	request,
		BOOL	notify
	)

static

Definition at line 1891 of file request.c.

{
    do
    {
        char *eol = memchr( request->read_buf + request->read_pos, '\n', request->read_size );
        if (eol)
        {
            remove_data( request, (eol + 1) - (request->read_buf + request->read_pos) );
            break;
        }
        request->read_pos = request->read_size = 0;  /* discard everything */
        if (!read_more_data( request, -1, notify )) return FALSE;
    } while (request->read_size);
    return TRUE;
}

Referenced by start_next_chunk().

◆ do_authorization()

static BOOL do_authorization	(	struct request *	request,
		DWORD	target,
		DWORD	scheme_flag
	)

static

Definition at line 1163 of file request.c.

{
    struct authinfo *authinfo, **auth_ptr;
    enum auth_scheme scheme = scheme_from_flag( scheme_flag );
    const WCHAR *auth_target, *username, *password;
    WCHAR auth_value[2048], *auth_reply;
    DWORD len = sizeof(auth_value), len_scheme, flags;
    BOOL ret, has_auth_value;
 
    if (scheme == SCHEME_INVALID) return FALSE;
 
    switch (target)
    {
    case WINHTTP_AUTH_TARGET_SERVER:
        has_auth_value = get_authvalue( request, WINHTTP_QUERY_WWW_AUTHENTICATE, scheme_flag, auth_value, len );
        auth_ptr = &request->authinfo;
        auth_target = attr_authorization;
        if (request->creds[TARGET_SERVER][scheme].username)
        {
            if (scheme != SCHEME_BASIC && !has_auth_value) return FALSE;
            username = request->creds[TARGET_SERVER][scheme].username;
            password = request->creds[TARGET_SERVER][scheme].password;
        }
        else
        {
            if (!has_auth_value) return FALSE;
            username = request->connect->username;
            password = request->connect->password;
        }
        break;
 
    case WINHTTP_AUTH_TARGET_PROXY:
        if (!get_authvalue( request, WINHTTP_QUERY_PROXY_AUTHENTICATE, scheme_flag, auth_value, len ))
            return FALSE;
        auth_ptr = &request->proxy_authinfo;
        auth_target = attr_proxy_authorization;
        if (request->creds[TARGET_PROXY][scheme].username)
        {
            username = request->creds[TARGET_PROXY][scheme].username;
            password = request->creds[TARGET_PROXY][scheme].password;
        }
        else
        {
            username = request->connect->session->proxy_username;
            password = request->connect->session->proxy_password;
        }
        break;
 
    default:
        WARN("unknown target %x\n", target);
        return FALSE;
    }
    authinfo = *auth_ptr;
 
    switch (scheme)
    {
    case SCHEME_BASIC:
    {
        int userlen, passlen;
 
        if (!username || !password) return FALSE;
        if ((!authinfo && !(authinfo = alloc_authinfo())) || authinfo->finished) return FALSE;
 
        userlen = WideCharToMultiByte( CP_UTF8, 0, username, strlenW( username ), NULL, 0, NULL, NULL );
        passlen = WideCharToMultiByte( CP_UTF8, 0, password, strlenW( password ), NULL, 0, NULL, NULL );
 
        authinfo->data_len = userlen + 1 + passlen;
        if (!(authinfo->data = heap_alloc( authinfo->data_len ))) return FALSE;
 
        WideCharToMultiByte( CP_UTF8, 0, username, -1, authinfo->data, userlen, NULL, NULL );
        authinfo->data[userlen] = ':';
        WideCharToMultiByte( CP_UTF8, 0, password, -1, authinfo->data + userlen + 1, passlen, NULL, NULL );
 
        authinfo->scheme   = SCHEME_BASIC;
        authinfo->finished = TRUE;
        break;
    }
    case SCHEME_NTLM:
    case SCHEME_NEGOTIATE:
    {
        SECURITY_STATUS status;
        SecBufferDesc out_desc, in_desc;
        SecBuffer out, in;
        ULONG flags = ISC_REQ_CONNECTION|ISC_REQ_USE_DCE_STYLE|ISC_REQ_MUTUAL_AUTH|ISC_REQ_DELEGATE;
        const WCHAR *p;
        BOOL first = FALSE;
 
        if (!authinfo)
        {
            TimeStamp exp;
            SEC_WINNT_AUTH_IDENTITY_W id;
            WCHAR *domain, *user;
 
            if (!username || !password || !(authinfo = alloc_authinfo())) return FALSE;
 
            first = TRUE;
            domain = (WCHAR *)username;
            user = strchrW( username, '\\' );
 
            if (user) user++;
            else
            {
                user = (WCHAR *)username;
                domain = NULL;
            }
            id.Flags          = SEC_WINNT_AUTH_IDENTITY_UNICODE;
            id.User           = user;
            id.UserLength     = strlenW( user );
            id.Domain         = domain;
            id.DomainLength   = domain ? user - domain - 1 : 0;
            id.Password       = (WCHAR *)password;
            id.PasswordLength = strlenW( password );
 
            status = AcquireCredentialsHandleW( NULL, (SEC_WCHAR *)auth_schemes[scheme].str,
                                                SECPKG_CRED_OUTBOUND, NULL, &id, NULL, NULL,
                                                &authinfo->cred, &exp );
            if (status == SEC_E_OK)
            {
                PSecPkgInfoW info;
                status = QuerySecurityPackageInfoW( (SEC_WCHAR *)auth_schemes[scheme].str, &info );
                if (status == SEC_E_OK)
                {
                    authinfo->max_token = info->cbMaxToken;
                    FreeContextBuffer( info );
                }
            }
            if (status != SEC_E_OK)
            {
                WARN("AcquireCredentialsHandleW for scheme %s failed with error 0x%08x\n",
                     debugstr_w(auth_schemes[scheme].str), status);
                heap_free( authinfo );
                return FALSE;
            }
            authinfo->scheme = scheme;
        }
        else if (authinfo->finished) return FALSE;
 
        if ((strlenW( auth_value ) < auth_schemes[authinfo->scheme].len ||
            strncmpiW( auth_value, auth_schemes[authinfo->scheme].str, auth_schemes[authinfo->scheme].len )))
        {
            ERR("authentication scheme changed from %s to %s\n",
                debugstr_w(auth_schemes[authinfo->scheme].str), debugstr_w(auth_value));
            destroy_authinfo( authinfo );
            *auth_ptr = NULL;
            return FALSE;
        }
        in.BufferType = SECBUFFER_TOKEN;
        in.cbBuffer   = 0;
        in.pvBuffer   = NULL;
 
        in_desc.ulVersion = 0;
        in_desc.cBuffers  = 1;
        in_desc.pBuffers  = &in;
 
        p = auth_value + auth_schemes[scheme].len;
        if (*p == ' ')
        {
            int len = strlenW( ++p );
            in.cbBuffer = decode_base64( p, len, NULL );
            if (!(in.pvBuffer = heap_alloc( in.cbBuffer ))) {
                destroy_authinfo( authinfo );
                *auth_ptr = NULL;
                return FALSE;
            }
            decode_base64( p, len, in.pvBuffer );
        }
        out.BufferType = SECBUFFER_TOKEN;
        out.cbBuffer   = authinfo->max_token;
        if (!(out.pvBuffer = heap_alloc( authinfo->max_token )))
        {
            heap_free( in.pvBuffer );
            destroy_authinfo( authinfo );
            *auth_ptr = NULL;
            return FALSE;
        }
        out_desc.ulVersion = 0;
        out_desc.cBuffers  = 1;
        out_desc.pBuffers  = &out;
 
        status = InitializeSecurityContextW( first ? &authinfo->cred : NULL, first ? NULL : &authinfo->ctx,
                                             first ? request->connect->servername : NULL, flags, 0,
                                             SECURITY_NETWORK_DREP, in.pvBuffer ? &in_desc : NULL, 0,
                                             &authinfo->ctx, &out_desc, &authinfo->attr, &authinfo->exp );
        heap_free( in.pvBuffer );
        if (status == SEC_E_OK)
        {
            heap_free( authinfo->data );
            authinfo->data     = out.pvBuffer;
            authinfo->data_len = out.cbBuffer;
            authinfo->finished = TRUE;
            TRACE("sending last auth packet\n");
        }
        else if (status == SEC_I_CONTINUE_NEEDED)
        {
            heap_free( authinfo->data );
            authinfo->data     = out.pvBuffer;
            authinfo->data_len = out.cbBuffer;
            TRACE("sending next auth packet\n");
        }
        else
        {
            ERR("InitializeSecurityContextW failed with error 0x%08x\n", status);
            heap_free( out.pvBuffer );
            destroy_authinfo( authinfo );
            *auth_ptr = NULL;
            return FALSE;
        }
        break;
    }
    default:
        ERR("invalid scheme %u\n", scheme);
        return FALSE;
    }
    *auth_ptr = authinfo;
 
    len_scheme = auth_schemes[authinfo->scheme].len;
    len = len_scheme + 1 + ((authinfo->data_len + 2) * 4) / 3;
    if (!(auth_reply = heap_alloc( (len + 1) * sizeof(WCHAR) ))) return FALSE;
 
    memcpy( auth_reply, auth_schemes[authinfo->scheme].str, len_scheme * sizeof(WCHAR) );
    auth_reply[len_scheme] = ' ';
    encode_base64( authinfo->data, authinfo->data_len, auth_reply + len_scheme + 1 );
 
    flags = WINHTTP_ADDREQ_FLAG_ADD | WINHTTP_ADDREQ_FLAG_REPLACE;
    ret = process_header( request, auth_target, auth_reply, flags, TRUE );
    heap_free( auth_reply );
    return ret;
}

Referenced by handle_authorization(), and send_request().

◆ drain_content()

static void drain_content ( struct request * request )

static

Definition at line 2063 of file request.c.

{
    DWORD size, bytes_read, bytes_total = 0, bytes_left = request->content_length - request->content_read;
    char buffer[2048];
 
    refill_buffer( request, FALSE );
    for (;;)
    {
        if (request->read_chunked) size = sizeof(buffer);
        else
        {
            if (bytes_total >= bytes_left) return;
            size = min( sizeof(buffer), bytes_left - bytes_total );
        }
        if (!read_data( request, buffer, size, &bytes_read, FALSE ) || !bytes_read) return;
        bytes_total += bytes_read;
    }
}

Referenced by send_request().

◆ encode_base64()

static UINT encode_base64	(	const char *	bin,
		unsigned int	len,
		WCHAR *	base64
	)

static

Definition at line 1007 of file request.c.

{
    UINT n = 0, x;
    static const char base64enc[] =
        "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
 
    while (len > 0)
    {
        /* first 6 bits, all from bin[0] */
        base64[n++] = base64enc[(bin[0] & 0xfc) >> 2];
        x = (bin[0] & 3) << 4;
 
        /* next 6 bits, 2 from bin[0] and 4 from bin[1] */
        if (len == 1)
        {
            base64[n++] = base64enc[x];
            base64[n++] = '=';
            base64[n++] = '=';
            break;
        }
        base64[n++] = base64enc[x | ((bin[1] & 0xf0) >> 4)];
        x = (bin[1] & 0x0f) << 2;
 
        /* next 6 bits 4 from bin[1] and 2 from bin[2] */
        if (len == 2)
        {
            base64[n++] = base64enc[x];
            base64[n++] = '=';
            break;
        }
        base64[n++] = base64enc[x | ((bin[2] & 0xc0) >> 6)];
 
        /* last 6 bits, all from bin [2] */
        base64[n++] = base64enc[bin[2] & 0x3f];
        bin += 3;
        len -= 3;
    }
    base64[n] = 0;
    return n;
}

Referenced by do_authorization().

◆ end_of_read_data()

static BOOL end_of_read_data ( struct request * request )

static

Definition at line 2010 of file request.c.

{
    if (!request->content_length) return TRUE;
    if (request->read_chunked) return request->read_chunked_eof;
    if (request->content_length == ~0u) return FALSE;
    return (request->content_length == request->content_read);
}

Referenced by query_data_available(), and read_data().

◆ ensure_cred_handle()

static BOOL ensure_cred_handle ( struct request * request )

static

Definition at line 1605 of file request.c.

{
    SECURITY_STATUS status = SEC_E_OK;
 
    if (request->cred_handle_initialized) return TRUE;
 
    if (!request->cred_handle_initialized)
    {
        SCHANNEL_CRED cred;
        memset( &cred, 0, sizeof(cred) );
        cred.dwVersion             = SCHANNEL_CRED_VERSION;
        cred.grbitEnabledProtocols = map_secure_protocols( request->connect->session->secure_protocols );
        if (request->client_cert)
        {
            cred.paCred = &request->client_cert;
            cred.cCreds = 1;
        }
        status = AcquireCredentialsHandleW( NULL, (WCHAR *)UNISP_NAME_W, SECPKG_CRED_OUTBOUND, NULL,
                                            &cred, NULL, NULL, &request->cred_handle, NULL );
        if (status == SEC_E_OK)
            request->cred_handle_initialized = TRUE;
    }
 
    if (status != SEC_E_OK)
    {
        WARN( "AcquireCredentialsHandleW failed: 0x%08x\n", status );
        return FALSE;
    }
    return TRUE;
}

◆ escape_string()

static DWORD escape_string	(	const char *	src,
		DWORD	len,
		char *	dst,
		enum escape_flags	flags
	)

static

Definition at line 2112 of file request.c.

{
    static const char hex[] = "0123456789ABCDEF";
    DWORD i, ret = len;
    char *ptr = dst;
 
    for (i = 0; i < len; i++)
    {
        if ((flags & ESCAPE_FLAG_STRIP_CRLF) && (src[i] == '\r' || src[i] == '\n'))
        {
            ret--;
            continue;
        }
        if (need_escape( src[i], flags ))
        {
            if (dst)
            {
                ptr[0] = '%';
                ptr[1] = hex[(src[i] >> 4) & 0xf];
                ptr[2] = hex[src[i] & 0xf];
                ptr += 3;
            }
            ret += 2;
        }
        else if (dst) *ptr++ = src[i];
    }
 
    if (dst) dst[ret] = 0;
    return ret;
}

Referenced by str_to_wire().

◆ finished_reading()

static void finished_reading ( struct request * request )

static

Definition at line 1975 of file request.c.

{
    static const WCHAR closeW[] = {'c','l','o','s','e',0};
 
    BOOL close = FALSE;
    WCHAR connection[20];
    DWORD size = sizeof(connection);
 
    if (!request->netconn) return;
 
    if (request->hdr.disable_flags & WINHTTP_DISABLE_KEEP_ALIVE) close = TRUE;
    else if (query_headers( request, WINHTTP_QUERY_CONNECTION, NULL, connection, &size, NULL ) ||
             query_headers( request, WINHTTP_QUERY_PROXY_CONNECTION, NULL, connection, &size, NULL ))
    {
        if (!strcmpiW( connection, closeW )) close = TRUE;
    }
    else if (!strcmpW( request->version, http1_0 )) close = TRUE;
    if (close)
    {
        close_connection( request );
        return;
    }
 
    cache_connection( request->netconn );
    request->netconn = NULL;
}

Referenced by read_data().

◆ free_header()

static void free_header ( struct header * header )

static

Definition at line 297 of file request.c.

{
    heap_free( header->field );
    heap_free( header->value );
    heap_free( header );
}

Referenced by add_request_headers(), parse_header(), and read_reply().

◆ free_request()

static void free_request ( struct winhttp_request * request )

static

Definition at line 3254 of file request.c.

{
    if (request->state < REQUEST_STATE_INITIALIZED) return;
    WinHttpCloseHandle( request->hrequest );
    WinHttpCloseHandle( request->hconnect );
    WinHttpCloseHandle( request->hsession );
#ifdef __REACTOS__
    CloseHandle( request->thread );
#else
    CloseHandle( request->done );
#endif
    CloseHandle( request->wait );
    CloseHandle( request->cancel );
    heap_free( (WCHAR *)request->proxy.lpszProxy );
    heap_free( (WCHAR *)request->proxy.lpszProxyBypass );
    heap_free( request->buffer );
    heap_free( request->verb );
    VariantClear( &request->data );
}

Referenced by winhttp_request_Release().

◆ get_authvalue()

static BOOL get_authvalue	(	struct request *	request,
		DWORD	level,
		DWORD	scheme,
		WCHAR *	buffer,
		DWORD	len
	)

static

Definition at line 1151 of file request.c.

{
    DWORD size, index = 0;
    for (;;)
    {
        size = len;
        if (!query_headers( request, level, NULL, buffer, &size, &index )) return FALSE;
        if (auth_scheme_from_header( buffer ) == scheme) break;
    }
    return TRUE;
}

Referenced by do_authorization().

◆ get_available_data()

static DWORD get_available_data ( struct request * request )

static

Definition at line 2003 of file request.c.

{
    if (request->read_chunked) return min( request->read_chunked_size, request->read_size );
    return request->read_size;
}

Referenced by query_data_available(), and read_data().

◆ get_header_index()

static int get_header_index	(	struct request *	request,
		const WCHAR *	field,
		int	requested_index,
		BOOL	request_only
	)

static

Definition at line 376 of file request.c.

{
    int index;
 
    TRACE("%s\n", debugstr_w(field));
 
    for (index = 0; index < request->num_headers; index++)
    {
        if (strcmpiW( request->headers[index].field, field )) continue;
        if (request_only && !request->headers[index].is_request) continue;
        if (!request_only && request->headers[index].is_request) continue;
 
        if (!requested_index) break;
        requested_index--;
    }
    if (index >= request->num_headers) index = -1;
    TRACE("returning %d\n", index);
    return index;
}

Referenced by handle_redirect(), process_header(), and query_headers().

◆ get_redirect_url()

static WCHAR * get_redirect_url	(	struct request *	request,
		DWORD *	len
	)

static

Definition at line 2684 of file request.c.

{
    DWORD size;
    WCHAR *ret;
 
    query_headers( request, WINHTTP_QUERY_LOCATION, NULL, NULL, &size, NULL );
    if (GetLastError() != ERROR_INSUFFICIENT_BUFFER) return NULL;
    if (!(ret = heap_alloc( size ))) return NULL;
    *len = size / sizeof(WCHAR) - 1;
    if (query_headers( request, WINHTTP_QUERY_LOCATION, NULL, ret, &size, NULL )) return ret;
    heap_free( ret );
    return NULL;
}

Referenced by handle_redirect().

◆ get_typeinfo()

static HRESULT get_typeinfo	(	enum type_id	tid,
		ITypeInfo **	ret
	)

static

Definition at line 3343 of file request.c.

{
    HRESULT hr;
 
    if (!winhttp_typelib)
    {
        ITypeLib *typelib;
 
        hr = LoadRegTypeLib( &LIBID_WinHttp, 5, 1, LOCALE_SYSTEM_DEFAULT, &typelib );
        if (FAILED(hr))
        {
            ERR("LoadRegTypeLib failed: %08x\n", hr);
            return hr;
        }
        if (InterlockedCompareExchangePointer( (void **)&winhttp_typelib, typelib, NULL ))
            ITypeLib_Release( typelib );
    }
    if (!winhttp_typeinfo[tid])
    {
        ITypeInfo *typeinfo;
 
        hr = ITypeLib_GetTypeInfoOfGuid( winhttp_typelib, winhttp_tid_id[tid], &typeinfo );
        if (FAILED(hr))
        {
            ERR("GetTypeInfoOfGuid(%s) failed: %08x\n", debugstr_guid(winhttp_tid_id[tid]), hr);
            return hr;
        }
        if (InterlockedCompareExchangePointer( (void **)(winhttp_typeinfo + tid), typeinfo, NULL ))
            ITypeInfo_Release( typeinfo );
    }
    *ret = winhttp_typeinfo[tid];
    ITypeInfo_AddRef(winhttp_typeinfo[tid]);
    return S_OK;
}

Referenced by winhttp_request_GetIDsOfNames(), winhttp_request_GetTypeInfo(), and winhttp_request_Invoke().

◆ handle_authorization()

static BOOL handle_authorization	(	struct request *	request,
		DWORD	status
	)

static

Definition at line 2469 of file request.c.

{
    DWORD i, schemes, first, level, target;
 
    switch (status)
    {
    case HTTP_STATUS_DENIED:
        target = WINHTTP_AUTH_TARGET_SERVER;
        level  = WINHTTP_QUERY_WWW_AUTHENTICATE;
        break;
 
    case HTTP_STATUS_PROXY_AUTH_REQ:
        target = WINHTTP_AUTH_TARGET_PROXY;
        level  = WINHTTP_QUERY_PROXY_AUTHENTICATE;
        break;
 
    default:
        WARN("unhandled status %u\n", status);
        return FALSE;
    }
 
    if (!query_auth_schemes( request, level, &schemes, &first )) return FALSE;
    if (do_authorization( request, target, first )) return TRUE;
 
    schemes &= ~first;
    for (i = 0; i < ARRAY_SIZE( auth_schemes ); i++)
    {
        if (!(schemes & auth_schemes[i].scheme)) continue;
        if (do_authorization( request, target, auth_schemes[i].scheme )) return TRUE;
    }
    return FALSE;
}

Referenced by receive_response().

◆ handle_passport_redirect()

static BOOL handle_passport_redirect ( struct request * request )

static

Definition at line 2824 of file request.c.

{
    static const WCHAR status401W[] = {'4','0','1',0};
    DWORD flags = WINHTTP_ADDREQ_FLAG_ADD | WINHTTP_ADDREQ_FLAG_REPLACE;
    int i, len = strlenW( request->raw_headers );
    WCHAR *p = request->raw_headers;
 
    if (!process_header( request, attr_status, status401W, flags, FALSE )) return FALSE;
 
    for (i = 0; i < len; i++)
    {
        if (i <= len - 3 && p[i] == '3' && p[i + 1] == '0' && p[i + 2] == '2')
        {
            p[i] = '4';
            p[i + 2] = '1';
            break;
        }
    }
    return TRUE;
}

Referenced by receive_response().

◆ handle_redirect()

static BOOL handle_redirect	(	struct request *	request,
		DWORD	status
	)

static

Definition at line 2698 of file request.c.

{
    BOOL ret = FALSE;
    DWORD len, len_loc;
    URL_COMPONENTS uc;
    struct connect *connect = request->connect;
    INTERNET_PORT port;
    WCHAR *hostname = NULL, *location;
    int index;
 
    if (!(location = get_redirect_url( request, &len_loc ))) return FALSE;
 
    memset( &uc, 0, sizeof(uc) );
    uc.dwStructSize = sizeof(uc);
    uc.dwSchemeLength = uc.dwHostNameLength = uc.dwUrlPathLength = uc.dwExtraInfoLength = ~0u;
 
    if (!WinHttpCrackUrl( location, len_loc, 0, &uc )) /* assume relative redirect */
    {
        WCHAR *path, *p;
 
        if (location[0] == '/')
        {
            if (!(path = heap_alloc( (len_loc + 1) * sizeof(WCHAR) ))) goto end;
            memcpy( path, location, len_loc * sizeof(WCHAR) );
            path[len_loc] = 0;
        }
        else
        {
            if ((p = strrchrW( request->path, '/' ))) *p = 0;
            len = strlenW( request->path ) + 1 + len_loc;
            if (!(path = heap_alloc( (len + 1) * sizeof(WCHAR) ))) goto end;
            strcpyW( path, request->path );
            strcatW( path, slashW );
            memcpy( path + strlenW(path), location, len_loc * sizeof(WCHAR) );
            path[len_loc] = 0;
        }
        heap_free( request->path );
        request->path = path;
 
        send_callback( &request->hdr, WINHTTP_CALLBACK_STATUS_REDIRECT, location, len_loc + 1 );
    }
    else
    {
        if (uc.nScheme == INTERNET_SCHEME_HTTP && request->hdr.flags & WINHTTP_FLAG_SECURE)
        {
            if (request->hdr.redirect_policy == WINHTTP_OPTION_REDIRECT_POLICY_DISALLOW_HTTPS_TO_HTTP) goto end;
            TRACE("redirect from secure page to non-secure page\n");
            request->hdr.flags &= ~WINHTTP_FLAG_SECURE;
        }
        else if (uc.nScheme == INTERNET_SCHEME_HTTPS && !(request->hdr.flags & WINHTTP_FLAG_SECURE))
        {
            TRACE("redirect from non-secure page to secure page\n");
            request->hdr.flags |= WINHTTP_FLAG_SECURE;
        }
 
        send_callback( &request->hdr, WINHTTP_CALLBACK_STATUS_REDIRECT, location, len_loc + 1 );
 
        len = uc.dwHostNameLength;
        if (!(hostname = heap_alloc( (len + 1) * sizeof(WCHAR) ))) goto end;
        memcpy( hostname, uc.lpszHostName, len * sizeof(WCHAR) );
        hostname[len] = 0;
 
        port = uc.nPort ? uc.nPort : (uc.nScheme == INTERNET_SCHEME_HTTPS ? 443 : 80);
        if (strcmpiW( connect->hostname, hostname ) || connect->serverport != port)
        {
            heap_free( connect->hostname );
            connect->hostname = hostname;
            connect->hostport = port;
            if (!(ret = set_server_for_hostname( connect, hostname, port ))) goto end;
 
            netconn_close( request->netconn );
            request->netconn = NULL;
            request->content_length = request->content_read = 0;
            request->read_pos = request->read_size = 0;
            request->read_chunked = request->read_chunked_eof = FALSE;
        }
        else heap_free( hostname );
 
        if (!(ret = add_host_header( request, WINHTTP_ADDREQ_FLAG_ADD | WINHTTP_ADDREQ_FLAG_REPLACE ))) goto end;
        if (!(ret = open_connection( request ))) goto end;
 
        heap_free( request->path );
        request->path = NULL;
        if (uc.dwUrlPathLength)
        {
            len = uc.dwUrlPathLength + uc.dwExtraInfoLength;
            if (!(request->path = heap_alloc( (len + 1) * sizeof(WCHAR) ))) goto end;
            memcpy( request->path, uc.lpszUrlPath, (len + 1) * sizeof(WCHAR) );
            request->path[len] = 0;
        }
        else request->path = strdupW( slashW );
    }
 
    /* remove content-type/length headers */
    if ((index = get_header_index( request, attr_content_type, 0, TRUE )) >= 0) delete_header( request, index );
    if ((index = get_header_index( request, attr_content_length, 0, TRUE )) >= 0 ) delete_header( request, index );
 
    if (status != HTTP_STATUS_REDIRECT_KEEP_VERB && !strcmpW( request->verb, postW ))
    {
        heap_free( request->verb );
        request->verb = strdupW( getW );
        request->optional = NULL;
        request->optional_len = 0;
    }
    ret = TRUE;
 
end:
    heap_free( location );
    return ret;
}

Referenced by receive_response().

◆ impl_from_IStream()

static struct stream * impl_from_IStream ( IStream * iface )

inlinestatic

Definition at line 4383 of file request.c.

{
    return CONTAINING_RECORD( iface, struct stream, IStream_iface );
}

Referenced by stream_AddRef(), stream_QueryInterface(), stream_Read(), stream_Release(), and stream_Seek().

◆ impl_from_IWinHttpRequest()

static struct winhttp_request * impl_from_IWinHttpRequest ( IWinHttpRequest * iface )

inlinestatic

Definition at line 3212 of file request.c.

{
    return CONTAINING_RECORD( iface, struct winhttp_request, IWinHttpRequest_iface );
}

◆ initialize_request()

static void initialize_request ( struct winhttp_request * request )

static

Definition at line 3589 of file request.c.

{
    request->wait   = CreateEventW( NULL, FALSE, FALSE, NULL );
    request->cancel = CreateEventW( NULL, FALSE, FALSE, NULL );
#ifndef __REACTOS__
    request->done   = CreateEventW( NULL, FALSE, FALSE, NULL );
#endif
    request->connect_timeout = 60000;
    request->send_timeout    = 30000;
    request->receive_timeout = 30000;
    request->url_codepage = CP_UTF8;
    VariantInit( &request->data );
    request->state = REQUEST_STATE_INITIALIZED;
}

Referenced by WinHttpRequest_create().

◆ insert_header()

static BOOL insert_header	(	struct request *	request,
		struct header *	header
	)

static

Definition at line 396 of file request.c.

{
    DWORD count = request->num_headers + 1;
    struct header *hdrs;
 
    if (request->headers)
        hdrs = heap_realloc_zero( request->headers, sizeof(struct header) * count );
    else
        hdrs = heap_alloc_zero( sizeof(struct header) );
    if (!hdrs) return FALSE;
 
    request->headers = hdrs;
    request->headers[count - 1].field = strdupW( header->field );
    request->headers[count - 1].value = strdupW( header->value );
    request->headers[count - 1].is_request = header->is_request;
    request->num_headers = count;
    return TRUE;
}

Referenced by process_header().

◆ is_passport_request()

static BOOL is_passport_request ( struct request * request )

static

Definition at line 2809 of file request.c.

{
    static const WCHAR passportW[] = {'P','a','s','s','p','o','r','t','1','.','4'};
    WCHAR buf[1024];
    DWORD len = ARRAY_SIZE(buf);
 
    if (!(request->connect->session->passport_flags & WINHTTP_ENABLE_PASSPORT_AUTH) ||
        !query_headers( request, WINHTTP_QUERY_WWW_AUTHENTICATE, NULL, buf, &len, NULL )) return FALSE;
 
    if (!strncmpiW( buf, passportW, ARRAY_SIZE(passportW) ) &&
        (buf[ARRAY_SIZE(passportW)] == ' ' || !buf[ARRAY_SIZE(passportW)])) return TRUE;
 
    return FALSE;
}

Referenced by receive_response().

◆ map_secure_protocols()

static DWORD map_secure_protocols ( DWORD mask )

static

Definition at line 1594 of file request.c.

{
    DWORD ret = 0;
    if (mask & WINHTTP_FLAG_SECURE_PROTOCOL_SSL2) ret |= SP_PROT_SSL2_CLIENT;
    if (mask & WINHTTP_FLAG_SECURE_PROTOCOL_SSL3) ret |= SP_PROT_SSL3_CLIENT;
    if (mask & WINHTTP_FLAG_SECURE_PROTOCOL_TLS1) ret |= SP_PROT_TLS1_CLIENT;
    if (mask & WINHTTP_FLAG_SECURE_PROTOCOL_TLS1_1) ret |= SP_PROT_TLS1_1_CLIENT;
    if (mask & WINHTTP_FLAG_SECURE_PROTOCOL_TLS1_2) ret |= SP_PROT_TLS1_2_CLIENT;
    return ret;
}

Referenced by ensure_cred_handle().

◆ need_escape()

static BOOL need_escape	(	char	ch,
		enum escape_flags	flags
	)

inlinestatic

Definition at line 2098 of file request.c.

{
    static const char unsafe[] = "\"#<>[\\]^`{|}";
    const char *ptr = unsafe;
 
    if ((flags & ESCAPE_FLAG_SPACE) && ch == ' ') return TRUE;
    if ((flags & ESCAPE_FLAG_PERCENT) && ch == '%') return TRUE;
    if ((flags & ESCAPE_FLAG_NON_PRINTABLE) && ch < 0x20) return TRUE;
    if ((flags & ESCAPE_FLAG_DEL) && ch == 0x7f) return TRUE;
    if ((flags & ESCAPE_FLAG_8BIT) && (ch & 0x80)) return TRUE;
    if ((flags & ESCAPE_FLAG_UNSAFE)) while (*ptr) { if (ch == *ptr++) return TRUE; }
    return FALSE;
}

Referenced by escape_string().

◆ open_connection()

static BOOL open_connection ( struct request * request )

static

Definition at line 1636 of file request.c.

{
    BOOL is_secure = request->hdr.flags & WINHTTP_FLAG_SECURE;
    struct hostdata *host = NULL, *iter;
    struct netconn *netconn = NULL;
    struct connect *connect;
    WCHAR *addressW = NULL;
    INTERNET_PORT port;
    DWORD len;
 
    if (request->netconn) goto done;
 
    connect = request->connect;
    port = connect->serverport ? connect->serverport : (request->hdr.flags & WINHTTP_FLAG_SECURE ? 443 : 80);
 
    EnterCriticalSection( &connection_pool_cs );
 
    LIST_FOR_EACH_ENTRY( iter, &connection_pool, struct hostdata, entry )
    {
        if (iter->port == port && !strcmpW( connect->servername, iter->hostname ) && !is_secure == !iter->secure)
        {
            host = iter;
            host->ref++;
            break;
        }
    }
 
    if (!host)
    {
        if ((host = heap_alloc( sizeof(*host) )))
        {
            host->ref = 1;
            host->secure = is_secure;
            host->port = port;
            list_init( &host->connections );
            if ((host->hostname = strdupW( connect->servername )))
            {
                list_add_head( &connection_pool, &host->entry );
            }
            else
            {
                heap_free( host );
                host = NULL;
            }
        }
    }
 
    LeaveCriticalSection( &connection_pool_cs );
 
    if (!host) return FALSE;
 
    for (;;)
    {
        EnterCriticalSection( &connection_pool_cs );
        if (!list_empty( &host->connections ))
        {
            netconn = LIST_ENTRY( list_head( &host->connections ), struct netconn, entry );
            list_remove( &netconn->entry );
        }
        LeaveCriticalSection( &connection_pool_cs );
        if (!netconn) break;
 
        if (netconn_is_alive( netconn )) break;
        TRACE("connection %p no longer alive, closing\n", netconn);
        netconn_close( netconn );
        netconn = NULL;
    }
 
    if (!connect->resolved && netconn)
    {
        connect->sockaddr = netconn->sockaddr;
        connect->resolved = TRUE;
    }
 
    if (!connect->resolved)
    {
        len = strlenW( host->hostname ) + 1;
        send_callback( &request->hdr, WINHTTP_CALLBACK_STATUS_RESOLVING_NAME, host->hostname, len );
 
        if (!netconn_resolve( host->hostname, port, &connect->sockaddr, request->resolve_timeout ))
        {
            release_host( host );
            return FALSE;
        }
        connect->resolved = TRUE;
 
        if (!(addressW = addr_to_str( &connect->sockaddr )))
        {
            release_host( host );
            return FALSE;
        }
        len = strlenW( addressW ) + 1;
        send_callback( &request->hdr, WINHTTP_CALLBACK_STATUS_NAME_RESOLVED, addressW, len );
    }
 
    if (!netconn)
    {
        if (!addressW && !(addressW = addr_to_str( &connect->sockaddr )))
        {
            release_host( host );
            return FALSE;
        }
 
        TRACE("connecting to %s:%u\n", debugstr_w(addressW), port);
 
        send_callback( &request->hdr, WINHTTP_CALLBACK_STATUS_CONNECTING_TO_SERVER, addressW, 0 );
 
        if (!(netconn = netconn_create( host, &connect->sockaddr, request->connect_timeout )))
        {
            heap_free( addressW );
            release_host( host );
            return FALSE;
        }
        netconn_set_timeout( netconn, TRUE, request->send_timeout );
        netconn_set_timeout( netconn, FALSE, request->receive_response_timeout );
 
        request->netconn = netconn;
 
        if (is_secure)
        {
            if (connect->session->proxy_server &&
                strcmpiW( connect->hostname, connect->servername ))
            {
                if (!secure_proxy_connect( request ))
                {
                    request->netconn = NULL;
                    heap_free( addressW );
                    netconn_close( netconn );
                    return FALSE;
                }
            }
 
            CertFreeCertificateContext( request->server_cert );
            request->server_cert = NULL;
 
            if (!ensure_cred_handle( request ) ||
                !netconn_secure_connect( netconn, connect->hostname, request->security_flags,
                                         &request->cred_handle, request->check_revocation ))
            {
                request->netconn = NULL;
                heap_free( addressW );
                netconn_close( netconn );
                return FALSE;
            }
        }
 
        send_callback( &request->hdr, WINHTTP_CALLBACK_STATUS_CONNECTED_TO_SERVER, addressW, strlenW(addressW) + 1 );
    }
    else
    {
        TRACE("using connection %p\n", netconn);
 
        netconn_set_timeout( netconn, TRUE, request->send_timeout );
        netconn_set_timeout( netconn, FALSE, request->receive_response_timeout );
        request->netconn = netconn;
    }
 
    if (netconn->secure && !(request->server_cert = netconn_get_certificate( netconn )))
    {
        heap_free( addressW );
        netconn_close( netconn );
        return FALSE;
    }
 
done:
    request->read_pos = request->read_size = 0;
    request->read_chunked = FALSE;
    request->read_chunked_size = ~0u;
    request->read_chunked_eof = FALSE;
    heap_free( addressW );
    return TRUE;
}

Referenced by handle_redirect(), and send_request().

◆ parse_header()

static struct header * parse_header ( const WCHAR * string )

static

Definition at line 325 of file request.c.

{
    const WCHAR *p, *q;
    struct header *header;
    int len;
 
    p = string;
    if (!(q = strchrW( p, ':' )))
    {
        WARN("no ':' in line %s\n", debugstr_w(string));
        return NULL;
    }
    if (q == string)
    {
        WARN("empty field name in line %s\n", debugstr_w(string));
        return NULL;
    }
    while (*p != ':')
    {
        if (!valid_token_char( *p ))
        {
            WARN("invalid character in field name %s\n", debugstr_w(string));
            return NULL;
        }
        p++;
    }
    len = q - string;
    if (!(header = heap_alloc_zero( sizeof(struct header) ))) return NULL;
    if (!(header->field = heap_alloc( (len + 1) * sizeof(WCHAR) )))
    {
        heap_free( header );
        return NULL;
    }
    memcpy( header->field, string, len * sizeof(WCHAR) );
    header->field[len] = 0;
 
    q++; /* skip past colon */
    while (*q == ' ') q++;
    len = strlenW( q );
 
    if (!(header->value = heap_alloc( (len + 1) * sizeof(WCHAR) )))
    {
        free_header( header );
        return NULL;
    }
    memcpy( header->value, q, len * sizeof(WCHAR) );
    header->value[len] = 0;
 
    return header;
}

Referenced by add_request_headers(), and read_reply().

◆ process_header()

BOOL process_header	(	struct request *	request,
		const WCHAR *	field,
		const WCHAR *	value,
		DWORD	flags,
		BOOL	request_only
	)

Definition at line 430 of file request.c.

{
    int index;
    struct header hdr;
 
    TRACE("%s: %s 0x%08x\n", debugstr_w(field), debugstr_w(value), flags);
 
    if ((index = get_header_index( request, field, 0, request_only )) >= 0)
    {
        if (flags & WINHTTP_ADDREQ_FLAG_ADD_IF_NEW) return FALSE;
    }
 
    if (flags & WINHTTP_ADDREQ_FLAG_REPLACE)
    {
        if (index >= 0)
        {
            delete_header( request, index );
            if (!value || !value[0]) return TRUE;
        }
        else if (!(flags & WINHTTP_ADDREQ_FLAG_ADD))
        {
            SetLastError( ERROR_WINHTTP_HEADER_NOT_FOUND );
            return FALSE;
        }
 
        hdr.field = (LPWSTR)field;
        hdr.value = (LPWSTR)value;
        hdr.is_request = request_only;
        return insert_header( request, &hdr );
    }
    else if (value)
    {
 
        if ((flags & (WINHTTP_ADDREQ_FLAG_COALESCE_WITH_COMMA | WINHTTP_ADDREQ_FLAG_COALESCE_WITH_SEMICOLON)) &&
            index >= 0)
        {
            WCHAR *tmp;
            int len, len_orig, len_value;
            struct header *header = &request->headers[index];
 
            len_orig = strlenW( header->value );
            len_value = strlenW( value );
 
            len = len_orig + len_value + 2;
            if (!(tmp = heap_realloc( header->value, (len + 1) * sizeof(WCHAR) ))) return FALSE;
            header->value = tmp;
            header->value[len_orig++] = (flags & WINHTTP_ADDREQ_FLAG_COALESCE_WITH_COMMA) ? ',' : ';';
            header->value[len_orig++] = ' ';
 
            memcpy( &header->value[len_orig], value, len_value * sizeof(WCHAR) );
            header->value[len] = 0;
            return TRUE;
        }
        else
        {
            hdr.field = (LPWSTR)field;
            hdr.value = (LPWSTR)value;
            hdr.is_request = request_only;
            return insert_header( request, &hdr );
        }
    }
 
    return TRUE;
}

Referenced by add_accept_types_header(), add_host_header(), add_request_headers(), do_authorization(), handle_passport_redirect(), read_reply(), and send_request().

◆ query_auth_schemes()

static BOOL query_auth_schemes	(	struct request *	request,
		DWORD	level,
		DWORD *	supported,
		DWORD *	first
	)

static

Definition at line 923 of file request.c.

{
    DWORD index = 0, supported_schemes = 0, first_scheme = 0;
    BOOL ret = FALSE;
 
    for (;;)
    {
        WCHAR *buffer;
        DWORD size, scheme;
 
        size = 0;
        query_headers( request, level, NULL, NULL, &size, &index );
        if (GetLastError() != ERROR_INSUFFICIENT_BUFFER) break;
 
        if (!(buffer = heap_alloc( size ))) return FALSE;
        if (!query_headers( request, level, NULL, buffer, &size, &index ))
        {
            heap_free( buffer );
            return FALSE;
        }
        scheme = auth_scheme_from_header( buffer );
        heap_free( buffer );
        if (!scheme) continue;
 
        if (!first_scheme) first_scheme = scheme;
        supported_schemes |= scheme;
 
        ret = TRUE;
    }
 
    if (ret)
    {
        *supported = supported_schemes;
        *first = first_scheme;
    }
    return ret;
}

Referenced by handle_authorization(), and WinHttpQueryAuthSchemes().

◆ query_data_available()

static BOOL query_data_available	(	struct request *	request,
		DWORD *	available,
		BOOL	async
	)

static

Definition at line 2962 of file request.c.

{
    DWORD count = 0;
    BOOL ret = TRUE;
 
    if (end_of_read_data( request )) goto done;
 
    count = get_available_data( request );
    if (!request->read_chunked && request->netconn) count += netconn_query_data_available( request->netconn );
    if (!count)
    {
        if (!(ret = refill_buffer( request, async ))) goto done;
        count = get_available_data( request );
        if (!request->read_chunked && request->netconn) count += netconn_query_data_available( request->netconn );
    }
 
done:
    TRACE("%u bytes available\n", count);
    if (async)
    {
        if (ret) send_callback( &request->hdr, WINHTTP_CALLBACK_STATUS_DATA_AVAILABLE, &count, sizeof(count) );
        else
        {
            WINHTTP_ASYNC_RESULT result;
            result.dwResult = API_QUERY_DATA_AVAILABLE;
            result.dwError  = GetLastError();
            send_callback( &request->hdr, WINHTTP_CALLBACK_STATUS_REQUEST_ERROR, &result, sizeof(result) );
        }
    }
 
    if (ret && available) *available = count;
    return ret;
}

Referenced by task_query_data_available(), and WinHttpQueryDataAvailable().

◆ query_headers()

static BOOL query_headers	(	struct request *	request,
		DWORD	level,
		const WCHAR *	name,
		void *	buffer,
		DWORD *	buflen,
		DWORD *	index
	)

static

Definition at line 651 of file request.c.

{
    struct header *header = NULL;
    BOOL request_only, ret = FALSE;
    int requested_index, header_index = -1;
    DWORD attr, len;
 
    request_only = level & WINHTTP_QUERY_FLAG_REQUEST_HEADERS;
    requested_index = index ? *index : 0;
 
    attr = level & ~QUERY_MODIFIER_MASK;
    switch (attr)
    {
    case WINHTTP_QUERY_CUSTOM:
    {
        header_index = get_header_index( request, name, requested_index, request_only );
        break;
    }
    case WINHTTP_QUERY_RAW_HEADERS:
    {
        WCHAR *headers, *p, *q;
 
        if (request_only)
            headers = build_request_string( request );
        else
            headers = request->raw_headers;
 
        if (!(p = headers)) return FALSE;
        for (len = 0; *p; p++) if (*p != '\r') len++;
 
        if (!buffer || len * sizeof(WCHAR) > *buflen)
            SetLastError( ERROR_INSUFFICIENT_BUFFER );
        else
        {
            for (p = headers, q = buffer; *p; p++, q++)
            {
                if (*p != '\r') *q = *p;
                else
                {
                    *q = 0;
                    p++; /* skip '\n' */
                }
            }
            TRACE("returning data: %s\n", debugstr_wn(buffer, len));
            if (len) len--;
            ret = TRUE;
        }
        *buflen = len * sizeof(WCHAR);
        if (request_only) heap_free( headers );
        return ret;
    }
    case WINHTTP_QUERY_RAW_HEADERS_CRLF:
    {
        WCHAR *headers;
 
        if (request_only)
            headers = build_request_string( request );
        else
            headers = request->raw_headers;
 
        if (!headers) return FALSE;
        len = strlenW( headers ) * sizeof(WCHAR);
        if (!buffer || len + sizeof(WCHAR) > *buflen)
        {
            len += sizeof(WCHAR);
            SetLastError( ERROR_INSUFFICIENT_BUFFER );
        }
        else
        {
            memcpy( buffer, headers, len + sizeof(WCHAR) );
            TRACE("returning data: %s\n", debugstr_wn(buffer, len / sizeof(WCHAR)));
            ret = TRUE;
        }
        *buflen = len;
        if (request_only) heap_free( headers );
        return ret;
    }
    case WINHTTP_QUERY_VERSION:
        len = strlenW( request->version ) * sizeof(WCHAR);
        if (!buffer || len + sizeof(WCHAR) > *buflen)
        {
            len += sizeof(WCHAR);
            SetLastError( ERROR_INSUFFICIENT_BUFFER );
        }
        else
        {
            strcpyW( buffer, request->version );
            TRACE("returning string: %s\n", debugstr_w(buffer));
            ret = TRUE;
        }
        *buflen = len;
        return ret;
 
    case WINHTTP_QUERY_STATUS_TEXT:
        len = strlenW( request->status_text ) * sizeof(WCHAR);
        if (!buffer || len + sizeof(WCHAR) > *buflen)
        {
            len += sizeof(WCHAR);
            SetLastError( ERROR_INSUFFICIENT_BUFFER );
        }
        else
        {
            strcpyW( buffer, request->status_text );
            TRACE("returning string: %s\n", debugstr_w(buffer));
            ret = TRUE;
        }
        *buflen = len;
        return ret;
 
    case WINHTTP_QUERY_REQUEST_METHOD:
        len = strlenW( request->verb ) * sizeof(WCHAR);
        if (!buffer || len + sizeof(WCHAR) > *buflen)
        {
            len += sizeof(WCHAR);
            SetLastError( ERROR_INSUFFICIENT_BUFFER );
        }
        else
        {
            strcpyW( buffer, request->verb );
            TRACE("returning string: %s\n", debugstr_w(buffer));
            ret = TRUE;
        }
        *buflen = len;
        return ret;
 
    default:
        if (attr >= ARRAY_SIZE(attribute_table))
        {
            SetLastError( ERROR_INVALID_PARAMETER );
            return FALSE;
        }
        if (!attribute_table[attr])
        {
            FIXME("attribute %u not implemented\n", attr);
            SetLastError( ERROR_WINHTTP_HEADER_NOT_FOUND );
            return FALSE;
        }
        TRACE("attribute %s\n", debugstr_w(attribute_table[attr]));
        header_index = get_header_index( request, attribute_table[attr], requested_index, request_only );
        break;
    }
 
    if (header_index >= 0)
    {
        header = &request->headers[header_index];
    }
    if (!header || (request_only && !header->is_request))
    {
        SetLastError( ERROR_WINHTTP_HEADER_NOT_FOUND );
        return FALSE;
    }
    if (level & WINHTTP_QUERY_FLAG_NUMBER)
    {
        if (!buffer || sizeof(int) > *buflen)
        {
            SetLastError( ERROR_INSUFFICIENT_BUFFER );
        }
        else
        {
            int *number = buffer;
            *number = atoiW( header->value );
            TRACE("returning number: %d\n", *number);
            ret = TRUE;
        }
        *buflen = sizeof(int);
    }
    else if (level & WINHTTP_QUERY_FLAG_SYSTEMTIME)
    {
        SYSTEMTIME *st = buffer;
        if (!buffer || sizeof(SYSTEMTIME) > *buflen)
        {
            SetLastError( ERROR_INSUFFICIENT_BUFFER );
        }
        else if ((ret = WinHttpTimeToSystemTime( header->value, st )))
        {
            TRACE("returning time: %04d/%02d/%02d - %d - %02d:%02d:%02d.%02d\n",
                  st->wYear, st->wMonth, st->wDay, st->wDayOfWeek,
                  st->wHour, st->wMinute, st->wSecond, st->wMilliseconds);
        }
        *buflen = sizeof(SYSTEMTIME);
    }
    else if (header->value)
    {
        len = strlenW( header->value ) * sizeof(WCHAR);
        if (!buffer || len + sizeof(WCHAR) > *buflen)
        {
            len += sizeof(WCHAR);
            SetLastError( ERROR_INSUFFICIENT_BUFFER );
        }
        else
        {
            strcpyW( buffer, header->value );
            TRACE("returning string: %s\n", debugstr_w(buffer));
            ret = TRUE;
        }
        *buflen = len;
    }
    if (ret && index) *index += 1;
    return ret;
}

Referenced by finished_reading(), get_authvalue(), get_redirect_url(), is_passport_request(), query_auth_schemes(), receive_response(), set_content_length(), and WinHttpQueryHeaders().

◆ queue_task()

static BOOL queue_task ( struct task_header * task )

static

Definition at line 252 of file request.c.

{
    struct request *request = task->request;
 
#ifdef __REACTOS__
    if (!request->task_thread)
#else
    if (!request->task_wait)
#endif
    {
        if (!(request->task_wait = CreateEventW( NULL, FALSE, FALSE, NULL ))) return FALSE;
        if (!(request->task_cancel = CreateEventW( NULL, FALSE, FALSE, NULL )))
        {
            CloseHandle( request->task_wait );
            request->task_wait = NULL;
            return FALSE;
        }
#ifdef __REACTOS__
        if (!(request->task_thread = CreateThread( NULL, 0, task_proc, request, 0, NULL )))
#else
        if (!TrySubmitThreadpoolCallback( task_proc, request, NULL ))
#endif
        {
            CloseHandle( request->task_wait );
            request->task_wait = NULL;
            CloseHandle( request->task_cancel );
            request->task_cancel = NULL;
            return FALSE;
        }
#ifndef __REACTOS__
        request->task_proc_running = TRUE;
#endif
        InitializeCriticalSection( &request->task_cs );
        request->task_cs.DebugInfo->Spare[0] = (DWORD_PTR)(__FILE__ ": request.task_cs");
    }
 
    EnterCriticalSection( &request->task_cs );
    TRACE("queueing task %p\n", task );
    list_add_tail( &request->task_queue, &task->entry );
    LeaveCriticalSection( &request->task_cs );
 
    SetEvent( request->task_wait );
    return TRUE;
}

Referenced by WinHttpQueryDataAvailable(), WinHttpReadData(), WinHttpReceiveResponse(), WinHttpSendRequest(), and WinHttpWriteData().

◆ read_data()

static BOOL read_data (

Macros
#define	COBJMACROS

#define	DEFAULT_KEEP_ALIVE_TIMEOUT 30000

#define	QUERY_MODIFIER_MASK (WINHTTP_QUERY_FLAG_REQUEST_HEADERS \| WINHTTP_QUERY_FLAG_SYSTEMTIME \| WINHTTP_QUERY_FLAG_NUMBER)

#define	ESCAPE_MASK_DEFAULT

#define	ESCAPE_MASK_PERCENT (ESCAPE_FLAG_PERCENT \| ESCAPE_MASK_DEFAULT)

#define	ESCAPE_MASK_DISABLE (ESCAPE_FLAG_SPACE \| ESCAPE_FLAG_8BIT \| ESCAPE_FLAG_STRIP_CRLF)

#define	MAX_REPLY_LEN 1460

#define	INITIAL_HEADER_BUFFER_LEN 512

Classes

Macros

Enumerations

Functions

Variables

Macro Definition Documentation

◆ COBJMACROS

◆ DEFAULT_KEEP_ALIVE_TIMEOUT

◆ ESCAPE_MASK_DEFAULT

◆ ESCAPE_MASK_DISABLE

◆ ESCAPE_MASK_PERCENT

◆ INITIAL_HEADER_BUFFER_LEN

◆ MAX_REPLY_LEN

◆ QUERY_MODIFIER_MASK

Enumeration Type Documentation

◆ escape_flags

◆ request_state

◆ type_id

Function Documentation

◆ add_host_header()

◆ add_request_headers()

◆ addr_to_str()

◆ alloc_authinfo()

◆ auth_scheme_from_header()

◆ build_absolute_request_path()

◆ build_proxy_connect_string()

◆ build_request_string()

◆ build_wire_path()

◆ build_wire_request()

◆ cache_connection()

◆ cancel_request()

◆ clear_response_headers()

◆ close_connection()

◆ connection_collector()

◆ decode_base64()

◆ decode_char()

◆ delete_header()

◆ dequeue_task()

◆ destroy_authinfo()

◆ discard_eol()

◆ do_authorization()

◆ drain_content()

◆ encode_base64()

◆ end_of_read_data()

◆ ensure_cred_handle()

◆ escape_string()

◆ finished_reading()

◆ free_header()

◆ free_request()

◆ get_authvalue()

◆ get_available_data()

◆ get_header_index()

◆ get_redirect_url()

◆ get_typeinfo()

◆ handle_authorization()

◆ handle_passport_redirect()

◆ handle_redirect()

◆ impl_from_IStream()

◆ impl_from_IWinHttpRequest()

◆ initialize_request()

◆ insert_header()

◆ is_passport_request()

◆ map_secure_protocols()

◆ need_escape()

◆ open_connection()

◆ parse_header()

◆ process_header()

◆ query_auth_schemes()

◆ query_data_available()

◆ query_headers()

◆ queue_task()

◆ read_data()