Began listening $address:$port. Listener is $sock
";
$output = array();
$input = array();
$timer = time();
$status = 0;
$plsnum = 0;
load_playlist ("hi.pls"); //here is the playlist we are going to play
if ($shuffle) {
srand ((float)microtime()*1000000);
shuffle ($pls);
}
$fset = array($sock);
//$fdmax = $sock;
do {
//sleep(1);
//echo "Pass $br
" . time() . "
\n";
unset($r_fds, $w_fds);
$r_fds = array();
$w_fds = array();
//here is the very strange thing:
foreach ($fset as $fd) {
if ($input[$fd]=="w") { //sockets need to be checked for non-blocked writing
$w_fds[] = $fd;
} else { // ...or reading
$r_fds[] = $fd;
}
}
unset ($fd);
$res = socket_select($r_fds, $w_fds, $e = NULL, NULL);
if (false === $res) {
echo "socket_select() failed, reason: " . socket_strerror(socket_last_error()) . "
\n";
}
unset($res);
//var_dump ($r_fds);
//var_dump ($w_fds);
//echo "
\n";
foreach($r_fds as $i) {
if ($i == $sock) { //the listener!
// handle new connections
if (($newfd = socket_accept($sock)) < 0) {
echo "socket_accept() failed: reason: " . socket_strerror ($newfd) .. "\n";
//break;
} else { //accepted new connection
array_push ($fset, $newfd);
/*if ($newfd > $fdmax) { // keep track of the maximum
$fdmax = $newfd;
}*/
socket_getpeername($newfd, $addr);
//socket_set_nonblock($newfd);
echo "Accepted new connection from $addr ($newfd)
";
}
} else {
// handle data from a client
if ($input[$i]!="w") { //unwritable
$buf = "";
if (FALSE === ($buf = socket_read ($i, 2048))) {
if ($res==false) { //kill the socket
socket_kill_my_socket($i);
}
}
$input[$i] .= $buf;
if (substr($input[$i], 0 , 4) == "kill") { //killing the serve
echo "The server is going down...
";
foreach($fset as $kl) {
socket_kill_my_socket($kl);
}
unset ($input, $output, $fset, $r_fds, $w_fds);
echo "The server is down ;)
";
exit;
}
if (substr($input[$i], -4) == "\r\n\r\n") {
echo "Socket $i became writable! Recieved data: " . nl2br($input[$i]) . "
\n";
$input[$i] = "w";
$songbuf = "ICY 200 OK
icy-notice1:This stream requires Winamp
icy-name:Ivun's broadcasting
icy-genre:Pop, dance, rock, hits
icy-url:http://mp3.lytkarino.ru
icy-pub:1
icy-br:$bitrate\r\n\r\n$out_buf";
socket_write ($i, $songbuf, strlen ($songbuf));
}
}
}
}
unset($i);
if ($timer<=time()) { //updating buffers
//checking if the buffers need to be updated
$is_need_update = false;
foreach($fset as $i) {
if ($input[$i]=="w") { //writable socket
if (strlen($output[$i]) < $outbufsize) $is_need_update = true;
}
}
unset($i);
if ($is_need_update) {
/*
$ln=0;
foreach(array_values(get_defined_vars()) as $a) {
$ln += strlen($a);
}
echo "Memory: $ln
";
*/
/*echo "";
var_dump(get_defined_vars());
echo "
";
*/
//echo "out=$output[$sock]
";
$curfile = $pls[$plsnum];
$outsize = (filesize($curfile)-128)-$status;
if ($outsize>$outbufsize) $outsize=$outbufsize;
//echo "outsize=$outsize
";
if (!$is_open) {
$outfile = fopen($curfile, "rb");
$is_open = true;
}
// fseek($outfile, $status);
$out_buf = fread($outfile, $outsize);
$status += $outsize;
if ($outsize<$outbufsize) { //EOF of the current file
//swithcing to the next one
$status = 0;
$plsnum++;
if ($plsnum>=count($pls)) $plsnum=0; //this was the last song in playlist
echo "Playing " . $pls[$plsnum] . " (" . time() . ")
";
fclose($outfile);
$is_open=false;
}
foreach($fset as $i) {
if ($input[$i]=="w") { //writable socket
$output[$i] .= $out_buf;
//echo "Added " . strlen($out_buf) . " to $i
";
}
}
unset ($outsize, $curfile, $i);
}
$timer = time()+1;
}
foreach($w_fds as $i) {
if ($input[$i]=="w") { //writable socket
$songbuf = substr($output[$i], 0, $smallbufsize);
$output[$i] = substr($output[$i], $smallbufsize);
$res = @socket_write ($i, $songbuf, $smallbufsize);
if ($res==false && strlen($songbuf)>0) { //kill the socket
socket_kill_my_socket ($i);
}
unset ($songbuf, $res);
//echo "Sent " . strlen($songbuf) . " to sock# $i (" . strlen($output[$i]) . ")
\n";
}
}
unset($i);
} while (true);
//socket_close ($msgsock);
socket_close ($sock);
function socket_kill_my_socket($i) {
global $fset, $output, $input;
$fnd = array_search($i, $fset);
unset($fset[$fnd]);
unset($output[$i]);
unset($input[$i]);
socket_shutdown($i); //???
socket_close($i);
echo "Closed $i
";
//print_r($GLOBALS['status']); echo "
";
}
function load_playlist($plsfile, $action = "L") { //$action is either A(dd) or L(oad)
global $pls;
if ($action=="L") $pls = array(); //clearing the array
$plstype = strtolower(substr($plsfile, -3)); //pls and m3u are supported
$file = fopen($plsfile, "r");
do {
$line = fgets($file, 1024);
$line = trim($line);
if ($plstype=="m3u") {
if (substr($line, 0, 1)!="#") $pls[]=$line;
} elseif ($plstype=="pls") {
if (strtolower(substr($line, 0, 4))=="file") {
$pos = strpos($line, "=");
$pls[] = substr($line, ++$pos);
}
}
} while (!feof($file));
fclose ($file);
//var_dump($pls);
}
?>