3 # Thierry Parmentelat <thierry.parmentelat@inria.fr>
4 # Copyright (C) 2010 INRIA
6 import sys, os, os.path
7 from argparse import ArgumentParser
11 from datetime import datetime
14 from TestPlc import TestPlc, Ignored
15 from TestBonding import TestBonding, onelab_bonding_spec
16 from TestSite import TestSite
17 from TestNode import TestNode
18 from macros import sequences
20 # add $HOME in PYTHONPATH so we can import LocalSubstrate.py
21 sys.path.append(os.environ['HOME'])
26 natives = TestPlc.__dict__
29 return self.name.replace('_', '-')
31 return self.name.replace('-', '_')
33 def __init__ (self, name):
35 # a native step is implemented as a method on TestPlc
36 self.native = self.internal() in Step.natives
38 self.method = Step.natives[self.internal()]
41 self.substeps = sequences[self.internal()]
42 except Exception as e:
43 print("macro step {} not found in macros.py ({}) - exiting".format(self.display(),e))
46 def print_doc (self, level=0):
50 start = level*' ' + '* '
51 # 2 is the len of '* '
52 width = tab - level - 2
53 format = "%%-%ds" % width
54 line = start + format % self.display()
57 print(self.method.__doc__)
59 print("*** no doc found")
61 beg_start = level*' ' + '>>> '
62 end_start = level*' ' + '<<< '
64 # 4 is the len of '>>> '
65 width = tab - level - 4 - trail
66 format = "%%-%ds" % width
67 beg_line = beg_start + format % self.display() + trail*'>'
68 end_line = end_start + format % self.display() + trail*'<'
70 for step in self.substeps:
71 Step(step).print_doc(level+1)
74 # return a list of (name, method) for all native steps involved
77 return [ (self.internal(), self.method,) ]
80 for substep in [ Step(name) for name in self.substeps ] :
81 result += substep.tuples()
84 # convenience for listing macros
85 # just do a listdir, hoping we're in the right directory...
88 names= list(sequences.keys())
94 default_config = [ 'default' ]
95 # default_rspec_styles = [ 'pl', 'pg' ]
96 default_rspec_styles = [ 'pg' ]
98 default_build_url = "git://git.onelab.eu/tests"
101 self.path = os.path.dirname(sys.argv[0]) or "."
104 def show_env(self, options, message):
105 if self.options.verbose:
106 utils.header(message)
107 utils.show_options("main options", options)
109 def init_steps(self):
110 self.steps_message = ""
111 if not self.options.bonding:
112 self.steps_message += 20*'x' + " Defaut steps are\n" + \
113 TestPlc.printable_steps(TestPlc.default_steps)
114 self.steps_message += 20*'x' + " Other useful steps are\n" + \
115 TestPlc.printable_steps(TestPlc.other_steps)
116 self.steps_message += 20*'x' + " Macro steps are\n" + \
117 " ".join(Step.list_macros())
119 self.steps_message += 20*'x' + " Default steps with bonding build are\n" + \
120 TestPlc.printable_steps(TestPlc.default_bonding_steps)
122 def list_steps(self):
123 if not self.options.verbose:
124 print(self.steps_message)
126 # steps mentioned on the command line
127 if self.options.steps:
128 scopes = [("Argument steps",self.options.steps)]
130 scopes = [("Default steps", TestPlc.default_steps)]
131 if self.options.all_steps:
132 scopes.append ( ("Other steps", TestPlc.other_steps) )
133 # try to list macro steps as well
134 scopes.append ( ("Macro steps", Step.list_macros()) )
135 for (scope, steps) in scopes:
136 print('--------------------', scope)
137 for step in [step for step in steps if TestPlc.valid_step(step)]:
139 (step, qualifier) = step.split('@')
143 for special in ['force', 'ignore']:
144 stepname = stepname.replace('_'+special, "")
145 Step(stepname).print_doc()
148 usage = """usage: %%prog [options] steps
149 arch-rpms-url defaults to the last value used, as stored in arg-arch-rpms-url,
151 config defaults to the last value used, as stored in arg-config,
153 ips_vnode, ips_vplc and ips_qemu defaults to the last value used,
154 as stored in arg-ips-{{bplc,vplc,bnode,vnode}},
155 default is to use IP scanning
156 steps refer to a method in TestPlc or to a step_* module
158 run with -l to see a list of available steps
160 """.format(TestMain.default_config)
162 parser = ArgumentParser(usage = usage)
163 parser.add_argument("-u", "--url", action="store", dest="arch_rpms_url",
164 help="URL of the arch-dependent RPMS area - for locating what to test")
165 parser.add_argument("-b", "--build", action="store", dest="build_url",
166 help="ignored, for legacy only")
167 parser.add_argument("-c", "--config", action="append", dest="config", default=[],
168 help="Config module - can be set multiple times, or use quotes")
169 parser.add_argument("-p", "--personality", action="store", dest="personality",
170 help="personality - as in vbuild-nightly")
171 parser.add_argument("-d", "--pldistro", action="store", dest="pldistro",
172 help="pldistro - as in vbuild-nightly")
173 parser.add_argument("-f", "--fcdistro", action="store", dest="fcdistro",
174 help="fcdistro - as in vbuild-nightly")
175 parser.add_argument("-e", "--exclude", action="append", dest="exclude", default=[],
176 help="steps to exclude - can be set multiple times, or use quotes")
177 parser.add_argument("-i", "--ignore", action="append", dest="ignore", default=[],
178 help="steps to run but ignore - can be set multiple times, or use quotes")
179 parser.add_argument("-a", "--all", action="store_true", dest="all_steps", default=False,
180 help="Run all default steps")
181 parser.add_argument("-l", "--list", action="store_true", dest="list_steps", default=False,
182 help="List known steps")
183 parser.add_argument("-V", "--vserver", action="append", dest="ips_bplc", default=[],
184 help="Specify the set of hostnames for the boxes that host the plcs")
185 parser.add_argument("-P", "--plcs", action="append", dest="ips_vplc", default=[],
186 help="Specify the set of hostname/IP's to use for vplcs")
187 parser.add_argument("-Q", "--qemus", action="append", dest="ips_bnode", default=[],
188 help="Specify the set of hostnames for the boxes that host the nodes")
189 parser.add_argument("-N", "--nodes", action="append", dest="ips_vnode", default=[],
190 help="Specify the set of hostname/IP's to use for vnodes")
191 parser.add_argument("-s", "--size", action="store", dest="size", default=1,
193 help="set test size in # of plcs - default is 1")
194 parser.add_argument("-q", "--qualifier", action="store", dest="qualifier", default=None,
196 help="run steps only on plc numbered <qualifier>, starting at 1")
197 parser.add_argument("-y", "--rspec-style", action="append", dest="rspec_styles", default=[],
198 help="pl is for planetlab rspecs, pg is for protogeni")
199 parser.add_argument("-k", "--keep-going", action="store", dest="keep_going", default=False,
200 help="proceeds even if some steps are failing")
201 parser.add_argument("-D", "--dbname", action="store", dest="dbname", default=None,
202 help="Used by plc_db_dump and plc_db_restore")
203 parser.add_argument("-v", "--verbose", action="store_true", dest="verbose", default=False,
204 help="Run in verbose mode")
205 parser.add_argument("-I", "--interactive", action="store_true", dest="interactive", default=False,
206 help="prompts before each step")
207 parser.add_argument("-n", "--dry-run", action="store_true", dest="dry_run", default=False,
208 help="Show environment and exits")
209 parser.add_argument("-t", "--trace", action="store", dest="trace_file", default=None,
210 help="Trace file location")
211 parser.add_argument("-g", "--bonding", action='store', dest='bonding', default=None,
212 help="specify build to bond with")
213 parser.add_argument("steps", nargs='*')
214 self.options = parser.parse_args()
216 # allow things like "run -c 'c1 c2' -c c3"
220 if hasattr(el, "__iter__") and not isinstance(el, str):
221 result.extend(flatten(el))
225 # flatten relevant options
226 for optname in ['config', 'exclude', 'ignore', 'ips_bplc', 'ips_vplc', 'ips_bnode', 'ips_vnode']:
227 setattr(self.options, optname,
228 flatten([arg.split() for arg in getattr(self.options, optname)]))
230 if not self.options.rspec_styles:
231 self.options.rspec_styles = TestMain.default_rspec_styles
233 # handle defaults and option persistence
234 for recname, filename, default, need_reverse in (
235 ('build_url', 'arg-build-url', TestMain.default_build_url, None),
236 ('ips_bplc', 'arg-ips-bplc', [], True),
237 ('ips_vplc', 'arg-ips-vplc', [], True),
238 ('ips_bnode', 'arg-ips-bnode', [], True),
239 ('ips_vnode', 'arg-ips-vnode', [], True),
240 ('config', 'arg-config', TestMain.default_config, False),
241 ('arch_rpms_url', 'arg-arch-rpms-url', "", None),
242 ('personality', 'arg-personality', "linux64", None),
243 ('pldistro', 'arg-pldistro', "onelab", None),
244 ('fcdistro', 'arg-fcdistro', 'f14', None),
246 # print('handling', recname)
248 is_list = isinstance(default, list)
249 is_bool = isinstance(default, bool)
250 if not getattr(self.options, recname):
252 with open(path) as file:
253 parsed = file.readlines()
255 parsed = [x.strip() for x in parsed]
256 else: # strings and booleans
258 print("{} - error when parsing {}".format(sys.argv[1], path))
260 parsed = parsed[0].strip()
262 parsed = parsed.lower() == 'true'
263 setattr(self.options, recname, parsed)
264 except Exception as e:
266 setattr(self.options, recname, default)
268 print("Cannot determine", recname, e)
269 print("Run {} --help for help".format(sys.argv[0]))
273 fsave = open(path, "w")
275 for value in getattr(self.options, recname):
276 fsave.write(value + "\n")
277 else: # strings and booleans - just call str()
278 fsave.write(str(getattr(self.options, recname)) + "\n")
280 # utils.header('Saved {} into {}'.format(recname, filename))
282 # lists need be reversed
283 # I suspect this is useful for the various pools but for config, it's painful
284 if isinstance(getattr(self.options, recname), list) and need_reverse:
285 getattr(self.options, recname).reverse()
287 if self.options.verbose:
288 utils.header('* Using {} = {}'.format(recname, getattr(self.options, recname)))
290 # hack : if sfa is not among the published rpms, skip these tests
291 TestPlc.check_whether_build_has_sfa(self.options.arch_rpms_url)
294 if not self.options.steps:
295 # defaults, depends on using bonding or not
296 if self.options.bonding:
297 self.options.steps = TestPlc.default_bonding_steps
299 self.options.steps = TestPlc.default_steps
301 if self.options.list_steps:
306 # rewrite '-' into '_' in step names
307 self.options.steps = [ step.replace('-', '_') for step in self.options.steps ]
308 self.options.exclude = [ step.replace('-', '_') for step in self.options.exclude ]
309 self.options.ignore = [ step.replace('-', '_') for step in self.options.ignore ]
311 # technicality, decorate known steps to produce the '_ignore' version
312 TestPlc.create_ignore_steps()
316 for step in self.options.steps:
318 for exclude in self.options.exclude:
319 if utils.match(step, exclude):
323 selected.append(step)
326 selected = [ step if step not in self.options.ignore else step + "_ignore"
327 for step in selected ]
329 self.options.steps = selected
331 # this is useful when propagating on host boxes, to avoid conflicts
332 self.options.buildname = os.path.basename(os.path.abspath(self.path))
334 if self.options.verbose:
335 self.show_env(self.options, "Verbose")
339 for config in self.options.config:
340 modulename = 'config_' + config
342 m = __import__(modulename)
343 all_plc_specs = m.config(all_plc_specs, self.options)
345 traceback.print_exc()
346 print('Cannot load config {} -- ignored'.format(modulename))
349 # provision on local substrate
350 all_plc_specs = LocalSubstrate.local_substrate.provision(all_plc_specs, self.options)
352 # remember substrate IP address(es) for next run
353 with open('arg-ips-bplc', 'w') as ips_bplc_file:
354 for plc_spec in all_plc_specs:
355 ips_bplc_file.write("{}\n".format(plc_spec['host_box']))
356 with open('arg-ips-vplc', 'w') as ips_vplc_file:
357 for plc_spec in all_plc_specs:
358 ips_vplc_file.write("{}\n".format(plc_spec['settings']['PLC_API_HOST']))
360 with open('arg-ips-bnode', 'w') as ips_bnode_file:
361 for plc_spec in all_plc_specs:
362 for site_spec in plc_spec['sites']:
363 for node_spec in site_spec['nodes']:
364 ips_bnode_file.write("{}\n".format(node_spec['host_box']))
365 with open('arg-ips-vnode','w') as ips_vnode_file:
366 for plc_spec in all_plc_specs:
367 for site_spec in plc_spec['sites']:
368 for node_spec in site_spec['nodes']:
369 # back to normal (unqualified) form
370 stripped = node_spec['node_fields']['hostname'].split('.')[0]
371 ips_vnode_file.write("{}\n".format(stripped))
373 # build a TestPlc object from the result, passing options
374 for spec in all_plc_specs:
375 spec['failed_step'] = False
376 all_plcs = [ (x, TestPlc(x,self.options)) for x in all_plc_specs]
378 # pass options to utils as well
379 utils.init_options(self.options)
381 # populate TestBonding objects
382 # need to wait until here as we need all_plcs
383 if self.options.bonding:
384 ## allow to pass -g ../2015.03.15--f18 so we can use bash completion
385 self.options.bonding = os.path.basename(self.options.bonding)
386 # this will fail if ../{bonding} has not the right arg- files
387 for spec, test_plc in all_plcs:
388 test_plc.test_bonding = TestBonding (test_plc,
389 onelab_bonding_spec(self.options.bonding),
390 LocalSubstrate.local_substrate,
393 overall_result = 'SUCCESS'
395 for step in self.options.steps:
396 if not TestPlc.valid_step(step):
398 # some steps need to be done regardless of the previous ones: we force them
400 if step.endswith("_force"):
401 step = step.replace("_force", "")
403 # allow for steps to specify an index like in
406 step, qualifier = step.split('@')
408 qualifier = self.options.qualifier
411 stepobj = Step (step)
412 for substep, method in stepobj.tuples():
413 # a cross step will run a method on TestPlc that has a signature like
414 # def cross_foo (self, all_test_plcs)
416 if substep.find("cross_") == 0:
418 all_step_infos.append ( (substep, method, force, cross, qualifier, ) )
420 utils.header("********** FAILED step {} (NOT FOUND) -- won't be run".format(step))
421 traceback.print_exc()
422 overall_result = 'FAILURE'
424 if self.options.dry_run:
425 self.show_env(self.options, "Dry run")
427 # init & open trace file if provided
428 if self.options.trace_file and not self.options.dry_run:
429 # create dir if needed
430 trace_dir = os.path.dirname(self.options.trace_file)
431 if trace_dir and not os.path.isdir(trace_dir):
432 os.makedirs(trace_dir)
433 trace = open(self.options.trace_file,"w")
435 # do all steps on all plcs
436 TIME_FORMAT = "%H-%M-%S"
437 TRACE_FORMAT = "TRACE: {plc_counter:d} {begin}->{seconds}s={duration}s " + \
438 "status={status} step={stepname} plc={plcname} force={force}\n"
439 for stepname, method, force, cross, qualifier in all_step_infos:
441 for spec, plc_obj in all_plcs:
443 # skip this step if we have specified a plc_explicit
444 if qualifier and plc_counter != int(qualifier):
447 plcname = spec['name']
448 across_plcs = [ o for (s,o) in all_plcs if o!=plc_obj ]
451 beg_time = datetime.now()
452 begin = beg_time.strftime(TIME_FORMAT)
453 if not spec['failed_step'] or force or self.options.interactive or self.options.keep_going:
455 if self.options.interactive:
458 msg="{:d} Run step {} on {} [r](un)/d(ry_run)/p(roceed)/s(kip)/q(uit) ? "\
459 .format(plc_counter, stepname, plcname)
460 answer = input(msg).strip().lower() or "r"
462 if answer in ['s','n']: # skip/no/next
463 print('{} on {} skipped'.format(stepname, plcname))
466 elif answer in ['q','b']: # quit/bye
469 elif answer in ['d']: # dry_run
470 dry_run = self.options.dry_run
471 self.options.dry_run = True
472 plc_obj.options.dry_run = True
473 plc_obj.apiserver.set_dry_run(True)
475 step_result=method(plc_obj)
477 step_result=method(plc_obj, across_plcs)
478 print('dry_run step ->', step_result)
479 self.options.dry_run = dry_run
480 plc_obj.options.dry_run = dry_run
481 plc_obj.apiserver.set_dry_run(dry_run)
482 elif answer in ['p']:
483 # take it as a yes and leave interactive mode
485 self.options.interactive = False
486 elif answer in ['r','y']: # run/yes
492 if force and spec['failed_step']:
493 force_msg=" (forced after {} has failed)".format(spec['failed_step'])
494 utils.header("********** {:d} RUNNING step {}{} on plc {}"\
495 .format(plc_counter, stepname, force_msg, plcname))
497 step_result = method(plc_obj)
499 step_result = method(plc_obj, across_plcs)
500 if isinstance (step_result, Ignored):
501 step_result = step_result.result
506 # do not overwrite if FAILURE
507 if overall_result == 'SUCCESS':
508 overall_result = 'IGNORED'
509 utils.header('********** {} IGNORED ({}) step {} on {}'\
510 .format(plc_counter, msg, stepname, plcname))
511 status="{}[I]".format(msg)
513 utils.header('********** {:d} SUCCESSFUL step {} on {}'\
514 .format(plc_counter, stepname, plcname))
517 overall_result = 'FAILURE'
518 spec['failed_step'] = stepname
519 utils.header('********** {:d} FAILED step {} on {} (discarded from further steps)'\
520 .format(plc_counter, stepname, plcname))
523 overall_result = 'FAILURE'
524 spec['failed_step'] = stepname
525 traceback.print_exc()
526 utils.header ('********** {} FAILED (exception) step {} on {} (discarded from further steps)'\
527 .format(plc_counter, stepname, plcname))
530 # do not run, just display it's skipped
532 why = "has failed {}".format(spec['failed_step'])
533 utils.header("********** {} SKIPPED Step {} on {} ({})"\
534 .format(plc_counter, stepname, plcname, why))
536 if not self.options.dry_run:
537 delay = datetime.now()-beg_time
538 seconds = int(delay.total_seconds())
539 duration = str(delay)
540 # always do this on stdout
541 print(TRACE_FORMAT.format(**locals()))
542 # duplicate on trace_file if provided
543 if self.options.trace_file:
544 trace.write(TRACE_FORMAT.format(**locals()))
547 if self.options.trace_file and not self.options.dry_run:
550 # free local substrate
551 LocalSubstrate.local_substrate.release(self.options)
553 return overall_result
555 # wrapper to run, returns a shell-compatible result
559 # 2: SUCCESS but some ignored steps failed
564 if success == 'SUCCESS':
566 elif success == 'IGNORED':
571 print('Caught SystemExit')
574 traceback.print_exc()
577 if __name__ == "__main__":
578 exit_code = TestMain().main()
579 print("TestMain exit code", exit_code)