Subversion Repositories Kolibri OS

;? Get HTTP buffer size                                                                           ;;

;? Get HTTP buffer size                                                                           ;;

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

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

;< eax = buffer size in bytes                                                                     ;;

;< eax = buffer size in bytes                                                                     ;;

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

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

        mov     eax, BUFFERSIZE

        mov     eax, [buffersize]

        ret

        ret

;? Set HTTP buffer size                                                                           ;;

;? Set HTTP buffer size                                                                           ;;

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

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

;> eax = buffer size in bytes                                                                     ;;

;> eax = buffer size in bytes                                                                     ;;

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

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

;        mov     [BUFFERSIZE], eax

        mov     [buffersize], eax

        ret

        ret

  .header_parsed:

  .header_parsed:

        ; If we're using ring buffer, check we crossed the boundary

        ; If we're using ring buffer, check we crossed the boundary

        test    [ebp + http_msg.flags], FLAG_RING

        test    [ebp + http_msg.flags], FLAG_RING

        jz      @f

        jz      @f

        mov     ebx, [ebp + http_msg.content_ptr]

        mov     ebx, [ebp + http_msg.content_ptr]

        cmp     [ebp + http_msg.write_ptr], ebx

        cmp     [ebp + http_msg.write_ptr], ebx

        jb      @f

        jb      @f

        DEBUGF  1, "Restarting at beginning of ring buffer\n"

        DEBUGF  1, "Restarting at beginning of ring buffer\n"

  @@:

  @@:

        ; Header was already parsed and connection isnt chunked.

        ; Header was already parsed and connection isnt chunked.

        ; Update content_received

        ; Update content_received

        add     [ebp + http_msg.content_received], eax

        add     [ebp + http_msg.content_received], eax

        ; If we received content-length parameter, check if we received all the data

        ; If we received content-length parameter, check if we received all the data

  .need_more_data_chunked:

  .need_more_data_chunked:

; If we're using ring buffer, check we crossed the boundary

; If we're using ring buffer, check we crossed the boundary

        test    [ebp + http_msg.flags], FLAG_RING

        test    [ebp + http_msg.flags], FLAG_RING

        jz      @f

        jz      @f

        mov     ebx, [ebp + http_msg.content_ptr]

        mov     ebx, [ebp + http_msg.content_ptr]

        cmp     [ebp + http_msg.write_ptr], ebx

        cmp     [ebp + http_msg.write_ptr], ebx

        jb      @f

        jb      @f

        DEBUGF  1, "Restarting at beginning of ring buffer\n"

        DEBUGF  1, "Restarting at beginning of ring buffer\n"

  @@:

  @@:

        ; We only got a partial chunk, or need more chunks, update content_received and request more data

        ; We only got a partial chunk, or need more chunks, update content_received and request more data

        add     [ebp + http_msg.content_received], eax

        add     [ebp + http_msg.content_received], eax

        popa

        popa

        xor     eax, eax

        xor     eax, eax

        dec     eax

        dec     eax

        ret

        ret

  .server_closed:

  .server_closed:

        DEBUGF  1, "server closed connection, transfer complete?\n"

        and     [ebp + http_msg.flags], not FLAG_CONNECTED

        test    [ebp + http_msg.flags], FLAG_GOT_HEADER

        test    [ebp + http_msg.flags], FLAG_GOT_HEADER

        jz      .err_server_closed

        jz      .err_server_closed

        test    [ebp + http_msg.flags], FLAG_CONTENT_LENGTH

        test    [ebp + http_msg.flags], FLAG_CONTENT_LENGTH

        jz      .got_all_data

        jz      .got_all_data