x/timmy
Code Issues Proposed changes

added: fake execution of commands

Browse Source
This commit is contained in:
adobdin 2016-02-19 13:17:52 +00:00
parent efec144331
commit 3adc1f569d
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
nodes.py
View File

@ -103,7 +103,7 @@ class Node(object):
logging.debug('add files:\nnode: %s, key: %s, files:\n%s' % logging.debug('add files:\nnode: %s, key: %s, files:\n%s' %
(self.node_id, key, self.files[key])) (self.node_id, key, self.files[key]))
def exec_cmd(self, label, sshvars, sshopts, odir='info', timeout=15): def exec_cmd(self, label, sshvars, sshopts, odir='info', timeout=15, fake=false):
sn = 'node-%s' % self.node_id sn = 'node-%s' % self.node_id
cl = 'cluster-%s' % self.cluster cl = 'cluster-%s' % self.cluster
logging.debug('%s/%s/%s/%s' % (odir, label, cl, sn)) logging.debug('%s/%s/%s/%s' % (odir, label, cl, sn))
@ -111,13 +111,14 @@ class Node(object):
mdir(ddir) mdir(ddir)
for f in self.files[label]: for f in self.files[label]:
logging.info('node:%s(%s), exec: %s' % (self.node_id, self.ip, f)) logging.info('node:%s(%s), exec: %s' % (self.node_id, self.ip, f))
outs, errs, code = ssh_node(ip=self.ip, if not fake:
filename=f, outs, errs, code = ssh_node(ip=self.ip,
sshvars=sshvars, filename=f,
sshopts=sshopts, sshvars=sshvars,
timeout=timeout, sshopts=sshopts,
command='' timeout=timeout,
) command=''
)
if code != 0: if code != 0:
logging.error("node: %s, ip: %s, cmdfile: %s," logging.error("node: %s, ip: %s, cmdfile: %s,"
" code: %s, error message: %s" % " code: %s, error message: %s" %