from TestPlc import TestPlc
from TestSite import TestSite
from TestNode import TestNode
+from macros import sequences
# add $HOME in PYTHONPATH so we can import LocalSubstrate.py
sys.path.append(os.environ['HOME'])
natives=TestPlc.__dict__
+ def display (self): return self.name.replace('_','-')
+ def internal (self): return self.name.replace('-','_')
+
def __init__ (self, name):
- self.name=name.replace('-','_')
+ self.name=name
# a native step is implemented as a method on TestPlc
- self.native = name in Step.natives
+ self.native = self.internal() in Step.natives
if self.native:
- self.method=Step.natives[self.name]
+ self.method=Step.natives[self.internal()]
else:
- # non-native steps (macros) are implemented as a 'Step'
try:
- modulename = 'macro_' + self.name
- module = __import__ (modulename)
- self.substeps = module.sequence
+ self.substeps=sequences[self.internal()]
except Exception,e:
- print "Cannot load macro step %s (%s) - exiting"%(self.name,e)
+ print "macro step %s not found in macros.py (%s) - exiting"%(self.display(),e)
raise
- def norm_name (self): return self.name.replace('_','-')
-
- def print_doc (self):
+ def print_doc (self,level=0):
+ tab=32
+ trail=8
if self.native:
- print '*',self.norm_name(),"\r",4*"\t",
+ start=level*' '+'* '
+ # 2 is the len of '* '
+ width=tab-level-2
+ format="%%-%ds"%width
+ line=start+format%self.display()
+ print line,
try:
print self.method.__doc__
except:
print "*** no doc found"
else:
- print '*',self.norm_name(),"\r",3*"\t","========== BEG MACRO step"
+ beg_start=level*' '+'>>> '
+ end_start=level*' '+'<<< '
+ trailer=trail*'-'
+ # 4 is the len of '>>> '
+ width=tab-level-4-trail
+ format=("%%-%ds"%width)
+ beg_line=beg_start+format%self.display()+trail*'>'
+ end_line=end_start+format%self.display()+trail*'<'
+ print beg_line
for step in self.substeps:
- Step(step).print_doc()
- print '*',self.norm_name(),"\r",3*"\t","========== END MACRO step"
+ Step(step).print_doc(level+1)
+ print end_line
# return a list of (name, method) for all native steps involved
def tuples (self):
- if self.native: return [ (self.name, self.method,) ]
+ if self.native: return [ (self.internal(), self.method,) ]
else:
result=[]
for substep in [ Step(name) for name in self.substeps ] :
# just do a listdir, hoping we're in the right directory...
@staticmethod
def list_macros ():
- names= [ filename.replace('macro_','').replace('.py','') for filename in glob.glob ('macro_*.py')]
+ names= sequences.keys()
names.sort()
return names
help="pldistro - as in vbuild-nightly")
parser.add_option("-f","--fcdistro",action="store", dest="fcdistro",
help="fcdistro - as in vbuild-nightly")
- parser.add_option("-x","--exclude",action="append", dest="exclude", default=[],
+ parser.add_option("-e","--exclude",action="append", dest="exclude", default=[],
help="steps to exclude - can be set multiple times, or use quotes")
parser.add_option("-a","--all",action="store_true",dest="all_steps", default=False,
help="Run all default steps")
help="Specify the set of hostnames for the boxes that host the nodes")
parser.add_option("-N","--nodes",action="append", dest="ips_vnode", default=[],
help="Specify the set of hostname/IP's to use for vnodes")
+ parser.add_option ('-X', "--lxc",action='store_true',dest='plcs_use_lxc',default=True,
+ help='use lxc-enabled plc boxes instead of vs-enabled ones')
+ parser.add_option ('-S', "--vs",action='store_false',dest='plcs_use_lxc',
+ help='use lxc-enabled plc boxes instead of vs-enabled ones')
parser.add_option("-s","--size",action="store",type="int",dest="size",default=1,
help="sets test size in # of plcs - default is 1")
parser.add_option("-q","--qualifier",action="store",type="int",dest="qualifier",default=None,
help="prompts before each step")
parser.add_option("-n","--dry-run", action="store_true", dest="dry_run", default=False,
help="Show environment and exits")
- parser.add_option("-r","--restart-nm", action="store_true", dest="forcenm", default=False,
- help="Force the NM to restart in ssh_slices step")
+# dropped when added Completer.py
+# parser.add_option("-r","--restart-nm", action="store_true", dest="forcenm", default=False,
+# help="Force the NM to restart in ssh_slices step")
parser.add_option("-t","--trace", action="store", dest="trace_file", default=None,
help="Trace file location")
(self.options, self.args) = parser.parse_args()
('personality','arg-personality',"linux64",None),
('pldistro','arg-pldistro',"onelab",None),
('fcdistro','arg-fcdistro','f14',None),
+ ('plcs_use_lxc','arg-plcs-use-lxc',False,None),
) :
# print 'handling',recname
path=filename
is_list = isinstance(default,list)
+ is_bool = isinstance(default,bool)
if not getattr(self.options,recname):
try:
parsed=file(path).readlines()
- if not is_list: # strings
+ if is_list: # lists
+ parsed=[x.strip() for x in parsed]
+ else: # strings and booleans
if len(parsed) != 1:
print "%s - error when parsing %s"%(sys.argv[1],path)
sys.exit(1)
parsed=parsed[0].strip()
- else: # lists
- parsed=[x.strip() for x in parsed]
+ if is_bool:
+ parsed = parsed.lower()=='true'
setattr(self.options,recname,parsed)
except:
if default != "":
# save for next run
fsave=open(path,"w")
- if not is_list:
- fsave.write(getattr(self.options,recname) + "\n")
- else:
+ if is_list: # lists
for value in getattr(self.options,recname):
fsave.write(value + "\n")
+ else: # strings and booleans - just call str()
+ fsave.write(str(getattr(self.options,recname)) + "\n")
fsave.close()
# utils.header('Saved %s into %s'%(recname,filename))
# rewrite '-' into '_' in step names
self.options.steps = [ step.replace('-','_') for step in self.options.steps ]
+ self.options.exclude = [ step.replace('-','_') for step in self.options.exclude ]
# exclude
selected=[]
raise
# provision on local substrate
+ if self.options.plcs_use_lxc: LocalSubstrate.local_substrate.rescope (plcs_on_vs=False, plcs_on_lxc=True)
all_plc_specs = LocalSubstrate.local_substrate.provision(all_plc_specs,self.options)
# remember substrate IP address(es) for next run
git://git.onelab.eu / tests.git / blobdiff