Skip to content

E
elphel-web-393
Commit 620a1357 authored by Andrey Filippov's avatar Andrey Filippov
Browse files
Options

implemented lwir16.php daemon mode, added ini file

parent fffd658c
Hide whitespace changes
Inline Side-by-side
Showing with 856 additions and 236 deletions
src/lwir16/Makefile
View file @ 620a1357
DOCUMENTROOT=$(DESTDIR)/www/pages/lwir16 DOCUMENTROOT=$(DESTDIR)/www/pages/lwir16
OWN = -o root -g root OWN = -o root -g root
INSTDOCS = 0644 INSTDOCS = 0644
INSTEXE = 0755
SYSCONFDIR =/etc
CONFDIR = $(SYSCONFDIR)/elphel393
INSTALL = install INSTALL = install
DOCS= index.html \ DOCS= index.html
lwir16.php
PHP_SCRIPTS_EXE=lwir16.php \
test_int.php \
test_wpipe.php \
test_ps.php
CONFIGS = lwir16.ini
all: all:
@echo "make all in src" @echo "make all in src"
...@@ -11,6 +23,10 @@ install: ...@@ -11,6 +23,10 @@ install:
@echo "make install in src" @echo "make install in src"
$(INSTALL) $(OWN) -d $(DOCUMENTROOT) $(INSTALL) $(OWN) -d $(DOCUMENTROOT)
$(INSTALL) $(OWN) -m $(INSTDOCS) $(DOCS) $(DOCUMENTROOT) $(INSTALL) $(OWN) -m $(INSTDOCS) $(DOCS) $(DOCUMENTROOT)
$(INSTALL) $(OWN) -m $(INSTEXE) $(PHP_SCRIPTS_EXE) $(DOCUMENTROOT)
$(INSTALL) -d $(DESTDIR)$(SYSCONFDIR)
$(INSTALL) -d $(DESTDIR)$(CONFDIR)
$(INSTALL) $(OWN) -m $(INSTDOCS) $(CONFIGS) $(DESTDIR)$(CONFDIR)
clean: clean:
@echo "make clean in src" @echo "make clean in src"
src/lwir16/lwir16.ini 0 → 100644
View file @ 620a1357
ips = "192.168.0.41,192.168.0.42,192.168.0.43,192.168.0.44,192.168.0.45"
duration = 100
pre_delay = 5.0
ffc_period = 300.0
ffc_groups = 2
ffc_frames = 8
ffc = 1
debug = 1
# no spaces around commas!
CMD = INIT,START
\ No newline at end of file
src/lwir16/lwir16.php
View file @ 620a1357
#!/usr/bin/php
<?php <?php
/*!******************************************************************************* /*!*******************************************************************************
*! FILE NAME : lwir.php *! FILE NAME : lwir.php
...@@ -24,76 +25,107 @@ ...@@ -24,76 +25,107 @@
set_include_path ( get_include_path () . PATH_SEPARATOR . '/www/pages/include' ); set_include_path ( get_include_path () . PATH_SEPARATOR . '/www/pages/include' );
include 'show_source_include.php'; include 'show_source_include.php';
include "elphel_functions_include.php"; // includes curl functions include "elphel_functions_include.php"; // includes curl functions
define("REG_FFC_FRAMES", "SENSOR_REGS4"); // Register for the number of FFC frames to integrate define('REG_FFC_FRAMES', 'SENSOR_REGS4'); // Register for the number of FFC frames to integrate
define("REG_FFC_RUN", "SENSOR_REGS26"); // Register to trigger FFC define('REG_FFC_RUN', 'SENSOR_REGS26'); // Register to trigger FFC
define("SCRIPT_RESET", "reset_frames.php"); // Reset frame numbers define('SCRIPT_RESET', 'reset_frames.php'); // Reset frame numbers
define("SCRIPT_WAIT", "wait_frame.php"); // wait frame define('SCRIPT_WAIT', 'wait_frame.php'); // wait frame
$duration = 100; define('DEFAULT_IPS', '192.168.0.41,192.168.0.42,192.168.0.43,192.168.0.44,192.168.0.45');
$pre_delay = 5.0; // seconds define('PIPE_CMD', '/tmp/pipe_cmd');
$compressor_run = 0; // stop all define('PIPE_RESPONSE', '/tmp/pipe_response');
$ffc = false; // perform FFC before starting a sequence (and before delay? reduce delay ?) define('PIPE_MODE', 0600);
$ffc_groups = 2; // 1/2/4 - do not run FFC on all channels simultaneously (43 failed) define('CONF_LWIR16', '/etc/elphel393/lwir16.ini');
$ffc_frames = 8; // read actual? define('EO_DECIMATE', 6);
// GLOBALS field name
define('IPS', 'ips');
define('DURATION', 'duration');
define('DURATION_EO', 'duration_eo');
define('PRE_DELAY', 'pre_delay');
define('FFC', 'ffc'); // use FFC
define('FFC_PERIOD', 'ffc_period');
define('FFC_GROUPS', 'ffc_groups');
define('FFC_FRAMES', 'ffc_frames');
define('COMPRESSOR_RUN', 'compressor_run'); // after init
define('DEBUG', 'debug');
define('DAEMON_RUN', 'daemon_run'); // not read through ini
define('CAPTURE_RUN', 'capture_run'); // not read through ini
define('LAST_FFC', 'last_ffc'); // not read through ini
define('SECUENCE_NUM', 'sequence_num'); // not read through ini
define('TIME_TO_FFC', 'time_to_ffc'); // not read through ini
define('DAEMON_CMD', 'CMD'); // command to be executed by a daemon
define('CMD_INIT', 'INIT'); // passed commands
define('CMD_START', 'START'); // passed commands
define('CMD_STOP', 'STOP'); // passed commands
define('CMD_EXIT', 'EXIT'); // passed commands
define('CMD_STATUS', 'STATUS'); // passed commands
define('CMD_REBOOT', 'REBOOT'); // passed commands
define('CR_EXTRA', 2); // not currenly used - wait extra frames in capture_range
// daemon control $_GET
define('DAEMON_CTRL', 'daemon');
define('DAEMON_CTRL_CMDS', 'cmd'); //comma-separated commands to be sent to the daemon
// initializations before reading lwir16.ini
$GLOBALS[COMPRESSOR_RUN] = 0;
$GLOBALS[DURATION] = 100;
$GLOBALS[PRE_DELAY] = 5.0; // seconds
$GLOBALS[FFC] = false; // perform FFC before starting a sequence (and before delay? reduce delay ?)
// $ffc = false;
$GLOBALS[FFC_GROUPS] = 2; // 1/2/4 - do not run FFC on all channels simultaneously (43 failed)
$GLOBALS[FFC_FRAMES] = 8; // read actual?
$ini = parse_ini_file(CONF_LWIR16);
applyConf($ini);
$ffc_wait_frames = 10; // extra wait after FFC finished (2xffc_frames) $ffc_wait_frames = 10; // extra wait after FFC finished (2xffc_frames)
$compressor_run = 0; // stop all
if (!($_SERVER ['REQUEST_METHOD'] == "GET")){
lwir16_daemon();
exit (0);
}
if (isset($_GET[DAEMON_CTRL])){
daemon_control($_GET['daemon']);
exit(0);
}
// public static final String REG_FFC_FRAMES= "SENSOR_REGS4"; // Register for the number of FFC frames to integrate
// public static final String REG_FFC_RUN= "SENSOR_REGS26"; // Register to trigger FFC
unset($duration);unset($duration_eo);
foreach($_GET as $key=>$value) { foreach($_GET as $key=>$value) {
if (($key == 'ip') || ($key == 'ips')){ // multicamera operation if (($key == 'ip') || ($key == 'ips')){ // multicamera operation
$ips = explode(',',$value); $GLOBALS[IPS] = explode(',',$value);
} else if (($key == 'lwir16') || ($key == 'cmd')){ } else if (($key == 'lwir16') || ($key == 'cmd')){
$lswir16cmds = explode(',',$value); $lswir16cmds = explode(',',$value);
} else if ($key == 'pre_delay'){ } else if ($key == 'pre_delay'){
$pre_delay = (double) $value; // only used with capture $GLOBALS[PRE_DELAY] = (double) $value; // only used with capture
} else if (($key == 'd') || ($key == 'duration')){ } else if (($key == 'd') || ($key == 'duration')){
$duration = (int) $value; // EO - make 1/6 +1 frames $duration = (int) $value; // EO - make 1/6 +1 frames
} else if (($key == 'de') || ($key == 'duration_eo')){ } else if (($key == 'de') || ($key == 'duration_eo')){
$duration_eo = (int) $value; // EO - make 1/6 +1 frames $duration_eo = (int) $value; // EO - make 1/6 +1 frames
} else if ($key == 'nowait'){ } else if ($key == 'nowait'){
$nowait = 1; $nowait = 1;
} else if ($key == 'run'){ } else if ($key == 'run'){
$compressor_run = 2; $GLOBALS[COMPRESSOR_RUN] = 2;
} else if ($key == 'ffc'){ } else if ($key == 'ffc'){
$GLOBALS[FFC] = true;
$ffc = true;
if ($value) { // string "0" will also be false if ($value) { // string "0" will also be false
$v = (int) $value; $v = (int) $value;
if (($v == 1) || ($v == 2) || ($v == 4)){ if (($v == 1) || ($v == 2) || ($v == 4)){
$ffc_groups = $v; $$GLOBALS[FFC_GROUPS] = $v;
} }
} }
// printf("<!--\n");
// printf('$ffc_groups= '.$ffc_groups."\n");
// printf('$ffc= '.$ffc."\n");
// printf("-->\n");
} }
} }
if (!isset ($ips)){ if (isset($duration) && !isset($duration_eo)){
$ips=array(); $duration_eo = (int) ($duration/EO_DECIMATE + 1);
$ips[] = '192.168.0.41';
$ips[] = '192.168.0.42';
$ips[] = '192.168.0.43';
$ips[] = '192.168.0.44';
$ips[] = '192.168.0.45';
} }
if ($duration < 1){ if (isset($duration)) $GLOBALS[DURATION] = $duration;
$duration = 1; if (isset($duration_eo)) $GLOBALS[DURATION_EO] = $duration_eo;
} if ($GLOBALS[DURATION] < 1) $GLOBALS[DURATION] = 1;
if (!isset($duration_eo)){ if ($GLOBALS[DURATION_EO] < 1) $GLOBALS[DURATION_EO] = 1;
$duration_eo = ($duration/6) + 1; // default
}
if ($duration_eo < 1){
$duration_eo = 1;
}
if (isset($lswir16cmds)){ if (isset($lswir16cmds)){
// exit(0);
$lwir_trig_dly = 0; $lwir_trig_dly = 0;
$eo_quality = 97; $eo_quality = 97;
$exposure = 1000; // 1 ms $exposure = 1000; // 1 ms
...@@ -105,7 +137,7 @@ ...@@ -105,7 +137,7 @@
$gScale = 1*0x10000; $gScale = 1*0x10000;
$autoWB = 1; $autoWB = 1;
$extra = 2; /// $extra = 2;
$wait = 1; $wait = 1;
if ($nowait){ if ($nowait){
$wait = 0; $wait = 0;
...@@ -123,110 +155,18 @@ ...@@ -123,110 +155,18 @@
// print("2"); // print("2");
// exit(0); // exit(0);
$lwir_ips= array($ips[0],$ips[1],$ips[2],$ips[3]); $lwir_ips= array($GLOBALS[IPS][0],$GLOBALS[IPS][1],$GLOBALS[IPS][2],$GLOBALS[IPS][3]);
// $twoIPs= array($ips[0],$ips[4]); // $twoIPs= array($GLOBALS[IPS][0],$GLOBALS[IPS][4]);
$twoIPs= $ips; // array($ips[0],$ips[4]); wait all $twoIPs= $GLOBALS[IPS]; // array($GLOBALS[IPS][0],$GLOBALS[IPS][4]); wait all
// print_r($lswir16cmds); // print_r($lswir16cmds);
// exit(0);
for ($ncmd = 0; $ncmd < count($lswir16cmds); $ncmd++){ for ($ncmd = 0; $ncmd < count($lswir16cmds); $ncmd++){
$cmd = $lswir16cmds[$ncmd]; $cmd = $lswir16cmds[$ncmd];
// print('cmd='.$cmd);
// exit(0);
if ($cmd == 'init'){ if ($cmd == 'init'){
// print_r($twoIPs); $results = runInit();
// exit(0);
$results0 = skipFrames($twoIPs, 2);
// print_r($results0);
$results1 = resetIPs($ips); // sync channels in each subcamera
// print_r($results1);
$results2 = skipFrames($twoIPs, 16); // was 1
// print_r($results2); print("<br/>");
$urls = array(); // eo - individual
for ($i = 0; $i < (count($ips) + 3); $i++){
$nip = $i;
if ($nip >= count($ips)){
$nip = count($ips)-1;
}
$urls[$i] = 'http://'.$ips[$nip].'/parsedit.php?immediate&sensor_port='.($i - $nip);
$urls[$i] .= '&TRIG_OUT=0x66555'.
'&TRIG_CONDITION=0x95555'.
'&TRIG_BITLENGTH=31'.
'&EXTERN_TIMESTAMP=1'.
'&XMIT_TIMESTAMP=1';
}
// print_r($urls); print("<br/>");
// exit(0);
for ($i = 0; $i < count($lwir_ips); $i++){
$urls[$i] .= '&TRIG_DELAY='.$lwir_trig_dly.'&*TRIG_DELAY=15'. // apply to all ports
'&BITS=16&*BITS=15'.
'&COLOR='.$COLOR_RAW .'&*COLOR=15'.
'&WOI_HEIGHT='.($LWIR_HEIGHT + ($LWIR_TELEMETRY ? $LWIR_TELEMETRY_LINES : 0)).'&*WOI_HEIGHT=15'.
'&'.$REG_FFC_FRAMES.'='.$FFC_FRAMES .'&*'.$REG_FFC_FRAMES.'=15'; // apply to all channels
$urls[$i] .= '&COMPRESSOR_RUN=2&*COMPRESSOR_RUN=15';
}
// print_r($urls); print("<br/>");
for ($chn = 0; $chn < 4; $chn++){
$urls[count($ips)-1 + $chn] .=
"&COLOR=". $COLOR_JP4.
"&QUALITY=". $eo_quality.
"&EXPOS=". $exposure.
"&AUTOEXP_EXP_MAX=".$autoExposureMax.
"&AUTOEXP_ON=". $autoExp.
"&GAING=". $gain.
"&RSCALE=". $rScale.//"*0".
"&BSCALE=". $bScale.//"*0".
"&GSCALE=". $gScale.//"*0". // GB/G ratio
"&WB_EN=". $autoWB.//"*0".
"&DAEMON_EN_TEMPERATURE=1";//"*0";
if (lrp.eo_full_window) {
$urls[count($ips)-1 + $chn] .=
"&WOI_LEFT=0".
"&WOI_TOP=0".
"&WOI_WIDTH=2592".
"&WOI_HEIGHT=1936";
}
if ($chn == 0) {
$urls[count($ips)-1] .= '&COMPRESSOR_RUN=2&*COMPRESSOR_RUN=15';
}
}
// print_r($urls);
// exit(0);
$curl_data = curl_multi_start ($urls);
$enable_echo = false;
$results3= curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML)
$results4 = skipFrames($twoIPs, 16);
// set external trigger mode for all LWIR and EO cameras
$urls = array();
for ($i = 0; $i<count($ips); $i++){
$urls[] = 'http://'.$ips[$i].'/parsedit.php?immediate&sensor_port=0&TRIG=4&*TRIG=15'.
'&COMPRESSOR_RUN='.$compressor_run.'*5&*COMPRESSOR_RUN=15'; // delay turning off COMPRESSOR_RUN
}
$curl_data = curl_multi_start ($urls);
$enable_echo = false;
$results5 = curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML)
$results6 = skipFrames($twoIPs, 16); // make sure all previous parameters are applied // waits for both LWIR and EO
// second reset after cameras running synchronously
$results7 = resetIPs($ips); // sync channels in each subcamera
$results8 = skipFrames($twoIPs, 16); // was 2
$results9 = resetIPs($ips); // sync channels in each subcamera
$results10 = skipFrames($twoIPs, 16); // was 2
$results = $results10;
/*
print("<br/>results0:");print_r($results0);print("<br/>");
print("<br/>results1:");print_r($results1);print("<br/>");
print("<br/>results2:");print_r($results2);print("<br/>");
print("<br/>results3:");print_r($results3);print("<br/>");
print("<br/>results4:");print_r($results4);print("<br/>");
print("<br/>results5:");print_r($results5);print("<br/>");
print("<br/>results6:");print_r($results6);print("<br/>");
print("<br/>results7:");print_r($results7);print("<br/>");
print("<br/>results8:");print_r($results8);print("<br/>");
*/
$xml = new SimpleXMLElement("<?xml version='1.0' standalone='yes'?><lwir16_init/>"); $xml = new SimpleXMLElement("<?xml version='1.0' standalone='yes'?><lwir16_init/>");
for ($i = 0; $i<count($results); $i++){ for ($i = 0; $i<count($results); $i++){
$xml_ip = $xml->addChild ('ip_'.$ips[$i]); $xml_ip = $xml->addChild ('ip_'.$GLOBALS[IPS][$i]);
foreach ($results[$i] as $key=>$value){ foreach ($results[$i] as $key=>$value){
$xml_ip->addChild($key,$value); $xml_ip->addChild($key,$value);
} }
...@@ -238,48 +178,13 @@ ...@@ -238,48 +178,13 @@
printf($rslt); printf($rslt);
exit(0); exit(0);
} else if ($cmd == 'capture'){ } else if ($cmd == 'capture'){
$sensor_port = 0; $results = runCapture($GLOBALS[FFC], $nowait); // runCapture($run_ffc, $nowait = 0, $debug=0)
if ($ffc){ // may move after measuring time, but need to make sure it will be not too late
runFFC($lwir_ips, $ffc_groups, $ffc_frames, $ffc_wait_frames);
}
$this_frame=elphel_get_frame($sensor_port);
$this_timestamp=elphel_frame2ts($sensor_port,$this_frame);
$timestamp = $this_timestamp + $pre_delay; // this will be a delay between capture sequences
// if ($ffc){ // may be here, then need to check that there is some time left
// runFFC($lwir_ips, $ffc_groups, $ffc_frames, $ffc_wait_frames);
// }
$urls = array();
for ($i = 0; $i<count($ips); $i++){
// $_SERVER[SCRIPT_NAME] STARTS WITH '/'
$url = 'http://'.$ips[$i].'/capture_range.php?sensor_port='.$sensor_port; //
$url .= '&ts='.$timestamp; // &timestamp" -> ×tamp
$url .= '&port_mask=15'; // .$port_mask[$i];
$dur = ($i < 4) ? $duration : $duration_eo;
$url .= '&duration='. $dur;
// $url .= '&maxahead='. $maxahead;
// $url .= '&minahead='. $minahead;
$url .= '&extra='. $extra;
if ($wait && ($i == (count($ips) - 1))){ // addd to the last ip in a list
$url .= '&wait';
}
$urls[] = $url;
}
// print ('URLs:'); print_r($urls); print ('<br/');
// exit(0);
$curl_data = curl_multi_start ($urls);
$enable_echo = false;
$results = curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML)
// print ('results:'); print_r($results); print ('<br/');
// exit(0);
$xml = new SimpleXMLElement("<?xml version='1.0' standalone='yes'?><capture_range/>"); $xml = new SimpleXMLElement("<?xml version='1.0' standalone='yes'?><capture_range/>");
$xml->addChild ('ffc', $ffc ? 'true':'false'); $xml->addChild ('ffc', $GLOBALS[FFC] ? 'true':'false');
$xml->addChild ('ffc_groups',$ffc_groups); $xml->addChild (FFC_GROUPS,$GLOBALS[FFC_GROUPS]);
$xml->addChild ('ffc_frames',$ffc_frames); $xml->addChild (FFC_FRAMES,$GLOBALS[FFC_FRAMES]);
for ($i = 0; $i<count($ips); $i++){ for ($i = 0; $i<count($GLOBALS[IPS]); $i++){
$xml_ip = $xml->addChild ('ip_'.$ips[$i]); $xml_ip = $xml->addChild ('ip_'.$GLOBALS[IPS][$i]);
foreach ($results[$i] as $key=>$value){ foreach ($results[$i] as $key=>$value){
$xml_ip->addChild($key,$value); $xml_ip->addChild($key,$value);
} }
...@@ -293,8 +198,8 @@ ...@@ -293,8 +198,8 @@
} else if ($cmd == 'reboot'){ } else if ($cmd == 'reboot'){
//log_msg('running autocampars.py ['.implode(',',$IPs).'] pyCmd reboot'); //log_msg('running autocampars.py ['.implode(',',$IPs).'] pyCmd reboot');
$xml = new SimpleXMLElement("<?xml version='1.0' standalone='yes'?><lwir16_reboot/>"); $xml = new SimpleXMLElement("<?xml version='1.0' standalone='yes'?><lwir16_reboot/>");
for ($i = 0; $i<count($ips); $i++){ for ($i = 0; $i<count($GLOBALS[IPS]); $i++){
$xml_ip = $xml->addChild ('ip_'.$ips[$i]); $xml_ip = $xml->addChild ('ip_'.$GLOBALS[IPS][$i]);
$xml_ip->addChild('reboot','started'); $xml_ip->addChild('reboot','started');
} }
$rslt=$xml->asXML(); $rslt=$xml->asXML();
...@@ -302,10 +207,7 @@ ...@@ -302,10 +207,7 @@
header("Content-Length: ".strlen($rslt)."\n"); header("Content-Length: ".strlen($rslt)."\n");
header("Pragma: no-cache\n"); header("Pragma: no-cache\n");
printf($rslt); printf($rslt);
// one of the next flushes prevent running reboot exec ( 'autocampars.py ['.implode(',',$GLOBALS[IPS]).'] pyCmd reboot', $output, $retval );
// ob_flesh();
// flush();
exec ( 'autocampars.py ['.implode(',',$ips).'] pyCmd reboot', $output, $retval );
exit(0); // no time to close log exit(0); // no time to close log
} else if ($cmd == 'state'){ } else if ($cmd == 'state'){
// TODO: read all subcameras // TODO: read all subcameras
...@@ -321,56 +223,251 @@ ...@@ -321,56 +223,251 @@
header("Content-Type: text/xml"); header("Content-Type: text/xml");
header("Content-Length: ".strlen($rslt)."\n"); header("Content-Length: ".strlen($rslt)."\n");
header("Pragma: no-cache\n"); header("Pragma: no-cache\n");
// printf('<!--');
// var_dump($_GET);
// printf( '-->');
printf($rslt); printf($rslt);
exit (0); exit (0);
} }
} }
} else { // Just output usage? } else { // Just output usage?
echo <<<EOT echo <<<EOT
<pre> <pre>
This script supports initialization of the LWIR16 camera (16 LWIR 640x512 sensors and 4 2592x1936 color ones) This script supports initialization of the LWIR16 camera (16 LWIR 640x512 sensors and 4 2592x1936 color ones)
and capturing of short image sequences (100 frames fit into 64MB per-channel image buffer) for (relatively) and capturing of short image sequences (100 frames fit into 64MB per-channel image buffer) for (relatively)
slow recording with camogm. Untill videocompression for 16-bit TIFFs is not implemented, recording is not fast slow recording with camogm. Untill videocompression for 16-bit TIFFs is not implemented, recording is not fast
enough for continupous recording. This script should be launched in the 'master' subcamera only, it will enough for continupous recording. This script should be launched in the 'master' subcamera only, it will
communidate with the other ones. communidate with the other ones.
URL parameters: URL parameters:
<b>lwir16=init</b> - syncronize all 5 cameras, set acquisition parameters <b>lwir16=init</b> - syncronize all 5 cameras, set acquisition parameters
<b>lwir16=capture</b> - wait specified time, synchronously turn on compressors in each channel of each subcamera, <b>lwir16=capture</b> - wait specified time, synchronously turn on compressors in each channel of each subcamera,
acquire specified number of frames in each channel (reduced, and turn compressors off. acquire specified number of frames in each channel (reduced, and turn compressors off.
</pre> </pre>
EOT; EOT;
// Watch EOT w/o any spaces!
}
function runInit($debug = 0) {
// TODO: use lwir16.ini
$eo_quality = 97;
$exposure = 1000; // 1 ms
$autoExposureMax = 500000;
$autoExp = 1;
$gain = 2 * 0x10000;
$rScale = 1 * 0x10000;
$bScale = 1 * 0x10000;
$gScale = 1 * 0x10000;
$autoWB = 1;
/// $extra = 2;
// $wait = 1;
// if ($nowait) {
// $wait = 0;
// }
$COLOR_JP4 = 5;
$COLOR_RAW = 15;
$LWIR_HEIGHT = 512;
$LWIR_TELEMETRY_LINES = 1;
$LWIR_TELEMETRY = 1;
$FRAMES_SKIP = 4;
$FFC_FRAMES = 8;
$REG_FFC_FRAMES = 'SENSOR_REGS4'; // Register for the number of FFC frames to integrate
$REG_FFC_RUN = 'SENSOR_REGS26'; // Register to trigger FFC
$lwir_ips = array(
$GLOBALS[IPS][0],
$GLOBALS[IPS][1],
$GLOBALS[IPS][2],
$GLOBALS[IPS][3]
);
$twoIPs = $GLOBALS[IPS]; // array($GLOBALS[IPS][0],$GLOBALS[IPS][4]); wait all
if ($debug) {
printf("--- twoIPs:\n");
print_r($twoIPs);
}
$results0 = skipFrames($twoIPs, 2, $debug);
// print_r($results0);
$results1 = resetIPs($GLOBALS[IPS],$debug); // sync channels in each subcamera
// print_r($results1);
$results2 = skipFrames($twoIPs, 16,$debug); // was 1
// print_r($results2); print("<br/>");
$urls = array(); // eo - individual
for ($i = 0; $i < (count($GLOBALS[IPS]) + 3); $i ++) {
$nip = $i;
if ($nip >= count($GLOBALS[IPS])) {
$nip = count($GLOBALS[IPS]) - 1;
}
$urls[$i] = 'http://' . $GLOBALS[IPS][$nip] . '/parsedit.php?immediate&sensor_port=' . ($i - $nip);
$urls[$i] .= '&TRIG_OUT=0x66555' . '&TRIG_CONDITION=0x95555' . '&TRIG_BITLENGTH=31' . '&EXTERN_TIMESTAMP=1' . '&XMIT_TIMESTAMP=1';
}
// print_r($urls); print("<br/>");
// exit(0);
for ($i = 0; $i < count($lwir_ips); $i ++) {
$urls[$i] .= '&TRIG_DELAY=' . $lwir_trig_dly . '&*TRIG_DELAY=15' . // apply to all ports
'&BITS=16&*BITS=15' . '&COLOR=' . $COLOR_RAW . '&*COLOR=15' . '&WOI_HEIGHT=' . ($LWIR_HEIGHT + ($LWIR_TELEMETRY ? $LWIR_TELEMETRY_LINES : 0)) . '&*WOI_HEIGHT=15' . '&' . $REG_FFC_FRAMES . '=' . $FFC_FRAMES . '&*' . $REG_FFC_FRAMES . '=15'; // apply to all channels
$urls[$i] .= '&COMPRESSOR_RUN=2&*COMPRESSOR_RUN=15';
}
if ($debug) {
print_r($GLOBALS[IPS]);
print_r($urls);
}
for ($chn = 0; $chn < 4; $chn ++) {
$urls[count($GLOBALS[IPS]) - 1 + $chn] .=
"&COLOR=" . $COLOR_JP4 .
"&QUALITY=" . $eo_quality .
"&EXPOS=" . $exposure .
"&AUTOEXP_EXP_MAX=" . $autoExposureMax .
"&AUTOEXP_ON=" . $autoExp .
"&GAING=" . $gain .
"&RSCALE=" . $rScale . // "*0".
"&BSCALE=" . $bScale . // "*0".
"&GSCALE=" . $gScale . // "*0". // GB/G ratio
"&WB_EN=" . $autoWB . // "*0".
"&DAEMON_EN_TEMPERATURE=1"; // "*0";
if (lrp . eo_full_window) {
$urls[count($GLOBALS[IPS]) - 1 + $chn] .= "&WOI_LEFT=0" . "&WOI_TOP=0" . "&WOI_WIDTH=2592" . "&WOI_HEIGHT=1936";
}
if ($chn == 0) {
$urls[count($GLOBALS[IPS]) - 1] .= '&COMPRESSOR_RUN=2&*COMPRESSOR_RUN=15';
}
}
if ($debug) {
printf("--- setting camera parameters, urls:\n");
print_r($urls);
}
// print_r($urls);
// exit(0);
$curl_data = curl_multi_start($urls);
$enable_echo = false;
$results3 = curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML)
if ($debug) {
printf("--- results3:\n");
print_r($results3);
}
$results4 = skipFrames($twoIPs, 16,$debug);
// set external trigger mode for all LWIR and EO cameras
$urls = array();
for ($i = 0; $i < count($GLOBALS[IPS]); $i ++) {
$urls[] = 'http://' . $GLOBALS[IPS][$i] .
'/parsedit.php?immediate&sensor_port=0&TRIG=4&*TRIG=15' .
'&COMPRESSOR_RUN=' . $GLOBALS[COMPRESSOR_RUN] . '*5&*COMPRESSOR_RUN=15'; // delay turning off COMPRESSOR_RUN
}
if ($debug) {
printf("--- finally setting camera parameters (see COMPRESSOR_RUN), urls:\n");
print_r($urls);
}
$curl_data = curl_multi_start($urls);
$enable_echo = false;
$results5 = curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML)
if ($debug) {
printf("--- results5:\n");
print_r($results5);
}
$results6 = skipFrames($twoIPs, 16,$debug); // make sure all previous parameters are applied // waits for both LWIR and EO
// second reset after cameras running synchronously
$results7 = resetIPs($GLOBALS[IPS]); // sync channels in each subcamera
$results8 = skipFrames($twoIPs, 16,$debug); // was 2
$results9 = resetIPs($GLOBALS[IPS]); // sync channels in each subcamera
$results10 = skipFrames($twoIPs, 16,$debug); // was 2
$results = $results10;
return $results;
}
function runCapture($run_ffc, $nowait = 0, $debug=0) {
// TODO: use lwir16.ini
// $eo_quality = 97;
// $exposure = 1000; // 1 ms
// $autoExposureMax = 500000;
// $autoExp = 1;
// $gain = 2 * 0x10000;
// $rScale = 1 * 0x10000;
// $bScale = 1 * 0x10000;
// $gScale = 1 * 0x10000;
// $autoWB = 1;
// $extra = 2;
$wait = 1;
if ($nowait) {
$wait = 0;
}
$COLOR_JP4 = 5;
$COLOR_RAW = 15;
$LWIR_HEIGHT = 512;
$LWIR_TELEMETRY_LINES = 1;
$LWIR_TELEMETRY = 1;
$FRAMES_SKIP = 4;
$FFC_FRAMES = 8;
$REG_FFC_FRAMES = 'SENSOR_REGS4'; // Register for the number of FFC frames to integrate
$REG_FFC_RUN = 'SENSOR_REGS26'; // Register to trigger FFC
$lwir_ips = array(
$GLOBALS[IPS][0],
$GLOBALS[IPS][1],
$GLOBALS[IPS][2],
$GLOBALS[IPS][3]
);
$twoIPs = $GLOBALS[IPS]; // array($GLOBALS[IPS][0],$GLOBALS[IPS][4]); wait all
$sensor_port = 0;
if ($debug) {
printf("--- runCapture: run_ffc=%d, wait=%d\n",$run_ffc,$wait);
print_r($lwir_ips);
}
if ($run_ffc){ // may move after measuring time, but need to make sure it will be not too late
runFFC($lwir_ips, $ffc_wait_frames, $debug);
}
$this_frame=elphel_get_frame($sensor_port);
$this_timestamp=elphel_frame2ts($sensor_port,$this_frame);
$timestamp = $this_timestamp + $GLOBALS[PRE_DELAY]; // this will be a delay between capture sequences
$urls = array();
for ($i = 0; $i<count($GLOBALS[IPS]); $i++){
// $_SERVER[SCRIPT_NAME] STARTS WITH '/'
$url = 'http://'.$GLOBALS[IPS][$i].'/capture_range.php?sensor_port='.$sensor_port; //
$url .= '&ts='.$timestamp; // &timestamp" -> ×tamp
$url .= '&port_mask=15'; // .$port_mask[$i];
$dur = ($i < 4) ? $GLOBALS[DURATION] : $GLOBALS[DURATION_EO];
$url .= '&duration='. $dur;
// $url .= '&maxahead='. $maxahead;
// $url .= '&minahead='. $minahead;
$url .= '&extra='. CR_EXTRA; // $extra;
if ($wait && ($i == (count($GLOBALS[IPS]) - 1))){ // addd to the last ip in a list
$url .= '&wait';
}
$urls[] = $url;
}
if ($debug) {
printf("--- runCapture: URLs:\n");
print_r($urls);
}
$curl_data = curl_multi_start ($urls);
$enable_echo = false;
$results = curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML)
return $results;
} }
/* function runFFC($lwir_ips, $ffc_wait_frames, $debug=0) { // return number of frames used
$ffc_groups = 2; // 1/2/4 - do not run FFC on all channels simultaneously (43 failed)
$ffc_frames = 8; // read actual?
$ffc_wait_frames = 10; // extra wait after FFC finished (2xffc_frames)
*/
function runFFC($lwir_ips, $ffc_groups, $ffc_frames, $ffc_wait_frames) { // return number of frames used
$skipped = 0; $skipped = 0;
$port_masks =array(); $port_masks =array();
foreach ($lwir_ips as $l){ foreach ($lwir_ips as $l){
$port_masks[] = 15; // select all 4 ports $port_masks[] = 15; // select all 4 ports
} }
if ($ffc_groups == 1) $group_masks = array(15); if ($GLOBALS[FFC_GROUPS] == 1) $group_masks = array(15);
else if ($ffc_groups == 2) $group_masks = array(5, 10); else if ($GLOBALS[FFC_GROUPS] == 2) $group_masks = array(5, 10);
else $group_masks = array(1, 2, 4, 8); else $group_masks = array(1, 2, 4, 8);
// printf("<!--\n"); if ($debug) {
// printf('$ffc_groups= '.$ffc_groups."\n"); printf('$GLOBALS[FFC_GROUPS]= '.$GLOBALS[FFC_GROUPS]."\n");
// printf('$ffc_frames= '.$ffc_frames."\n"); printf('$GLOBALS[FFC_FRAMES]= '.$GLOBALS[FFC_FRAMES]."\n");
// printf('$ffc_wait_frames='.$ffc_wait_frames."\n"); printf('$ffc_wait_frames='.$ffc_wait_frames."\n");
// print_r($group_masks); print_r($group_masks);
// printf("-->\n"); }
for ($ig = 0; $ig < $ffc_groups; $ig++){ for ($ig = 0; $ig < $GLOBALS[FFC_GROUPS]; $ig++){
$urls = array(); $urls = array();
$ip0 = -1; $ip0 = -1;
for ($i = 0; $i < count($lwir_ips); $i++) { // start urls for 4 of lwir port0 for ($i = 0; $i < count($lwir_ips); $i++) { // start urls for 4 of lwir port0
...@@ -385,17 +482,21 @@ EOT; ...@@ -385,17 +482,21 @@ EOT;
} }
} }
// printf("<!--\n"); if ($debug) {
// printf('$ig= '.$ig."\n"); printf('$ig= '.$ig."\n");
// print_r($urls); print_r($urls);
// printf("-->\n"); }
if ($urls){ // not empty if ($urls){ // not empty
$curl_data = curl_multi_start ($urls); $curl_data = curl_multi_start ($urls);
$enable_echo = false; $enable_echo = false;
$results = curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML) $results = curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML)
} }
$skip_frames = 2 * $ffc_frames + $ffc_wait_frames; $skip_frames = 2 * $GLOBALS[FFC_FRAMES] + $ffc_wait_frames;
skipFrames(array($lwir_ips[$ip0]), $skip_frames); skipFrames(array($lwir_ips[$ip0]), $skip_frames);
if ($debug) {
printf("FFC done, result:\n");
print_r($results);
}
} }
return $skipped; // better read actual frame after return $skipped; // better read actual frame after
} }
...@@ -404,7 +505,7 @@ EOT; ...@@ -404,7 +505,7 @@ EOT;
// define("REG_FFC_RUN", "SENSOR_REGS26"); // Register to trigger FFC // define("REG_FFC_RUN", "SENSOR_REGS26"); // Register to trigger FFC
function resetIPs($ips) { function resetIPs($ips,$debug=0) {
$frame = -2; // skip 2 frames before reset $frame = -2; // skip 2 frames before reset
$urls = array(); $urls = array();
for ($i = 0; $i<count($ips); $i++){ for ($i = 0; $i<count($ips); $i++){
...@@ -412,24 +513,388 @@ EOT; ...@@ -412,24 +513,388 @@ EOT;
$url = 'http://'.$ips[$i].'/'.SCRIPT_RESET.'?frame='.$frame; // $url = 'http://'.$ips[$i].'/'.SCRIPT_RESET.'?frame='.$frame; //
$urls[] = $url; $urls[] = $url;
} }
// printf("<!--\n"); if ($debug) {
// print_r($urls); printf("--- resetIPs(), urls=\n");
// printf("-->\n"); print_r($urls);
}
$curl_data = curl_multi_start ($urls); $curl_data = curl_multi_start ($urls);
$enable_echo = false; $enable_echo = false;
return curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML) return curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML)
} }
function skipFrames($ips,$skip) { function skipFrames($ips, $skip, $debug=0) {
$urls = array(); $urls = array();
for ($i = 0; $i<count($ips); $i++){ for ($i = 0; $i<count($ips); $i++){
// $url = 'http://'.$ips[$i].$_SERVER[SCRIPT_NAME].'?frame='.$frame; // // $url = 'http://'.$ips[$i].$_SERVER[SCRIPT_NAME].'?frame='.$frame; //
$url = 'http://'.$ips[$i].'/'.SCRIPT_WAIT.'?frame='.(-$skip); // $url = 'http://'.$ips[$i].'/'.SCRIPT_WAIT.'?frame='.(-$skip); //
$urls[] = $url; $urls[] = $url;
} }
if ($debug) {
printf("--- skipFrames(%d), urls=\n",$skip);
print_r($urls);
}
$curl_data = curl_multi_start ($urls); $curl_data = curl_multi_start ($urls);
$enable_echo = false; $enable_echo = false;
return curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML) return curl_multi_finish($curl_data, true, 0, $enable_echo); // Switch true -> false if errors are reported (other output damaged XML)
} }
function lwir16_daemon() {
// ini parameters are already read in
declare(ticks = 1);
set_time_limit(0); // no limit - run forever
pcntl_signal(SIGTERM, "signal_handler");
pcntl_signal(SIGINT, "signal_handler");
if(file_exists(PIPE_CMD)){
unlink(PIPE_CMD); //delete pipe if it was already there - waiting prevents signal handling!
}
$GLOBALS[DAEMON_RUN] = 1;
$GLOBALS[CAPTURE_RUN] = 0; // until command
$GLOBALS[LAST_FFC] = 0; // overdue
$GLOBALS[SECUENCE_NUM] = 0;
if ($GLOBALS[DEBUG > 1]) {
printf("--- GLOBALS: ---\n");
print_r($GLOBALS);
}
// exit(0);
$from_pipe = false; // first commands are form INI
while ($GLOBALS[DAEMON_RUN]){
if (isset($GLOBALS[DAEMON_CMD])){ // execute command (INIT, RUN, STOP)
$commands = explode(',',$GLOBALS[DAEMON_CMD]);
unset($GLOBALS[DAEMON_CMD]);
if ($GLOBALS[DEBUG]) {
printf("--- executing commands: ---\n");
print_r($commands);
}
foreach($commands as $cmd){
if ($cmd == CMD_INIT){
if ($GLOBALS[DEBUG]) printf("--- got command: INIT ---\n");
$result = runInit($GLOBALS[DEBUG]); // debug
if ($GLOBALS[DEBUG]){
printf("--- command: INIT done, result ---\n");
print_r($result);
}
} else if ($cmd == CMD_START){
$GLOBALS[CAPTURE_RUN] = 1;
} else if ($cmd == CMD_STOP){
$GLOBALS[CAPTURE_RUN] = 0;
} else if ($from_pipe && ($cmd == CMD_STATUS)){ // generate status data and send over response pipe
$state = file('/var/state/camera');
//TODO: add daemon status itself
$xml = new SimpleXMLElement("<?xml version='1.0' standalone='yes'?><lwir16_status/>");
$xml_state = $xml->addChild ('state');
foreach ($state as $line){
$kv = explode('=',$line);
if (count ($kv) > 1){
$xml_state->addChild (trim($kv[0]),trim($kv[1]));
}
}
$xml->addChild (SECUENCE_NUM, $GLOBALS[SECUENCE_NUM]);
if ($GLOBALS[FFC]) {
$GLOBALS[TIME_TO_FFC] = $GLOBALS[LAST_FFC] + $GLOBALS[FFC_PERIOD] - time();
$xml->addChild (TIME_TO_FFC, $GLOBALS[TIME_TO_FFC]);
}
$xml->addChild (IPS, implode(',',$GLOBALS[IPS]));
$xml->addChild (DURATION, $GLOBALS[DURATION]);
$xml->addChild (DURATION_EO, $GLOBALS[DURATION_EO]);
$xml->addChild (PRE_DELAY, $GLOBALS[PRE_DELAY]);
$xml->addChild (FFC, $GLOBALS[FFC]);
$xml->addChild (FFC_PERIOD, $GLOBALS[FFC_PERIOD]);
$xml->addChild (FFC_GROUPS, $GLOBALS[FFC_GROUPS]);
$xml->addChild (FFC_FRAMES, $GLOBALS[FFC_FRAMES]);
$xml->addChild (COMPRESSOR_RUN, $GLOBALS[COMPRESSOR_RUN]);
$xml->addChild (DEBUG, $GLOBALS[DEBUG]);
$xml->addChild (DAEMON_RUN, $GLOBALS[DAEMON_RUN]);
$xml->addChild (CAPTURE_RUN, $GLOBALS[CAPTURE_RUN]);
$xml->addChild (LAST_FFC, $GLOBALS[LAST_FFC]);
$rslt=$xml->asXML();
if(!file_exists(PIPE_RESPONSE)) {
// create the pipe
umask(0);
posix_mkfifo(PIPE_RESPONSE,PIPE_MODE);
}
$fr = fopen(PIPE_RESPONSE,"w");
fwrite($fr,$rslt);
fclose ($fr);
if ($GLOBALS[DEBUG]){
printf('--- command: Sent status report ---\n');
printf($rslt);
}
} else if ($cmd == CMD_EXIT){
$GLOBALS[CAPTURE_RUN] = 0;
unset($GLOBALS[DAEMON_RUN]);
continue;
} else if ($cmd == CMD_REBOOT){
exec ( 'autocampars.py ['.implode(',',$GLOBALS[IPS]).'] pyCmd reboot', $output, $retval );
exit(0);
}
}
continue; // try read new commands befor capturing
}
// Read / execute commands
if(file_exists(PIPE_CMD)) {
if ($GLOBALS[DEBUG]){
printf("--- got from pipe: ---\n");
}
/*
$f = fopen(PIPE_CMD,"r");
if ($GLOBALS[DEBUG]) echo "(r) opened cmd\n";
$cmd_lines = fgets($f);
fclose ($f);
*/
$cmd_lines = file_get_contents(PIPE_CMD);
if ($GLOBALS[DEBUG]) echo $cmd_lines."\n";
if ($GLOBALS[DEBUG]) echo "(r) closed cmd\n";
unlink(PIPE_CMD); //delete pipe
$ini = parse_ini_string($cmd_lines); // parse_ini_file(PIPE_CMD); does not work!
if ($GLOBALS[DEBUG]){
print_r($ini);
}
unset ($GLOBALS[DAEMON_CMD]);
applyConf ($ini); // update $GLOBALS
$from_pipe = true;
if ($GLOBALS[DEBUG] > 1){
printf("--- update GLOBALS: ---\n");
print_r($GLOBALS);
}
continue; // will execute commands
}
if ($GLOBALS[DEBUG] > 1){
printf("--- capture_run: ---%d \n",$GLOBALS[CAPTURE_RUN]);
}
if ($GLOBALS[CAPTURE_RUN]){
$ffc_due = $GLOBALS[LAST_FFC] + $GLOBALS[FFC_PERIOD];
$run_ffc = false;
$now = time();
if ($GLOBALS[FFC] && ($now > $ffc_due)){
$run_ffc = true;
$GLOBALS[LAST_FFC] = $now;
}
$result = runCapture($run_ffc, false, $GLOBALS[DEBUG]);
$GLOBALS[SECUENCE_NUM]++;
if ($GLOBALS[DEBUG] > 1){
printf("--- capture_run: ---\n");
print_r($result);
}
} else {
// jusrt skip a frame
$ips0 = array($GLOBALS[IPS][0]); // just master camera IP
$skip = 10; // OK if more
$rslt = skipFrames($ips0,$skip);
}
}
if ($GLOBALS[DEBUG]){
printf("--- Exiting ...\n");
if ($GLOBALS[DEBUG]>1){
print_r($GLOBALS);
}
}
}
function signal_handler($signal) {
switch($signal) {
case SIGTERM:
print "Caught SIGTERM\n";
$GLOBALS[DAEMON_RUN] = 0;
return; // exit;
case SIGKILL:
print "Caught SIGKILL\n";
$GLOBALS[DAEMON_RUN] = 0;
return; // exit;
case SIGINT:
print "Caught SIGINT\n";
$GLOBALS[DAEMON_RUN] = 0;
return; // exit;
}
}
function applyConf($arr){
if (isset($arr[IPS])) $GLOBALS[IPS] = explode(',',$arr[IPS]);
if (isset($arr[DURATION])){
$GLOBALS[DURATION] = (int) $arr[DURATION];
$GLOBALS[DURATION_EO] = (int) ($GLOBALS[DURATION]/EO_DECIMATE+1);
}
if (isset($arr[DURATION_EO])) $GLOBALS[DURATION_EO] = (int) $arr[DURATION_EO];
if (isset($arr[PRE_DELAY])) $GLOBALS[PRE_DELAY] = (double) $arr[PRE_DELAY];
if (isset($arr[FFC_PERIOD])) $GLOBALS[FFC_PERIOD] = (double) $arr[FFC_PERIOD];
if (isset($arr[FFC_GROUPS])) $GLOBALS[FFC_GROUPS] = (int) $arr[FFC_GROUPS];
if (isset($arr[FFC_FRAMES])) $GLOBALS[FFC_FRAMES] = (int) $arr[FFC_FRAMES];
if (isset($arr[DAEMON_CMD])) $GLOBALS[DAEMON_CMD] = $arr[DAEMON_CMD];
if (isset($arr[DEBUG])) $GLOBALS[DEBUG] = (int) $arr[DEBUG];
if (isset($arr[COMPRESSOR_RUN])) $GLOBALS[COMPRESSOR_RUN] = (int) $arr[COMPRESSOR_RUN]; // only after INIT
if (isset($arr[FFC])) $GLOBALS[FFC] = $arr[FFC]?true:false; // only after INIT
}
/**
* start/stop/restart/status/pars daemon
*
* @param string $cmd
*/
function daemon_control($cmd)
{
/*
echo "<pre>\n";
print_r($_SERVER);
echo "</pre>\n";
exit(0);
*/
// see if it already running
$max_wait = 10; // seconds
// $sript_name = substr($_SERVER['SCRIPT_NAME'], 1); // remove leading '/'
$sript_path = $_SERVER['SCRIPT_FILENAME'];
$sript_name = basename($sript_path);
$pids = getPIDByName($sript_name, 'php', $active_only = false);
// Stop if needed
if ($pids && (($cmd == 'restart') || ($cmd == 'stop'))) {
$mode = 0600;
if (! file_exists(PIPE_CMD)) {
// create the pipe
umask(0);
posix_mkfifo(PIPE_CMD, $mode);
}
$f = fopen(PIPE_CMD, "w+"); // make it non-blocking as the receiver may be hang
fwrite($f, "CMD=EXIT");
fclose($f);
for ($i = 0; $i < $max_wait; $i ++) {
$pids = getPIDByName($sript_name, 'php', $active_only = false);
if (! $pid)
break;
}
if ($pids) { // did not exit
foreach ($pids as $proc) {
exec('kill -9 ' . $proc['pid'], $output, $retval);
}
}
}
$pids = getPIDByName($sript_name, 'php', $active_only = false);
if (!$pids && ($cmd != 'stop')) {
exec($sript_path . ' > /dev/null 2>&1 &'); // "> /dev/null 2>&1 &" makes sure it is really really run as a background job that does not wait for input
// wait it to run
for ($i = 0; $i < $max_wait; $i ++) {
$pids = getPIDByName($sript_name, 'php', $active_only = false);
if ($pid) break;
}
}
if (($cmd == 'restart') || ($cmd == 'start') || ($cmd == 'stop') || !pids) { // nothing else to do if it is not running
// just respond with $pids xml
$xml = new SimpleXMLElement("<?xml version='1.0' standalone='yes'?><lwir16_daemon_status/>");
if ($pids) {
/*
echo "<pre>\n";
print_r($pids);
echo "</pre>\n";
exit(0);
*/
foreach ($pids[0] as $key => $value) {
if (is_array($value)){
$xml_arr= $xml->addChild($key);
for ($i = 0; $i < count($value); $i++) {
$xml_arr->addChild($key.$i, $value[$i]);
}
// $value = serialize($value);
} else {
$xml->addChild($key, $value);
}
}
if (count($pids) > 1) { // abnormal
$arr = array();
for ($i = 1; $i < count($pids); $i ++) {
$arr[] = $pids[$i]['pid'];
}
$xml->addChild('other_pids', implode(',', $arr));
}
} else {
$xml->addChild($sript_name, 'not running');
}
$rslt=$xml->asXML();
header("Content-Type: text/xml");
header("Content-Length: ".strlen($rslt)."\n");
header("Pragma: no-cache\n");
printf($rslt);
exit(0);
}
// process other commands (all but status are 'silent'
$parameters = array();
unset ($daemon_cmds);
foreach($_GET as $key=>$value) {
if ($key != DAEMON_CTRL){ // already processed
if (($key == DAEMON_CTRL_CMDS) || ($key == DAEMON_CMD)){ // CMD/cmd confusion
$daemon_cmds = $value;
} else {
$parameters[$key]= $value;
}
}
}
if ($cmd == 'status'){
if (!isset($daemon_cmds)){
$daemon_cmds=CMD_STATUS;
} else if (strstr($daemon_cmds,CMD_STATUS) === false){
$daemon_cmds .= ','.CMD_STATUS;
}
}
$cmds_to_send = "";
foreach ($parameters as $key=>$value){
$cmds_to_send .= sprintf("%s = %s\n",$key,$value);
}
$cmds_to_send .= sprintf("%s = %s\n",DAEMON_CMD,$daemon_cmds);
$has_status= strstr($daemon_cmds,CMD_STATUS) !== false;
$mode=0600;
if(!file_exists(PIPE_CMD)) {
// create the pipe
umask(0);
posix_mkfifo(PIPE_CMD,$mode);
}
if (file_exists(PIPE_RESPONSE)){
unlink(PIPE_RESPONSE); //delete old pipe
}
/*
echo "<pre>\n";
print_r($cmds_to_send);
echo 'has_status='.$has_status."\n";
echo 'daemon_cmds='.$daemon_cmds."\n";
echo "parameters\n";
print_r($parameters);
echo "</pre>\n";
exit(0);
*/
$f = fopen(PIPE_CMD,"w");
fwrite($f,$cmds_to_send);
// echo "(w) sent commands:\n".$cmds."\n";
fclose ($f);
// echo "(w) closed\n";
if ($has_status) {
while (!file_exists(PIPE_RESPONSE)); // just wait
// echo "(w) got PIPE_RESPONSE\n";
$rslt = file_get_contents(PIPE_RESPONSE);
// var_dump($fl);
unlink(PIPE_RESPONSE); //delete pipe
header("Content-Type: text/xml");
header("Content-Length: ".strlen($rslt)."\n");
header("Pragma: no-cache\n");
printf($rslt);
exit(0);
} else {
$xml = new SimpleXMLElement("<?xml version='1.0' standalone='yes'?><lwir16_daemon_input/>");
foreach ($parameters as $key => $value) {
$xml->addChild($key, $value);
}
if ($daemon_cmds) {
$xml->addChild(DAEMON_CMD, $daemon_cmds);
}
$rslt=$xml->asXML();
header("Content-Type: text/xml");
header("Content-Length: ".strlen($rslt)."\n");
header("Pragma: no-cache\n");
printf($rslt);
exit(0);
}
}
?> ?>
\ No newline at end of file
src/lwir16/test_int.php 0 → 100755
View file @ 620a1357
#!/usr/bin/php
<?php
set_include_path ( get_include_path () . PATH_SEPARATOR . '/www/pages/include' );
include 'show_source_include.php';
include "elphel_functions_include.php"; // includes curl functions
$pipe_cmd="/tmp/pipe_cmd";
$pipe_response="/tmp/pipe_response";
$mode=0600;
declare(ticks = 1);
pcntl_signal(SIGTERM, "signal_handler");
pcntl_signal(SIGINT, "signal_handler");
function signal_handler($signal) {
switch($signal) {
case SIGTERM:
print "Caught SIGTERM\n";
exit;
case SIGKILL:
print "Caught SIGKILL\n";
exit;
case SIGINT:
print "Caught SIGINT\n";
exit;
}
}
if(file_exists($pipe_cmd)){
unlink($pipe_cmd); //delete pipe if it was already there - waiting prevents signal handling!
}
while(1) {
if(file_exists($pipe_cmd)) {
//block and read from the pipe
$f = fopen($pipe_cmd,"r");
echo "(r) opened cmd\n";
$l = fgets($f);
fclose ($f);
echo "(r) closed cmd\n";
unlink($pipe_cmd); //delete pipe
echo "(r) deleted cmd\n";
if(!file_exists($pipe_response)) {
// create the pipe
umask(0);
posix_mkfifo($pipe_response,$mode);
}
$fr = fopen($pipe_response,"w");
fwrite($fr,"response1: ".$l);
fwrite($fr,"response2: ".$l);
fwrite($fr,"response3: ".$l);
echo "(r) sent responses\n";
sleep(1);
fclose ($fr);
echo "(r) closed response pipe\n";
}
//
}
?>
src/lwir16/test_ps.php 0 → 100644
View file @ 620a1357
#!/usr/bin/php
<?php
print_r($argv);
set_include_path ( get_include_path () . PATH_SEPARATOR . '/www/pages/include' );
include 'show_source_include.php';
include "elphel_functions_include.php"; // includes curl functions
$name = 'test_ps.php'; // int.php';
$interpreter='php';
echo "\n--------- interpreter=$interpreter, name = $name ----------\n";
$arr = getPIDByName($name, $interpreter, $active_only=false);
// var_dump($arr);
print_r($arr);
$name = 'test_ps.php'; // 'php-cgi';
$interpreter='';
echo "\n--------- interpreter=$interpreter, name = $name ----------\n";
$arr = getPIDByName($name, $interpreter, $active_only=false);
// var_dump($arr);
print_r($arr);
$interpreter='python';
$name = 'tempmon.py';
echo "\n--------- interpreter=$interpreter, name = $name ----------\n";
$arr = getPIDByName($name, $interpreter, $active_only=false);
// var_dump($arr);
print_r($arr);
?>
src/lwir16/test_wpipe.php 0 → 100755
View file @ 620a1357
#!/usr/bin/php
<?php
define('PIPE_CMD', '/tmp/pipe_cmd');
define('PIPE_RESPONSE', '/tmp/pipe_response');
define('PIPE_MODE', 0600);
set_include_path ( get_include_path () . PATH_SEPARATOR . '/www/pages/include' );
include 'show_source_include.php';
include "elphel_functions_include.php"; // includes curl functions
$cmd = 'STATUS';
$kw = 'CMD';
if (count($argv) > 2){
$kw = $argv[1];
$cmd = $argv[2];
} else if (count($argv) > 1){
$cmd = $argv[1];
}
$mode=0600;
if(!file_exists(PIPE_CMD)) {
// create the pipe
umask(0);
posix_mkfifo(PIPE_CMD,$mode);
}
if (file_exists(PIPE_RESPONSE)){
unlink(PIPE_RESPONSE); //delete old pipe
}
$f = fopen(PIPE_CMD,"w");
// sleep(1);
$cmds = $kw.' = '.$cmd."\n";
fwrite($f,$cmds);
// sleep (1);
echo "(w) sent commands:\n".$cmds."\n";
fclose ($f);
// sleep(1);
echo "(w) closed\n";
if ($cmd == 'STATUS') {
while (!file_exists(PIPE_RESPONSE)); // just wait
echo "(w) got PIPE_RESPONSE\n";
$fl = file(PIPE_RESPONSE);
var_dump($fl);
unlink(PIPE_RESPONSE); //delete pipe
}
?>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment