Subversion Repositories Kolibri OS

;;------------------------------------------------------------------------------------------------;;

;;------------------------------------------------------------------------------------------------;;

;> identifier   = pointer to buffer containing http_msg struct.                                   ;;

;> identifier   = pointer to buffer containing http_msg struct.                                   ;;

;;------------------------------------------------------------------------------------------------;;

;;------------------------------------------------------------------------------------------------;;

;< eax = -1 (not finished) / 0 finished                                                           ;;

;< eax = -1 (not finished) / 0 finished                                                           ;;

;;================================================================================================;;

;;================================================================================================;;

        pusha

        pusha

        mov     ebp, [identifier]

        mov     ebp, [identifier]

; Receive some data

; Receive some data

        mov     edi, [ebp + http_msg.write_ptr]

        mov     edi, [ebp + http_msg.write_ptr]

        add     [ebp + http_msg.write_ptr], eax

        add     [ebp + http_msg.write_ptr], eax

        sub     [ebp + http_msg.buffer_length], eax

        sub     [ebp + http_msg.buffer_length], eax

        jz      .got_all_data

        jz      .got_all_data

; If data is chunked, combine chunks into contiguous data.

; If data is chunked, combine chunks into contiguous data.

        test    [ebp + http_msg.flags], FLAG_CHUNKED

        test    [ebp + http_msg.flags], FLAG_CHUNKED

        jnz     .chunk_loop

        jnz     .chunk_loop

; Did we detect the header yet?

; Did we detect the header yet?

        test    [ebp + http_msg.flags], FLAG_GOT_HEADER

        jnz     .header_parsed

        push    eax

; We havent found the header yet, search for it..

; We havent found the header yet, search for it..

        sub     eax, 4

        sub     eax, 4

        jl      .need_more_data

        jl      .need_more_data_pop

  .scan:

  .scan:

        ; scan for end of header (empty line)

        ; scan for end of header (empty line)

        cmp     dword[edi], 0x0a0d0a0d                  ; end of header

        cmp     dword[edi], 0x0a0d0a0d                  ; end of header

        je      .end_of_header

        je      .end_of_header

        cmp     word[edi+2], 0x0a0a

        cmp     word[edi+2], 0x0a0a

        je      .end_of_header

        je      .end_of_header

        inc     edi

        dec     eax

        dec     eax

        jnz     .scan

        jnz     .scan

        jmp     .need_more_data_pop

        sub     ecx, [ebp + http_msg.write_ptr]

        sub     ecx, [ebp + http_msg.write_ptr]

        mov     [ebp + http_msg.buffer_length], ecx

        mov     [ebp + http_msg.buffer_length], ecx

        invoke  mem.realloc, ebp, edx

        invoke  mem.realloc, ebp, edx

        mov     eax, [received]

        pop     eax

        sub     eax, [ebp + http_msg.header_length]

        sub     eax, [ebp + http_msg.header_length]

        jmp     .header_parsed  ; hooray!

        jmp     .header_parsed  ; hooray!

        jne     .invalid_header

        jne     .invalid_header

        or      [ebp + http_msg.flags], FLAG_CHUNKED

        or      [ebp + http_msg.flags], FLAG_CHUNKED

        DEBUGF  1, "Transfer type is: chunked\n"

        pop     eax

; Set chunk pointer where first chunk should begin.

; Set chunk pointer where first chunk should begin.

        lea     eax, [ebp + http_msg.data]

        lea     eax, [ebp + http_msg.data]

  .header_parsed:

  .header_parsed:

        add     [ebp + http_msg.content_received], eax

        add     [ebp + http_msg.content_received], eax

        mov     eax, [ebp + http_msg.content_length]

        mov     eax, [ebp + http_msg.content_length]

        cmp     eax, [ebp + http_msg.content_received]

        cmp     eax, [ebp + http_msg.content_received]

        jae     .got_all_data

        jae     .got_all_data

  .need_more_data:

  .need_more_data:

        popa

        popa

        xor     eax, eax

        xor     eax, eax

        dec     eax

        dec     eax

        ret

        ret

        popa

        popa

        xor     eax, eax

        xor     eax, eax

        ret

        ret

  .invalid_header:

        pop     eax

        DEBUGF  1, "ERROR: invalid header\n"

        DEBUGF  1, "ERROR: invalid header\n"

        or      [ebp + http_msg.flags], FLAG_INVALID_HEADER

        or      [ebp + http_msg.flags], FLAG_INVALID_HEADER

        popa

        popa

        xor     eax, eax

        xor     eax, eax

        ret

  .no_ram_pop:

        pop     eax

  .no_ram:

  .no_ram:

        DEBUGF  1, "ERROR: out of RAM\n"

        DEBUGF  1, "ERROR: out of RAM\n"

        or      [ebp + http_msg.flags], FLAG_NO_RAM

        or      [ebp + http_msg.flags], FLAG_NO_RAM