1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
|
<?php
function sessioncreate($type, $url, $mode)
{
global $httppath, $ffmpegpath, $segmenterpath, $quality;
// Get a free session
$i=0;
for ($i=0; $i<1000; $i++)
{
$session = "session" .$i;
if (!file_exists('../ram/' .$session))
break;
}
// Default
$qparams = $quality[0];
// Get parameters
foreach ($quality as $qn => $qp)
{
if ($qn == $mode)
{
$qparams = $qp;
break;
}
}
// Create session
exec('mkdir ../ram/' .$session);
$url = str_replace("\\'", "'", $url);
switch ($type)
{
case 'tv':
$cmd = "export SHELL=\"/bin/sh\";printf \"./istream.sh \\\"" .$url ."\\\" " .$qparams ." " .$httppath ." 2 " .$ffmpegpath ." " .$segmenterpath ." " .$session ." \" | at now";
break;
case 'rec':
$cmd = "export SHELL=\"/bin/sh\";printf \"cat \\\"" .$url ."\\\"/0* | ./istream.sh - " .$qparams ." " .$httppath ." 1260 " .$ffmpegpath ." " .$segmenterpath ." " .$session ." \" | at now";
break;
case 'vid':
$cmd = "export SHELL=\"/bin/sh\";printf \"./istream.sh \\\"" .$url ."\\\" " .$qparams ." " .$httppath ." 1260 " .$ffmpegpath ." " .$segmenterpath ." " .$session ." \" | at now";
break;
default:
$cmd = "";
}
$cmd = str_replace('%', '%%', $cmd);
exec ('echo "' .$cmd .'" > /tmp/a');
exec ($cmd);
// Extract $channame if needed
switch ($type)
{
case 'tv':
$urlarray = explode("/", $url);
$channum = $urlarray[count($urlarray)-1];
$channame = vdrgetchanname($channum);
break;
case 'rec':
list($channame, $title, $desc) = vdrgetrecinfo($url);
break;
default:
$channame = "";
break;
}
// Write streaminfo
writeinfostream($session, $type, $mode, $url, $channame);
// Create logo
if ($type == 'vid')
generatelogo($type, $url, '../ram/' .$session .'/logo.png');
else
generatelogo($type, $channame, '../ram/' .$session .'/logo.png');
return $session;
}
function sessiondelete($session)
{
if ($session == 'all')
{
$dir_handle = @opendir('../ram/');
if ($dir_handle)
{
while ($session = readdir($dir_handle))
{
if($session == "." || $session == ".." || $session == 'lost+found')
continue;
if (!is_dir('../ram/' .$session))
continue;
// Get info
list($type, $mode, $url, $channame) = readinfostream($session);
if ($type)
sessiondeletesingle($session);
}
}
}
else
return sessiondeletesingle($session);
}
function sessiondeletesingle($session)
{
$ram = "../ram/" .$session ."/";
// Get segmenter PID if any
if (file_exists($ram ."segmenter.pid"))
$cmd = "/usr/local/bin/fw;kill `cat " .$ram ."segmenter.pid`; rm " .$ram ."segmenter.pid; ";
$cmd .= "rm -rf " .$ram;
exec ($cmd);
}
?>
|
