0, 'temp'=>0, 'fsSize'=>0, 'fsUsed'=>0, 'fsFree'=>0, 'ioReads'=>0, 'ioWrites'=>0, 'numReads'=>0, 'numWrites'=>0, 'numErrors'=>0];
extract(parse_plugin_cfg('dynamix',true));
function model($id) {
return substr($id,0,strrpos($id,'_'));
}
// sort unassigned devices on disk identification
if (count($devs)>1) array_multisort(array_column($devs,'sectors'),SORT_DESC,array_map('model',array_column($devs,'id')),SORT_NATURAL|SORT_FLAG_CASE,array_column($devs,'device'),$devs);
require_once "$docroot/webGui/include/CustomMerge.php";
function in_parity_log($log,$timestamp) {
if (file_exists($log)) {
$handle = fopen($log, 'r');
while (($line = fgets($handle))!==false) {
if (strpos($line,$timestamp)!==false) break;
}
fclose($handle);
}
return !empty($line);
}
function device_info(&$disk,$online) {
global $path, $var, $crypto;
$name = $disk['name'];
$fancyname = $disk['type']=='New' ? $name : my_disk($name);
$type = $disk['type']=='Flash' || $disk['type']=='New' ? $disk['type'] : 'Device';
$action = strpos($disk['color'],'blink')===false ? 'down' : 'up';
switch ($disk['color']) {
case 'green-on': $orb = 'circle'; $color = 'green'; $help = 'Normal operation, device is active'; break;
case 'green-blink': $orb = 'circle'; $color = 'grey'; $help = 'Device is in standby mode (spun-down)'; break;
case 'blue-on': $orb = 'square'; $color = 'blue'; $help = 'New device'; break;
case 'blue-blink': $orb = 'square'; $color = 'grey'; $help = 'New device, in standby mode (spun-down)'; break;
case 'yellow-on': $orb = 'warning'; $color = 'yellow'; $help = $disk['type']=='Parity' ? 'Parity is invalid' : 'Device contents emulated'; break;
case 'yellow-blink': $orb = 'warning'; $color = 'grey'; $help = $disk['type']=='Parity' ? 'Parity is invalid, in standby mode (spun-down)' : 'Device contents emulated, in standby mode (spun-down)'; break;
case 'red-on': case 'red-blink': $orb = 'times'; $color = 'red'; $help = $disk['type']=='Parity' ? 'Parity device is disabled' : 'Device is disabled, contents emulated'; break;
case 'red-off': $orb = 'times'; $color = 'red'; $help = $disk['type']=='Parity' ? 'Parity device is missing' : 'Device is missing (disabled), contents emulated'; break;
case 'grey-off': $orb = 'square'; $color = 'grey'; $help = 'Device not present'; break;
}
$ctrl = '';
if ($var['fsState']=='Started' && $type!='Flash' && strpos($disk['status'],'_NP')===false) {
$ctrl = " style='cursor:pointer' onclick=\"toggle_state('$type','$name','$action')\"";
$help .= "
Click to spin $action device";
}
$status = "$help";
$link = ($disk['type']=='Parity' && strpos($disk['status'],'_NP')===false) ||
($disk['type']=='Data' && $disk['status']!='DISK_NP') ||
($disk['type']=='Cache' && $disk['status']!='DISK_NP') ||
($disk['name']=='cache') || ($disk['name']=='flash') ||
$disk['type']=='New' ? "".$fancyname."" : $fancyname;
if ($crypto) switch ($disk['luksState']) {
case 0:
if (!vfs_luks($disk['fsType']))
$luks = "";
else
$luks = "Device to be encrypted";
break;
case 1:
if ($online) {
$luks = "Device encrypted and unlocked";
break;
}
/* fall thru */
case 2:
$luks = "Device encrypted";
break;
case 3:
$luks = "Device locked: wrong encryption key";
break;
default:
$luks = "Device locked: unknown error";
break;
} else $luks = '';
return $status.$luks.$link;
}
function device_browse(&$disk) {
global $path;
$dir = $disk['name']=='flash' ? "/boot" : "/mnt/{$disk['name']}";
return "
";
}
function device_desc(&$disk) {
global $var;
$size = my_scale($disk['size'] ? $disk['size']*1024 : $disk['sectors']*$disk['sector_size'],$unit,-1);
switch ($disk['type']) {
case 'Flash' : $type = 'usb'; break;
case 'Parity': $type = $disk['rotational'] ? 'disk' : 'nvme'; break;
case 'Data' :
case 'Cache' : $type = $disk['rotational'] ? ($disk['luksState'] ? 'disk-encrypted' : 'disk') : 'nvme'; break;
}
$log = $var['fsState']=='Started' ? "Disk log information" : "";
return $log."".my_id($disk['id'])." - $size $unit ({$disk['device']})";
}
function assignment(&$disk) {
global $var, $devs;
$out = "";
}
function vfs_type($fs) {
return str_replace('luks:','',$fs);
}
function vfs_luks($fs) {
return ($fs != vfs_type($fs));
}
function fs_info(&$disk) {
global $display;
if ($disk['fsStatus']=='-') {
echo ($disk['type']=='Cache' && $disk['name']!='cache') ? "Device is part of cache pool | | " : " | ";
return;
} elseif ($disk['fsStatus']=='Mounted') {
echo "".vfs_type($disk['fsType'])." | ";
echo "".my_scale(($disk['fsSize']??0)*1024,$unit,-1)." $unit | ";
if ($display['text']%10==0) {
echo "".my_scale($disk['fsUsed']*1024,$unit)." $unit | ";
} else {
$used = isset($disk['fsSize']) && $disk['fsSize']>0 ? 100-round(100*$disk['fsFree']/$disk['fsSize']) : 0;
echo "".my_scale($disk['fsUsed']*1024,$unit)." $unit | ";
}
if ($display['text']<10 ? $display['text']%10==0 : $display['text']%10!=0) {
echo "".my_scale($disk['fsFree']*1024,$unit)." $unit | ";
} else {
$free = isset($disk['fsSize']) && $disk['fsSize']>0 ? round(100*$disk['fsFree']/$disk['fsSize']) : 0;
echo "".my_scale($disk['fsFree']*1024,$unit)." $unit | ";
}
echo "".device_browse($disk)." | ";
} else
echo "".vfs_type($disk['fsType'])." | {$disk['fsStatus']}";
}
function my_diskio($data) {
return my_scale($data,$unit,1)." $unit/s";
}
function parity_only($disk) {
return $disk['type']=='Parity';
}
function data_only($disk) {
return $disk['type']=='Data';
}
function cache_only($disk) {
return $disk['type']=='Cache';
}
function array_offline(&$disk) {
global $var, $disks;
if (strpos($var['mdState'],'ERROR:')===false) {
$text = 'All existing data on this device will be OVERWRITTEN when array is Started';
if ($disk['type']=='Cache') {
if (!empty($disks['cache']['uuid']) && $disk['status']=='DISK_NEW') $warning = $text;
} else {
if ($var['mdState']=='NEW_ARRAY') {
if ($disk['type']=='Parity') $warning = $text;
} else if ($var['mdNumInvalid']<=1) {
if (in_array($disk['status'],['DISK_INVALID','DISK_DSBL_NEW','DISK_WRONG','DISK_NEW'])) $warning = $text;
}
}
}
echo " | ";
switch ($disk['status']) {
case 'DISK_NP':
case 'DISK_NP_DSBL':
echo "| ".device_info($disk,false)." | ";
echo "".assignment($disk)." | ";
echo " | ";
break;
case 'DISK_NP_MISSING':
echo "".device_info($disk,false)."
Missing | ";
echo "".assignment($disk)."{$disk['idSb']} - ".my_scale($disk['sizeSb']*1024,$unit)." $unit | ";
echo " | ";
break;
case 'DISK_OK':
case 'DISK_DSBL':
case 'DISK_INVALID':
case 'DISK_DSBL_NEW':
case 'DISK_NEW':
$spin = strpos($disk['color'],'blink')===false;
echo "".device_info($disk,false)." | ";
echo "".assignment($disk)." | ";
echo "".($spin ? my_temp($disk['temp']) : '*')." | ";
echo "$warning | ";
break;
case 'DISK_WRONG':
echo "".device_info($disk,false)."
Wrong | ";
echo "".assignment($disk)."{$disk['idSb']} - ".my_scale($disk['sizeSb']*1024,$unit)." $unit | ";
echo "".my_temp($disk['temp'])." | ";
echo "$warning | ";
break;
}
echo "
";
}
function array_online(&$disk) {
global $sum, $diskio;
if ($disk['device']!='') {
$dev = $disk['device'];
$data = explode(' ',$diskio[$dev] ?? '0 0');
$sum['ioReads'] += $data[0];
$sum['ioWrites'] += $data[1];
}
if (is_numeric($disk['temp'])) {
$sum['count']++;
$sum['temp'] += $disk['temp'];
}
$sum['numReads'] += $disk['numReads'];
$sum['numWrites'] += $disk['numWrites'];
$sum['numErrors'] += $disk['numErrors'];
if (isset($disk['fsFree'])) {
$disk['fsUsed'] = $disk['fsSize']-$disk['fsFree'];
$sum['fsSize'] += $disk['fsSize'];
$sum['fsUsed'] += $disk['fsUsed'];
$sum['fsFree'] += $disk['fsFree'];
}
echo "";
switch ($disk['status']) {
case 'DISK_NP':
if ($disk['name']=="cache") {
echo "| ".device_info($disk,true)." | ";
echo "Not installed | ";
echo " | ";
fs_info($disk);
}
break;
case 'DISK_NP_DSBL':
echo "".device_info($disk,true)." | ";
echo "Not installed | ";
echo " | ";
fs_info($disk);
break;
case 'DISK_DSBL':
default:
$spin = strpos($disk['color'],'blink')===false;
echo "".device_info($disk,true)." | ";
echo "".device_desc($disk)." | ";
echo "".($spin ? my_temp($disk['temp']) : '*')." | ";
echo "".my_diskio($data[0])."".my_number($disk['numReads'])." | ";
echo "".my_diskio($data[1])."".my_number($disk['numWrites'])." | ";
echo "".my_number($disk['numErrors'])." | ";
fs_info($disk);
break;
}
echo "
";
}
function my_clock($time) {
if (!$time) return 'less than a minute';
$days = floor($time/1440);
$hour = $time/60%24;
$mins = $time%60;
return plus($days,'day',($hour|$mins)==0).plus($hour,'hour',$mins==0).plus($mins,'minute',true);
}
function read_disk($name, $part) {
global $var;
$port = port_name($name);
switch ($part) {
case 'color':
return exec("hdparm -C ".escapeshellarg("/dev/$port")."|grep -Po 'active|unknown'") ? 'blue-on' : 'blue-blink';
case 'temp':
$smart = "/var/local/emhttp/smart/$name";
$type = $var['smType'] ?? '';
if (!file_exists($smart) || (time()-filemtime($smart)>=$var['poll_attributes'])) exec("smartctl -n standby -A $type ".escapeshellarg("/dev/$port")." >".escapeshellarg($smart)." &");
return exec("awk 'BEGIN{s=t=\"*\"}\$1==190{s=\$10};\$1==194{t=\$10;exit};\$1==\"Temperature:\"{t=\$2;exit};/^Current Drive Temperature:/{t=\$4;exit} END{if(t!=\"*\")print t; else print s}' ".escapeshellarg($smart)." 2>/dev/null");
}
}
function show_totals($text) {
global $var, $display, $sum;
echo "";
echo " | ";
echo "$text | ";
echo "".($sum['count']>0 ? my_temp(round($sum['temp']/$sum['count'],1)) : '*')." | ";
echo "".my_diskio($sum['ioReads'])."".my_number($sum['numReads'])." | ";
echo "".my_diskio($sum['ioWrites'])."".my_number($sum['numWrites'])." | ";
echo "".my_number($sum['numErrors'])." | ";
echo " | ";
if (strstr($text,'Array') && ($var['startMode']=='Normal')) {
echo "".my_scale($sum['fsSize']*1024,$unit,-1)." $unit | ";
if ($display['text']%10==0) {
echo "".my_scale($sum['fsUsed']*1024,$unit)." $unit | ";
} else {
$used = $sum['fsSize'] ? 100-round(100*$sum['fsFree']/$sum['fsSize']) : 0;
echo "".my_scale($sum['fsUsed']*1024,$unit)." $unit | ";
}
if ($display['text']<10 ? $display['text']%10==0 : $display['text']%10!=0) {
echo "".my_scale($sum['fsFree']*1024,$unit)." $unit | ";
} else {
$free = $sum['fsSize'] ? round(100*$sum['fsFree']/$sum['fsSize']) : 0;
echo "".my_scale($sum['fsFree']*1024,$unit)." $unit | ";
}
echo " | ";
} else
echo " | ";
echo "
";
}
function array_slots() {
global $var;
$min = max($var['sbNumDisks'], 3);
$max = $var['MAX_ARRAYSZ'];
$out = "";
return $out;
}
function cache_slots($disabled) {
global $var;
$off = $disabled ? ' disabled' : '';
$min = $var['cacheSbNumDisks'];
$max = $var['MAX_CACHESZ'];
$out = "";
return $out;
}
$crypto = false;
switch ($_POST['device']) {
case 'array':
$parity = array_filter($disks,'parity_only');
$data = array_filter($disks,'data_only');
foreach ($data as $disk) $crypto |= $disk['luksState']!=0 || vfs_luks($disk['fsType']);
if ($var['fsState']=='Stopped') {
foreach ($parity as $disk) array_offline($disk);
echo " |
";
foreach ($data as $disk) array_offline($disk);
echo "| Slots: | ".array_slots()." | |
";
} else {
foreach ($parity as $disk) if ($disk['status']!='DISK_NP_DSBL') array_online($disk);
foreach ($data as $disk) array_online($disk);
if ($display['total']) show_totals('Array of '.my_word($var['mdNumDisks']).' devices');
}
break;
case 'flash':
$disk = &$disks['flash'];
$data = explode(' ',$diskio[$disk['device']] ?? '0 0');
$disk['fsUsed'] = $disk['fsSize']-$disk['fsFree'];
$flash = &$sec['flash']; $share = "";
if ($var['shareSMBEnabled']=='yes' && $flash['export']=='e' && $flash['security']=='public')
$share = "Flash device is set as public share
Please change share SMB security
Click on FLASH above this message";
echo "";
echo "| ".$share.device_info($disk,true)." | ";
echo "".device_desc($disk)." | ";
echo "* | ";
echo "".my_diskio($data[0])."".my_number($disk['numReads'])." | ";
echo "".my_diskio($data[1])."".my_number($disk['numWrites'])." | ";
echo "".my_number($disk['numErrors'])." | ";
fs_info($disk);
echo "
";
break;
case 'cache':
$cache = array_filter($disks,'cache_only');
$tmp = '/var/tmp/cache_log.tmp';
foreach ($cache as $disk) $crypto |= $disk['luksState']!=0 || vfs_luks($disk['fsType']);
if ($var['fsState']=='Stopped') {
$log = file_exists($tmp) ? parse_ini_file($tmp) : [];
$off = false;
foreach ($cache as $disk) {
array_offline($disk);
if (isset($log[$disk['name']])) $off |= ($log[$disk['name']]!=$disk['id']); else $log[$disk['name']] = $disk['id'];
}
$data = []; foreach ($log as $key => $value) $data[] = "$key=\"$value\"";
file_put_contents($tmp,implode("\n",$data));
echo "| Slots: | ".cache_slots($off)." | |
";
} else {
foreach ($cache as $disk) array_online($disk);
@unlink($tmp);
if ($display['total'] && $var['cacheSbNumDisks']>1) show_totals('Pool of '.my_word($var['cacheNumDevices']).' devices');
}
break;
case 'open':
foreach ($devs as $disk) {
$dev = $disk['device'];
$data = explode(' ',$diskio[$dev] ?? '0 0 0 0');
$disk['name'] = $dev;
$disk['type'] = 'New';
$disk['color'] = read_disk($dev,'color');
$disk['temp'] = read_disk($dev,'temp');
echo "";
echo "| ".device_info($disk,true)." | ";
echo "".device_desc($disk)." | ";
echo "".my_temp($disk['temp'])." | ";
echo "".my_diskio($data[0])."".my_number($data[2])." | ";
echo "".my_diskio($data[1])."".my_number($data[3])." | ";
if (file_exists("/tmp/preclear_stat_$dev")) {
$text = exec("cut -d'|' -f3 /tmp/preclear_stat_$dev|sed 's:\^n:\:g'");
if (strpos($text,'Total time')===false) $text = 'Preclear in progress... '.$text;
echo "$text | ";
} else
echo " | ";
echo "
";
}
break;
case 'parity':
$data = [];
if ($var['mdResyncPos']) {
$data[] = my_scale($var['mdResyncSize']*1024,$unit,-1)." $unit";
$data[] = my_clock(floor((time()-$var['sbSynced'])/60)).($var['mdResyncDt'] ? '' : ' (paused)');
$data[] = my_scale($var['mdResyncPos']*1024,$unit)." $unit (".number_format(($var['mdResyncPos']/($var['mdResyncSize']/100+1)),1,$display['number'][0],'')." %)";
$data[] = $var['mdResyncDt'] ? my_scale($var['mdResyncDb']*1024/$var['mdResyncDt'],$unit, 1)." $unit/sec" : '---';
$data[] = $var['mdResyncDb'] ? my_clock(round(((($var['mdResyncDt']*(($var['mdResyncSize']-$var['mdResyncPos'])/($var['mdResyncDb']/100+1)))/100)/60),0)) : 'Unknown';
$data[] = $var['sbSyncErrs'];
echo implode(';',$data);
} else {
if ($var['sbSynced']==0 || $var['sbSynced2']==0) break;
$log = '/boot/config/parity-checks.log';
$timestamp = str_replace(['.0','.'],[' ',' '],date('M.d H:i:s',$var['sbSynced2']));
if (in_parity_log($log,$timestamp)) break;
$duration = $var['sbSynced2'] - $var['sbSynced'];
$status = $var['sbSyncExit'];
$speed = ($status==0) ? my_scale($var['mdResyncSize']*1024/$duration,$unit,1)." $unit/s" : "Unavailable";
$error = $var['sbSyncErrs'];
$year = date('Y',$var['sbSynced2']);
if ($status==0||file_exists($log)) file_put_contents($log,"$year $timestamp|$duration|$speed|$status|$error\n",FILE_APPEND);
}
break;
}
?>