1
0
kolibrios/programs/network/mp3s/trunk/mp3s.asm

783 lines
13 KiB
NASM
Raw Normal View History

;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
; ;
; 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,0x14ffffff
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: