WebSVN – Kolibri OS – Diff – /programs/network/mp3s/trunk/mp3s.asm


;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
;                                             ;
;    Tiny MP3 Shoutcast Server v0.1 (vt)      ;
;                                             ;
;    Compile with FASM for Menuet             ;
;                                             ;
;    Listening to port 8008                   ;
;    Connect with eg: 192.168.1.22:8008       ;
;                                             ;
;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
 
version  equ  '0.3'
 
  use32
  org     0x0
  db      'MENUET01'    ; 8 byte id
  dd      0x01          ; header version
  dd      START         ; program start
  dd      I_END         ; program image size
  dd      0x80000       ; memory usage
  dd      0x20000       ; stack
  dd      0,0
 
include 'lang.inc'
include '..\..\..\macros.inc'
 
; 0x0+      program image
; 0x1ffff   stack
; 0x20000   work area for file read
; 0x40000+  file send buffer ( 100 kb )
 
 
START:                          ; start of execution
 
    mov  [status],0
    call clear_input
    call draw_window            ; at first, draw the window
 
still:
 
    mov  eax,23                 ; wait here for event
    mov  ebx,2
    mcall
 
    call check_events
 
    call check_connection_status
 
    cmp  [status],4
    je   start_transmission
 
    jmp  still
 
 
check_events:
 
    cmp  eax,1                  ; redraw request ?
    jz   red
    cmp  eax,2                  ; key in buffer ?
    jz   key
    cmp  eax,3                  ; button in buffer ?
    jz   button
 
    ret
 
red:                           ; redraw
    call draw_window
    ret
 
key:
    mov  eax,2                 ; Just read it and ignore
    mcall
    ret
 
button:                         ; button
 
    mov  eax,17                 ; get id
    mcall
 
    cmp  ah,1                   ; close
    jne  no_close
    mov  eax,-1
    mcall
  no_close:
 
    cmp  ah,2                   ; button id=2 ?
    jnz  tst3
    ; open socket
    mov  eax,53
    mov  ebx,5
    mov  ecx,8008   ; local port # - http
    mov  edx,0      ; no remote port specified
    mov  esi,0      ; no remote ip specified
    mov  edi,0      ; PASSIVE open
    mcall
    mov  [socket], eax
    mov  [posy],1
    mov  [posx],0
    mov  [read_on],1
    call check_for_incoming_data
    call draw_window
    ret
  tst3:
 
    cmp  ah,4
    je   close_socket
    cmp  ah,6
    je   close_socket
    jmp  no_socket_close
  close_socket:
    mov  edx,eax
    ; Close socket
    mov  eax, 53
    mov  ebx, 8
    mov  ecx, [socket]
    mcall
    mov  esp,0x1fff0
    cmp  dh,6
    je   read_string
    jmp  still
  no_socket_close:
 
    cmp  ah,9
    jne  no_bps_add
    add  [bps],8*1000
    call draw_window
    ret
  no_bps_add:
 
    cmp  ah,8
    jne  no_bps_sub
    sub  [bps],8*1000
    call draw_window
    ret
  no_bps_sub:
 
 
    ret
 
 
clear_input:
 
    mov  edi,input_text
    mov  eax,0
    mov  ecx,60*40
    cld
    rep  stosb
 
    ret
 
 
read_string:
 
    mov  [addr],dword filename
    mov  [ya],dword 95
 
    mov  edi,[addr]
    mov  eax,32
    mov  ecx,30
    cld
    rep  stosb
 
    call print_text
 
    mov  edi,[addr]
 
  f11:
    mov  eax,10
    mcall
    cmp  eax,2
    jne  read_done
    mov  eax,2
    mcall
    shr  eax,8
    cmp  eax,13
    je   read_done
    cmp  eax,8
    jnz  nobsl
    cmp  edi,[addr]
    jz   f11
    sub  edi,1
    mov  [edi],byte 32
    call print_text
    jmp  f11
  nobsl:
    cmp  eax,dword 31
    jbe  f11
    cmp  eax,dword 95
    jb   keyok
    sub  eax,32
  keyok:
    mov  [edi],al
 
    call print_text
 
    add  edi,1
    mov  esi,[addr]
    add  esi,30
    cmp  esi,edi
    jnz  f11
 
  read_done:
 
    mov  ecx,40
    mov  eax,0
    cld
    rep  movsb
 
    call print_text
 
    jmp  still
 
 
print_text:
 
    pusha
 
    mov  eax,13
    mov  ebx,56*65536+30*6
    mov  ecx,[ya]
    shl  ecx,16
    mov  cx,8
    mov  edx,0xffffff
    mcall
 
    mov  eax,4
    mov  edx,[addr]
    mov  ebx,56*65536
    add  ebx,[ya]
    mov  ecx,0x000000
    mov  esi,30
    mcall
 
    popa
    ret
 
 
wait_for  dd 0x0
 
transmission_start  dd  0x0
sentbytes           dd  0x0
 
start_transmission:
 
    call clear_input
 
    mov  eax,5
    mov  ebx,50
    mcall
 
    call check_for_incoming_data
    call draw_window
 
    call send_header
 
    mov  [fileinfo+4],dword 0   ; start from beginning
    mov  [read_to],0x40000
    mov  [playpos],0x40000
 
    mov  ecx,1024 / 512
 
  new_buffer:
 
    mov  eax,[read_to]
    mov  ebx,1
    call read_file
 
    loop new_buffer
 
 
  newpart:
 
    call check_connection_status
    call draw_window
 
    mov  eax,26
    mov  ebx,9
    mcall
    mov  [transmission_start],eax
    mov  [sentbytes],0
 
  newblock:
 
    mov  eax,[read_to]
    mov  ebx,2
    call read_file
 
  wait_more:
 
    mov  eax,26
    mov  ebx,9
    mcall
 
    cmp  eax,[wait_for]
    jge  nomw
 
    mov  eax,5
    mov  ebx,1
    mcall
 
    jmp  wait_more
 
  nomw:
 
    add  eax,2
    mov  [wait_for],eax
 
    mov  eax,11
    mcall
    call check_events
 
    mov  eax,53
    mov  ebx,255
    mov  ecx,103
    mcall
 
    cmp  eax,0
    jne  wait_more
 
    ; write to socket
    mov  eax,53
    mov  ebx,7
    mov  ecx,[socket]
    mov  edx,[playadd]
    mov  esi,[playpos]
    mcall
 
    add  [sentbytes],edx
 
    mov  esi,[playpos]
    add  esi,[playadd]
    mov  edi,0x40000
    mov  ecx,110000 / 4
    cld
    rep  movsd
 
    mov  eax,[playadd]
    sub  [read_to],eax
 
    call check_for_incoming_data
    call show_progress
    call check_rate
 
    mov  eax, 53
    mov  ebx, 6
    mov  ecx, [socket]
    mcall
    cmp  eax,4
    jne  end_stream
 
    cmp  [read_to],0x40000
    jge  newblock
 
  end_stream:
 
    ; Close socket
 
    mov  eax, 53
    mov  ebx, 8
    mov  ecx, [socket]
    mcall
 
    mov  eax,5
    mov  ebx,5
    mcall
 
    ; Open socket
 
    mov  eax,53
    mov  ebx,5
    mov  ecx,8008   ; local port # - http
    mov  edx,0      ; no remote port specified
    mov  esi,0      ; no remote ip specified
    mov  edi,0      ; PASSIVE open
    mcall
    mov  [socket], eax
    mov  [posy],1
    mov  [posx],0
    mov  [read_on],0
 
    call draw_window
 
    jmp  still
 
 
check_rate:
 
    pusha
 
    mov  eax,[bps]
    xor  edx,edx
    mov  ebx,8*100
    div  ebx
    shl  eax,1
    mov  [playadd],eax
 
    mov  eax,26
    mov  ebx,9
    mcall
 
    sub  eax,[transmission_start]
    shr  eax,1
 
    imul eax,[playadd]
 
    mov  edx,0x00dd00
 
    cmp  [sentbytes],eax
    jge  sendok
 
    sub  eax,20000
    cmp  [sentbytes],eax        ; a long buffer underrun correction
    jge  no_buffer_overrun      ; actually leads to overrun
    mov  [sentbytes],eax
  no_buffer_overrun:
 
    add  [playadd],150
    mov  edx,0xdd0000
 
  sendok:
 
    mov  eax,13
    mov  ebx,320*65536+10
    mov  ecx,105*65536+10
    mcall
 
    mov  eax,47
    mov  ebx,4*65536
    mov  ecx,[playadd]
    mov  edx,322*65536+106
    mov  esi,0x000000
;    mcall
 
    popa
 
    ret
 
 
show_progress:
 
    pusha
 
    mov  eax,13
    mov  ebx,236*65536+10*6
    mov  ecx,107*65536+8
    mov  edx,0xffffff
    mcall
 
    mov  ecx,[fileinfo+4]
    imul ecx,512
 
    mov  eax,47               ; file read
    mov  ebx,9*65536
    mov  edx,236*65536+107
    mov  esi,0x000000
    mcall
 
    popa
    ret
 
 
playpos  dd  0x100000
playadd  dd  256000 / 8 / 100
 
 
send_header:
 
    pusha
 
    mov   [playpos],0x40000
 
    mov   esi,fileinfo+5*4
    mov   edi,transname
    mov   ecx,30
    cld
    rep   movsb
 
    mov   eax, 53
    mov   ebx, 7
    mov   ecx, [socket]
    mov   edx, headere-headers
    mov   esi, headers
    mcall
 
    popa
    ret
 
 
read_file:
 
    cmp  [read_to],0x40000+2000
    jg   cache_ok
    mov  [read_on],1
  cache_ok:
 
    cmp  [read_to],0x40000+95500
    jg   no_read_1
 
    mov  [fileinfo+12],eax
    mov  [fileinfo+8],ebx
 
    mov  eax,58
    mov  ebx,fileinfo
    mcall
 
    cmp  eax,0
    jne  no_read_1
 
    mov  eax,[fileinfo+8]
    add  [fileinfo+4],eax
 
    add  [read_to],512*2
 
    ret
 
  no_read_1:
 
    mov  [read_on],0
 
    ret
 
 
 
check_for_incoming_data:
 
    pusha
 
    mov  eax, 53
    mov  ebx, 2
    mov  ecx, [socket]
    mcall
 
    cmp  eax,0
    je   _ret_now
 
  new_data:
 
    mov  eax, 53
    mov  ebx, 2
    mov  ecx, [socket]
    mcall
 
    cmp  eax,0
    je   _ret
 
    mov  eax,53
    mov  ebx,3
    mov  ecx,[socket]
    mcall
 
    cmp  bl,10
    jne  no_lf
    inc  [posy]
    mov  [posx],0
    jmp  new_data
  no_lf:
 
    cmp  bl,20
    jb   new_data
 
    inc  [posx]
    cmp  [posx],60
    jbe  xok
    inc  [posy]
    mov  [posx],0
  xok:
 
    cmp  [posy],12
    jbe  yok
    mov  [posy],1
  yok:
 
    mov  eax,[posy]
    imul eax,60
    add  eax,[posx]
 
    mov  [input_text+eax],bl
 
    jmp  new_data
 
  _ret:
 
;    call draw_window
 
  _ret_now:
 
    popa
    ret
 
 
 
check_connection_status:
 
    pusha
 
    mov  eax, 53
    mov  ebx, 6
    mov  ecx, [socket]
    mcall
 
    cmp  eax,[status]
    je   .ccs_ret
    mov  [status],eax
    add  eax,48
    mov  [text+20],al
    call draw_window
   .ccs_ret:
 
    popa
    ret
 
 
 
 
;   *********************************************
;   *******  WINDOW DEFINITIONS AND DRAW ********
;   *********************************************
 
 
draw_window:
 
    pusha
 
    mov  eax,12                    ; function 12:tell os about windowdraw
    mov  ebx,1                     ; 1, start of draw
    mcall
 
    mov  eax,0                     ; Draw Window
    mov  ebx,50*65536+410
    mov  ecx,100*65536+141
    mov  edx,0x13ffffff
    mov  edi,title
    mcall
 
    mov  eax,8                     ; Start server
    mov  ebx,(25)*65536+21
    mov  ecx,57*65536+10
    mov  edx,2
    mov  esi,0x409040
    mcall                      ; Stop server
;    mov  eax,8
    mov  ebx,(25)*65536+21
    mov  ecx,69*65536+10
    mov  edx,4
    mov  esi,0x904040
    mcall
 
    mov  esi,0x3366d0
 
;    mov  eax,8                     ; Enter filename
    mov  ebx,(25)*65536+21
    mov  ecx,93*65536+10
    mov  edx,6
    mcall
;    mov  eax,8                     ; Decrease transfer rate
    mov  ebx,(25)*65536+10
    mov  ecx,105*65536+10
;    mov  edx,8
    mcall
;    mov  eax,8                     ; Increase transfer rate
    mov  ebx,(36)*65536+10
    mov  ecx,105*65536+10
    mov  edx,9
    mcall
 
    mov  ebx,10*65536+35           ; draw info text
    mov  ecx,0x00000000
    mov  edx,text
    mov  esi,40
  newline:
    mov  eax,4
    mcall
    add  ebx,12
    add  edx,40
    cmp  [edx],byte 'x'
    jnz  newline
 
    mov  eax,4                     ; Filename
    mov  ebx,56*65536+95
    mov  ecx,0x000000
    mov  edx,filename
    mov  esi,30
    mcall
 
    mov  eax,[bps]
    xor  edx,edx
    mov  ebx,1000
    div  ebx
    mov  ecx,eax
 
    mov  eax,47
    mov  ebx,3*65536
    mov  edx,58*65536+107
    mov  esi,0x00000000
    mcall
 
    mov  [input_text+0],dword 'RECE'
    mov  [input_text+4],dword 'IVED'
    mov  [input_text+8],dword ':   '
 
    mov  ebx,230*65536+35           ; draw info text
    mov  ecx,0x00000000
    mov  edx,input_text
    mov  esi,28
    mov  edi,7
   newline2:
    mov  eax,4
    mcall
    add  ebx,10
    add  edx,60
    dec  edi
    jnz  newline2
 
    mov  eax,38
    mov  ebx,210*65536+210
    mov  ecx,22*65536+136
    mov  edx,0x6699cc ; 002288
    mcall
 
    mov  eax,38
    mov  ebx,211*65536+211
    mov  ecx,22*65536+136
    mov  edx,0x336699 ; 002288
    mcall
 
    mov  eax,12                    ; function 12:tell os about windowdraw
    mov  ebx,2                     ; 2, end of draw
    mcall
 
    popa
 
    ret
 
 
 
; DATA AREA
 
text:
   db '        TCB status: 0                   '
   db '                                        '
   db '        Activate - port 8008            '
   db '        Stop server                     '
   db '                                        '
   db '    >                                   '
   db '   < >      Kbps                        '
   db 'x';  <- END MARKER, DONT DELETE
 
headers:
 
  db   'ICY 200 OK',13,10
  db   'icy-notice1:This stream requires Winamp or xmms',13,10
  db   'icy-url:http://www.menuetos.org',13,10
  db   'icy-pub: 1',13,10
  db   'icy-name: Menuet Mp3 Shoutcast Radio ',version,' - '
 transname:
  db   '                              ',13,10,13,10
 
headere:
 
title  db   'MP3 shoutcast server ',version,0
 
socket   dd  0
status   dd  0
 
posy     dd  1
posx     dd  0
 
read_on  db  1
read_to  dd  0
 
addr     dd  0
ya       dd  0
 
bps      dd  128*1000
 
fileinfo:  dd  0,0,0,0,0x20000
filename:  db  '/sys/MENUET.MP3',0
times 50   db  0
 
input_text:
 
I_END:

Rev 485	Rev 539
1	;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;	1	;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
2	; ;	2	; ;
3	; Tiny MP3 Shoutcast Server v0.1 (vt) ;	3	; Tiny MP3 Shoutcast Server v0.1 (vt) ;
4	; ;	4	; ;
5	; Compile with FASM for Menuet ;	5	; Compile with FASM for Menuet ;
6	; ;	6	; ;
7	; Listening to port 8008 ;	7	; Listening to port 8008 ;
8	; Connect with eg: 192.168.1.22:8008 ;	8	; Connect with eg: 192.168.1.22:8008 ;
9	; ;	9	; ;
10	;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;	10	;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
11		11
12	version equ '0.3'	12	version equ '0.3'
13		13
14	use32	14	use32
15	org 0x0	15	org 0x0
16	db 'MENUET01' ; 8 byte id	16	db 'MENUET01' ; 8 byte id
17	dd 0x01 ; header version	17	dd 0x01 ; header version
18	dd START ; program start	18	dd START ; program start
19	dd I_END ; program image size	19	dd I_END ; program image size
20	dd 0x80000 ; memory usage	20	dd 0x80000 ; memory usage
21	dd 0x20000 ; stack	21	dd 0x20000 ; stack
22	dd 0,0	22	dd 0,0
23		23
24	include 'lang.inc'	24	include 'lang.inc'
25	include '..\..\..\macros.inc'	25	include '..\..\..\macros.inc'
26		26
27	; 0x0+ program image	27	; 0x0+ program image
28	; 0x1ffff stack	28	; 0x1ffff stack
29	; 0x20000 work area for file read	29	; 0x20000 work area for file read
30	; 0x40000+ file send buffer ( 100 kb )	30	; 0x40000+ file send buffer ( 100 kb )
31		31
32		32
33	START: ; start of execution	33	START: ; start of execution
34		34
35	mov [status],0	35	mov [status],0
36	call clear_input	36	call clear_input
37	call draw_window ; at first, draw the window	37	call draw_window ; at first, draw the window
38		38
39	still:	39	still:
40		40
41	mov eax,23 ; wait here for event	41	mov eax,23 ; wait here for event
42	mov ebx,2	42	mov ebx,2
43	mcall	43	mcall
44		44
45	call check_events	45	call check_events
46		46
47	call check_connection_status	47	call check_connection_status
48		48
49	cmp [status],4	49	cmp [status],4
50	je start_transmission	50	je start_transmission
51		51
52	jmp still	52	jmp still
53		53
54		54
55	check_events:	55	check_events:
56		56
57	cmp eax,1 ; redraw request ?	57	cmp eax,1 ; redraw request ?
58	jz red	58	jz red
59	cmp eax,2 ; key in buffer ?	59	cmp eax,2 ; key in buffer ?
60	jz key	60	jz key
61	cmp eax,3 ; button in buffer ?	61	cmp eax,3 ; button in buffer ?
62	jz button	62	jz button
63		63
64	ret	64	ret
65		65
66	red: ; redraw	66	red: ; redraw
67	call draw_window	67	call draw_window
68	ret	68	ret
69		69
70	key:	70	key:
71	mov eax,2 ; Just read it and ignore	71	mov eax,2 ; Just read it and ignore
72	mcall	72	mcall
73	ret	73	ret
74		74
75	button: ; button	75	button: ; button
76		76
77	mov eax,17 ; get id	77	mov eax,17 ; get id
78	mcall	78	mcall
79		79
80	cmp ah,1 ; close	80	cmp ah,1 ; close
81	jne no_close	81	jne no_close
82	mov eax,-1	82	mov eax,-1
83	mcall	83	mcall
84	no_close:	84	no_close:
85		85
86	cmp ah,2 ; button id=2 ?	86	cmp ah,2 ; button id=2 ?
87	jnz tst3	87	jnz tst3
88	; open socket	88	; open socket
89	mov eax,53	89	mov eax,53
90	mov ebx,5	90	mov ebx,5
91	mov ecx,8008 ; local port # - http	91	mov ecx,8008 ; local port # - http
92	mov edx,0 ; no remote port specified	92	mov edx,0 ; no remote port specified
93	mov esi,0 ; no remote ip specified	93	mov esi,0 ; no remote ip specified
94	mov edi,0 ; PASSIVE open	94	mov edi,0 ; PASSIVE open
95	mcall	95	mcall
96	mov [socket], eax	96	mov [socket], eax
97	mov [posy],1	97	mov [posy],1
98	mov [posx],0	98	mov [posx],0
99	mov [read_on],1	99	mov [read_on],1
100	call check_for_incoming_data	100	call check_for_incoming_data
101	call draw_window	101	call draw_window
102	ret	102	ret
103	tst3:	103	tst3:
104		104
105	cmp ah,4	105	cmp ah,4
106	je close_socket	106	je close_socket
107	cmp ah,6	107	cmp ah,6
108	je close_socket	108	je close_socket
109	jmp no_socket_close	109	jmp no_socket_close
110	close_socket:	110	close_socket:
111	mov edx,eax	111	mov edx,eax
112	; Close socket	112	; Close socket
113	mov eax, 53	113	mov eax, 53
114	mov ebx, 8	114	mov ebx, 8
115	mov ecx, [socket]	115	mov ecx, [socket]
116	mcall	116	mcall
117	mov esp,0x1fff0	117	mov esp,0x1fff0
118	cmp dh,6	118	cmp dh,6
119	je read_string	119	je read_string
120	jmp still	120	jmp still
121	no_socket_close:	121	no_socket_close:
122		122
123	cmp ah,9	123	cmp ah,9
124	jne no_bps_add	124	jne no_bps_add
125	add [bps],8*1000	125	add [bps],8*1000
126	call draw_window	126	call draw_window
127	ret	127	ret
128	no_bps_add:	128	no_bps_add:
129		129
130	cmp ah,8	130	cmp ah,8
131	jne no_bps_sub	131	jne no_bps_sub
132	sub [bps],8*1000	132	sub [bps],8*1000
133	call draw_window	133	call draw_window
134	ret	134	ret
135	no_bps_sub:	135	no_bps_sub:
136		136
137		137
138	ret	138	ret
139		139
140		140
141	clear_input:	141	clear_input:
142		142
143	mov edi,input_text	143	mov edi,input_text
144	mov eax,0	144	mov eax,0
145	mov ecx,60*40	145	mov ecx,60*40
146	cld	146	cld
147	rep stosb	147	rep stosb
148		148
149	ret	149	ret
150		150
151		151
152	read_string:	152	read_string:
153		153
154	mov [addr],dword filename	154	mov [addr],dword filename
155	mov [ya],dword 95	155	mov [ya],dword 95
156		156
157	mov edi,[addr]	157	mov edi,[addr]
158	mov eax,32	158	mov eax,32
159	mov ecx,30	159	mov ecx,30
160	cld	160	cld
161	rep stosb	161	rep stosb
162		162
163	call print_text	163	call print_text
164		164
165	mov edi,[addr]	165	mov edi,[addr]
166		166
167	f11:	167	f11:
168	mov eax,10	168	mov eax,10
169	mcall	169	mcall
170	cmp eax,2	170	cmp eax,2
171	jne read_done	171	jne read_done
172	mov eax,2	172	mov eax,2
173	mcall	173	mcall
174	shr eax,8	174	shr eax,8
175	cmp eax,13	175	cmp eax,13
176	je read_done	176	je read_done
177	cmp eax,8	177	cmp eax,8
178	jnz nobsl	178	jnz nobsl
179	cmp edi,[addr]	179	cmp edi,[addr]
180	jz f11	180	jz f11
181	sub edi,1	181	sub edi,1
182	mov [edi],byte 32	182	mov [edi],byte 32
183	call print_text	183	call print_text
184	jmp f11	184	jmp f11
185	nobsl:	185	nobsl:
186	cmp eax,dword 31	186	cmp eax,dword 31
187	jbe f11	187	jbe f11
188	cmp eax,dword 95	188	cmp eax,dword 95
189	jb keyok	189	jb keyok
190	sub eax,32	190	sub eax,32
191	keyok:	191	keyok:
192	mov [edi],al	192	mov [edi],al
193		193
194	call print_text	194	call print_text
195		195
196	add edi,1	196	add edi,1
197	mov esi,[addr]	197	mov esi,[addr]
198	add esi,30	198	add esi,30
199	cmp esi,edi	199	cmp esi,edi
200	jnz f11	200	jnz f11
201		201
202	read_done:	202	read_done:
203		203
204	mov ecx,40	204	mov ecx,40
205	mov eax,0	205	mov eax,0
206	cld	206	cld
207	rep movsb	207	rep movsb
208		208
209	call print_text	209	call print_text
210		210
211	jmp still	211	jmp still
212		212
213		213
214	print_text:	214	print_text:
215		215
216	pusha	216	pusha
217		217
218	mov eax,13	218	mov eax,13
219	mov ebx,5665536+306	219	mov ebx,5665536+306
220	mov ecx,[ya]	220	mov ecx,[ya]
221	shl ecx,16	221	shl ecx,16
222	mov cx,8	222	mov cx,8
223	mov edx,0xffffff	223	mov edx,0xffffff
224	mcall	224	mcall
225		225
226	mov eax,4	226	mov eax,4
227	mov edx,[addr]	227	mov edx,[addr]
228	mov ebx,56*65536	228	mov ebx,56*65536
229	add ebx,[ya]	229	add ebx,[ya]
230	mov ecx,0x000000	230	mov ecx,0x000000
231	mov esi,30	231	mov esi,30
232	mcall	232	mcall
233		233
234	popa	234	popa
235	ret	235	ret
236		236
237		237
238	wait_for dd 0x0	238	wait_for dd 0x0
239		239
240	transmission_start dd 0x0	240	transmission_start dd 0x0
241	sentbytes dd 0x0	241	sentbytes dd 0x0
242		242
243	start_transmission:	243	start_transmission:
244		244
245	call clear_input	245	call clear_input
246		246
247	mov eax,5	247	mov eax,5
248	mov ebx,50	248	mov ebx,50
249	mcall	249	mcall
250		250
251	call check_for_incoming_data	251	call check_for_incoming_data
252	call draw_window	252	call draw_window
253		253
254	call send_header	254	call send_header
255		255
256	mov [fileinfo+4],dword 0 ; start from beginning	256	mov [fileinfo+4],dword 0 ; start from beginning
257	mov [read_to],0x40000	257	mov [read_to],0x40000
258	mov [playpos],0x40000	258	mov [playpos],0x40000
259		259
260	mov ecx,1024 / 512	260	mov ecx,1024 / 512
261		261
262	new_buffer:	262	new_buffer:
263		263
264	mov eax,[read_to]	264	mov eax,[read_to]
265	mov ebx,1	265	mov ebx,1
266	call read_file	266	call read_file
267		267
268	loop new_buffer	268	loop new_buffer
269		269
270		270
271	newpart:	271	newpart:
272		272
273	call check_connection_status	273	call check_connection_status
274	call draw_window	274	call draw_window
275		275
276	mov eax,26	276	mov eax,26
277	mov ebx,9	277	mov ebx,9
278	mcall	278	mcall
279	mov [transmission_start],eax	279	mov [transmission_start],eax
280	mov [sentbytes],0	280	mov [sentbytes],0
281		281
282	newblock:	282	newblock:
283		283
284	mov eax,[read_to]	284	mov eax,[read_to]
285	mov ebx,2	285	mov ebx,2
286	call read_file	286	call read_file
287		287
288	wait_more:	288	wait_more:
289		289
290	mov eax,26	290	mov eax,26
291	mov ebx,9	291	mov ebx,9
292	mcall	292	mcall
293		293
294	cmp eax,[wait_for]	294	cmp eax,[wait_for]
295	jge nomw	295	jge nomw
296		296
297	mov eax,5	297	mov eax,5
298	mov ebx,1	298	mov ebx,1
299	mcall	299	mcall
300		300
301	jmp wait_more	301	jmp wait_more
302		302
303	nomw:	303	nomw:
304		304
305	add eax,2	305	add eax,2
306	mov [wait_for],eax	306	mov [wait_for],eax
307		307
308	mov eax,11	308	mov eax,11
309	mcall	309	mcall
310	call check_events	310	call check_events
311		311
312	mov eax,53	312	mov eax,53
313	mov ebx,255	313	mov ebx,255
314	mov ecx,103	314	mov ecx,103
315	mcall	315	mcall
316		316
317	cmp eax,0	317	cmp eax,0
318	jne wait_more	318	jne wait_more
319		319
320	; write to socket	320	; write to socket
321	mov eax,53	321	mov eax,53
322	mov ebx,7	322	mov ebx,7
323	mov ecx,[socket]	323	mov ecx,[socket]
324	mov edx,[playadd]	324	mov edx,[playadd]
325	mov esi,[playpos]	325	mov esi,[playpos]
326	mcall	326	mcall
327		327
328	add [sentbytes],edx	328	add [sentbytes],edx
329		329
330	mov esi,[playpos]	330	mov esi,[playpos]
331	add esi,[playadd]	331	add esi,[playadd]
332	mov edi,0x40000	332	mov edi,0x40000
333	mov ecx,110000 / 4	333	mov ecx,110000 / 4
334	cld	334	cld
335	rep movsd	335	rep movsd
336		336
337	mov eax,[playadd]	337	mov eax,[playadd]
338	sub [read_to],eax	338	sub [read_to],eax
339		339
340	call check_for_incoming_data	340	call check_for_incoming_data
341	call show_progress	341	call show_progress
342	call check_rate	342	call check_rate
343		343
344	mov eax, 53	344	mov eax, 53
345	mov ebx, 6	345	mov ebx, 6
346	mov ecx, [socket]	346	mov ecx, [socket]
347	mcall	347	mcall
348	cmp eax,4	348	cmp eax,4
349	jne end_stream	349	jne end_stream
350		350
351	cmp [read_to],0x40000	351	cmp [read_to],0x40000
352	jge newblock	352	jge newblock
353		353
354	end_stream:	354	end_stream:
355		355
356	; Close socket	356	; Close socket
357		357
358	mov eax, 53	358	mov eax, 53
359	mov ebx, 8	359	mov ebx, 8
360	mov ecx, [socket]	360	mov ecx, [socket]
361	mcall	361	mcall
362		362
363	mov eax,5	363	mov eax,5
364	mov ebx,5	364	mov ebx,5
365	mcall	365	mcall
366		366
367	; Open socket	367	; Open socket
368		368
369	mov eax,53	369	mov eax,53
370	mov ebx,5	370	mov ebx,5
371	mov ecx,8008 ; local port # - http	371	mov ecx,8008 ; local port # - http
372	mov edx,0 ; no remote port specified	372	mov edx,0 ; no remote port specified
373	mov esi,0 ; no remote ip specified	373	mov esi,0 ; no remote ip specified
374	mov edi,0 ; PASSIVE open	374	mov edi,0 ; PASSIVE open
375	mcall	375	mcall
376	mov [socket], eax	376	mov [socket], eax
377	mov [posy],1	377	mov [posy],1
378	mov [posx],0	378	mov [posx],0
379	mov [read_on],0	379	mov [read_on],0
380		380
381	call draw_window	381	call draw_window
382		382
383	jmp still	383	jmp still
384		384
385		385
386	check_rate:	386	check_rate:
387		387
388	pusha	388	pusha
389		389
390	mov eax,[bps]	390	mov eax,[bps]
391	xor edx,edx	391	xor edx,edx
392	mov ebx,8*100	392	mov ebx,8*100
393	div ebx	393	div ebx
394	shl eax,1	394	shl eax,1
395	mov [playadd],eax	395	mov [playadd],eax
396		396
397	mov eax,26	397	mov eax,26
398	mov ebx,9	398	mov ebx,9
399	mcall	399	mcall
400		400
401	sub eax,[transmission_start]	401	sub eax,[transmission_start]
402	shr eax,1	402	shr eax,1
403		403
404	imul eax,[playadd]	404	imul eax,[playadd]
405		405
406	mov edx,0x00dd00	406	mov edx,0x00dd00
407		407
408	cmp [sentbytes],eax	408	cmp [sentbytes],eax
409	jge sendok	409	jge sendok
410		410
411	sub eax,20000	411	sub eax,20000
412	cmp [sentbytes],eax ; a long buffer underrun correction	412	cmp [sentbytes],eax ; a long buffer underrun correction
413	jge no_buffer_overrun ; actually leads to overrun	413	jge no_buffer_overrun ; actually leads to overrun
414	mov [sentbytes],eax	414	mov [sentbytes],eax
415	no_buffer_overrun:	415	no_buffer_overrun:
416		416
417	add [playadd],150	417	add [playadd],150
418	mov edx,0xdd0000	418	mov edx,0xdd0000
419		419
420	sendok:	420	sendok:
421		421
422	mov eax,13	422	mov eax,13
423	mov ebx,320*65536+10	423	mov ebx,320*65536+10
424	mov ecx,105*65536+10	424	mov ecx,105*65536+10
425	mcall	425	mcall
426		426
427	mov eax,47	427	mov eax,47
428	mov ebx,4*65536	428	mov ebx,4*65536
429	mov ecx,[playadd]	429	mov ecx,[playadd]
430	mov edx,322*65536+106	430	mov edx,322*65536+106
431	mov esi,0x000000	431	mov esi,0x000000
432	; mcall	432	; mcall
433		433
434	popa	434	popa
435		435
436	ret	436	ret
437		437
438		438
439	show_progress:	439	show_progress:
440		440
441	pusha	441	pusha
442		442
443	mov eax,13	443	mov eax,13
444	mov ebx,23665536+106	444	mov ebx,23665536+106
445	mov ecx,107*65536+8	445	mov ecx,107*65536+8
446	mov edx,0xffffff	446	mov edx,0xffffff
447	mcall	447	mcall
448		448
449	mov ecx,[fileinfo+4]	449	mov ecx,[fileinfo+4]
450	imul ecx,512	450	imul ecx,512
451		451
452	mov eax,47 ; file read	452	mov eax,47 ; file read
453	mov ebx,9*65536	453	mov ebx,9*65536
454	mov edx,236*65536+107	454	mov edx,236*65536+107
455	mov esi,0x000000	455	mov esi,0x000000
456	mcall	456	mcall
457		457
458	popa	458	popa
459	ret	459	ret
460		460
461		461
462	playpos dd 0x100000	462	playpos dd 0x100000
463	playadd dd 256000 / 8 / 100	463	playadd dd 256000 / 8 / 100
464		464
465		465
466	send_header:	466	send_header:
467		467
468	pusha	468	pusha
469		469
470	mov [playpos],0x40000	470	mov [playpos],0x40000
471		471
472	mov esi,fileinfo+5*4	472	mov esi,fileinfo+5*4
473	mov edi,transname	473	mov edi,transname
474	mov ecx,30	474	mov ecx,30
475	cld	475	cld
476	rep movsb	476	rep movsb
477		477
478	mov eax, 53	478	mov eax, 53
479	mov ebx, 7	479	mov ebx, 7
480	mov ecx, [socket]	480	mov ecx, [socket]
481	mov edx, headere-headers	481	mov edx, headere-headers
482	mov esi, headers	482	mov esi, headers
483	mcall	483	mcall
484		484
485	popa	485	popa
486	ret	486	ret
487		487
488		488
489	read_file:	489	read_file:
490		490
491	cmp [read_to],0x40000+2000	491	cmp [read_to],0x40000+2000
492	jg cache_ok	492	jg cache_ok
493	mov [read_on],1	493	mov [read_on],1
494	cache_ok:	494	cache_ok:
495		495
496	cmp [read_to],0x40000+95500	496	cmp [read_to],0x40000+95500
497	jg no_read_1	497	jg no_read_1
498		498
499	mov [fileinfo+12],eax	499	mov [fileinfo+12],eax
500	mov [fileinfo+8],ebx	500	mov [fileinfo+8],ebx

Subversion Repositories Kolibri OS

(root)/programs/network/mp3s/trunk/mp3s.asm – Rev 485 → 539