ViewVC Help
View File | Revision Log | Show Annotations | Root Listing
root/cvsroot/UserCode/RateMonShiftTool_dev/AddTableInfo_db.py
(Generate patch)

Comparing UserCode/RateMonShiftTool_dev/AddTableInfo_db.py (file contents):
Revision 1.33 by grchrist, Mon Jul 2 12:52:29 2012 UTC vs.
Revision 1.37 by amott, Mon Sep 17 15:09:26 2012 UTC

# Line 2 | Line 2 | import sys
2   from colors import *
3   from DatabaseParser import *
4   from termcolor import colored, cprint
5 + from StreamMonitor import *
6 + import time
7 +
8 +
9   write = sys.stdout.write
10  
11 < NHighExpress=0
12 < NHighStreamA=0
11 > NHighStreamA = 0
12 > NHighExpress = 0
13  
14   def MoreTableInfo(parser,LumiRange,config,isCol=True):
15      print "Monitoring Run %d" % (parser.RunNumber,)
16 <    print "len=",len(LumiRange)
17 <    print "LSRange=", LumiRange
16 >    localtime = time.asctime( time.localtime(time.time()) )
17 >    print "Local current time :", localtime
18 >    #print "Lumisections used=", LumiRange
19      if len(LumiRange)>0:
20          
21          [AvInstLumi, AvLiveLumi, AvDeliveredLumi, AvDeadTime,PSCols] = parser.GetAvLumiInfo(LumiRange)
22          deadtimebeamactive=parser.GetDeadTimeBeamActive(LumiRange)*100
23 +        
24          ##print "dtba=",deadtimebeamactive
25      else:
26          print "no lumisections to monitor"
27          return
28 +  ## check if lumi is being filled
29 +    if parser.LastLSParsed > 4:
30 +        if set(parser.InstLumiByLS.values()) == set([None]):
31 +            write(colored("LUMI INFORMATION NOT BEING SENT!\n",'red',attrs=['reverse']))
32 +            write(colored("Check with Shift Leader if this is expected\n",'red',attrs=['reverse']))
33 +            write(colored("If not, call Lumi DOC\n",'red',attrs=['reverse']))
34 +            return
35 +                                                                                                                                                                                                                                                                    
36 +    try:
37 +        #print "trying v3"
38 +        lograte=parser.GetTriggerRatesByLS("HLT_LogMonitor_v3")
39 +        #print lograte
40 +        if not len(lograte):
41 +            #print "trying v4"
42 +            lograte=parser.GetTriggerRatesByLS("HLT_LogMonitor_v4")
43 +            
44 +        #print lograte
45 +        for lumi in lograte.iterkeys():
46 +            #print lumi, lograte[lumi]
47 +            if lograte[lumi]>config.MaxLogMonRate:
48 +                write(bcolors.WARNING)
49 +                print lograte[lumi], "post to elog. LogMonitor rate is high."
50 +                write(bcolors.ENDC+"\n")
51 +    except:
52 +        write(bcolors.WARNING)
53 +        print "problem getting log monitor rates"
54 +        write(bcolors.ENDC+"\n")
55 +
56      try:
57          LastPSCol = PSCols[-1]
58      except:
59          LastPSCol = -1
26 –    if isCol:
27 –        
28 –        aRates = parser.GetTriggerRatesByLS("AOutput")
29 –        bRates = parser.GetTriggerRatesByLS("BOutput")
30 –        if len(bRates) == 0:
31 –            realARates = aRates
32 –        else:
33 –            realARates={}
34 –            for k,v in bRates.iteritems():
35 –                realARates[k]=aRates[k]-bRates[k]*20
36 –                #realARates = aRates - bRates*20;
37 –    else:
38 –        if len(parser.GetTriggerRatesByLS("AOutput"))>0:
39 –            aRates = parser.GetTriggerRatesByLS("AOutput")
40 –            bRates = parser.GetTriggerRatesByLS("BOutput")
41 –        else:
42 –            aRates = parser.GetTriggerRatesByLS("AForPPOutput")
43 –            bRates = parser.GetTriggerRatesByLS("BForPPOutput")
44 –            
60      
61      expressRates = {}
62      if isCol:
63          expressRates = parser.GetTriggerRatesByLS("ExpressOutput")
64      else:
65          if len(parser.GetTriggerRatesByLS("ExpressOutput"))>0:
66 <            expressRates=parser.GetTriggerRatesByLS("ExpressOutput")
66 >            expressRates=parser.GetTriggerRatesByLS("else")
67          else:
68              expressRates = parser.GetTriggerRatesByLS("ExpressForCosmicsOutput")
69 +
70      ExpRate=0
71      PeakRate=0
72      AvgExpRate=0
73      
58 –    ARate=0
59 –    PeakRateA=0
60 –    AvgRateA=0
61 –    
62 –    realARate=0
63 –    realPeakRateA=0
64 –    realAvgRateA=0
65 –    
74      if len(expressRates.values()) > 20:
75          AvgExpRate = sum(expressRates.values())/len(expressRates.values())
76 +    counter=0    
77  
78      for ls in LumiRange:  ## Find the sum and peak express stream rates
79          thisR = expressRates.get(ls,0)
# Line 72 | Line 81 | def MoreTableInfo(parser,LumiRange,confi
81          if thisR>PeakRate:
82              PeakRate=thisR
83  
84 <        thisRateA=aRates.get(ls,0)
76 <        ARate+=thisRateA
77 <        if thisRateA>PeakRateA:
78 <            PeakRateA=thisRateA
79 <
80 <        thisRealRateA = aRates.get(ls,0) - bRates.get(ls,0)*20
81 <        realARate+=thisRealRateA
82 <        if thisRealRateA > realPeakRateA:
83 <            realReakRateA = thisRealRateA
84 <        #ARate+=aRates.get(ls,0)
84 >
85      ## Print Stream A Rate --moved see below
86      ##print "Current Steam A Rate is: %0.1f Hz" % (ARate/len(LumiRange),)
87  
# Line 90 | Line 90 | def MoreTableInfo(parser,LumiRange,confi
90      ##########################################
91      ## Check if the express stream is too high or low
92      ##########################################
93 –    global NHighExpress
93      badExpress = ((ExpRate/len(LumiRange) > config.MaxExpressRate) or (ExpRate/len(LumiRange)<0.1 and isCol)) ## avg express stream rate too high?
94      baseText = "\nCurrent Express Stream rate is: %0.1f Hz" % (ExpRate/len(LumiRange),) ## text to display
95      if badExpress:
# Line 121 | Line 120 | def MoreTableInfo(parser,LumiRange,confi
120      ##Check if Stream A is too high
121      #########################################
122      global NHighStreamA
123 <    badStreamA =realARate/len(LumiRange) > config.MaxStreamARate ##Cosmics Express Rate 300 Hz max
124 <    baseTextA= "\nCurrent Steam A Rate is: %0.1f Hz" % (ARate/len(LumiRange),)
125 <    baseTextRealA= "\nCurrent PROMPT Steam A Rate is: %0.1f Hz" % (realARate/len(LumiRange),)
126 <    if badStreamA:
127 <        textA=colored(baseTextA,'red',attrs=['reverse'])  ## bad, make the text white on red
128 <        textRealA=colored(baseTextRealA,'red',attrs=['reverse'])  ## bad, make the text white on red
129 <        NHighStreamA+=1
130 <    else:
131 <        textA=baseTextA
132 <        textRealA=baseTextRealA
133 <        NHighStreamA=0
134 <
135 <    write(textA)
136 <    write(textRealA)
137 <    if badStreamA:
138 <        if len(LumiRange)>1:
139 <            if (realARate-realPeakRateA)/(len(LumiRange)-1) <=config.MaxStreamARate: ## one lumisection causes this
123 >    stream_mon = StreamMonitor()
124 >    core_a_rates = stream_mon.getStreamACoreRatesByLS(parser,LumiRange,config,isCol).values()
125 >    a_rates = stream_mon.getStreamARatesByLS(parser,LumiRange).values()
126 >    peak_core_a_rate = max(core_a_rates)
127 >
128 >    if len(LumiRange) > 0:
129 >        avg_core_a_rate = sum(core_a_rates)/len(LumiRange)
130 >        avg_a_rate = sum(a_rates)/len(LumiRange)
131 >        badStreamA = stream_mon.compareStreamARate(config, avg_core_a_rate, LumiRange,AvInstLumi,isCol)
132 >
133 >        baseTextA= "\nCurrent Stream A Rate is: %0.1f Hz" % (avg_a_rate)
134 >        baseTextRealA= "\nCurrent PROMPT Stream A Rate is: %0.1f Hz" % (avg_core_a_rate)
135 >
136 >        if badStreamA:
137 >            textA=colored(baseTextA,'red',attrs=['reverse'])  ## bad, make the text white on red
138 >            textRealA=colored(baseTextRealA,'red',attrs=['reverse'])  ## bad, make the text white on red
139 >            NHighStreamA+=1
140 >        else:
141 >            textA=baseTextA
142 >            textRealA=baseTextRealA
143 >
144 >        write(textA)
145 >        write(textRealA)
146 >    
147 >        if badStreamA and len(LumiRange) > 1:
148 >            trimmed_core_a_rates = core_a_rates
149 >            trimmed_core_a_rates.remove(peak_core_a_rate)
150 >            if sum(trimmed_core_a_rates)/(len(LumiRange)-1) <= config.MaxStreamARate: ## one lumisection causes this
151                  write("  <<  This appears to be due to a 1 lumisection spike, please monitor\n")
152              else:
153 <                if NHighStreamA >1: ##Call HLT doc!
153 >                if NHighStreamA > 1: ##Call HLT doc!
154                      write(colored("  <<  WARNING: Current Stream A rate is too high!",'red',attrs=['reverse']) )
155                      Warn = True
156      write("\n\n")
# Line 156 | Line 166 | def MoreTableInfo(parser,LumiRange,confi
166  
167          write( colored(line,'red',attrs=['reverse','blink']) )
168          write( colored("*"*cols+"\n",'red',attrs=['reverse','blink']) )
169 <    
169 >        
170      
171      PrescaleColumnString=''
172      PSCols = list(set(PSCols))

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines