Monitoring Main Control Interface

Eventbuilder

Trigger

Triggerbox
Beam Abort

Wall

Forward Wall Rates
Forward Wall HV
Forward Wall HV Currents

Environment

All available options

Please prefer the links above, use this only if there is no proper link in the lists above."; my @o = qx(ls -1 files/*.htt); foreach my $a (@o) { if ($a =~ m%files/(\w+).htt%) { diff --git a/hmon/monitor.cgi b/hmon/monitor.cgi index 7cef534..10ac4e4 100755 --- a/hmon/monitor.cgi +++ b/hmon/monitor.cgi @@ -23,7 +23,7 @@ my @args = split('-',$ENV{'QUERY_STRING'}); $newurl =~ /(-|^|\?)(\w+)$/; my $width; my $height; - print $geom; + #print $geom; if($geom && $geom ne '' && $geom =~ /(\d+)x(\d+)/) { $width = 80*$1-8; $height = 50*$2-8; @@ -33,23 +33,25 @@ my @args = split('-',$ENV{'QUERY_STRING'}); my $str = <$MYF>; close($MYF); $str =~ /width(\d+)\sheight(\d+)/; - $width = 80*$1-6; + $width = 80*$1-4; $height = 50*$2+2; } - $out = qq$ + +# $out = qq$ +$out = qq$ -Hmon +Hmon - + $; } $out .= qq$ diff --git a/hmon/permanent/hmon_beamabort.pl b/hmon/permanent/hmon_beamabort.pl index a022d3f..d23f724 100755 --- a/hmon/permanent/hmon_beamabort.pl +++ b/hmon/permanent/hmon_beamabort.pl @@ -8,23 +8,26 @@ use Data::Dumper; use POSIX qw/floor ceil/; use Hmon; use QA; -use Perl2Epics; +use Perl2Epics2; +#JAM 22-nov-23- use local perl2epics installation on hades33 instead of lxhadesdaq installation my $fqa = QA::OpenQAFile(); my @res; my @oldres= ("R22222222 #20", "R22222222 #21", "R22222222 #30", "R22222222 #22"); -my $cmd = 'ssh hadaq@hadeswrp02 "~/bin/readreg.sh"'; +#my $cmd = 'ssh hadaq@hadeswrp02 "~/bin/readreg.sh"'; +# JAM 22-11-23: enable above line if spare machine is used +my $cmd = 'ssh hadaq@hadeswrp01 "~/bin/readreg.sh"'; my $longtext; my $value = ""; my $qastate; my $laststate = QA::ERROR; my $iterator = 0; -Perl2Epics::Connect("fpga", "HAD:BEAM:beamAbort:status:FPGA"); -Perl2Epics::Connect("soft", "HAD:BEAM:beamAbort:status:soft"); -Perl2Epics::Connect("hard", "HAD:BEAM:beamAbort:status:hard"); -Perl2Epics::Connect("latch", "HAD:BEAM:beamAbort:status:latch"); -Perl2Epics::Connect("iterator", "HAD:BEAM:beamAbort:status:filler"); +Perl2Epics2::Connect("fpga", "HAD:BEAM:beamAbort:status:FPGA"); +Perl2Epics2::Connect("soft", "HAD:BEAM:beamAbort:status:soft"); +Perl2Epics2::Connect("hard", "HAD:BEAM:beamAbort:status:hard"); +Perl2Epics2::Connect("latch", "HAD:BEAM:beamAbort:status:latch"); +Perl2Epics2::Connect("iterator", "HAD:BEAM:beamAbort:status:filler"); while (1) { @@ -63,13 +66,13 @@ while (1) { $longtext .= "none" if (substr($res[3],3,1) ne "1"); $longtext .= "ABORTED" if (substr($res[3],3,1) eq "1"); - $value = "inactive" if $longtext =~ /inactive/; $value = "ABORT" if $longtext =~ /ABORT/; $value = "ABORTED" if $longtext =~ /ABORTED/; + $value = "inactive" if $longtext =~ /inactive/; $qastate = QA::WARN if $longtext =~ /inactive/; - $qastate = QA::WARN_2 if $longtext =~ /Soft\sOverride:\sinactive/; $qastate = QA::FATAL if $longtext =~ /ABORT/; $qastate = QA::ERROR if $longtext =~ /ABORTED/; + $qastate = QA::WARN_2 if $longtext =~ /Soft\sOverride:\sinactive/; # EPICS part @@ -79,27 +82,27 @@ while (1) { # || substr($res[3],3,1) ne substr($oldres[3],3,1) # ) { # print substr($res[0],5,2)." ".substr($res[2],7,2)." ".substr($res[0],7,2)." ".substr($res[3],3,1); - Perl2Epics::Put("fpga",0) if substr($res[0],5,2) eq "11"; - Perl2Epics::Put("fpga",1) if substr($res[0],5,2) eq "01" || substr($res[0],5,2) eq "10"; - Perl2Epics::Put("fpga",2) if substr($res[0],5,2) eq "00"; + Perl2Epics2::Put("fpga",0) if substr($res[0],5,2) eq "11"; + Perl2Epics2::Put("fpga",1) if substr($res[0],5,2) eq "01" || substr($res[0],5,2) eq "10"; + Perl2Epics2::Put("fpga",2) if substr($res[0],5,2) eq "00"; - Perl2Epics::Put("soft",0) if substr($res[2],7,2) eq "10"; - Perl2Epics::Put("soft",1) if substr($res[2],7,2) eq "00"; - Perl2Epics::Put("soft",2) if substr($res[2],8,1) eq "1"; + Perl2Epics2::Put("soft",0) if substr($res[2],7,2) eq "10"; + Perl2Epics2::Put("soft",1) if substr($res[2],7,2) eq "00"; + Perl2Epics2::Put("soft",2) if substr($res[2],8,1) eq "1"; - Perl2Epics::Put("hard",0) if substr($res[0],7,2) eq "10"; - Perl2Epics::Put("hard",1) if substr($res[0],7,2) eq "00"; - Perl2Epics::Put("hard",2) if substr($res[0],8,1) eq "1"; + Perl2Epics2::Put("hard",0) if substr($res[0],7,2) eq "10"; + Perl2Epics2::Put("hard",1) if substr($res[0],7,2) eq "00"; + Perl2Epics2::Put("hard",2) if substr($res[0],8,1) eq "1"; - Perl2Epics::Put("latch",1) if substr($res[3],3,1) ne "1"; - Perl2Epics::Put("latch",2) if substr($res[3],3,1) eq "1"; - Perl2Epics::Update(0.2); + Perl2Epics2::Put("latch",1) if substr($res[3],3,1) ne "1"; + Perl2Epics2::Put("latch",2) if substr($res[3],3,1) eq "1"; + Perl2Epics2::Update(0.2); # } } if($iterator == 1) { - my $curr_it = Perl2Epics::Get("iterator"); - Perl2Epics::Put("iterator",$curr_it+1); + my $curr_it = Perl2Epics2::Get("iterator"); + Perl2Epics2::Put("iterator",$curr_it+1); $iterator = 0; } diff --git a/hmon/permanent/hmon_caveTemp.pl b/hmon/permanent/hmon_caveTemp.pl index 46e2e71..e63ed97 100755 --- a/hmon/permanent/hmon_caveTemp.pl +++ b/hmon/permanent/hmon_caveTemp.pl @@ -28,9 +28,9 @@ my $plotShort = { xlabel => "Minutes", ylabel => "Temperature / Â°C", sizex => 950, - sizey => 360, - ymin => "15", - ymax => "25<*", + sizey => 340, + # ymin => "15", + ymax => "25<*<35", curves => 3, xscale => 60/10, storable=> 1, @@ -50,9 +50,9 @@ my $plotLong = { xlabel => "Hours", ylabel => "Temperature / Â°C", sizex => 950, - sizey => 360, - ymin => "15", - ymax => "25<*", + sizey => 340, + # ymin => "15", + ymax => "25<*<35", curves => 3, xscale => 60, storable=> 1, diff --git a/hmon/permanent/hmon_cpu.pl b/hmon/permanent/hmon_cpu.pl index c907580..8fdff7c 100755 --- a/hmon/permanent/hmon_cpu.pl +++ b/hmon/permanent/hmon_cpu.pl @@ -32,7 +32,7 @@ my $fqa = QA::OpenQAFile(); # JAM 6.1.2020 - for the moment exlude hosts depcp418 and lxhaddcs03 not available # MT 2022.02.09 - all to internal HADES-VLAN CPU-names -my @srv = qw( lxhadeb08p lxhadeb09p lxhadeb10p lxhadeb11p lxhadeb12p lxhadeb14p lxhadeb15p lxhadeb16p lxhadeb17p lxhadeb18p lxhadesdaqp lxhadeb13p lxhaddcs10p lxhaddcs11p lxhaddcs12p lxhaddcs13p hadesdaqp03 hadesdaqp04 hadesp30 hadesp57 hadesp31 hadesp33 hadesp63 hadesp66 hadesp70); +my @srv = qw( lxhadeb08p lxhadeb09p lxhadeb10p lxhadeb11p lxhadeb12p lxhadeb14p lxhadeb15p lxhadeb16p lxhadeb17p lxhadeb18p lxhadesdaqp lxhadeb13p lxhaddcs10p lxhaddcs11p lxhaddcs12p lxhaddcs13p hadesdaqp03 hadesdaqp04 hadesp57 hadesp31 hadesp33 hadesp63 hadesp66 hadesp67 hadesp69 hadesp70); my $template .= "\n\n
"; for(my $d=1;$d<=32;$d++) { @@ -44,8 +44,14 @@ while(1) { $laststore = clone($store); $store = {}; for(my $n=0;$n< scalar @srv;$n++) { - print "$srv[$n]\n"; - my @out = Hmon::qxtimeout("ssh $srv[$n] \"cat /proc/stat \" {0}->{0}->{'idle'}) { - $str = Hmon::MakeTitle(9,14,"Server CPU Usage"); + $str = Hmon::MakeTitle(9,15,"Server CPU Usage"); $str .= $template; for(my $s = 0; $s < scalar @srv; $s++) { $str .= "\n
$srv[$s]"; diff --git a/hmon/permanent/hmon_eb_run.pl b/hmon/permanent/hmon_eb_run.pl index 9a5be6b..c97533d 100755 --- a/hmon/permanent/hmon_eb_run.pl +++ b/hmon/permanent/hmon_eb_run.pl @@ -366,7 +366,7 @@ while (1) { if ($opt_debug<1) { - Hmon::Speak('ebrun',"Eventbuilder Error") if $qastate > 60; + Hmon::Speak('ebrun',"Event builder Error") if $qastate > 60; QA::WriteQALog($fqa, "eb", "run", 10, $qastate, $qatitle, "i:$num_act_ins, b:$num_act_build ($prefix)", $qamsg); } else { @@ -434,7 +434,7 @@ while (1) { if($speak_counter>20) { $speak_counter=-20; - Hmon::Speak('ebfiles', "event builders do not write files to disk.") unless $opt_debug>0 ||($masterstate =~ /NoNodes/); + Hmon::Speak('ebfiles', "Event building not writing files to disk.") unless $opt_debug>0 ||($masterstate =~ /NoNodes/); print "No files are written by eventbuilders.\n" unless $opt_debug<1; } } diff --git a/hmon/permanent/hmon_ebdiskfill.pl b/hmon/permanent/hmon_ebdiskfill.pl index 69f6d61..7ff4de1 100755 --- a/hmon/permanent/hmon_ebdiskfill.pl +++ b/hmon/permanent/hmon_ebdiskfill.pl @@ -27,9 +27,9 @@ $max = 0; my $str; while (1) { $maxqa = 0; - $str = Hmon::MakeTitle(8,6,"Eventbuilder Disk Fill Level"); + $str = Hmon::MakeTitle(2,6,"Eventbuilder Disk Fill Level"); $str .= "\n
"; - for (my $d=1;$d<=15;$d++) { + for (my $d=1;$d<=1;$d++) { $str .= " $d"; } for (my $n=8;$n<=18;$n++) { @@ -49,7 +49,7 @@ while (1) { } } $str .= "\n
$hostn"; - for (my $d=1;$d<=15;$d++) { + for (my $d=1;$d<=1;$d++) { my $id = $d; $id = '0'.$d if $d<10; $store->{$n}->{$id} = 0 unless exists $store->{$n}->{$id}; diff --git a/hmon/permanent/hmon_ecalhv.pl b/hmon/permanent/hmon_ecalhv.pl index c196295..298caf1 100755 --- a/hmon/permanent/hmon_ecalhv.pl +++ b/hmon/permanent/hmon_ecalhv.pl @@ -16,7 +16,7 @@ use HPlot; my $flog = QA::OpenQAFile(); my @colors = ("#333333","#00ff00","#ff0000","#0000ff","#dddd00","#dd00dd"); -my $TOTALCHANS = 815; +my $TOTALCHANS = 1008; for my $i (0..5) { HPlot::PlotInit( { @@ -171,7 +171,7 @@ while(1) { my $min_i = -1E5; my $max_i = 1E5; my $ChnlsOn = 0; - my $data = Perl2Epics::GetAll(); + my $data = Perl2Epics::GetAll(3); for(my $i = 0; $i <=5; $i++) { for(my $j = 0; $j<=167; $j++) { @@ -411,5 +411,5 @@ while(1) { } } - usleep(2500000); +# usleep(2500000); } diff --git a/hmon/permanent/hmon_fwhv.pl b/hmon/permanent/hmon_fwhv.pl index 7fe1336..1907868 100755 --- a/hmon/permanent/hmon_fwhv.pl +++ b/hmon/permanent/hmon_fwhv.pl @@ -184,8 +184,8 @@ while(1) { $longtext .= "
".$str; $qastate = QA::GetQAState('above', $ChnlsOn, @QA::FwHvLimits); - if ($ChnlsOn == 0){ $qastate = QA::WARN_2; $value = "OFF";} if ($ChnlsOld >= 0) { $qastate = QA::WARN_2;} + if ($ChnlsOn <= 2){ $qastate = QA::ERROR; $value = "OFF";} if ($QA::FwHvOff == 1) { $qastate = QA::OK;} diff --git a/hmon/permanent/hmon_mdcpressure.pl b/hmon/permanent/hmon_mdcpressure.pl index fb19d7e..6e809dd 100755 --- a/hmon/permanent/hmon_mdcpressure.pl +++ b/hmon/permanent/hmon_mdcpressure.pl @@ -12,6 +12,7 @@ use Perl2Epics; use HPlot; my $fqa = QA::OpenQAFile(); +$ENV{EPICS_CA_AUTO_ADDR_LIST} = 'YES'; my @names = qw( reflowPressureAthm:average reflowPressureCompr reflowInO2 opensysFreshARGON opensysFreshCO2 reflowFreshArgon reflowFreshIsob CO2:concentration CO2:concentration2 reflowPressureLP ); my @namesLABEL = qw( AtmosphericPressure reflowPressureCompressor reflow_O2_concentration planeI_argon_fresh planeI_CO2_frsh reflowFreshArgon reflowFreshCO2 CO2-P1 CO2-P2 LP-pressure ); @@ -269,7 +270,7 @@ Perl2Epics::Connect("Gate" ,"HAD:VAC:beamlineGate"); print "Connected.\n"; while(1) { - my $data = Perl2Epics::GetAll(); + my $data = Perl2Epics::GetAll(10); $str = Hmon::MakeTitle(8, 22, "MDC Gas Pressure", 1, ""); $str .= "
Chamber differential pressure [Pa]
\n"; $str .= "\n"; #
@@ -377,7 +378,7 @@ while(1) { HPlot::PlotDraw("VacuumLow"); HPlot::PlotDraw("VacuumHigh"); - $str = Hmon::MakeTitle(8,12,"Vacuum",0); + $str = Hmon::MakeTitle(8,12,"Vacuum",1); $str .= qq@\n@; $str .= qq@
@; $str .= sprintf("Low Vacuum %.2fE-7 mbar
",$data->{"Vaclow"}->{val}*1E7); @@ -402,7 +403,7 @@ while(1) { if ($data->{"Gate"}->{tme}==-1) { $msg="ERROR"; $longmsg.="
No Data"; - $qastat = QA::WARN_2; + $qastat = QA::ERROR; } elsif ($data->{"Gate"}->{val}!=1) { $msg="ERROR"; @@ -410,10 +411,9 @@ while(1) { $qastat = QA::ERROR; } - QA::WriteQALog($fqa, "hv2", "valve", 60, $qastat, "Vacuum", $msg, $longmsg); + QA::WriteQALog($fqa, "misc", "valve", 60, $qastat, "Vacuum", $msg, $longmsg); $timer++; - sleep(10); } diff --git a/hmon/permanent/hmon_open_ssh_master_channels.pl b/hmon/permanent/hmon_open_ssh_master_channels.pl index 9b5f169..fac0789 100755 --- a/hmon/permanent/hmon_open_ssh_master_channels.pl +++ b/hmon/permanent/hmon_open_ssh_master_channels.pl @@ -6,17 +6,20 @@ use v5.10.0; my @cpus = qw | -hades30 hades33 hadesdaqp02 hadesdaqp03 hadesdaqp04 hadesp28 hadesp30 hadesp31 hadesp33 hadesp57 hadesp63 hadesp66 hadesp70 lxhaddcs05p lxhaddcs06p lxhaddcs10p lxhaddcs11p lxhaddcs12p lxhaddcs13p lxhadeb07p lxhadeb08p lxhadeb09p lxhadeb10p lxhadeb11p lxhadeb12p lxhadeb13p lxhadeb14p lxhadeb15p lxhadeb16p lxhadesdaqp +hades30 hades33 hadesdaqp02 hadesdaqp03 hadesdaqp04 hadesp28 hadesp30 hadesp31 hadesp33 hadesp57 hadesp63 hadesp66 hadesp70 lxhaddcs10p lxhaddcs11p lxhaddcs12p lxhaddcs13p lxhadeb07p lxhadeb08p lxhadeb09p lxhadeb10p lxhadeb11p lxhadeb12p lxhadeb13p lxhadeb14p lxhadeb15p lxhadeb16p lxhadesdaqp lxhadeb18p lxhadeb17p |; #lxhadeb07 lxhadeb08 lxhadeb09 lxhadeb10 lxhadeb11 lxhadeb12 lxhadeb13 lxhadeb14 lxhadeb15 lxhadeb16 lxhaddcs05 lxhaddcs06 lxhaddcs11 lxhadesdaq hadesdaq01 hades30 ha#desp31 hades33 lxhadeb07p lxhadeb08p lxhadeb09p lxhadeb10p lxhadeb11p lxhadeb12p lxhadeb13p lxhadeb14p lxhadeb15p lxhadeb16p lxhaddcs05p lxhaddcs06p lxhaddcs11p lxhad#esdaqp hadesdaqp02 hadesdaqp03 hadesdaqp04 hadesp30 hadesp33 hadesp57 hadesp70 for my $cpu (@cpus) { - my $c = "~/trbsoft/hadesdaq/hmon/hmon_ssh hadaq\@$cpu -N -f /dev/null&"; + my $c = "~/trbsoft/hadesdaq/hmon/hmon_ssh $cpu -N -f /dev/null&"; if ($cpu =~ /hadesp28/) { $c=~s/hadaq\@/magnet\@/; } + if ($cpu =~ /hades13p/) { + $c=~s/hadaq\@/hades-qa\@/; + } #my $c = "~/trbsoft/hadesdaq/hmon/hmon_ssh hadaq\@$cpu -N -f"; print "command: $c\n"; system($c); diff --git a/hmon/permanent/hmon_qaplots.pl b/hmon/permanent/hmon_qaplots.pl index 9834b3c..fe576f1 100755 --- a/hmon/permanent/hmon_qaplots.pl +++ b/hmon/permanent/hmon_qaplots.pl @@ -77,12 +77,12 @@ $files-> { "Main" } = [ "MainTrigger" , "MainTriggerTrend" , "MainPTScaler" , # $files-> { "PionTrackerRaw" } = [ "Mult" , "TS" , "Strip" , "Pileup" , "Overflow" , "ADCStrip" , "TSStrip" , "XY" , "RawPTHodoDt" ]; # $files-> { "PionTrackerCal" } = [ "CalTS" , "CalADCStrip" , "CalTSStrip" , "CalPTHodoDt" ]; $files-> { "Start" } = [ "StartMain", "StartTestEfficiency", "StartTestRawStripToT", "StartTestTDIFFvsTOTmod0", "StartTestTDIFFvsTOTmod1" ]; -$files-> { "InnerTOF" } = [ "InnerTofMultiplicity", "InnerTofRawHitPattern", "InnerTofRawHitPatternWithSum"]; +#$files-> { "InnerTOF" } = [ "InnerTofMultiplicity", "InnerTofRawHitPattern", "InnerTofRawHitPatternWithSum"]; -$files-> { "Hodo" } = [ "HODOMain" ]; -$files-> { "ForwardDet" } = [ "StrawCounts", "StrawToT", "StrawLeadTime", "ToT", "DriftTime", "Multiplicity"]; +#$files-> { "Hodo" } = [ "HODOMain" ]; +#$files-> { "ForwardDet" } = [ "StrawCounts", "StrawToT", "StrawLeadTime", "ToT", "DriftTime", "Multiplicity"]; -$files-> { "RICH" } = [ "RICHMult" , "RICHCharge" , "RICHColRow" , "RICHHitMult" , "RICHDirClus" ]; +$files-> { "RICH" } = [ "RICHMult" , "RICHCharge" , "RICHColRow" , "RICHHitMult" , "RICHDirClus", "Cals", "CalsXY", "EdgeInfo", "LaserMult" , "NofPerEvent", "RawHits", "RawMult", "SecLaserTrend","SecMultCals","SecMultRings","SingleEvent" ]; $files-> { "MDCMon" } = [ "MDCMain" , "Errors" ]; $files-> { "MDCTimes" } = [ "potato" ]; $files-> { "MDCExpert" } = [ "Hits" , "MDCL0" , "MDCL1" , "MDCL2" , "MDCL3" , "MDCMboNoise" , "MDCT0" , "MDCT1" , "MDCT2" , "MDCT3" , "MDCMb" , "MDCMboTrend" , "MDCMbTCal0" , "MDCMbTCal1" , "MDCMbTCal2" , "MDCMbTCal3" , "MDCCalStat" , "MDCErrStat" ]; @@ -91,9 +91,9 @@ $files-> { "MDCTimesRaw" } = [ "MDCTimesRaw0" , "MDCTimesRaw1" , "MDCTimes2Ra $files-> { "TOFMon" } = [ "TOFMain" , "TOFADC" , "TOFTDC" , "TOFHIT" ]; $files-> { "RPC" } = [ "RPCMain" , "RPCRawRPCMult" , "RPCRawSecMult" , "RPCRawColCellMult" , "RPCRawColCellMult2" , "RPCRawHitsTrend" , "RPCRawChargeDiff" , "RPCFeeTrbMbo" , "RPCFeeMboDbo" , "RPCFeeTrbChannel" , "RPCRpcHit" , "RPCRpcShower" ]; $files-> { "WALLMon" } = [ "WALLMain" , "WALLHit" , "WALLControl" , "WALLControlLATCH" ]; -# $files-> { "SHOWERMon" } = [ "SHOWERMain" , "SHOWERMults" , "SHOWERSUMS" , "SHOWERCAL" , "SHOWERSUMTREND" ]; $files-> { "Physics" } = [ "PhysMultCand" , "PhysMatch" , "PhysMultDist" , "PhysBetaMomSys0" , "PhysBetaMomSys1" , "PhysVertex" , "PhysToTmips" ]; $files-> { "EcalMon"} = ["RawMult", "SlowTot"]; +$files->{"Trigger"} = qw(MainPTScaler MainTrigger MainTriggerTrend ); # while(1) { diff --git a/hmon/permanent/hmon_richhv.pl b/hmon/permanent/hmon_richhv.pl index f7a7b3e..a6dc3b0 100755 --- a/hmon/permanent/hmon_richhv.pl +++ b/hmon/permanent/hmon_richhv.pl @@ -235,7 +235,7 @@ while(1) { } $qastate = QA::WARN_2 if ($ChnlsOn < 74); -$qastate = QA::ERROR_2 if ($ChnlsOn == 0); +$qastate = QA::ERROR if ($ChnlsOn == 0); $qastate = QA::NOTE if ($QA::RichHvOff == 1); if( $timer % (4*$OVERCURRENT_period) == 0) { diff --git a/hmon/permanent/hmon_sequencer.pl b/hmon/permanent/hmon_sequencer.pl index d405dce..a200483 100755 --- a/hmon/permanent/hmon_sequencer.pl +++ b/hmon/permanent/hmon_sequencer.pl @@ -134,7 +134,7 @@ while(1) { $longtxt = "All sequencers running" if $longtxt eq ""; my $value = ((scalar @names)-$count)."/".(scalar @names); - QA::WriteQALog($flog,"misc","sequencer",50,$qastate,"HV Sequencer",$value,$longtxt); + QA::WriteQALog($flog,"hv2","sequencer",50,$qastate,"HV Sequencer",$value,$longtxt); if($qastate == QA::FATAL) { if(!($errorcounter%15)){ Hmon::Speak('nobeam', "High Voltage Control is not working"); diff --git a/hmon/permanent/hmon_spillmon.pl b/hmon/permanent/hmon_spillmon.pl index bc74caa..78e5c8b 100755 --- a/hmon/permanent/hmon_spillmon.pl +++ b/hmon/permanent/hmon_spillmon.pl @@ -84,6 +84,29 @@ HPlot::PlotInit({ }); +HPlot::PlotInit({ + name => "StartMap", + file => "files/StartMap", + title => "Start Coincidence Rate", + entries => 16, + curves => 16, + type => HPlot::TYPE_HEATMAP, + output => HPlot::OUT_PNG, + zlabel => "Hitrate", + sizex => 310, + sizey => 310, + nokey => 1, + buffer => 1, + ymin => 15.5, + ymax => -0.5, + xmin => -0.5, + xmax => 15.5, + cbmax => "100<*<1E5", + cbmin => 1, + noinit => 1, + additional => "set logscale cb;unset ytics;set format cb \"_{10}{\%L}\"", + showvalues => 0, + }); my $str = Hmon::MakeTitle(12, 6, "Beam QFactor",0); @@ -97,15 +120,24 @@ $str .= qq@
\n@; $str .= Hmon::MakeFooter(); Hmon::WriteFile("MicroSpillStructure",$str); +$str = Hmon::MakeTitle(4, 7, "StartMap",0); +$str .= qq@
\n@; +$str .= Hmon::MakeFooter(); +Hmon::WriteFile("StartMap",$str); + -trb_init_ports() or die trb_strerror(); +trb_init_ports() or die trb_strerror(); +my $old; +my $oldtime = time(); +my $time = time(); +my $diff; my $round = 0; while(1) { - my $o = trb_register_read_mem(0xf3c0,0xb810,1,500) or print trb_strerror() or sleep 5 and next; + my $o = trb_register_read_mem(0xffff,0xb810,1,500) or print trb_strerror() or sleep 5 and next; foreach my $b (keys %$o) { my $time = 0; @@ -142,12 +174,12 @@ while(1) { # if($round == 8) { # trb_register_write(0xf3c0,0xb801,0x80000000); # } - $o = trb_register_read(0xf3c0,0xb806); - if($o->{0xf3c0} == 3) { - $o = trb_register_read_mem(0xf3c0,0xb811,1,6000) or print trb_strerror() or sleep 5 and next; + $o = trb_register_read(0xffff,0xb806); + if($o->{0xffff} == 3) { + $o = trb_register_read_mem(0xffff,0xb811,1,6000) or print trb_strerror() or sleep 5 and next; - trb_register_write(0xffff,0xb805,200000); #50000 = 1s offset to spill start - trb_register_write(0xffff,0xb804,0x00003559); #Only 5000/5001 as source +# trb_register_write(0xffff,0xb805,200000); #50000 = 1s offset to spill start +# trb_register_write(0xffff,0xb804,0x00003559); #Only 5000/5001 as source foreach my $b (keys %$o) { @@ -159,7 +191,34 @@ while(1) { HPlot::PlotDraw('MicroRate'); HPlot::PlotDraw('MicroRate10ms'); } - + + $o = trb_register_read_mem(0xffff,0xba00,0,256) or print trb_strerror() or sleep 5 and next; + + if (defined $old) { + my $tdiff = (time() - $oldtime)|1; + foreach my $b (keys %$o) { + + for my $v (0..255) { + my $vdiff = ($o->{$b}->[$v]&0xfffff) - ($old->{$b}->[$v]&0xfffff); + + if ($vdiff < 0) { $vdiff += 2**20;} + $diff->{$b}->[$v] = $vdiff/$tdiff; + #$ratesum += $diff->{$b}->[$v+1]; +# print "$v $diff->{$b}->[$v]\n"; + HPlot::PlotFill('StartMap',$diff->{$b}->[$v],$v%16,$v/16); + } + + } + + HPlot::PlotDrawFork('StartMap'); + + + + } + + $old = $o; + $oldtime = time(); + $round++; sleep 1; } diff --git a/hmon/permanent/hmon_tdcchanerrors_testmonitor.pl b/hmon/permanent/hmon_tdcchanerrors_testmonitor.pl old mode 100755 new mode 100644 index b4e9bfc..8cb093d --- a/hmon/permanent/hmon_tdcchanerrors_testmonitor.pl +++ b/hmon/permanent/hmon_tdcchanerrors_testmonitor.pl @@ -21,7 +21,7 @@ use Try::Tiny; trb_init_ports() or die trb_strerror(); my $data; -my $NUMPLOTS = 9; +my $NUMPLOTS = 10; my $SERVER = 'calib'; #calib or calibtest @@ -39,7 +39,7 @@ my $SERVER = 'calib'; #calib or calibtest my $numboards = $entry; $labels .= ') rotate by 90 offset 0,-1.4 font ",6";'; - my @names = qw(LeadingAverage[ns] LeadingSigma[ps] IgnoredOutliers IgnoredHits ToTAverage[ns] ToTSigma[ps] IgnoredToTOutliers IgnoredToT CorrectedHits); + my @names = qw(LeadingAverage[ns] LeadingSigma[ps] IgnoredOutliers IgnoredHits ToTAverage[ns] ToTSigma[ps] IgnoredToTOutliers IgnoredToT CorrectedHits ToTShifts[ns]); HPlot::PlotInit({ name => "TdcCalMon0", @@ -242,7 +242,30 @@ HPlot::PlotInit({ additional => $labels,#."set logscale cb;", showvalues => 0, }); -while(1){ +HPlot::PlotInit({ + name => "TdcCalMon9", + file => "files/TdcCalMon9", + cblabel => "TdcCalMon ".$names[9], + entries => $numboards, + curves => 49, + type => HPlot::TYPE_HEATMAP, + output => HPlot::OUT_PNG, + sizex => 10000, + sizey => 500, + nokey => 1, + buffer => 0, + xmin => -0.5, + xmax => $numboards-0.5, + ymin => -0.5, + ymax => 48.5, + noinit => 1, + cbmin => 0, + cbmax => 50, + palette => 'defined (0 "#33ff00", 0.000001 "#ff0000", 21 "#ff0000", 21.6 "#ff5500", 22 "#00ff00", 43 "yellow", 44 "red", 50 "red")', + additional => $labels,#."set logscale cb;", + showvalues => 0, }); + +# while(1){ ################################################################################################### #loop until run is finished print "Wait for end of analysis run\n"; @@ -254,11 +277,12 @@ while(1){ $evnum = $eventhist->{bins}[13]; print "run".$evnum."\n"; sleep 10; - }while($evnum == 0 || $evnum != $oldevnum); + }while(($oldevnum == 0 || $evnum == 0 || $evnum != $oldevnum)); ################################################################################################### print "End detected. Start to work\n"; - + Hmon::Speak('caltest',"Calibration Test: Root analysis finished."); + my $str = Hmon::MakeTitle(200, 110, "TDC Cal Mon",1); $str .= '
'.QA::getTimeString().'
'; $str .= '
Working
'; @@ -284,13 +308,20 @@ while(1){ $p = $datahistlist->{'_allnames'}{$p}; my $corr = getroothist($SERVER,$p) if($p) ; next unless $corr; - + + $p = sprintf("TDC_%04X_TotShifts",$b); + $p = $datahistlist->{'_allnames'}{$p}; + my $shifts = getroothist($SERVER,$p) if($p) ; + next unless $shifts; + for(my $i=1;$i<=48;$i++) { next unless $activechannels & (1<<($i-1)); - next if($b >= 0x5000 && $b < 0x5008 && !($i&1)); +# next if($b >= 0x5000 && $b < 0x5008 && !($i&1)); my $avg = ($corr->{bins}[$i]//0) / ($hits->{bins}[$i*2]||1); HPlot::PlotFill("TdcCalMon8",$avg,$entry,$i); + HPlot::PlotFill("TdcCalMon9",$shifts->{bins}[$i]//0,$entry,$i); + } } @@ -307,7 +338,7 @@ while(1){ for(my $i=1;$i<=48;$i++) { next unless $activechannels & (1<<($i-1)); - next if($b < 0x5008 && $b >= 0x5000 && !($i&1)); +# next if($b < 0x5008 && $b >= 0x5000 && !($i&1)); my ($sum,$avg,$sigma,$outlier,$ignored) = stats($d->{bins}[$i]); @@ -329,10 +360,11 @@ while(1){ for(my $i=1;$i<=48;$i++) { next unless $activechannels & (1<<($i-1)); - next if($b >= 0x5000 && $b < 0x5008 && !($i&1)); +# next if($b >= 0x5000 && $b < 0x5008 && !($i&1)); - my ($sum,$avg,$sigma,$outlier,$ignored) = stats($d->{bins}[$i],1460,1540) if ($b < 0x7000); + my ($sum,$avg,$sigma,$outlier,$ignored) = stats($d->{bins}[$i],1460,1540) if ($b < 0x7000 && $b >= 0x5100); ($sum,$avg,$sigma,$outlier,$ignored) = stats($d->{bins}[$i],960,1040) if ($b >= 0x7000); + ($sum,$avg,$sigma,$outlier,$ignored) = stats($d->{bins}[$i],960,1040) if ($b >= 0x5000 && $b <= 0x50ff); $avg = ($avg/50); $sigma = ($sigma*20); @@ -359,16 +391,17 @@ while(1){ } $str .= Hmon::MakeFooter(); Hmon::WriteFile("TdcCalMon",$str); + Hmon::Speak('caltest2',"Calibration Test: H-mon analysis finished."); - do{ - $oldevnum = $evnum; - $eventhist = getroothist($SERVER,"/HADES/Run/HLD/HLD_EvType"); - $evnum = $eventhist->{bins}[13]; - print "wait".$evnum."\n"; - sleep 5; - }while($evnum == $oldevnum); -} +# do{ +# $oldevnum = $evnum; +# $eventhist = getroothist($SERVER,"/HADES/Run/HLD/HLD_EvType"); +# $evnum = $eventhist->{bins}[13]; +# print "wait".$evnum."\n"; +# sleep 5; +# }while($evnum == $oldevnum); +# } diff --git a/hmon/speakdaemon.pl b/hmon/speakdaemon.pl index 746513c..29dead6 100755 --- a/hmon/speakdaemon.pl +++ b/hmon/speakdaemon.pl @@ -7,43 +7,50 @@ use Hmon; use QA; my $inhibit = 0; -$SIG{USR1} = sub { $inhibit = 1; }; -$SIG{USR2} = sub { $inhibit = 0; system("killall espeak");}; #system("espeak -ven-male2 -s 130 -g 1 \"Speech daemon is online\" 2>/dev/null"); +$SIG{USR1} = sub { $inhibit = 1; }; #system("killall larynx");}; +$SIG{USR2} = sub { $inhibit = 0; }; #system("espeak -ven-male2 -s 130 -g 1 \"Speech daemon is online\" 2>/dev/null"); # my $fq = QA::OpenQAFile(); -my $cmd = "ssh hades33 /home/hadaq/trbsoft/daq/hmon/hmon_tail -n 0 -F /home/hadaq/trbsoft/hadesdaq/hmon/files/speaklog"; +my $cmd = "LANG=en_US.UTF-8 ssh hadesp33 /home/hadaq/trbsoft/daq/hmon/hmon_tail -n 0 -F /home/hadaq/trbsoft/hadesdaq/hmon/files/speaklog"; # my $fq = "remote"; # my $cmd = "./hmon_ssh -T $QA::QAServer \"tail -n 0 -F /home/hadaq/trbsoft/daq/tools/hmon/files/speaklog\" /dev/null #-ven+m2 -s 130 -g 1 "); -ven-us+f2 -p50 -s120 +# system("espeak -ven-us+f2 -p60 -s150 -g 1 \"oh-oh -- $a\" 2>/dev/null"); +# system("espeak-ng -ven-german -s140 -p 90 \"$a\" 2>/dev/null"); +# system("espeak -s120 -p 90 \"$a\" 2>/dev/null"); -if($f) { + +#while(1) { + my $fn = "LANG=en_US.UTF-8 larynx -v southern_english_male --length-scale 1 --interactive 2>&1"; + open my $fh, "|$fn" or die "error: no larynx"; + $fh->autoflush(1); + while(1) { - open(FTRB, "$cmd|"); + open(FTRB, "$cmd|"); while(my $a = ) { if ($inhibit == 0) { -# system("espeak -vus-mbrola-1 -s125 \"$a\" 2>/dev/null #-ven+m2 -s 130 -g 1 "); -ven-us+f2 -p50 -s120 -# system("espeak -ven-us+f2 -p60 -s150 -g 1 \"oh-oh -- $a\" 2>/dev/null"); - system("espeak-ng -ven-german -s140 -p 90 \"$a\" 2>/dev/null"); -# system("espeak -s120 -p 90 \"$a\" 2>/dev/null"); + print $fh ": ".$a ; + sleep 3; } } } - } -else { - while(1) { - if($inhibit == 0) { -# QA::WriteQALog($fq, "main", "speech", 120, QA::OK, -# "Speech Output", "running", "The speech daemon is running."); - } - else { -# QA::WriteQALog($fq, "main", "speech", 120, QA::WARN, -# "Speech Output", "muted", "The speech daemon is muted."); - } - sleep 60; - } - } +# } +# else { +# while(1) { +# if($inhibit == 0) { +# # QA::WriteQALog($fq, "main", "speech", 120, QA::OK, +# # "Speech Output", "running", "The speech daemon is running."); +# } +# else { +# # QA::WriteQALog($fq, "main", "speech", 120, QA::WARN, +# # "Speech Output", "muted", "The speech daemon is muted."); +# } +# sleep 60; +# } +# } diff --git a/hmon/speakdaemon_mdc.pl b/hmon/speakdaemon_mdc.pl index 3baf551..9a70284 100755 --- a/hmon/speakdaemon_mdc.pl +++ b/hmon/speakdaemon_mdc.pl @@ -8,7 +8,7 @@ use QA; my $inhibit = 0; $SIG{USR1} = sub { $inhibit = 1; }; -$SIG{USR2} = sub { $inhibit = 0; system("killall espeak");}; #system("espeak -ven-male2 -s 130 -g 1 \"Speech daemon is online\" 2>/dev/null"); +$SIG{USR2} = sub { $inhibit = 0; system("killall larynx");}; #system("espeak -ven-male2 -s 130 -g 1 \"Speech daemon is online\" 2>/dev/null"); # my $fq = QA::OpenQAFile(); my $cmd = "ssh hades33 /home/hadaq/trbsoft/daq/hmon/hmon_tail -n 0 -F /home/hadaq/trbsoft/hadesdaq/hmon/files/speaklog_mdc"; @@ -16,34 +16,40 @@ my $cmd = "ssh hades33 /home/hadaq/trbsoft/daq/hmon/hmon_tail -n 0 -F /home/hada # my $fq = "remote"; # my $cmd = "./hmon_ssh -T $QA::QAServer \"tail -n 0 -F /home/hadaq/trbsoft/daq/tools/hmon/files/speaklog\" /dev/null #-ven+m2 -s 130 -g 1 "); -ven-us+f2 -p50 -s120 +# system("espeak -ven-us+f2 -p60 -s150 -g 1 \"oh-oh -- $a\" 2>/dev/null"); +# system("espeak-ng -ven-german -s140 -p 90 \"$a\" 2>/dev/null"); +# system("espeak -s120 -p 90 \"$a\" 2>/dev/null"); -if($f) { +# if($f) { + my $fn = "larynx -v southern_english_male --length-scale 1.2 --interactive 2>&1"; + open my $fh, "|$fn" or die "error: no larynx"; + $fh->autoflush(1); + while(1) { - open(FTRB, "$cmd|"); + open(FTRB, "$cmd|"); while(my $a = ) { if ($inhibit == 0) { -# system("espeak -vus-mbrola-1 -s125 \"$a\" 2>/dev/null #-ven+m2 -s 130 -g 1 "); -ven-us+f2 -p50 -s120 -# system("espeak -ven-us+f2 -p60 -s150 -g 1 \"$a\" 2>/dev/null"); - system("espeak-ng -ven-german -s140 -p 90 \"$a\" 2>/dev/null"); -# system("espeak -s120 -p 90 \"$a\" 2>/dev/null"); + print $fh $a ; } } } - } -else { - while(1) { - if($inhibit == 0) { -# QA::WriteQALog($fq, "main", "speech", 120, QA::OK, -# "Speech Output", "running", "The speech daemon is running."); - } - else { -# QA::WriteQALog($fq, "main", "speech", 120, QA::WARN, -# "Speech Output", "muted", "The speech daemon is muted."); - } - sleep 60; - } - } +# } +# else { +# while(1) { +# if($inhibit == 0) { +# # QA::WriteQALog($fq, "main", "speech", 120, QA::OK, +# # "Speech Output", "running", "The speech daemon is running."); +# } +# else { +# # QA::WriteQALog($fq, "main", "speech", 120, QA::WARN, +# # "Speech Output", "muted", "The speech daemon is muted."); +# } +# sleep 60; +# } +# } diff --git a/hmon/start.sh b/hmon/start.sh index 1188c83..f43806c 100755 --- a/hmon/start.sh +++ b/hmon/start.sh @@ -3,7 +3,9 @@ #Mount RAM file system #mount -t tmpfs none /var/spool/ramdisk -o size=256m -export PERL5LIB="./" +source ~/.bashrc + +#export PERL5LIB="./:/home/hadaq/soft/EPICS/EPICS-7.0.7/base/lib/perl/" mkdir /dev/shm/hmon #Kill old tunnel, make new one. Better: Check if tunnel still exists, if not restart. @@ -45,9 +47,9 @@ mkdir -p `pwd`/pion #pkill -f "sshfs -o allow_other hadaq@hadesp66:/home/hades-qa/online/5.34.38/pics" fusermount -u qa -timeout 2 bash -c "sshfs -o allow_other hadaq@hadesp66:/home/hades-qa/online/5.34.38/pics `pwd`/qa" +timeout 2 bash -c "sshfs -o allow_other hadaq@hadesp66:/home/hades-qa/online/5.34.38/feb24/pics `pwd`/qa" fusermount -u vertex -timeout 2 bash -c "sshfs -o allow_other hadaq@hadesp66:/home/hades-qa/online/5.34.38/feb22/vertex/pics `pwd`/vertex" +timeout 2 bash -c "sshfs -o allow_other hadaq@hadesp66:/home/hades-qa/online/5.34.38/feb24/vertex/pics `pwd`/vertex" #pkill -f "sshfs -o allow_other hadaq@hadesp63:/home/hadaq/local/tdcmon/dabc/cal" fusermount -u calibration @@ -74,6 +76,7 @@ ln -fs `pwd`/mdc.png /srv/www/htdocs/mon/ ln -fs `pwd`/background.png /srv/www/htdocs/mon/files/ ln -fs `pwd`/QA.pm /srv/www/htdocs/mon/ ln -fs `pwd`/styles.css files/ +ln -fs `pwd`/stylesmonitor.css files/ #ln -fs `pwd`/indexstyles.css files/ ln -fs `pwd`/ecal_drawing.htm /srv/www/htdocs/mon/ ln -fs `pwd`/rich_drawing.htm /srv/www/htdocs/mon/ @@ -124,6 +127,7 @@ rm ~/trbsoft/hadesdaq/hmon/files/note.htt #ssh hadesp57 'cd /home/hadaq/trbsoft/daq/hmon/; PERL5LIB=. ./speakdaemon.pl 1>/dev/null 2>>/home/hadaq/trbsoft/hadesdaq/hmon/logs/perlerror_speakdaemon' & ssh hadesp33 'cd /home/hadaq/trbsoft/daq/hmon/; PERL5LIB=. ./speakdaemon.pl 1>/dev/null 2>>/home/hadaq/trbsoft/hadesdaq/hmon/logs/perlerror_speakdaemon' & +ssh hadesp33 'cd /home/hadaq/trbsoft/daq/hmon/; PULSE_SINK=Virtual1 PERL5LIB=. ./speakdaemon_mdc.pl 1>/dev/null 2>>/home/hadaq/trbsoft/hadesdaq/hmon/logs/perlerror_speakdaemon_mdc' & sleep 1; # echo " Done." diff --git a/hmon/stop.sh b/hmon/stop.sh index ba2289f..a5611f5 100755 --- a/hmon/stop.sh +++ b/hmon/stop.sh @@ -5,6 +5,7 @@ echo " Killing all sub-processes..." pkill -f "\./hmon_.+\.pl" 2>/dev/null 1>/dev/null pkill -f "sh -c \./hmon_.*\.sh" pkill -f "/usr/bin/perl -w \./speakdaemon.pl" +pkill -f "/usr/bin/perl -w \./speakdaemon_mdc.pl" pkill -f "/usr/bin/perl -w \./hmon_.*\.sh" pkill -f "hmon_tail -n" #pkill -f "hmon_ssh" # don't do that for a normal daq-restart diff --git a/hmon/stopall.sh b/hmon/stopall.sh index b73ea5a..a423f9f 100755 --- a/hmon/stopall.sh +++ b/hmon/stopall.sh @@ -1,9 +1,11 @@ #!/bin/bash - +source ~/.bashrc killall hmon_permanent_tail cd permanent killall hmon*.pl 2>/dev/null 1>/dev/null +pkill -f "/usr/bin/perl -w \./speakdaemon.pl" +pkill -f "/usr/bin/perl -w \./speakdaemon_mdc.pl" cd ../ pkill -f "sshfs -o allow_other hadaq@hadesp66:/home/hades-qa/online/5.34.38/pics" diff --git a/hmon/styles.css b/hmon/styles.css index 2f30c73..c32303b 100644 --- a/hmon/styles.css +++ b/hmon/styles.css @@ -1,3 +1,7 @@ +.monitor{ + scrollbar-width:none; + } + body { font-family:sans-serif; background:#346;/*#def;*/ @@ -8,7 +12,7 @@ body { } body>div>div { - float:left; +/* float:left; */ margin: 0px 2px 0px 0; padding: 0 0 10px 0 ; border: 1px solid #777; @@ -75,16 +79,31 @@ div.errorstamp { div#content { - -moz-transform-origin:0 0; - -moz-transform:scale(1); + //-moz-transform-origin:0 0; + //-moz-transform:scale(1); } div#contentback { z-index : -1; +} + + +div#content, div#contentback { + justify-content: space-evenly; + display:flex; + flex-wrap:wrap; +/* width:100%; */ position:absolute; + } - +div#contentinner { + justify-content: space-evenly; + display:flex; + flex-wrap:wrap; +} + + /* //plus 24 in width, plus 29 in height for each size step. //base is 70x40, 80x50 with border diff --git a/nettools/Perl2Epics.pm b/nettools/Perl2Epics.pm index 9ecbfd4..7e37b3a 100644 --- a/nettools/Perl2Epics.pm +++ b/nettools/Perl2Epics.pm @@ -9,16 +9,34 @@ use Data::Dumper; # use lib '/home/hadaq/soft/EPICS/EPICS-3.16.1/base/' . '/lib/perl'; # use lib '/home/epics/EPICS/EPICS-3.16.1/base/' . '/lib/perl'; # use lib '/home/hadaq/soft/EPICS/EPICS-7.0.1.1/base/' . '/lib/perl'; -use lib '/home/hadaq/soft/EPICS/EPICS-7.0.7/base/lib/perl/'; -use CA; +# use lib '/home/hadaq/soft/EPICS/EPICS-7.0.7/base/lib/perl/'; + + +#my $find_epics_command =q|bash -c '. /home/hadaq/local/bin/epics'|; +my $find_epics_command =q|bash -c '. epics'|; +my @find_epics_result = qx($find_epics_command); +#print Dumper @find_epics_result; +my ($EPICS_BASE)= grep(/^EPICS_BASE /, @find_epics_result); +#print Dumper $EPICS_BASE; +my @temp_split=split /\s+/, $EPICS_BASE; +$EPICS_BASE = $temp_split[3]; + +#print "found EPICS_BASE: $EPICS_BASE\n"; +my $ca_lib_path = $EPICS_BASE . '/lib/perl/'; +#print "ca_lib_path: $ca_lib_path\n"; +#use lib $ca_lib_path; +#use lib '/home/hadaq/EPICS/EPICS-3.15.6/base/lib/perl/'; +#use CA; +require "$ca_lib_path/CA.pm"; +CA->import; #JAM 2020: back to default after EBs are done with epics # $ENV{EPICS_CA_AUTO_ADDR_LIST} = 'YES'; $ENV{EPICS_CA_AUTO_ADDR_LIST} = 'NO'; #JoF2022: updated during beamtime -$ENV{EPICS_CA_ADDR_LIST} = "cryo1.hades.gsi.de lxhadeb07p frpcpid1 lxhaddcs05p lxhaddcs06p lxhaddcs10p lxhaddcs11p lxhaddcs12p lxhaddcs13p gas.hades.gsi.de richhvcrate"; -# $ENV{EPICS_CA_ADDR_LIST} = "192.168.111.255"; +$ENV{EPICS_CA_ADDR_LIST} = "cryo1.hades.gsi.de frpcpid1 lxhaddcs10p lxhaddcs11 lxhaddcs12p lxhaddcs13p gas.hades.gsi.de richhvcrate"; +# $ENV{EPICS_CA_ADDR_LIST} = "192.168.111.255"; lxhadeb07p lxhaddcs05p lxhaddcs06p #$ENV{EPICS_CA_ADDR_LIST} = "192.168.103.182 192.168.100.235 192.168.100.236 192.168.97.10 192.168.97.11 192.168.97.14 192.168.97.15 192.168.100.17 192.168.97.4 192.168.100.216"; #JAM2018: updated after network mask redefinition: @@ -44,7 +62,7 @@ my $errcnt = {}; sub callback { my ($chan, $status, $data) = @_; -# print Dumper $data; +# print Dumper $data; if ($status) { printf "%-30s %s\n", $chan->name, $status; } @@ -67,7 +85,7 @@ sub Connect { my ($title, $varname, $type, $wait) = @_; # push(@EpicsChans,CA->new($name)); # $EpicsChans[-1]->create_subscription('v', \&callback, 'DBR_TIME_DOUBLE'); - ## print $varname."\n"; +# print $varname."\n"; $type = 'DBR_TIME_DOUBLE' unless defined $type; $EpicsStore->{$varname}->{tme} = []; $EpicsStore->{$varname}->{val} = []; @@ -92,12 +110,14 @@ sub Update { sub GetAll { + my ($delay) = @_; my $store = {}; my $time; my $val; + my $diffflag = -1;#undefined difference #Update(0.001); - Update(0.2); + Update($delay || 0.2); foreach my $el (keys %{$EpicsNames}) { my $varname = $EpicsNames->{$el}; @@ -112,15 +132,21 @@ sub GetAll { if(!$success) { $time = -1; $val = 0; - } elsif (scalar @{$EpicsStore->{$varname}->{tme}} > 0) { + } elsif (scalar @{$EpicsStore->{$varname}->{tme}} == 1) { $time = (@{$EpicsStore->{$varname}->{tme}})[-1]; $val = (@{$EpicsStore->{$varname}->{val}})[-1]; + } elsif (scalar @{$EpicsStore->{$varname}->{tme}} > 1) { + $time = (@{$EpicsStore->{$varname}->{tme}})[-1]; + $val = (@{$EpicsStore->{$varname}->{val}})[-1]; + my $oldval = (@{$EpicsStore->{$varname}->{val}})[-2]; + $diffflag = ( ($val - $oldval) == 0 ) ? 0 : 1; } else { $time = $EpicsStore->{$varname}->{lasttime}; $val = $EpicsStore->{$varname}->{lastval}; } - $store->{$el}->{tme} = $time; - $store->{$el}->{val} = $val; + $store->{$el}->{tme} = $time; + $store->{$el}->{val} = $val; + $store->{$el}->{diffflag} = $diffflag; $EpicsStore->{$varname}->{lasttime} = $time; $EpicsStore->{$varname}->{lastval} = $val; } diff --git a/nettools/Perl2Epics2.pm b/nettools/Perl2Epics2.pm new file mode 100644 index 0000000..b11448a --- /dev/null +++ b/nettools/Perl2Epics2.pm @@ -0,0 +1,302 @@ +package Perl2Epics2; +use warnings; +use strict; +use Data::Dumper; +# use Hmon; + +# use lib '/home/scs/EPICS/EPICS-3.14.12.4/base/' . '/lib/perl'; +# use lib '/home/hadaq/EPICS/EPICS-3.15.6/base' . '/lib/perl'; +# use lib '/home/hadaq/soft/EPICS/EPICS-3.16.1/base/' . '/lib/perl'; +# use lib '/home/epics/EPICS/EPICS-3.16.1/base/' . '/lib/perl'; +# use lib '/home/hadaq/soft/EPICS/EPICS-7.0.1.1/base/' . '/lib/perl'; +use lib '/home/hadaq/soft/EPICS/EPICS-7.0.7/base/lib/perl/'; +use CA; + +#JAM 2020: back to default after EBs are done with epics +# $ENV{EPICS_CA_AUTO_ADDR_LIST} = 'YES'; +$ENV{EPICS_CA_AUTO_ADDR_LIST} = 'NO'; + +#JoF2022: updated during beamtime +$ENV{EPICS_CA_ADDR_LIST} = "cryo1.hades.gsi.de lxhadeb07p frpcpid1 lxhaddcs05p lxhaddcs06p lxhaddcs10p lxhaddcs11p lxhaddcs12p lxhaddcs13p gas.hades.gsi.de richhvcrate"; +# $ENV{EPICS_CA_ADDR_LIST} = "192.168.111.255"; +#$ENV{EPICS_CA_ADDR_LIST} = "192.168.103.182 192.168.100.235 192.168.100.236 192.168.97.10 192.168.97.11 192.168.97.14 192.168.97.15 192.168.100.17 192.168.97.4 192.168.100.216"; + +#JAM2018: updated after network mask redefinition: +#$ENV{EPICS_CA_ADDR_LIST} = "192.168.111.255 192.168.111.255:10012 192.168.111.255:10008 192.168.111.255:10003 192.168.111.255:10002 192.168.111.255:10001 192.168.111.255:10014 192.168.111.255:10007 192.168.111.255:10004 192.168.111.255:10010 192.168.111.255:10013 192.168.111.255:10015 192.168.111.255:10016 192.168.111.255:10009 192.168.111.255:10005 192.168.103.83:10011 192.168.111.255:10006 localhost"; +#$ENV{EPICS_CA_ADDR_LIST} = "192.168.111.255:10006 192.168.111.255:10010 192.168.111.255:10011 192.168.111.255:10012 192.168.111.255:10013 192.168.111.255:10014 192.168.111.255:10015 192.168.111.255:10016 192.168.111.255:10017 192.168.111.255:10018 192.168.111.255:10019"; +#$ENV{EPICS_CA_ADDR_LIST} = "192.168.103.83:10000 192.168.103.83:10008 192.168.103.83:10003 192.168.103.83:10002 192.168.111.255:10001"; +#$ENV{EPICS_CA_ADDR_LIST} = "192.168.103.83 192.168.103.83:10012 192.168.103.83:10008 192.168.103.83:10003 192.168.103.83:10002 192.168.103.83:10001 192.168.103.83:10014 192.168.103.83:10007 192.168.103.83:10004 192.168.103.83:10010 192.168.103.83:10013 192.168.103.83:10015 192.168.103.83:10016 192.168.103.83:10009 192.168.103.83:10005 192.168.103.83:10011 192.168.103.83:10006 localhost"; + +#hotfix PZ 2022-02-14 +#$ENV{EPICS_CA_ADDR_LIST} = "192.168.111.255"; +#$ENV{EPICS_CA_AUTO_ADDR_LIST} = 'NO'; + +# +# JAM added fixed port numbers of EB epics +#$ENV{EPICS_CA_ADDR_LIST} = "192.168.103.255 192.168.103.255:10012 192.168.103.255:10008 192.168.103.255:10003 192.168.103.255:10002 192.168.103.255:10001 192.168.103.255:10014 192.168.103.255:10007 192.168.103.255:10004 192.168.103.255:10010 192.168.103.255:10013 192.168.103.255:10015 192.168.103.255:10016 192.168.103.255:10009 192.168.103.255:10005 192.168.103.255:10011 192.168.103.255:10006 localhost"; +#$ENV{EPICS_CA_ADDR_LIST} = "192.168.100.11 192.168.100.12 192.168.100.13 192.168.100.14 192.168.100.15 localhost"; + +my $EpicsStore = {}; +my $EpicsNames = {}; +my $errcnt = {}; + +sub callback { + my ($chan, $status, $data) = @_; + # print("callback\n"); + # print $chan->name."\n"; + # print Dumper $data; + if ($status) { + printf "%-30s %s\n", $chan->name, $status; + } + else { +# print $chan->name . ": $data->{value}\n"; +# print scalar @{$EpicsStore->{$chan->name}->{tme}}."\n"; + if(scalar @{$EpicsStore->{$chan->name}->{tme}} > 10) { + shift @{$EpicsStore->{$chan->name}->{tme}}; + shift @{$EpicsStore->{$chan->name}->{val}}; + } + push(@{$EpicsStore->{$chan->name}->{tme}}, $data->{stamp}); + push(@{$EpicsStore->{$chan->name}->{val}}, $data->{value}); + $EpicsStore->{$chan->name}->{status} = $data->{status}; + } +} + +sub callbackStatusUpdate { + my ($chan, $status, $data) = @_; + # print("callbackStatusUpdate\n"); + # print($chan." ") if $chan; + # print($status." ") if $status; + # print($data." ") if $data; + if ($status) { + printf "%-30s %s\n", $chan->name, $status; + } + else { + $EpicsStore->{$chan->name}->{status} = $data->{status}; + } +} + +sub Connect { + my ($title, $varname, $type, $delay) = @_; + $type = 'DBR_TIME_DOUBLE' unless defined $type; + $EpicsStore->{$varname}->{tme} = []; + $EpicsStore->{$varname}->{val} = []; + $EpicsStore->{$varname}->{delay} = $delay || 0.05; + $EpicsNames->{$title} = $varname; + $errcnt->{$varname} = 0; + my $success; + eval { + my $c = CA->new($varname); + # print("0 ".$title." ".$varname." ".$c->is_connected()." ".$c->state."\n"); + CA->pend_io($EpicsStore->{$varname}->{delay}); + # print("1 ".$title." ".$varname." ".$c->is_connected()." ".$c->state."\n"); + $c->create_subscription('v', \&callback, $type); + # print("2 ".$title." ".$varname." ".$c->is_connected()." ".$c->state."\n"); + $c->get_callback(\&callbackStatusUpdate, $type, 1); + # print("3 ".$title." ".$varname." ".$c->is_connected()." ".$c->state."\n"); + $EpicsStore->{$varname}->{ca} = $c; + $success = $c->is_connected(); + }; + return ($success); +} + +sub Update { + CA->pend_event($_[0]); +} + + +sub GetAll { + my ($delay) = @_; + my $store = {}; + my $time; + my $val; + my $status; + + #Update(0.001); + Update($delay || 0.2); + + foreach my $el (keys %{$EpicsNames}) { + my $varname = $EpicsNames->{$el}; + my $ca = $EpicsStore->{$varname}->{ca}; + my $r = $ca->is_connected() if(defined $ca); + my $success = 1; + if(!$r && (!defined $errcnt->{$el} || $errcnt->{$el} < 2000)) { + $success = Connect($el, $varname); + $errcnt->{$el}++; + } + $status = $EpicsStore->{$varname}->{status}; + + if(!$success) { + $time = -1; + $val = 0; + $status = "NOCONN"; + # print($el." ".$errcnt->{$el}."\n"); + } elsif (scalar @{$EpicsStore->{$varname}->{tme}} >= 1) { + $time = (@{$EpicsStore->{$varname}->{tme}})[-1]; + $val = (@{$EpicsStore->{$varname}->{val}})[-1]; + } else { + $time = $EpicsStore->{$varname}->{lasttime}; + $val = $EpicsStore->{$varname}->{lastval}; + } + # print($time."\n"); + # print("curr:".time."\n"); + $store->{$el}->{tme} = $time; + $store->{$el}->{val} = $val; + $store->{$el}->{status} = $status; + $EpicsStore->{$varname}->{lasttime} = $time; + $EpicsStore->{$varname}->{lastval} = $val; + } + + + return $store; +} + +sub Get { + my ($title,$latest) = @_; + my $varname = $EpicsNames->{$title}; + my $time; + my $val; +# print $varname; + + my $c = $EpicsStore->{$varname}->{ca}; + my $r = $c->is_connected() if(defined $c); + + my $success = 1; + if(!$r) { + $success = Connect($title, $varname); + } + + if(!$success) { + return (-1, 0); + } + + #Update(0.00001); + Update(0.2); + + if (scalar @{$EpicsStore->{$varname}->{tme}} > 0) { + if(defined $latest && $latest == 1) { + $time = (@{$EpicsStore->{$varname}->{tme}})[-1]; + $val = (@{$EpicsStore->{$varname}->{val}})[-1]; + } + else { #if (scalar @{$EpicsStore->{$varname}->{tme}} > 1) + $time = shift (@{$EpicsStore->{$varname}->{tme}}); + $val = shift (@{$EpicsStore->{$varname}->{val}}); + } + } + else { + $time = $EpicsStore->{$varname}->{lasttime}; + $val = $EpicsStore->{$varname}->{lastval}; + } + $EpicsStore->{$varname}->{lasttime} = $time; + $EpicsStore->{$varname}->{lastval} = $val; + $time = $time || -1; + $val = $val || 0; + return ($time,$val); +} + +sub Put { + my ($title, $value) = @_; + my $varname = $EpicsNames->{$title}; + if (!defined $varname) { + return -1; + } + + my $c = $EpicsStore->{$varname}->{ca}; + my $r = $c->is_connected() if(defined $c); + + my $success = 1; + if(!$r) { + $success = Connect($title, $varname); + } + + if(!$success) { + return -2; + } + + if (!$c || ($c->element_count()) != 1) { + print "5\n"; + return -3; + } + + my $type = $c->field_type; + my @values; + if ($type !~ m/ ^DBR_STRING$ | ^DBR_ENUM$ /x) { + # Make @ARGV strings numeric + push (@values, (map { +$_; } $value)); + } else { + # Use strings + push (@values, $value); + } + $c->put(@values); + + return 0; +} + +sub TimeSinceLastDataChange { + my ($name, $print) = @_; + die if !$name or !$EpicsNames->{$name}; + my @this_vals = @{$EpicsStore->{$EpicsNames->{$name}}->{val}}; + my @this_times = @{$EpicsStore->{$EpicsNames->{$name}}->{tme}}; + my $lastval = $this_vals[-1]; + for (my $i = 2; $i <= scalar @this_vals; $i++) { + print("checking -".$i." where ".$this_vals[-$i]." compsto ".$lastval."\n") if defined $print; + return (time-$this_times[-$i]) if($this_vals[-$i] != $lastval); + } + return time-$this_times[-(scalar @this_vals)]; +} + +sub IsDataStatusGood { + my ($data, $ignoreLOHI) = @_; + if( $data->{status} ) { + if($ignoreLOHI) { + return 1 if $data->{status} eq "LO"; + return 1 if $data->{status} eq "LOLO"; + return 1 if $data->{status} eq "HI"; + return 1 if $data->{status} eq "HIHI"; + } + return 0 if $data->{status}; #NOCONN and LINK are definite errors but there also exists e.g. LO or LOLO + } + + return 1; +} + +sub ForceCheckIsDataStatusGood { + my ($name, $ignoreLOHI) = @_; + my $this_epics = $EpicsStore->{$EpicsNames->{$name}}; + if( $this_epics + && $this_epics->{ca} + && $this_epics->{ca}->is_connected() + ) { + eval{ + my $this_epics = $EpicsStore->{$EpicsNames->{$name}}; + $this_epics->{ca}->get(); + CA->pend_io($this_epics->{delay}); + return IsDataStatusGood($this_epics->{status}, $ignoreLOHI); + }; + if ($@){ + $this_epics->{status} = "NOCONN"; + return 0; + } + } + else { + print("EPICS variable $name does not exist"); + return 0; + } + + return 1; +} + +sub GetDataStatus { + my ($name) = @_; #if name is provided, an update of the data status is pulled (caget) + my $this_epics = $EpicsStore->{$EpicsNames->{$name}}; + if( $name + && $this_epics + ) { + return $this_epics->{status}; + } + else { + return "EPICS variable $name does not exist"; + } +} + +1; +__END__ -- 2.43.0

Error Handling

Documents

Other Ressources

DAQ Network

Trigger

Beam

ECal

ECal

RICH

RICH

MDC

MDC

Eventbuilder

Trigger

Wall

Wall

Beam

Environment

Environment

Eventbuilder

All available options

Chamber differential pressure [Pa]