source: trunk/server/script/land.py

Last change on this file was 745, checked in by Silvan Scherrer, 13 years ago

Samba Server: updated trunk to 3.6.0
File size: 25.4 KB
RevLine 
[740]1#!/usr/bin/env python
2# run tests on all Samba subprojects and push to a git tree on success
3# Copyright Andrew Tridgell 2010
4# Copyright Jelmer Vernooij 2010
5# released under GNU GPL v3 or later
6
7from cStringIO import StringIO
8import fcntl
9from subprocess import call, check_call, Popen, PIPE
10import os, tarfile, sys, time
11from optparse import OptionParser
12import smtplib
13sys.path.insert(0, os.path.join(os.path.dirname(__file__), "../selftest"))
14sys.path.insert(0, os.path.join(os.path.dirname(__file__), "../lib/testtools"))
15sys.path.insert(0, os.path.join(os.path.dirname(__file__), "../lib/subunit/python"))
16import subunit
17import testtools
18import subunithelper
19import tempfile
20from email.mime.application import MIMEApplication
21from email.mime.text import MIMEText
22from email.mime.multipart import MIMEMultipart
23
24samba_master = os.getenv('SAMBA_MASTER', 'git://git.samba.org/samba.git')
25samba_master_ssh = os.getenv('SAMBA_MASTER_SSH', 'git+ssh://git.samba.org/data/git/samba.git')
26
27cleanup_list = []
28
29os.environ['CC'] = "ccache gcc"
30
31tasks = {
32 "source3" : [ ("autogen", "./autogen.sh", "text/plain"),
33 ("configure", "./configure.developer ${PREFIX}", "text/plain"),
34 ("make basics", "make basics", "text/plain"),
35 ("make", "make -j 4 everything", "text/plain"), # don't use too many processes
36 ("install", "make install", "text/plain"),
37 ("test", "TDB_NO_FSYNC=1 make subunit-test", "text/x-subunit") ],
38
39 "source4" : [ ("configure", "./configure.developer ${PREFIX}", "text/plain"),
40 ("make", "make -j", "text/plain"),
41 ("install", "make install", "text/plain"),
42 ("test", "TDB_NO_FSYNC=1 make subunit-test", "text/x-subunit") ],
43
44 "source4/lib/ldb" : [ ("configure", "./configure --enable-developer -C ${PREFIX}", "text/plain"),
45 ("make", "make -j", "text/plain"),
46 ("install", "make install", "text/plain"),
47 ("test", "make test", "text/plain") ],
48
49 "lib/tdb" : [ ("autogen", "./autogen-waf.sh", "text/plain"),
50 ("configure", "./configure --enable-developer -C ${PREFIX}", "text/plain"),
51 ("make", "make -j", "text/plain"),
52 ("install", "make install", "text/plain"),
53 ("test", "make test", "text/plain") ],
54
55 "lib/talloc" : [ ("autogen", "./autogen-waf.sh", "text/plain"),
56 ("configure", "./configure --enable-developer -C ${PREFIX}", "text/plain"),
57 ("make", "make -j", "text/plain"),
58 ("install", "make install", "text/plain"),
59 ("test", "make test", "text/x-subunit"), ],
60
61 "lib/replace" : [ ("autogen", "./autogen-waf.sh", "text/plain"),
62 ("configure", "./configure --enable-developer -C ${PREFIX}", "text/plain"),
63 ("make", "make -j", "text/plain"),
64 ("install", "make install", "text/plain"),
65 ("test", "make test", "text/plain"), ],
66
67 "lib/tevent" : [ ("configure", "./configure --enable-developer -C ${PREFIX}", "text/plain"),
68 ("make", "make -j", "text/plain"),
69 ("install", "make install", "text/plain"),
70 ("test", "make test", "text/plain"), ],
71}
72
73
74def run_cmd(cmd, dir=None, show=None, output=False, checkfail=True, shell=False):
75 if show is None:
76 show = options.verbose
77 if show:
78 print("Running: '%s' in '%s'" % (cmd, dir))
79 if output:
80 return Popen(cmd, stdout=PIPE, cwd=dir, shell=shell).communicate()[0]
81 elif checkfail:
82 return check_call(cmd, cwd=dir, shell=shell)
83 else:
84 return call(cmd, cwd=dir, shell=shell)
85
86
87def clone_gitroot(test_master, revision="HEAD"):
88 run_cmd(["git", "clone", "--shared", gitroot, test_master])
89 if revision != "HEAD":
90 run_cmd(["git", "checkout", revision])
91
92
93class RetryChecker(object):
94 """Check whether it is necessary to retry."""
95
96 def __init__(self, dir):
97 run_cmd(["git", "remote", "add", "-t", "master", "master", samba_master])
98 run_cmd(["git", "fetch", "master"])
99 cmd = '''set -e
100 while :; do
101 sleep 60
102 git describe master/master > old_master.desc
103 git fetch master
104 git describe master/master > master.desc
105 diff old_master.desc master.desc
106 done
107 '''
108 self.proc = Popen(cmd, shell=True, cwd=self.dir)
109
110 def poll(self):
111 return self.proc.poll()
112
113 def kill(self):
114 self.proc.terminate()
115 self.proc.wait()
116 self.retry.proc = None
117
118
119class TreeStageBuilder(object):
120 """Handle building of a particular stage for a tree.
121 """
122
123 def __init__(self, tree, name, command, fail_quickly=False):
124 self.tree = tree
125 self.name = name
126 self.command = command
127 self.fail_quickly = fail_quickly
128 self.exitcode = None
129 self.stdin = open(os.devnull, 'r')
130
131 def start(self):
132 raise NotImplementedError(self.start)
133
134 def poll(self):
135 self.exitcode = self.proc.poll()
136 return self.exitcode
137
138 def kill(self):
139 if self.proc is not None:
140 try:
141 run_cmd(["killbysubdir", self.tree.sdir], checkfail=False)
142 except OSError:
143 # killbysubdir doesn't exist ?
144 pass
145 self.proc.terminate()
146 self.proc.wait()
147 self.proc = None
148
149 @property
150 def failure_reason(self):
151 raise NotImplementedError(self.failure_reason)
152
153 @property
154 def failed(self):
155 return (self.exitcode != 0)
156
157
158class PlainTreeStageBuilder(TreeStageBuilder):
159
160 def start(self):
161 print '%s: [%s] Running %s' % (self.name, self.name, self.command)
162 self.proc = Popen(self.command, shell=True, cwd=self.tree.dir,
163 stdout=self.tree.stdout, stderr=self.tree.stderr,
164 stdin=self.stdin)
165
166 @property
167 def failure_reason(self):
168 return "failed '%s' with exit code %d" % (self.command, self.exitcode)
169
170
171class AbortingTestResult(subunithelper.TestsuiteEnabledTestResult):
172
173 def __init__(self, stage):
174 super(AbortingTestResult, self).__init__()
175 self.stage = stage
176
177 def addError(self, test, details=None):
178 self.stage.proc.terminate()
179
180 def addFailure(self, test, details=None):
181 self.stage.proc.terminate()
182
183
184class FailureTrackingTestResult(subunithelper.TestsuiteEnabledTestResult):
185
186 def __init__(self, stage):
187 super(FailureTrackingTestResult, self).__init__()
188 self.stage = stage
189
190 def addError(self, test, details=None):
191 if self.stage.failed_test is None:
192 self.stage.failed_test = ("error", test)
193
194 def addFailure(self, test, details=None):
195 if self.stage.failed_test is None:
196 self.stage.failed_test = ("failure", test)
197
198
199class SubunitTreeStageBuilder(TreeStageBuilder):
200
201 def __init__(self, tree, name, command, fail_quickly=False):
202 super(SubunitTreeStageBuilder, self).__init__(tree, name, command,
203 fail_quickly)
204 self.failed_test = None
205 self.subunit_path = os.path.join(gitroot,
206 "%s.%s.subunit" % (self.tree.tag, self.name))
207 self.tree.logfiles.append(
208 (self.subunit_path, os.path.basename(self.subunit_path),
209 "text/x-subunit"))
210 self.subunit = open(self.subunit_path, 'w')
211
212 formatter = subunithelper.PlainFormatter(False, True, {})
213 clients = [formatter, subunit.TestProtocolClient(self.subunit),
214 FailureTrackingTestResult(self)]
215 if fail_quickly:
216 clients.append(AbortingTestResult(self))
217 self.subunit_server = subunit.TestProtocolServer(
218 testtools.MultiTestResult(*clients),
219 self.subunit)
220 self.buffered = ""
221
222 def start(self):
223 print '%s: [%s] Running' % (self.tree.name, self.name)
224 self.proc = Popen(self.command, shell=True, cwd=self.tree.dir,
225 stdout=PIPE, stderr=self.tree.stderr, stdin=self.stdin)
226 fd = self.proc.stdout.fileno()
227 fl = fcntl.fcntl(fd, fcntl.F_GETFL)
228 fcntl.fcntl(fd, fcntl.F_SETFL, fl | os.O_NONBLOCK)
229
230 def poll(self):
231 try:
232 data = self.proc.stdout.read()
233 except IOError:
234 return None
235 else:
236 self.buffered += data
237 buffered = ""
238 for l in self.buffered.splitlines(True):
239 if l[-1] == "\n":
240 self.subunit_server.lineReceived(l)
241 else:
242 buffered += l
243 self.buffered = buffered
244 self.exitcode = self.proc.poll()
245 if self.exitcode is not None:
246 self.subunit.close()
247 return self.exitcode
248
249 @property
250 def failure_reason(self):
251 if self.failed_test:
252 return "failed '%s' with %s in test %s" (self.command, self.failed_test[0], self.failed_test[1])
253 else:
254 return "failed '%s' with exit code %d in unknown test" % (self.command, self.exitcode)
255
256
257class TreeBuilder(object):
258 '''handle build of one directory'''
259
260 def __init__(self, name, sequence, fail_quickly=False):
261 self.name = name
262 self.fail_quickly = fail_quickly
263
264 self.tag = self.name.replace('/', '_')
265 self.sequence = sequence
266 self.next = 0
267 self.stages = []
268 self.stdout_path = os.path.join(gitroot, "%s.stdout" % (self.tag, ))
269 self.stderr_path = os.path.join(gitroot, "%s.stderr" % (self.tag, ))
270 self.logfiles = [
271 (self.stdout_path, os.path.basename(self.stdout_path), "text/plain"),
272 (self.stderr_path, os.path.basename(self.stderr_path), "text/plain"),
273 ]
274 if options.verbose:
275 print("stdout for %s in %s" % (self.name, self.stdout_path))
276 print("stderr for %s in %s" % (self.name, self.stderr_path))
277 if os.path.exists(self.stdout_path):
278 os.unlink(self.stdout_path)
279 if os.path.exists(self.stderr_path):
280 os.unlink(self.stderr_path)
281 self.stdout = open(self.stdout_path, 'w')
282 self.stderr = open(self.stderr_path, 'w')
283 self.sdir = os.path.join(testbase, self.tag)
284 if name in ['pass', 'fail', 'retry']:
285 self.dir = self.sdir
286 else:
287 self.dir = os.path.join(self.sdir, self.name)
288 self.prefix = os.path.join(testbase, "prefix", self.tag)
289 run_cmd(["rm", "-rf", self.sdir])
290 cleanup_list.append(self.sdir)
291 cleanup_list.append(self.prefix)
292 os.makedirs(self.sdir)
293 run_cmd(["rm", "-rf", self.sdir])
294 clone_gitroot(self.sdir, revision)
295 self.start_next()
296 self.exitcode = None
297
298 def start_next(self):
299 if self.next == len(self.sequence):
300 print '%s: Completed OK' % self.name
301 self.done = True
302 self.stdout.close()
303 self.stderr.close()
304 return
305 (stage_name, cmd, output_mime_type) = self.sequence[self.next]
306 cmd = cmd.replace("${PREFIX}", "--prefix=%s" % self.prefix)
307 if output_mime_type == "text/plain":
308 self.current_stage = PlainTreeStageBuilder(self, stage_name, cmd,
309 self.fail_quickly)
310 elif output_mime_type == "text/x-subunit":
311 self.current_stage = SubunitTreeStageBuilder(self, stage_name, cmd,
312 self.fail_quickly)
313 else:
314 raise Exception("Unknown output mime type %s" % output_mime_type)
315 self.stages.append(self.current_stage)
316 self.current_stage.start()
317 self.next += 1
318
319 def remove_logs(self):
320 for path, name, mime_type in self.logfiles:
321 os.unlink(path)
322
323 def poll(self):
324 self.exitcode = self.current_stage.poll()
325 if self.exitcode is not None:
326 self.current_stage = None
327 return self.exitcode
328
329 def kill(self):
330 if self.current_stage is not None:
331 self.current_stage.kill()
332 self.current_stage = None
333
334 @property
335 def failed(self):
336 return any([s.failed for s in self.stages])
337
338 @property
339 def failed_stage(self):
340 for s in self.stages:
341 if s.failed:
342 return s
343 return s
344
345 @property
346 def failure_reason(self):
347 return "%s: [%s] %s" % (self.name, self.failed_stage.name,
348 self.failed_stage.failure_reason)
349
350
351class BuildList(object):
352 '''handle build of multiple directories'''
353
354 def __init__(self, tasklist, tasknames):
355 global tasks
356 self.tlist = []
357 self.tail_proc = None
358 self.retry = None
359 if tasknames == ['pass']:
360 tasks = { 'pass' : [ ("pass", '/bin/true', "text/plain") ]}
361 if tasknames == ['fail']:
362 tasks = { 'fail' : [ ("fail", '/bin/false', "text/plain") ]}
363 if tasknames == []:
364 tasknames = tasklist
365 for n in tasknames:
366 b = TreeBuilder(n, tasks[n], not options.fail_slowly)
367 self.tlist.append(b)
368 if options.retry:
369 self.retry = RetryChecker(self.sdir)
370 self.need_retry = False
371
372 def kill_kids(self):
373 if self.tail_proc is not None:
374 self.tail_proc.terminate()
375 self.tail_proc.wait()
376 self.tail_proc = None
377 if self.retry is not None:
378 self.retry.kill()
379 for b in self.tlist:
380 b.kill()
381
382 def wait_one(self):
383 while True:
384 none_running = True
385 for b in self.tlist:
386 if b.current_stage is None:
387 continue
388 none_running = False
389 if b.poll() is None:
390 continue
391 return b
392 if options.retry:
393 ret = self.retry.poll()
394 if ret:
395 self.need_retry = True
396 self.retry = None
397 return None
398 if none_running:
399 return None
400 time.sleep(0.1)
401
402 def run(self):
403 while True:
404 b = self.wait_one()
405 if options.retry and self.need_retry:
406 self.kill_kids()
407 print("retry needed")
408 return (0, None, None, None, "retry")
409 if b is None:
410 break
411 if b.failed:
412 self.kill_kids()
413 return (b.exitcode, b.name, b.failed_stage, b.tag, b.failure_reason)
414 b.start_next()
415 self.kill_kids()
416 return (0, None, None, None, "All OK")
417
418 def tarlogs(self, name=None, fileobj=None):
419 tar = tarfile.open(name=name, fileobj=fileobj, mode="w:gz")
420 for b in self.tlist:
421 for (path, name, mime_type) in b.logfiles:
422 tar.add(path, arcname=name)
423 if os.path.exists("autobuild.log"):
424 tar.add("autobuild.log")
425 tar.close()
426
427 def attach_logs(self, outer):
428 f = StringIO()
429 self.tarlogs(fileobj=f)
430 msg = MIMEApplication(f.getvalue(), "x-gzip")
431 msg.add_header('Content-Disposition', 'attachment',
432 filename="logs.tar.gz")
433 outer.attach(msg)
434
435 def remove_logs(self):
436 for b in self.tlist:
437 b.remove_logs()
438
439 def start_tail(self):
440 cmd = "tail -f *.stdout *.stderr"
441 self.tail_proc = Popen(cmd, shell=True, cwd=gitroot)
442
443
444def cleanup():
445 if options.nocleanup:
446 return
447 print("Cleaning up ....")
448 for d in cleanup_list:
449 run_cmd(["rm", "-rf", d])
450
451
452def find_git_root(p):
453 '''get to the top of the git repo'''
454 while p != '/':
455 if os.path.isdir(os.path.join(p, ".git")):
456 return p
457 p = os.path.abspath(os.path.join(p, '..'))
458 return None
459
460
461def daemonize(logfile):
462 pid = os.fork()
463 if pid == 0: # Parent
464 os.setsid()
465 pid = os.fork()
466 if pid != 0: # Actual daemon
467 os._exit(0)
468 else: # Grandparent
469 os._exit(0)
470
471 import resource # Resource usage information.
472 maxfd = resource.getrlimit(resource.RLIMIT_NOFILE)[1]
473 if maxfd == resource.RLIM_INFINITY:
474 maxfd = 1024 # Rough guess at maximum number of open file descriptors.
475 for fd in range(0, maxfd):
476 try:
477 os.close(fd)
478 except OSError:
479 pass
480 os.open(logfile, os.O_RDWR | os.O_CREAT)
481 os.dup2(0, 1)
482 os.dup2(0, 2)
483
484
485def rebase_tree(url):
486 print("Rebasing on %s" % url)
487 run_cmd(["git", "remote", "add", "-t", "master", "master", url], show=True,
488 dir=test_master)
489 run_cmd(["git", "fetch", "master"], show=True, dir=test_master)
490 if options.fix_whitespace:
491 run_cmd(["git", "rebase", "--whitespace=fix", "master/master"],
492 show=True, dir=test_master)
493 else:
494 run_cmd(["git", "rebase", "master/master"], show=True, dir=test_master)
495 diff = run_cmd(["git", "--no-pager", "diff", "HEAD", "master/master"],
496 dir=test_master, output=True)
497 if diff == '':
498 print("No differences between HEAD and master/master - exiting")
499 sys.exit(0)
500
501def push_to(url):
502 print("Pushing to %s" % url)
503 if options.mark:
504 run_cmd("EDITOR=script/commit_mark.sh git commit --amend -c HEAD",
505 dir=test_master, shell=True)
506 # the notes method doesn't work yet, as metze hasn't allowed
507 # refs/notes/* in master
508 # run_cmd("EDITOR=script/commit_mark.sh git notes edit HEAD",
509 # dir=test_master)
510 run_cmd(["git", "remote", "add", "-t", "master", "pushto", url], show=True,
511 dir=test_master)
512 run_cmd(["git", "push", "pushto", "+HEAD:master"], show=True,
513 dir=test_master)
514
515def_testbase = os.getenv("AUTOBUILD_TESTBASE")
516if def_testbase is None:
517 if os.path.exists("/memdisk"):
518 def_testbase = "/memdisk/%s" % os.getenv('USER')
519 else:
520 def_testbase = os.path.join(tempfile.gettempdir(), "autobuild-%s" % os.getenv("USER"))
521
522parser = OptionParser()
523parser.add_option("--repository", help="repository to run tests for", default=None, type=str)
524parser.add_option("--revision", help="revision to compile if not HEAD", default=None, type=str)
525parser.add_option("--tail", help="show output while running", default=False, action="store_true")
526parser.add_option("--keeplogs", help="keep logs", default=False, action="store_true")
527parser.add_option("--nocleanup", help="don't remove test tree", default=False, action="store_true")
528parser.add_option("--testbase", help="base directory to run tests in (default %s)" % def_testbase,
529 default=def_testbase)
530parser.add_option("--passcmd", help="command to run on success", default=None)
531parser.add_option("--verbose", help="show all commands as they are run",
532 default=False, action="store_true")
533parser.add_option("--rebase", help="rebase on the given tree before testing",
534 default=None, type='str')
535parser.add_option("--rebase-master", help="rebase on %s before testing" % samba_master,
536 default=False, action='store_true')
537parser.add_option("--pushto", help="push to a git url on success",
538 default=None, type='str')
539parser.add_option("--push-master", help="push to %s on success" % samba_master_ssh,
540 default=False, action='store_true')
541parser.add_option("--mark", help="add a Tested-By signoff before pushing",
542 default=False, action="store_true")
543parser.add_option("--fix-whitespace", help="fix whitespace on rebase",
544 default=False, action="store_true")
545parser.add_option("--retry", help="automatically retry if master changes",
546 default=False, action="store_true")
547parser.add_option("--email", help="send email to the given address on failure",
548 type='str', default=None)
549parser.add_option("--always-email", help="always send email, even on success",
550 action="store_true")
551parser.add_option("--daemon", help="daemonize after initial setup",
552 action="store_true")
553parser.add_option("--fail-slowly", help="continue running tests even after one has already failed",
554 action="store_true")
555
556
557def email_failure(blist, exitcode, failed_task, failed_stage, failed_tag, errstr):
558 '''send an email to options.email about the failure'''
559 user = os.getenv("USER")
560 text = '''
561Dear Developer,
562
563Your autobuild failed when trying to test %s with the following error:
564 %s
565
566the autobuild has been abandoned. Please fix the error and resubmit.
567
568You can see logs of the failed task here:
569
570 http://git.samba.org/%s/samba-autobuild/%s.stdout
571 http://git.samba.org/%s/samba-autobuild/%s.stderr
572
573A summary of the autobuild process is here:
574
575 http://git.samba.org/%s/samba-autobuild/autobuild.log
576
577or you can get full logs of all tasks in this job here:
578
579 http://git.samba.org/%s/samba-autobuild/logs.tar.gz
580
581The top commit for the tree that was built was:
582
583%s
584
585''' % (failed_task, errstr, user, failed_tag, user, failed_tag, user, user,
586 get_top_commit_msg(test_master))
587
588 msg = MIMEMultipart()
589 msg['Subject'] = 'autobuild failure for task %s during %s' % (
590 failed_task, failed_stage.name)
591 msg['From'] = 'autobuild@samba.org'
592 msg['To'] = options.email
593
594 main = MIMEText(text)
595 msg.attach(main)
596
597 blist.attach_logs(msg)
598
599 s = smtplib.SMTP()
600 s.connect()
601 s.sendmail(msg['From'], [msg['To']], msg.as_string())
602 s.quit()
603
604def email_success(blist):
605 '''send an email to options.email about a successful build'''
606 user = os.getenv("USER")
607 text = '''
608Dear Developer,
609
610Your autobuild has succeeded.
611
612'''
613
614 if options.keeplogs:
615 text += '''
616
617you can get full logs of all tasks in this job here:
618
619 http://git.samba.org/%s/samba-autobuild/logs.tar.gz
620
621''' % user
622
623 text += '''
624The top commit for the tree that was built was:
625
626%s
627''' % (get_top_commit_msg(test_master),)
628
629 msg = MIMEMultipart()
630 msg['Subject'] = 'autobuild success'
631 msg['From'] = 'autobuild@samba.org'
632 msg['To'] = options.email
633
634 main = MIMEText(text, 'plain')
635 msg.attach(main)
636
637 blist.attach_logs(msg)
638
639 s = smtplib.SMTP()
640 s.connect()
641 s.sendmail(msg['From'], [msg['To']], msg.as_string())
642 s.quit()
643
644
645(options, args) = parser.parse_args()
646
647if options.retry:
648 if not options.rebase_master and options.rebase is None:
649 raise Exception('You can only use --retry if you also rebase')
650
651testbase = os.path.join(options.testbase, "b%u" % (os.getpid(),))
652test_master = os.path.join(testbase, "master")
653
654if options.repository is not None:
655 repository = options.repository
656else:
657 repository = os.getcwd()
658
659gitroot = find_git_root(repository)
660if gitroot is None:
661 raise Exception("Failed to find git root under %s" % repository)
662
663# get the top commit message, for emails
664if options.revision is not None:
665 revision = options.revision
666else:
667 revision = "HEAD"
668
669def get_top_commit_msg(reporoot):
670 return run_cmd(["git", "log", "-1"], dir=reporoot, output=True)
671
672try:
673 os.makedirs(testbase)
674except Exception, reason:
675 raise Exception("Unable to create %s : %s" % (testbase, reason))
676cleanup_list.append(testbase)
677
678if options.daemon:
679 logfile = os.path.join(testbase, "log")
680 print "Forking into the background, writing progress to %s" % logfile
681 daemonize(logfile)
682
683while True:
684 try:
685 run_cmd(["rm", "-rf", test_master])
686 cleanup_list.append(test_master)
687 clone_gitroot(test_master, revision)
688 except:
689 cleanup()
690 raise
691
692 try:
693 if options.rebase is not None:
694 rebase_tree(options.rebase)
695 elif options.rebase_master:
696 rebase_tree(samba_master)
697 blist = BuildList(tasks, args)
698 if options.tail:
699 blist.start_tail()
700 (exitcode, failed_task, failed_stage, failed_tag, errstr) = blist.run()
701 if exitcode != 0 or errstr != "retry":
702 break
703 cleanup()
704 except:
705 cleanup()
706 raise
707
708blist.kill_kids()
709if options.tail:
710 print("waiting for tail to flush")
711 time.sleep(1)
712
713if exitcode == 0:
714 print errstr
715 if options.passcmd is not None:
716 print("Running passcmd: %s" % options.passcmd)
717 run_cmd(options.passcmd, dir=test_master, shell=True)
718 if options.pushto is not None:
719 push_to(options.pushto)
720 elif options.push_master:
721 push_to(samba_master_ssh)
722 if options.keeplogs:
723 blist.tarlogs("logs.tar.gz")
724 print("Logs in logs.tar.gz")
725 if options.always_email:
726 email_success(blist)
727 blist.remove_logs()
728 cleanup()
729 print(errstr)
730else:
731 # something failed, gather a tar of the logs
732 blist.tarlogs("logs.tar.gz")
733
734 if options.email is not None:
735 email_failure(blist, exitcode, failed_task, failed_stage, failed_tag,
736 errstr)
737
738 cleanup()
739 print(errstr)
740 print("Logs in logs.tar.gz")
741sys.exit(exitcode)
Note: See TracBrowser for help on using the repository browser.