ViewVC Help

View File | Revision Log | Show Annotations | Root Listing

root/cvsroot/UserCode/RateMonShiftTool_dev/AddTableInfo_db.py

Comparing UserCode/RateMonShiftTool_dev/AddTableInfo_db.py (file contents):
Revision 1.35 by grchrist, Tue Jul 17 15:12:27 2012 UTC vs.
Revision 1.39 by amott, Mon Sep 17 15:16:09 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		localtime = time.asctime( time.localtime(time.time()) )
17		print "Local current time :", localtime
17	–	#print "len=",len(LumiRange)
18		#print "Lumisections used=", LumiRange
19		if len(LumiRange)>0:
20
#	Line 25 | Line 25 | def MoreTableInfo(parser,LumiRange,confi
25		else:
26		print "no lumisections to monitor"
27		return
28	<
28	>	## check if lumi is being filled
29	>	if parser.LastLSParsed > 4:
30	>	if set(parser.InstLumiByLS.values()) == set([None]):
31	>	write(colored("\n\nLUMI 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, HFLUMI needs to be red-recycled\n\n\n",'red',attrs=['reverse']))
34	>	write(colored("If in doubt, call Lumi DOC\n\n\n",'red',attrs=['reverse']))
35	>	#return
36	>
37		try:
38		#print "trying v3"
39		lograte=parser.GetTriggerRatesByLS("HLT_LogMonitor_v3")
#	Line 50 | Line 58 | def MoreTableInfo(parser,LumiRange,confi
58		LastPSCol = PSCols[-1]
59		except:
60		LastPSCol = -1
53	–	if isCol:
54	–
55	–	aRates = parser.GetTriggerRatesByLS("AOutput")
56	–	aRatesPrompt = parser.GetTriggerRatesByLS("DQMOutput")
57	–	bRates = parser.GetTriggerRatesByLS("BOutput")
58	–	if len(bRates) == 0:
59	–	realARates = aRates
60	–	else:
61	–	realARates={}
62	–	for k,v in bRates.iteritems():
63	–	realARates[k]=aRates[k]-bRates[k]*20
64	–	#realARates = aRates - bRates*20;
65	–	else:
66	–	if len(parser.GetTriggerRatesByLS("AOutput"))>0:
67	–	aRates = parser.GetTriggerRatesByLS("AOutput")
68	–	bRates = parser.GetTriggerRatesByLS("BOutput")
69	–	else:
70	–	aRates = parser.GetTriggerRatesByLS("AForPPOutput")
71	–	bRates = parser.GetTriggerRatesByLS("BForPPOutput")
72	–
61
62		expressRates = {}
63		if isCol:
64		expressRates = parser.GetTriggerRatesByLS("ExpressOutput")
65		else:
66		if len(parser.GetTriggerRatesByLS("ExpressOutput"))>0:
67	<	expressRates=parser.GetTriggerRatesByLS("ExpressOutput")
67	>	expressRates=parser.GetTriggerRatesByLS("else")
68		else:
69		expressRates = parser.GetTriggerRatesByLS("ExpressForCosmicsOutput")
70	+
71		ExpRate=0
72		PeakRate=0
73		AvgExpRate=0
74
86	–	ARate=0
87	–	PeakRateA=0
88	–	AvgRateA=0
89	–
90	–	realARate=0
91	–
92	–	realPeakRateA=0
93	–	realAvgRateA=0
94	–
75		if len(expressRates.values()) > 20:
76		AvgExpRate = sum(expressRates.values())/len(expressRates.values())
77		counter=0
78	+
79		for ls in LumiRange:  ## Find the sum and peak express stream rates
80		thisR = expressRates.get(ls,0)
81		ExpRate+=thisR
82		if thisR>PeakRate:
83		PeakRate=thisR
84
85	<	thisRateA=aRates.get(ls,0)
105	<	ARate+=thisRateA
106	<	if thisRateA>PeakRateA:
107	<	PeakRateA=thisRateA
108	<	##print PSCols[counter]
109	<	if isCol:
110	<	if PSCols[counter]!=config.CircBeamCol:
111	<	thisRealRateA= aRatesPrompt.get(ls,0)*10
112	<	else:
113	<	thisRealRateA = aRates.get(ls,0) - bRates.get(ls,0)*20
114	<	else:
115	<	thisRealRateA = aRates.get(ls,0) - bRates.get(ls,0)*20
116	<	realARate+=thisRealRateA
117	<	if thisRealRateA > realPeakRateA:
118	<	realReakRateA = thisRealRateA
119	<	counter=counter+1
120	<	#ARate+=aRates.get(ls,0)
85	>
86		## Print Stream A Rate --moved see below
87		##print "Current Steam A Rate is: %0.1f Hz" % (ARate/len(LumiRange),)
88
#	Line 126 | Line 91 | def MoreTableInfo(parser,LumiRange,confi
91		##########################################
92		## Check if the express stream is too high or low
93		##########################################
129	–	global NHighExpress
94		badExpress = ((ExpRate/len(LumiRange) > config.MaxExpressRate) or (ExpRate/len(LumiRange)<0.1 and isCol)) ## avg express stream rate too high?
95		baseText = "\nCurrent Express Stream rate is: %0.1f Hz" % (ExpRate/len(LumiRange),) ## text to display
96		if badExpress:
#	Line 157 | Line 121 | def MoreTableInfo(parser,LumiRange,confi
121		##Check if Stream A is too high
122		#########################################
123		global NHighStreamA
124	<	badStreamA =realARate/len(LumiRange) > config.MaxStreamARate ##Cosmics Express Rate 300 Hz max
125	<	baseTextA= "\nCurrent Steam A Rate is: %0.1f Hz" % (ARate/len(LumiRange),)
126	<	baseTextRealA= "\nCurrent PROMPT Steam A Rate is: %0.1f Hz" % (realARate/len(LumiRange),)
127	<	if badStreamA:
128	<	textA=colored(baseTextA,'red',attrs=['reverse'])  ## bad, make the text white on red
129	<	textRealA=colored(baseTextRealA,'red',attrs=['reverse'])  ## bad, make the text white on red
130	<	NHighStreamA+=1
131	<	else:
132	<	textA=baseTextA
133	<	textRealA=baseTextRealA
134	<	NHighStreamA=0
135	<
136	<	write(textA)
137	<	write(textRealA)
138	<	if badStreamA:
139	<	if len(LumiRange)>1:
140	<	if (realARate-realPeakRateA)/(len(LumiRange)-1) <=config.MaxStreamARate: ## one lumisection causes this
124	>	stream_mon = StreamMonitor()
125	>	core_a_rates = stream_mon.getStreamACoreRatesByLS(parser,LumiRange,config,isCol).values()
126	>	a_rates = stream_mon.getStreamARatesByLS(parser,LumiRange).values()
127	>	peak_core_a_rate = max(core_a_rates)
128	>
129	>	if len(LumiRange) > 0:
130	>	avg_core_a_rate = sum(core_a_rates)/len(LumiRange)
131	>	avg_a_rate = sum(a_rates)/len(LumiRange)
132	>	badStreamA = stream_mon.compareStreamARate(config, avg_core_a_rate, LumiRange,AvInstLumi,isCol)
133	>
134	>	baseTextA= "\nCurrent Stream A Rate is: %0.1f Hz" % (avg_a_rate)
135	>	baseTextRealA= "\nCurrent PROMPT Stream A Rate is: %0.1f Hz" % (avg_core_a_rate)
136	>
137	>	if badStreamA:
138	>	textA=colored(baseTextA,'red',attrs=['reverse'])  ## bad, make the text white on red
139	>	textRealA=colored(baseTextRealA,'red',attrs=['reverse'])  ## bad, make the text white on red
140	>	NHighStreamA+=1
141	>	else:
142	>	textA=baseTextA
143	>	textRealA=baseTextRealA
144	>
145	>	write(textA)
146	>	write(textRealA)
147	>
148	>	if badStreamA and len(LumiRange) > 1:
149	>	trimmed_core_a_rates = core_a_rates
150	>	trimmed_core_a_rates.remove(peak_core_a_rate)
151	>	if sum(trimmed_core_a_rates)/(len(LumiRange)-1) <= config.MaxStreamARate: ## one lumisection causes this
152		write("  <<  This appears to be due to a 1 lumisection spike, please monitor\n")
153		else:
154	<	if NHighStreamA >1: ##Call HLT doc!
154	>	if NHighStreamA > 1: ##Call HLT doc!
155		write(colored("  <<  WARNING: Current Stream A rate is too high!",'red',attrs=['reverse']) )
156		Warn = True
157		write("\n\n")
#	Line 192 | Line 167 | def MoreTableInfo(parser,LumiRange,confi
167
168		write( colored(line,'red',attrs=['reverse','blink']) )
169		write( colored("*"*cols+"\n",'red',attrs=['reverse','blink']) )
170	<
170	>
171
172		PrescaleColumnString=''
173		PSCols = list(set(PSCols))

Diff Legend

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