Subversion Repositories Kolibri OS

        popa

        popa

        DEBUGF  DEBUG_NETWORK_VERBOSE, "TCP_input: socket ptr=%x state=%u flags=%x\n", ebx, [ebx + TCP_SOCKET.t_state], [edx + TCP_header.Flags]:2

        DEBUGF  DEBUG_NETWORK_VERBOSE, "TCP_input: socket ptr=%x state=%u flags=%x\n", ebx, [ebx + TCP_SOCKET.t_state], [edx + TCP_header.Flags]:2

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

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

; Check if socket isnt closed

; Check if socket is not closed

        movzx   eax, [edx + TCP_header.Window]

        movzx   eax, [edx + TCP_header.Window]

        push    ecx

        push    ecx

        mov     cl, [ebx + TCP_SOCKET.SND_SCALE]

        mov     cl, [ebx + TCP_SOCKET.SND_SCALE]

        mov     dword[edx + TCP_header.Window], eax     ; word after window is checksum, we dont need checksum anymore

        mov     dword[edx + TCP_header.Window], eax     ; word after window is checksum, we don't need checksum anymore

        pop     ecx

        pop     ecx

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

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

        mov     [ebx + TCP_SOCKET.ts_val], eax

        mov     [ebx + TCP_SOCKET.ts_val], eax

        lodsd                                   ; timestamp echo reply

        lodsd                                   ; timestamp echo reply

        mov     [ebx + TCP_SOCKET.ts_ecr], eax

        mov     [ebx + TCP_SOCKET.ts_ecr], eax

        or      [temp_bits], TCP_BIT_TIMESTAMP

        or      [temp_bits], TCP_BIT_TIMESTAMP

        ; Since we have a timestamp, lets do the paws test right away!

        ; Since we have a timestamp, let's do the paws test right away!

        test    [edx + TCP_header.Flags], TH_RST

        test    [edx + TCP_header.Flags], TH_RST

        test    [temp_bits], TCP_BIT_FIN_IS_ACKED

        test    [temp_bits], TCP_BIT_FIN_IS_ACKED

        jz      .ack_processed

        jz      .ack_processed

; If we can't receive any more data, then closing user can proceed.

; If we can't receive any more data, then closing user can proceed.

; Starting the timer is contrary to the specification, but if we dont get a FIN,

; Starting the timer is contrary to the specification, but if we don't get a FIN,

; we'll hang forever.

; we'll hang forever.

; Advance sequence number to correspond to first data byte.

; Advance sequence number to correspond to first data byte.

; If data, trim to stay within window, dropping FIN if necessary

; If data, trim to stay within window, dropping FIN if necessary

; Drop any received data that doesnt fit in the receive window.

; Drop any received data that doesn't fit in the receive window.

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

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

  .ack_processed:

  .ack_processed:

; dont look at window if no ACK

; don't look at window if no ACK

; The connection is established?

; The connection is established?

        cmp     [ebx + TCP_SOCKET.t_state], TCPS_ESTABLISHED

        cmp     [ebx + TCP_SOCKET.t_state], TCPS_ESTABLISHED

; Ok, lets do this..  Set delayed ACK flag and copy data into socket buffer

; Ok, let's do this..  Set delayed ACK flag and copy data into socket buffer

  .out_of_order:

  .out_of_order:

        DEBUGF  DEBUG_NETWORK_VERBOSE,  "TCP data is out of order!\nSequencenumber is %u, we expected %u.\n", \

        DEBUGF  DEBUG_NETWORK_VERBOSE,  "TCP data is out of order!\nSequencenumber is %u, we expected %u.\n", \

; Uh-oh, some data is out of order, lets call TCP reassemble for help

; Uh-oh, some data is out of order, let's call TCP reassemble for help

        pop     edx ebx

        pop     edx ebx

        test    [edx + TCP_header.Flags], TH_RST

        test    [edx + TCP_header.Flags], TH_RST

; TODO: if its a multicast/broadcast, also drop

; TODO: if it's a multicast/broadcast, also drop

  .respond_seg_reset:

  .respond_seg_reset:

        test    [edx + TCP_header.Flags], TH_RST

        test    [edx + TCP_header.Flags], TH_RST

; TODO: if its a multicast/broadcast, also drop

; TODO: if it's a multicast/broadcast, also drop