BlueGreycalmElegant

Català-Valencià – Catalan中文 – Chinese (Simplified)中文 – Chinese (Traditional)Česky – CzechDansk – DanishNederlands – DutchEnglish – EnglishSuomi – FinnishFrançais – FrenchDeutsch – Germanעברית – Hebrewहिंदी – HindiMagyar – HungarianBahasa Indonesia – IndonesianItaliano – Italian日本語 – Japanese한국어 – KoreanМакедонски – Macedonianमराठी – MarathiNorsk – NorwegianPolski – PolishPortuguês – PortuguesePortuguês – Portuguese (Brazil)Русский – RussianSlovenčina – SlovakSlovenščina – SlovenianEspañol – SpanishSvenska – SwedishTürkçe – TurkishУкраїнська – UkrainianOëzbekcha – Uzbek

Compare Revisions

• This comparison shows the changes necessary to convert path

  → /kernel/ @ 2993

  → /kernel/ @ 2994

  ↔ Reverse comparison

• Compare Path:	Rev

  With Path:	Rev

Regard whitespace Rev 2993 → Rev 2994

/kernel/branches/net/network/socket.inc
228,6 → 228,26
;-----------------------------------------------------------------
;
; SOCKET_block
;
;-----------------------------------------------------------------
macro SOCKET_block socket, loop, done {
test [socket + SOCKET.options], SO_BLOCK ; Is this a blocking socket?
jz done ; No, return immediately
push esi
mov esi, 5 ; yes, wait for event
call delay_ms
pop esi
jmp loop
}
;-----------------------------------------------------------------
;
; Socket API (function 74)
;
;-----------------------------------------------------------------
564,6 → 584,8
mov eax, ebx
call TCP_output
;;; TODO: wait for successfull connection if blocking socket
mov dword [esp+32], 0
ret
666,7 → 688,10
cmp [eax + SOCKET.Protocol], IP_PROTO_TCP
jne s_error
get_from_queue (eax + SOCKET_QUEUE_LOCATION), MAX_backlog, 4, s_error
.loop:
get_from_queue (eax + SOCKET_QUEUE_LOCATION), MAX_backlog, 4, .block
; Ok, we got a socket ptr
mov eax, [esi]
; Change PID to that of the current process
674,11 → 699,15
mov ebx, [ebx + TASKDATA.pid]
mov [eax + SOCKET.PID], ebx
; Convert it to a socket number
call SOCKET_ptr_to_num
jz s_error
; and return it to caller
mov [esp+32], eax
ret
.block:
SOCKET_block eax, .loop, s_error
;-----------------------------------------------------------------
;
719,6 → 748,8
call TCP_usrclosed
call TCP_output ;;;; Fixme: is this nescessary??
;;; TODO: wait for successfull termination if blocking socket
mov dword [esp+32], 0
ret
760,7 → 791,8
mov ebx, esi
mov edi, edx ; addr to buffer
get_from_queue (eax + SOCKET_QUEUE_LOCATION), SOCKET_QUEUE_SIZE, sizeof.socket_queue_entry, s_error ; destroys esi and ecx
.loop:
get_from_queue (eax + SOCKET_QUEUE_LOCATION), SOCKET_QUEUE_SIZE, sizeof.socket_queue_entry, .block ; destroys esi and ecx
mov ecx, [esi + socket_queue_entry.data_size]
DEBUGF 1,"SOCKET_receive: %u bytes data\n", ecx
795,6 → 827,10
DEBUGF 1,"SOCKET_receive: Buffer too small\n"
jmp s_error
.block:
SOCKET_block eax, .loop, s_error
align 4
SOCKET_receive_tcp:
802,16 → 838,21
mov ecx, esi
mov edi, edx
xor edx, edx
add eax, STREAM_SOCKET.rcv
xor edx, edx
.loop: ;;;; FIXME: ecx!
call SOCKET_ring_read
test ecx, ecx
jz .block
call SOCKET_ring_free
mov [esp+32], ecx ; return number of bytes copied
ret
.block:
SOCKET_block (eax - STREAM_SOCKET.rcv), .loop, s_error
;-----------------------------------------------------------------
;
; SOCKET_send
1308,9 → 1349,13
; IN: eax = ring struct ptr
; ecx = bytes to read
; edx = offset
; edi = ptr to buffer
; edi = ptr to buffer start
;
; OUT: ecx = number of bytes read (0 on error)
; OUT: eax = unchanged
; ecx = number of bytes read (0 on error)
; edx = destroyed
; esi = destroyed
; edi = ptr to buffer end
;
;-----------------------------------------------------------------
align 4

/kernel/branches/net/network/stack.inc
80,6 → 80,8
SO_USELOOPBACK = 1 shl 8
SO_BINDTODEVICE = 1 shl 9
SO_BLOCK = 1 shl 10
; Socket level
SOL_SOCKET = 0