$socktimeoutsec, 'usec' => 0));
$res = socket_connect($socket, $addr, $port);
if ($res === false)
{
$error = socket_strerror(socket_last_error());
$msg = "socket connect($addr,$port) failed";
$error = "ERR: $msg '$error'\n";
socket_close($socket);
return null;
}
return $socket;
}
#
function readsockline($socket)
{
$line = '';
while (true)
{
$byte = socket_read($socket, 1);
if ($byte === false || $byte === '')
break;
if ($byte === "\0")
break;
$line .= $byte;
}
return $line;
}
#
function api($cmd)
{
global $miner, $port;
$socket = getsock($miner, $port);
if ($socket != null)
{
socket_write($socket, $cmd, strlen($cmd));
$line = readsockline($socket);
socket_close($socket);
if (strlen($line) == 0)
{
$error = "WARN: '$cmd' returned nothing\n";
return $line;
}
# print "$cmd returned '$line'\n";
$data = array();
$objs = explode('|', $line);
foreach ($objs as $obj)
{
if (strlen($obj) > 0)
{
$items = explode(',', $obj);
$item = $items[0];
$id = explode('=', $items[0], 2);
if (count($id) == 1 or !ctype_digit($id[1]))
$name = $id[0];
else
$name = $id[0].$id[1];
if (strlen($name) == 0)
$name = 'null';
if (isset($data[$name]))
{
$num = 1;
while (isset($data[$name.$num]))
$num++;
$name .= $num;
}
$counter = 0;
foreach ($items as $item)
{
$id = explode('=', $item, 2);
if (count($id) == 2)
$data[$name][$id[0]] = $id[1];
else
$data[$name][$counter] = $id[0];
$counter++;
}
}
}
return $data;
}
return null;
}
#
function getparam($name, $both = false)
{
$a = null;
if (isset($_POST[$name]))
$a = $_POST[$name];
if (($both === true) and ($a === null))
{
if (isset($_GET[$name]))
$a = $_GET[$name];
}
if ($a == '' || $a == null)
return null;
// limit to 1K just to be safe
return substr($a, 0, 1024);
}
#
function fmt($section, $name, $value)
{
global $dfmt;
$errorclass = ' class=err';
$warnclass = ' class=warn';
$b = ' ';
$ret = $value;
$class = '';
switch ($section.'.'.$name)
{
case 'GPU.Last Share Time':
case 'PGA.Last Share Time':
$ret = date('H:i:s', $value);
break;
case 'SUMMARY.Elapsed':
$s = $value % 60;
$value -= $s;
$value /= 60;
if ($value == 0)
$ret = $s.'s';
else
{
$m = $value % 60;
$value -= $m;
$value /= 60;
if ($value == 0)
$ret = sprintf("%dm$b%02ds", $m, $s);
else
{
$h = $value % 24;
$value -= $h;
$value /= 24;
if ($value == 0)
$ret = sprintf("%dh$b%02dm$b%02ds", $h, $m, $s);
else
{
if ($value == 1)
$days = '';
else
$days = 's';
$ret = sprintf("%dday$days$b%02dh$b%02dm$b%02ds", $value, $h, $m, $s);
}
}
}
break;
case 'NOTIFY.Last Well':
if ($value == '0')
{
$ret = 'Never';
$class = $warnclass;
}
else
$ret = date('H:i:s', $value);
break;
case 'NOTIFY.Last Not Well':
if ($value == '0')
$ret = 'Never';
else
{
$ret = date('H:i:s', $value);
$class = $errorclass;
}
break;
case 'NOTIFY.Reason Not Well':
if ($value != 'None')
$class = $errorclass;
break;
case 'GPU.Utility':
case 'PGA.Utility':
case 'SUMMARY.Utility':
$ret = $value.'/m';
break;
case 'PGA.Temperature':
$ret = $value.'°C';
break;
case 'GPU.Temperature':
$ret = $value.'°C';
case 'GPU.Fan Speed':
case 'GPU.Fan Percent':
case 'GPU.GPU Clock':
case 'GPU.Memory Clock':
case 'GPU.GPU Voltage':
case 'GPU.GPU Activity':
if ($value == 0)
$class = $warnclass;
break;
case 'GPU.MHS av':
case 'PGA.MHS av':
case 'SUMMARY.MHS av':
case 'GPU.Total MH':
case 'PGA.Total MH':
case 'SUMMARY.Total MH':
case 'SUMMARY.Getworks':
case 'GPU.Accepted':
case 'PGA.Accepted':
case 'SUMMARY.Accepted':
case 'GPU.Rejected':
case 'PGA.Rejected':
case 'SUMMARY.Rejected':
case 'SUMMARY.Local Work':
case 'POOL.Getworks':
case 'POOL.Accepted':
case 'POOL.Rejected':
case 'POOL.Discarded':
$parts = explode('.', $value, 2);
if (count($parts) == 1)
$dec = '';
else
$dec = '.'.$parts[1];
$ret = number_format($parts[0]).$dec;
break;
case 'GPU.Status':
case 'PGA.Status':
case 'POOL.Status':
if ($value != 'Alive')
$class = $errorclass;
break;
case 'GPU.Enabled':
case 'PGA.Enabled':
if ($value != 'Y')
$class = $warnclass;
break;
case 'STATUS.When':
$ret = date($dfmt, $value);
break;
}
if ($section == 'NOTIFY' && substr($name, 0, 1) == '*' && $value != '0')
$class = $errorclass;
return array($ret, $class);
}
#
global $poolcmd;
$poolcmd = array( 'Switch to' => 'switchpool',
'Enable' => 'enablepool',
'Disable' => 'disablepool' );
#
function showhead($cmd, $item, $values)
{
global $poolcmd, $readonly;
echo '';
foreach ($values as $name => $value)
{
if ($name == '0' or $name == '')
$name = ' ';
echo "| $name | ";
}
if ($cmd == 'pools' && $readonly === false)
foreach ($poolcmd as $name => $pcmd)
echo "$name | ";
echo ' ';
}
#
function details($cmd, $list, $rig)
{
global $tablebegin, $tableend, $dfmt;
global $poolcmd, $readonly;
global $showndate;
$stas = array('S' => 'Success', 'W' => 'Warning', 'I' => 'Informational', 'E' => 'Error', 'F' => 'Fatal');
echo $tablebegin;
if ($showndate === false)
{
echo '| Date: '.date($dfmt).' | ';
echo $tableend.$tablebegin;
$showndate = true;
}
if (isset($list['STATUS']))
{
echo '';
echo '| Computer: '.$list['STATUS']['Description'].' | ';
if (isset($list['STATUS']['When']))
echo 'When: '.date($dfmt, $list['STATUS']['When']).' | ';
$sta = $list['STATUS']['STATUS'];
echo 'Status: '.$stas[$sta].' | ';
echo 'Message: '.$list['STATUS']['Msg'].' | ';
echo ' ';
}
$section = '';
foreach ($list as $item => $values)
{
if ($item == 'STATUS')
continue;
$sectionname = preg_replace('/\d/', '', $item);
if ($sectionname != $section)
{
echo $tableend.$tablebegin;
showhead($cmd, $item, $values);
$section = $sectionname;
}
echo '';
foreach ($values as $name => $value)
{
list($showvalue, $class) = fmt($section, $name, $value);
echo "$showvalue";
}
if ($cmd == 'pools' && $readonly === false)
{
reset($values);
$pool = current($values);
foreach ($poolcmd as $name => $pcmd)
{
echo '| ';
if ($pool === false)
echo ' ';
else
{
echo "";
}
echo ' | ';
}
}
echo ' ';
}
echo $tableend;
}
#
global $devs;
$devs = null;
#
function gpubuttons($count, $rig)
{
global $tablebegin, $tableend;
global $devs;
$basic = array( 'GPU', 'Enable', 'Disable', 'Restart' );
$options = array( 'intensity' => 'Intensity',
'fan' => 'Fan Percent',
'engine' => 'GPU Clock',
'mem' => 'Memory Clock',
'vddc' => 'GPU Voltage' );
echo $tablebegin.'';
foreach ($basic as $head)
echo "| $head | ";
foreach ($options as $name => $des)
echo "$des | ";
$n = 0;
for ($c = 0; $c < $count; $c++)
{
echo ' ';
foreach ($basic as $name)
{
echo '| ';
if ($name == 'GPU')
echo $c;
else
{
echo "";
}
echo ' | ';
}
foreach ($options as $name => $des)
{
echo '';
if (!isset($devs["GPU$c"][$des]))
echo ' ';
else
{
$value = $devs["GPU$c"][$des];
echo "";
echo "";
$n++;
}
echo ' | ';
}
}
echo ' '.$tableend;
}
#
function processgpus($rig)
{
global $error;
global $warnfont, $warnoff;
$gpus = api('gpucount');
if ($error != null)
echo '| Error getting GPU count: '.$warnfont.$error.$warnoff.' | ';
else
{
if (!isset($gpus['GPUS']['Count']))
echo '| No GPU count returned: '.$warnfont.$gpus['STATUS']['STATUS'].' '.$gpus['STATUS']['Msg'].$ro.' | ';
else
{
$count = $gpus['GPUS']['Count'];
if ($count == 0)
echo '| No GPUs | ';
else
gpubuttons($count, $rig);
}
}
}
#
function process($cmds, $rig)
{
global $error, $devs;
global $warnfont, $warnoff;
foreach ($cmds as $cmd => $des)
{
$process = api($cmd);
if ($error != null)
{
echo "| Error getting $des: ";
echo $warnfont.$error.$warnoff.' | ';
break;
}
else
{
details($cmd, $process, $rig);
echo '
| ';
if ($cmd == 'devs')
$devs = $process;
}
}
}
#
# $head is a hack but this is just a demo anyway :)
function doforeach($cmd, $des, $sum, $head, $datetime)
{
global $miner, $port;
global $error, $readonly, $notify, $rigs;
global $tablebegin, $tableend, $warnfont, $warnoff, $dfmt;
global $rigerror;
$header = $head;
$anss = array();
$count = 0;
$preverr = count($rigerror);
foreach ($rigs as $rig)
{
if (isset($rigerror[$rig]))
continue;
$parts = explode(':', $rig, 2);
if (count($parts) == 2)
{
$miner = $parts[0];
$port = $parts[1];
$ans = api($cmd);
if ($error != null)
{
echo "| Error on rig $count getting $des: ";
echo $warnfont.$error.$warnoff.' | ';
$rigerror[$rig] = $error;
$error = null;
}
else
$anss[$count] = $ans;
}
$count++;
}
if (count($anss) == 0)
{
echo '| Failed to access any rigs successfully';
if ($preverr > 0)
echo ' (or rigs had previous errors)';
echo ' | ';
return;
}
if ($datetime)
{
echo '| Date: '.date($dfmt).' | ';
echo $tableend.$tablebegin;
$dthead = array('' => 1, 'STATUS' => 1, 'Description' => 1, 'When' => 1);
showhead('', null, $dthead);
foreach ($anss as $rig => $ans)
{
echo '';
foreach ($ans as $item => $row)
{
if ($item != 'STATUS')
continue;
foreach ($dthead as $name => $x)
{
if ($name == '')
echo " | ";
else
{
if (isset($row[$name]))
list($showvalue, $class) = fmt('STATUS', $name, $row[$name]);
else
{
$class = '';
$showvalue = ' ';
}
echo "$showvalue";
}
}
}
echo ' ';
}
echo $tableend;
echo '
| ';
echo $tablebegin;
}
$total = array();
foreach ($anss as $rig => $ans)
{
foreach ($ans as $item => $row)
{
if ($item == 'STATUS')
continue;
if (count($row) > count($header))
{
$header = $head;
foreach ($row as $name => $value)
if (!isset($header[$name]))
$header[$name] = '';
}
if ($sum != null)
foreach ($sum as $name)
{
if (isset($row[$name]))
{
if (isset($total[$name]))
$total[$name] += $row[$name];
else
$total[$name] = $row[$name];
}
}
}
}
if ($sum != null)
$anss['total']['total'] = $total;
showhead('', null, $header);
$section = '';
foreach ($anss as $rig => $ans)
{
foreach ($ans as $item => $row)
{
if ($item == 'STATUS')
continue;
echo '';
$newsection = preg_replace('/\d/', '', $item);
if ($newsection != 'total')
$section = $newsection;
foreach ($header as $name => $x)
{
if ($name == '')
{
if ($rig === 'total')
echo "| Total: | ";
else
echo " | ";
}
else
{
if (isset($row[$name]))
list($showvalue, $class) = fmt($section, $name, $row[$name]);
else
{
$class = '';
$showvalue = ' ';
}
if ($rig === 'total' and $class == '')
$class = ' class=tot';
echo "$showvalue";
}
}
echo ' ';
}
}
}
#
function doOne($rig, $preprocess)
{
global $error, $readonly, $notify;
global $rigs;
htmlhead(true);
$error = null;
echo " | ";
if ($preprocess != null)
process(array($preprocess => $preprocess), $rig);
$cmds = array( 'devs' => 'device list',
'summary' => 'summary information',
'pools' => 'pool list');
if ($notify)
$cmds['notify'] = 'device status';
$cmds['config'] = 'cgminer config';
process($cmds, $rig);
if ($error == null && $readonly === false)
processgpus($rig);
}
#
function display()
{
global $tablebegin, $tableend;
global $miner, $port;
global $error, $readonly, $notify, $rigs;
$rig = trim(getparam('rig', true));
$arg = trim(getparam('arg', true));
$preprocess = null;
if ($arg != null and $arg != '')
{
$num = null;
if ($rig != null and $rig != '')
{
if ($rig >= 0 and $rig < count($rigs))
$num = $rig;
}
else
if (count($rigs) == 0)
$num = 0;
if ($num != null)
{
$parts = explode(':', $rigs[$num], 2);
if (count($parts) == 2)
{
$miner = $parts[0];
$port = $parts[1];
$preprocess = $arg;
}
}
}
if ($rigs == null or count($rigs) == 0)
{
echo "| No rigs defined | ";
return;
}
if (count($rigs) == 1)
{
$parts = explode(':', $rigs[0], 2);
if (count($parts) == 2)
{
$miner = $parts[0];
$port = $parts[1];
doOne(0, $preprocess);
}
else
echo '| Invalid "$rigs" array | ';
return;
}
if ($rig != null and $rig != '' and $rig >= 0 and $rig < count($rigs))
{
$parts = explode(':', $rigs[$rig], 2);
if (count($parts) == 2)
{
$miner = $parts[0];
$port = $parts[1];
doOne($rig, $preprocess);
}
else
echo '| Invalid "$rigs" array | ';
return;
}
htmlhead(false);
echo " | ";
if ($preprocess != null)
process(array($preprocess => $preprocess), $rig);
echo $tablebegin;
$sum = array('MHS av', 'Getworks', 'Found Blocks', 'Accepted', 'Rejected', 'Discarded', 'Stale', 'Utility', 'Local Work', 'Total MH');
doforeach('summary', 'summary information', $sum, array(), true);
echo $tableend;
echo '
| ';
echo $tablebegin;
doforeach('devs', 'device list', $sum, array(''=>'','ID'=>'','Name'=>''), false);
echo $tableend;
echo '
| ';
echo $tablebegin;
doforeach('pools', 'pool list', $sum, array(''=>''), false);
echo $tableend;
}
#
display();
#
?>
|