Subversion Repositories Kolibri OS

Compare Revisions

Regard whitespace Rev 4207 → Rev 4209

/programs/develop/libraries/http/http.asm
87,7 → 87,7
;> ecx = pointer to memory reallocation routine ;;
;> edx = pointer to library loading routine ;;
;;---------------------------------------------------------------------------;;
;< eax = 1 (fail) / 0 (ok) (library initialization result) ;;
;< eax = 1 (fail) / 0 (ok) ;;
;;===========================================================================;;
mov [mem.alloc], eax
mov [mem.free], ebx
95,8 → 95,8
mov [dll.load], edx
 
invoke dll.load, @IMPORT
or eax, eax
jz .ok
test eax, eax
jnz .error
 
; load proxy settings
invoke ini.get_str, inifile, sec_proxy, key_proxy, proxyAddr, 256, proxyAddr
106,17 → 106,17
invoke ini.get_str, inifile, sec_proxy, key_password, proxyPassword, 256, proxyPassword
 
xor eax, eax
inc eax
ret
 
.ok:
.error:
xor eax, eax
inc eax
 
ret
 
 
 
 
 
;;================================================================================================;;
proc HTTP_get URL ;///////////////////////////////////////////////////////////////////////////////;;
;;------------------------------------------------------------------------------------------------;;
421,6 → 421,7
pusha
mov ebp, [identifier]
 
; If the connection is closed, return immediately
test [ebp + http_msg.flags], FLAG_CONNECTED
jz .connection_closed
 
431,6 → 432,7
je .check_socket
DEBUGF 1, "Received %u bytes\n", eax
 
; Update timestamp
push eax
mcall 29, 9
mov [ebp + http_msg.timestamp], eax
888,9 → 890,146
 
 
 
;;================================================================================================;;
proc URI_escape URI ;/////////////////////////////////////////////////////////////////////////////;;
;;------------------------------------------------------------------------------------------------;;
;? ;;
;;------------------------------------------------------------------------------------------------;;
;> URI = ptr to ASCIIZ URI ;;
;;------------------------------------------------------------------------------------------------;;
;< eax = 0 (error) / ptr to ASCIIZ URI ;;
;;================================================================================================;;
 
pusha
 
invoke mem.alloc, URLMAXLEN
test eax, eax
jz .error
mov [esp + 7 * 4], eax ; return ptr in eax
mov esi, [URI]
mov edi, eax
xor ebx, ebx
xor ecx, ecx
.loop:
lodsb
test al, al
jz .done
 
mov cl, al
and cl, 0x1f
mov bl, al
shr bl, 5
bt dword[bits_must_escape + ebx], ecx
jc .escape
 
stosb
jmp .loop
 
.escape:
mov al, '%'
stosb
mov bl, byte[esi-1]
shr bl, 4
mov al, byte[str_hex + ebx]
stosb
mov bl, byte[esi-1]
and bl, 0x0f
mov al, byte[str_hex + ebx]
stosb
jmp .loop
 
 
.done:
stosb
 
popa
ret
 
.error:
popa
xor eax, eax
ret
 
endp
 
 
 
;;================================================================================================;;
proc URI_unescape URI ;///////////////////////////////////////////////////////////////////////////;;
;;------------------------------------------------------------------------------------------------;;
;? ;;
;;------------------------------------------------------------------------------------------------;;
;> URI = ptr to ASCIIZ URI ;;
;;------------------------------------------------------------------------------------------------;;
;< eax = 0 (error) / ptr to ASCIIZ URI ;;
;;================================================================================================;;
 
pusha
 
invoke mem.alloc, URLMAXLEN
test eax, eax
jz .error
mov [esp + 7 * 4], eax ; return ptr in eax
mov esi, [URI]
mov edi, eax
.loop:
lodsb
test al, al
jz .done
 
cmp al, '%'
je .unescape
 
stosb
jmp .loop
 
.unescape:
xor ebx, ebx
xor ecx, ecx
.unescape_nibble:
lodsb
sub al, '0'
jb .fail
cmp al, 9
jbe .nibble_ok
sub al, 'A' - '0' - 10
jb .fail
cmp al, 15
jbe .nibble_ok
sub al, 'a' - 'A'
cmp al, 15
ja .fail
.nibble_ok:
shl bl, 8
or bl, al
dec ecx
jc .unescape_nibble
mov al, bl
stosb
jmp .loop
 
.fail:
DEBUGF 1, "ERROR: invalid URI!\n"
jmp .loop
 
.done:
stosb
 
popa
ret
 
.error:
popa
xor eax, eax
ret
 
endp
 
 
 
 
 
;;================================================================================================;;
;;////////////////////////////////////////////////////////////////////////////////////////////////;;
;;================================================================================================;;
;! Internal procedures section ;;
1161,7 → 1300,9
find_header_field , 'find_header_field' , \
HTTP_process , 'process' , \
HTTP_free , 'free' , \
HTTP_stop , 'stop'
HTTP_stop , 'stop' , \
URI_escape , 'escape' , \
URI_unescape , 'unescape'
 
; HTTP_put , 'put' , \
; HTTP_delete , 'delete' , \
1201,6 → 1342,20
str_head db 'HEAD ', 0
str_post db 'POST ', 0
 
bits_must_escape:
dd 0xffffffff ; 00-1F
dd 1 shl 0 + 1 shl 2 + 1 shl 3 + 1 shl 5 + 1 shl 28 + 1 shl 30 ; "#%<>
dd 1 shl 27 + 1 shl 28 + 1 shl 29 + 1 shl 30 ;[\]^
dd 1 shl 0 + 1 shl 27 + 1 shl 28 + 1 shl 29 + 1 shl 31 ;`{|} DEL
 
dd 0xffffffff
dd 0xffffffff
dd 0xffffffff
dd 0xffffffff
 
str_hex:
db '0123456789ABCDEF'
 
include_debug_strings
 
; uninitialized data
/programs/develop/libraries/http/http.inc
13,6 → 13,7
;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
 
 
; Bitflags for http_msg.flags
FLAG_HTTP11 = 1 shl 0
FLAG_GOT_HEADER = 1 shl 1
FLAG_GOT_ALL_DATA = 1 shl 2
19,8 → 20,7
FLAG_CONTENT_LENGTH = 1 shl 3
FLAG_CHUNKED = 1 shl 4
FLAG_CONNECTED = 1 shl 5
 
; error flags go into the upper word
; ERROR flags go into the upper word
FLAG_INVALID_HEADER = 1 shl 16
FLAG_NO_RAM = 1 shl 17
FLAG_SOCKET_ERROR = 1 shl 18
27,15 → 27,17
FLAG_TIMEOUT_ERROR = 1 shl 19
 
struc http_msg {
.socket dd ?
.flags dd ?
.write_ptr dd ?
.buffer_length dd ?
.chunk_ptr dd ?
.timestamp dd ?
.status dd ?
.header_length dd ?
.content_length dd ?
.content_received dd ?
 
.socket dd ? ; socket on which the actual transfer happens
.flags dd ? ; flags, reflects status of the transfer using bitflags
.write_ptr dd ? ; internal use only (where to write new data in buffer)
.buffer_length dd ? ; internal use only (number of available bytes in buffer)
.chunk_ptr dd ? ; internal use only (where the next chunk begins)
.timestamp dd ? ; internal use only (when last data was received)
.status dd ? ; HTTP status
.header_length dd ? ; length of HTTP header
.content_length dd ? ; length of HTTP content
.content_received dd ? ; number of currently received content bytes
.data:
 
}