blob: 21f918617804202e7849d6c00fd6b162631e4f9b [file] [log] [blame]
Jeremy Ronquillob27ce4c2017-07-17 12:41:28 -07001"""
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -07002Copyright 2015 Open Networking Foundation ( ONF )
Jeremy Ronquillob27ce4c2017-07-17 12:41:28 -07003
4Please refer questions to either the onos test mailing list at <onos-test@onosproject.org>,
5the System Testing Plans and Results wiki page at <https://wiki.onosproject.org/x/voMg>,
6or the System Testing Guide page at <https://wiki.onosproject.org/x/WYQg>
7
8 TestON is free software: you can redistribute it and/or modify
9 it under the terms of the GNU General Public License as published by
10 the Free Software Foundation, either version 2 of the License, or
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -070011 ( at your option ) any later version.
Jeremy Ronquillob27ce4c2017-07-17 12:41:28 -070012
13 TestON is distributed in the hope that it will be useful,
14 but WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 GNU General Public License for more details.
17
18 You should have received a copy of the GNU General Public License
19 along with TestON. If not, see <http://www.gnu.org/licenses/>.
20"""
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -070021"""
YPZhang38fb1192016-08-11 11:03:38 -070022 SCPFswitchLat
23 Test Switch add/remove latency
24 calculate package latency between switch and ONOS
25 Switch UP:
26 TCP -- Feature Reply -- Role Request -- Role Reply -- Device -- Graph
27 Siwtch Down:
28 Openflow FIN/ACK -- ACK -- Device -- Graph
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -070029"""
cameron@onlab.us21106ea2015-07-23 15:32:51 -070030class SCPFswitchLat:
31
Devin Lim142b5342017-07-20 15:22:39 -070032 def __init__( self ):
cameron@onlab.us21106ea2015-07-23 15:32:51 -070033 self.default = ''
34
YPZhang38fb1192016-08-11 11:03:38 -070035 def CASE0( self, main ):
cameron@onlab.us21106ea2015-07-23 15:32:51 -070036 import os
YPZhang38fb1192016-08-11 11:03:38 -070037 import imp
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -070038 """
YPZhang38fb1192016-08-11 11:03:38 -070039 - GIT
40 - BUILDING ONOS
41 Pull specific ONOS branch, then Build ONOS ono ONOS Bench.
42 This step is usually skipped. Because in a Jenkins driven automated
43 test env. We want Jenkins jobs to pull&build for flexibility to handle
44 different versions of ONOS.
45 - Construct tests variables
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -070046 """
Devin Lim58046fa2017-07-05 16:55:00 -070047 try:
48 from tests.dependencies.ONOSSetup import ONOSSetup
49 main.testSetUp = ONOSSetup()
50 except ImportError:
51 main.log.error( "ONOSSetup not found. exiting the test" )
Devin Lim44075962017-08-11 10:56:37 -070052 main.cleanAndExit()
Devin Lim58046fa2017-07-05 16:55:00 -070053 main.testSetUp.envSetupDescription()
54 stepResult = main.FALSE
55 try:
56 # The dictionary to record different type of wrongs
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -070057 main.wrong = { 'totalWrong': 0, 'skipDown': 0, 'TsharkValueIncorrect': 0,
58 'TypeError': 0, 'decodeJasonError': 0,
59 'checkResultIncorrect': 0 }
60 main.maxWrong = int( main.params[ 'TEST' ][ 'MaxWrong' ] )
Devin Lim142b5342017-07-20 15:22:39 -070061 main.resultRange = main.params[ 'TEST' ][ 'ResultRange' ]
62 main.searchTerm = main.params[ 'TEST' ][ 'SearchTerm' ]
63 main.MN1Ip = main.params[ 'MN' ][ 'ip1' ]
Devin Lim58046fa2017-07-05 16:55:00 -070064 main.dependencyPath = main.testOnDirectory + \
Devin Lim142b5342017-07-20 15:22:39 -070065 main.params[ 'DEPENDENCY' ][ 'path' ]
66 main.topoName = main.params[ 'DEPENDENCY' ][ 'topology' ]
67 main.dependencyFunc = main.params[ 'DEPENDENCY' ][ 'function' ]
68 main.cellName = main.params[ 'ENV' ][ 'cellName' ]
69 main.apps = main.params[ 'ENV' ][ 'cellApps' ]
70 main.scale = ( main.params[ 'SCALE' ] ).split( "," )
YPZhang38fb1192016-08-11 11:03:38 -070071
Devin Lim142b5342017-07-20 15:22:39 -070072 main.ofPackage = main.params[ 'TSHARK' ]
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -070073 main.defaultTopoCfg = main.params[ 'CFG' ][ 'defaultTopo' ]
Devin Lim142b5342017-07-20 15:22:39 -070074 main.tsharkResultPath = main.params[ 'TEST' ][ 'tsharkResultPath' ]
75 main.sampleSize = int( main.params[ 'TEST' ][ 'sampleSize' ] )
76 main.warmUp = int( main.params[ 'TEST' ][ 'warmUp' ] )
77 main.dbFileName = main.params[ 'DATABASE' ][ 'dbName' ]
78 main.startUpSleep = int( main.params[ 'SLEEP' ][ 'startup' ] )
79 main.measurementSleep = int( main.params[ 'SLEEP' ][ 'measure' ] )
80 main.deleteSwSleep = int( main.params[ 'SLEEP' ][ 'deleteSW' ] )
81 main.maxScale = int( main.params[ 'max' ] )
82 main.timeout = int( main.params[ 'TIMEOUT' ][ 'timeout' ] )
83 main.MNSleep = int( main.params[ 'SLEEP' ][ 'mininet' ] )
84 main.device = main.params[ 'TEST' ][ 'device' ]
85 stepResult = main.testSetUp.envSetup()
86 main.log.info( "Create Database file " + main.dbFileName )
87 resultsDB = open( main.dbFileName, "w+" )
Devin Lim58046fa2017-07-05 16:55:00 -070088 resultsDB.close()
YPZhang38fb1192016-08-11 11:03:38 -070089
Devin Lim142b5342017-07-20 15:22:39 -070090 main.switchFunc = imp.load_source( main.dependencyFunc,
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -070091 main.dependencyPath +
92 main.dependencyFunc +
93 ".py" )
Devin Lim58046fa2017-07-05 16:55:00 -070094 except Exception as e:
95 main.testSetUp.envSetupException( e )
Jon Hallaa1d9b82020-07-30 13:49:42 -070096 main.testSetUp.envSetupConclusion( stepResult )
Devin Lim58046fa2017-07-05 16:55:00 -070097 main.commit = main.commit.split( " " )[ 1 ]
You Wang0e4ca9e2017-08-04 16:40:33 -070098
Devin Lim142b5342017-07-20 15:22:39 -070099 def CASE1( self, main ):
YPZhang38fb1192016-08-11 11:03:38 -0700100 # Clean up test environment and set up
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700101 import time
Devin Lim58046fa2017-07-05 16:55:00 -0700102 try:
103 from tests.dependencies.utils import Utils
104 except ImportError:
105 main.log.error( "Utils not found exiting the test" )
Devin Lim44075962017-08-11 10:56:37 -0700106 main.cleanAndExit()
Devin Lim58046fa2017-07-05 16:55:00 -0700107 try:
108 main.Utils
109 except ( NameError, AttributeError ):
110 main.Utils = Utils()
111 main.maxNumBatch = 0
You Wanga0f6ff62018-01-11 15:46:30 -0800112 main.testSetUp.ONOSSetUp( main.Cluster, True,
Devin Lim142b5342017-07-20 15:22:39 -0700113 cellName=main.cellName, killRemoveMax=False )
YPZhang38fb1192016-08-11 11:03:38 -0700114
Devin Lim142b5342017-07-20 15:22:39 -0700115 main.log.info( "Configure apps" )
116 main.Cluster.active( 0 ).CLI.setCfg( main.defaultTopoCfg,
117 "maxEvents 1" )
118 main.Cluster.active( 0 ).CLI.setCfg( main.defaultTopoCfg,
119 "maxBatchMs 0" )
120 main.Cluster.active( 0 ).CLI.setCfg( main.defaultTopoCfg,
121 "maxIdleMs 0" )
122 main.Cluster.command( "logSet",
123 args=[ "DEBUG", "org.onosproject.metrics.topology" ],
124 specificDriver=2 )
125 time.sleep( 1 )
YPZhang38fb1192016-08-11 11:03:38 -0700126
Devin Lim142b5342017-07-20 15:22:39 -0700127 main.log.info( "Copy topology file to Mininet" )
128 main.ONOSbench.copyMininetFile( main.topoName,
129 main.dependencyPath,
130 main.Mininet1.user_name,
131 main.Mininet1.ip_address )
Devin Lim58046fa2017-07-05 16:55:00 -0700132 main.Utils.mininetCleanup( main.Mininet1 )
Devin Lim142b5342017-07-20 15:22:39 -0700133 time.sleep( main.MNSleep )
134 main.log.info( "Start new mininet topology" )
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700135 main.Mininet1.startNet()
Devin Lim142b5342017-07-20 15:22:39 -0700136 main.log.info( "Assign switch to controller to ONOS node 1" )
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700137
Devin Lim142b5342017-07-20 15:22:39 -0700138 time.sleep( 2 )
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700139
Devin Lim142b5342017-07-20 15:22:39 -0700140 def CASE2( self, main ):
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700141 import time
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700142 import json
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700143 import numpy
144
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -0700145 resultDict = { 'up': {}, 'down': {} }
Devin Lim142b5342017-07-20 15:22:39 -0700146 for i in range( 1, main.Cluster.numCtrls + 1 ):
147 resultDict[ 'up' ][ 'node' + str( i ) ] = {}
148 resultDict[ 'up' ][ 'node' + str( i ) ][ 'Ave' ] = {}
149 resultDict[ 'up' ][ 'node' + str( i ) ][ 'Std' ] = {}
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -0700150 resultDict[ 'up' ][ 'node' + str( i ) ][ 'T_F' ] = [] # TCP to Feature
Devin Limf70bb3a2018-04-13 19:15:51 -0700151 resultDict[ 'up' ][ 'node' + str( i ) ][ 'F_D' ] = [] # Feature to Device
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -0700152 resultDict[ 'up' ][ 'node' + str( i ) ][ 'D_G' ] = [] # Device to Graph
153 resultDict[ 'up' ][ 'node' + str( i ) ][ 'E_E' ] = [] # TCP to Graph
Jon Hall4ba53f02015-07-29 13:07:41 -0700154
Devin Lim142b5342017-07-20 15:22:39 -0700155 for i in range( 1, main.Cluster.numCtrls + 1 ):
156 resultDict[ 'down' ][ 'node' + str( i ) ] = {}
157 resultDict[ 'down' ][ 'node' + str( i ) ][ 'Ave' ] = {}
158 resultDict[ 'down' ][ 'node' + str( i ) ][ 'Std' ] = {}
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -0700159 resultDict[ 'down' ][ 'node' + str( i ) ][ 'FA_A' ] = [] # Fin_ack to ACK
160 resultDict[ 'down' ][ 'node' + str( i ) ][ 'A_D' ] = [] # Ack to Device
161 resultDict[ 'down' ][ 'node' + str( i ) ][ 'D_G' ] = [] # Device to Graph
162 resultDict[ 'down' ][ 'node' + str( i ) ][ 'E_E' ] = [] # fin_ack to Graph
You Wang51f903b2017-08-04 16:22:48 -0700163 for i in range( 0, main.sampleSize + main.warmUp ):
Devin Lim142b5342017-07-20 15:22:39 -0700164 main.log.info( "************************************************************" )
You Wang51f903b2017-08-04 16:22:48 -0700165 main.log.info( "************************ Iteration: {} **********************" .format( str( i + 1 ) ) )
YPZhang38fb1192016-08-11 11:03:38 -0700166 if i < main.warmUp:
167 main.switchFunc.captureOfPack( main, main.device, main.ofPackage,
168 "up", resultDict, True )
169 main.switchFunc.captureOfPack( main, main.device, main.ofPackage,
170 "down", resultDict, True )
You Wanga3649ee2018-04-19 16:57:18 -0700171 main.log.debug( "Before devices : " + str( main.Cluster.active( 0 ).CLI.devices() ) )
Devin Lim142b5342017-07-20 15:22:39 -0700172 main.Cluster.active( 0 ).CLI.removeDevice( "of:0000000000000001" )
You Wanga3649ee2018-04-19 16:57:18 -0700173 main.log.debug( "After devices : " + str( main.Cluster.active( 0 ).CLI.devices() ) )
Devin Limaa256a72017-10-13 13:40:30 -0700174 while main.Cluster.active( 0 ).CLI.devices() != "[]":
175 main.log.error( "DEVICE NOT REMOVED !!!!!")
176 main.Cluster.active( 0 ).CLI.removeDevice( "of:0000000000000001" )
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700177 else:
YPZhang38fb1192016-08-11 11:03:38 -0700178 main.switchFunc.captureOfPack( main, main.device, main.ofPackage,
179 "up", resultDict, False )
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -0700180 main.switchFunc.captureOfPack( main, main.device, main.ofPackage,
181 "down", resultDict, False )
You Wanga3649ee2018-04-19 16:57:18 -0700182 main.log.debug( "Before devices : " + str( main.Cluster.active( 0 ).CLI.devices() ) )
Devin Lim142b5342017-07-20 15:22:39 -0700183 main.Cluster.active( 0 ).CLI.removeDevice( "of:0000000000000001" )
You Wanga3649ee2018-04-19 16:57:18 -0700184 main.log.debug("After devices : " + str(main.Cluster.active(0).CLI.devices()))
Devin Limaa256a72017-10-13 13:40:30 -0700185 while main.Cluster.active( 0 ).CLI.devices() != "[]":
186 main.log.error( "DEVICE NOT REMOVED !!!!!")
187 main.Cluster.active( 0 ).CLI.removeDevice( "of:0000000000000001" )
chengchiyu08303a02016-09-08 17:40:26 -0700188
YPZhang38fb1192016-08-11 11:03:38 -0700189 # Dictionary for result
Jeremy Ronquillo23fb2162017-09-15 14:59:57 -0700190 maxDict = {}
Devin Lim142b5342017-07-20 15:22:39 -0700191 maxDict[ 'down' ] = {}
192 maxDict[ 'up' ] = {}
193 maxDict[ 'down' ][ 'max' ] = 0
194 maxDict[ 'up' ][ 'max' ] = 0
195 maxDict[ 'down' ][ 'node' ] = 0
196 maxDict[ 'up' ][ 'node' ] = 0
Jon Hall4ba53f02015-07-29 13:07:41 -0700197
Devin Lim142b5342017-07-20 15:22:39 -0700198 for i in range( 1, main.Cluster.numCtrls + 1 ):
YPZhang38fb1192016-08-11 11:03:38 -0700199 # calculate average and std for result, and grep the max End to End data
Devin Lim142b5342017-07-20 15:22:39 -0700200 EtoEtemp = numpy.average( resultDict[ 'up' ][ 'node' + str( i ) ][ 'E_E' ] )
201 resultDict[ 'up' ][ 'node' + str( i ) ][ 'Ave' ][ 'E_E' ] = EtoEtemp
202 if maxDict[ 'up' ][ 'max' ] < EtoEtemp:
YPZhang38fb1192016-08-11 11:03:38 -0700203 # get max End to End latency
Devin Lim142b5342017-07-20 15:22:39 -0700204 maxDict[ 'up' ][ 'max' ] = EtoEtemp
205 maxDict[ 'up' ][ 'node' ] = i
206 resultDict[ 'up' ][ 'node' + str( i ) ][ 'Ave' ][ 'T_F' ] = numpy.average( resultDict[ 'up' ][ 'node' + str( i ) ][ 'T_F' ] )
Devin Limf70bb3a2018-04-13 19:15:51 -0700207 resultDict[ 'up' ][ 'node' + str( i ) ][ 'Ave' ][ 'F_D' ] = numpy.average( resultDict[ 'up' ][ 'node' + str( i ) ][ 'F_D' ] )
Devin Lim142b5342017-07-20 15:22:39 -0700208 resultDict[ 'up' ][ 'node' + str( i ) ][ 'Ave' ][ 'D_G' ] = numpy.average( resultDict[ 'up' ][ 'node' + str( i ) ][ 'D_G' ] )
Jon Hall4ba53f02015-07-29 13:07:41 -0700209
Devin Lim142b5342017-07-20 15:22:39 -0700210 resultDict[ 'up' ][ 'node' + str( i ) ][ 'Std' ][ 'E_E' ] = numpy.std( resultDict[ 'up' ][ 'node' + str( i ) ][ 'E_E' ] )
211 resultDict[ 'up' ][ 'node' + str( i ) ][ 'Std' ][ 'T_F' ] = numpy.std( resultDict[ 'up' ][ 'node' + str( i ) ][ 'T_F' ] )
Devin Limf70bb3a2018-04-13 19:15:51 -0700212 resultDict[ 'up' ][ 'node' + str( i ) ][ 'Std' ][ 'F_D' ] = numpy.std( resultDict[ 'up' ][ 'node' + str( i ) ][ 'F_D' ] )
Devin Lim142b5342017-07-20 15:22:39 -0700213 resultDict[ 'up' ][ 'node' + str( i ) ][ 'Std' ][ 'D_G' ] = numpy.std( resultDict[ 'up' ][ 'node' + str( i ) ][ 'D_G' ] )
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700214
YPZhang38fb1192016-08-11 11:03:38 -0700215 # calculate average and std for result, and grep the max End to End data
Devin Lim142b5342017-07-20 15:22:39 -0700216 EtoEtemp = numpy.average( resultDict[ 'down' ][ 'node' + str( i ) ][ 'E_E' ] )
217 resultDict[ 'down' ][ 'node' + str( i ) ][ 'Ave' ][ 'E_E' ] = EtoEtemp
218 if maxDict[ 'down' ][ 'max' ] < EtoEtemp:
YPZhang38fb1192016-08-11 11:03:38 -0700219 # get max End to End latency
Devin Lim142b5342017-07-20 15:22:39 -0700220 maxDict[ 'down' ][ 'max' ] = EtoEtemp
221 maxDict[ 'down' ][ 'node' ] = i
222 resultDict[ 'down' ][ 'node' + str( i ) ][ 'Ave' ][ 'FA_A' ] = numpy.average( resultDict[ 'down' ][ 'node' + str( i ) ][ 'FA_A' ] )
223 resultDict[ 'down' ][ 'node' + str( i ) ][ 'Ave' ][ 'A_D' ] = numpy.average( resultDict[ 'down' ][ 'node' + str( i ) ][ 'A_D' ] )
224 resultDict[ 'down' ][ 'node' + str( i ) ][ 'Ave' ][ 'D_G' ] = numpy.average( resultDict[ 'down' ][ 'node' + str( i ) ][ 'D_G' ] )
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700225
Devin Lim142b5342017-07-20 15:22:39 -0700226 resultDict[ 'down' ][ 'node' + str( i ) ][ 'Std' ][ 'E_E' ] = numpy.std( resultDict[ 'down' ][ 'node' + str( i ) ][ 'E_E' ] )
227 resultDict[ 'down' ][ 'node' + str( i ) ][ 'Std' ][ 'FA_A' ] = numpy.std( resultDict[ 'down' ][ 'node' + str( i ) ][ 'FA_A' ] )
228 resultDict[ 'down' ][ 'node' + str( i ) ][ 'Std' ][ 'A_D' ] = numpy.std( resultDict[ 'down' ][ 'node' + str( i ) ][ 'A_D' ] )
229 resultDict[ 'down' ][ 'node' + str( i ) ][ 'Std' ][ 'D_G' ] = numpy.std( resultDict[ 'down' ][ 'node' + str( i ) ][ 'D_G' ] )
Jon Hall4ba53f02015-07-29 13:07:41 -0700230
Devin Lim142b5342017-07-20 15:22:39 -0700231 main.log.report( "=====node{} Summary:=====".format( str( i ) ) )
YPZhang38fb1192016-08-11 11:03:38 -0700232 main.log.report( "=============Switch up=======" )
You Wang28cb8552019-02-19 16:11:52 -0800233 main.log.report( "End to End average: {}".format( str( resultDict[ "up" ][ 'node' + str( i ) ][ 'Ave' ][ 'E_E' ] ) ) )
234 main.log.report( "End to End Std: {}".format( str( resultDict[ "up" ][ 'node' + str( i ) ][ 'Std' ][ 'E_E' ] ) ) )
235 main.log.report( "TCP to Feature average: {}".format( str( resultDict[ "up" ][ 'node' + str( i ) ][ 'Ave' ][ 'T_F' ] ) ) )
236 main.log.report( "TCP to Feature Std: {}".format( str( resultDict[ "up" ][ 'node' + str( i ) ][ 'Std' ][ 'T_F' ] ) ) )
237 main.log.report( "Feature to Device average: {}".format( str( resultDict[ "up" ][ 'node' + str( i ) ][ 'Ave' ][ 'F_D' ] ) ) )
238 main.log.report( "Feature to Device Std: {}".format( str( resultDict[ "up" ][ 'node' + str( i ) ][ 'Std' ][ 'F_D' ] ) ) )
239 main.log.report( "Device to Graph average: {}".format( str( resultDict[ "up" ][ 'node' + str( i ) ][ 'Ave' ][ 'D_G' ] ) ) )
240 main.log.report( "Device to Graph Std: {}".format( str( resultDict[ "up" ][ 'node' + str( i ) ][ 'Std' ][ 'D_G' ] ) ) )
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700241
YPZhang38fb1192016-08-11 11:03:38 -0700242 main.log.report( "=============Switch down=======" )
You Wang28cb8552019-02-19 16:11:52 -0800243 main.log.report( "End to End average: {}".format( str( resultDict[ "down" ][ 'node' + str( i ) ][ 'Ave' ][ 'E_E' ] ) ) )
244 main.log.report( "End to End Std: {}".format( str( resultDict[ "down" ][ 'node' + str( i ) ][ 'Std' ][ 'E_E' ] ) ) )
245 main.log.report( "Fin_ACK to ACK average: {}".format( str( resultDict[ "down" ][ 'node' + str( i ) ][ 'Ave' ][ 'FA_A' ] ) ) )
246 main.log.report( "Fin_ACK to ACK Std: {}".format( str( resultDict[ "down" ][ 'node' + str( i ) ][ 'Std' ][ 'FA_A' ] ) ) )
247 main.log.report( "ACK to Device average: {}".format( str( resultDict[ "down" ][ 'node' + str( i ) ][ 'Ave' ][ 'A_D' ] ) ) )
248 main.log.report( "ACK to Device Std: {}".format( str( resultDict[ "down" ][ 'node' + str( i ) ][ 'Std' ][ 'A_D' ] ) ) )
249 main.log.report( "Device to Graph average: {}".format( str( resultDict[ "down" ][ 'node' + str( i ) ][ 'Ave' ][ 'D_G' ] ) ) )
250 main.log.report( "Device to Graph Std: {}".format( str( resultDict[ "down" ][ 'node' + str( i ) ][ 'Std' ][ 'D_G' ] ) ) )
Jon Hall4ba53f02015-07-29 13:07:41 -0700251
You Wang28cb8552019-02-19 16:11:52 -0800252 # Check if any result is abnormal
You Wangaa7bc722019-02-21 17:55:39 -0800253 # Switch-up
You Wang28cb8552019-02-19 16:11:52 -0800254 result = resultDict[ 'up' ][ 'node' + str( maxDict[ 'up' ][ 'node' ] ) ][ 'Ave' ][ 'E_E' ]
You Wangaa7bc722019-02-21 17:55:39 -0800255 threshold = float( main.params[ 'ALARM' ][ 'maxSwitchUpAvg' ].split( ',' )[ main.cycle - 1 ] )
256 if result > threshold:
257 main.log.alarm( "{}-node switch-up avg: {} ms > {} ms".format( main.Cluster.numCtrls, result, threshold ) )
You Wang28cb8552019-02-19 16:11:52 -0800258 result = resultDict[ 'up' ][ 'node' + str( maxDict[ 'up' ][ 'node' ] ) ][ 'Std' ][ 'E_E' ]
You Wangaa7bc722019-02-21 17:55:39 -0800259 threshold = float( main.params[ 'ALARM' ][ 'maxSwitchUpStd' ].split( ',' )[ main.cycle - 1 ] )
260 if result > threshold:
261 main.log.alarm( "{}-node switch-up std: {} ms > {} ms".format( main.Cluster.numCtrls, result, threshold ) )
262 # Switch-down
You Wang28cb8552019-02-19 16:11:52 -0800263 result = resultDict[ 'down' ][ 'node' + str( maxDict[ 'down' ][ 'node' ] ) ][ 'Ave' ][ 'E_E' ]
You Wangaa7bc722019-02-21 17:55:39 -0800264 threshold = float( main.params[ 'ALARM' ][ 'maxSwitchDownAvg' ].split( ',' )[ main.cycle - 1 ] )
265 if result > threshold:
266 main.log.alarm( "{}-node switch-down avg: {} ms > {} ms".format( main.Cluster.numCtrls, result, threshold ) )
You Wang28cb8552019-02-19 16:11:52 -0800267 result = resultDict[ 'down' ][ 'node' + str( maxDict[ 'down' ][ 'node' ] ) ][ 'Std' ][ 'E_E' ]
You Wangaa7bc722019-02-21 17:55:39 -0800268 threshold = float( main.params[ 'ALARM' ][ 'maxSwitchDownStd' ].split( ',' )[ main.cycle - 1 ] )
269 if result > threshold:
270 main.log.alarm( "{}-node switch-down std: {} ms > {} ms".format( main.Cluster.numCtrls, result, threshold ) )
Jon Hall4ba53f02015-07-29 13:07:41 -0700271
Devin Lim142b5342017-07-20 15:22:39 -0700272 with open( main.dbFileName, "a" ) as dbFile:
YPZhang38fb1192016-08-11 11:03:38 -0700273 # Scale number
Devin Lim142b5342017-07-20 15:22:39 -0700274 temp = str( main.Cluster.numCtrls )
YPZhang38fb1192016-08-11 11:03:38 -0700275 temp += ",'baremetal1'"
276 # put result
Devin Lim142b5342017-07-20 15:22:39 -0700277 temp += "," + str( "%.2f" % resultDict[ 'up' ][ 'node' + str( maxDict[ 'up' ][ 'node' ] ) ][ 'Ave' ][ 'E_E' ] )
278 temp += "," + str( "%.2f" % resultDict[ 'up' ][ 'node' + str( maxDict[ 'up' ][ 'node' ] ) ][ 'Ave' ][ 'T_F' ] )
Devin Limf70bb3a2018-04-13 19:15:51 -0700279 temp += "," + str( "%.2f" % resultDict[ 'up' ][ 'node' + str( maxDict[ 'up' ][ 'node' ] ) ][ 'Ave' ][ 'F_D' ] )
Devin Lim142b5342017-07-20 15:22:39 -0700280 temp += "," + str( "%.2f" % resultDict[ 'up' ][ 'node' + str( maxDict[ 'up' ][ 'node' ] ) ][ 'Ave' ][ 'D_G' ] )
cameron@onlab.us21106ea2015-07-23 15:32:51 -0700281
Devin Lim142b5342017-07-20 15:22:39 -0700282 temp += "," + str( "%.2f" % resultDict[ 'down' ][ 'node' + str( maxDict[ 'down' ][ 'node' ] ) ][ 'Ave' ][ 'E_E' ] )
283 temp += "," + str( "%.2f" % resultDict[ 'down' ][ 'node' + str( maxDict[ 'down' ][ 'node' ] ) ][ 'Ave' ][ 'FA_A' ] )
284 temp += "," + str( "%.2f" % resultDict[ 'down' ][ 'node' + str( maxDict[ 'down' ][ 'node' ] ) ][ 'Ave' ][ 'A_D' ] )
285 temp += "," + str( "%.2f" % resultDict[ 'down' ][ 'node' + str( maxDict[ 'down' ][ 'node' ] ) ][ 'Ave' ][ 'D_G' ] )
chengchiyuc6f4cc02016-08-24 14:04:20 -0700286
Devin Lim142b5342017-07-20 15:22:39 -0700287 temp += "," + str( "%.2f" % resultDict[ 'up' ][ 'node' + str( maxDict[ 'up' ][ 'node' ] ) ][ 'Std' ][ 'E_E' ] )
288 temp += "," + str( "%.2f" % resultDict[ 'down' ][ 'node' + str( maxDict[ 'down' ][ 'node' ] ) ][ 'Std' ][ 'E_E' ] )
chengchiyuc6f4cc02016-08-24 14:04:20 -0700289
YPZhang38fb1192016-08-11 11:03:38 -0700290 temp += "\n"
291 dbFile.write( temp )
292 dbFile.close()