mirror of
https://gitlab.com/fdroid/fdroidserver.git
synced 2024-11-19 21:30:10 +01:00
build: enable watchdog timer for each build that kills in 2 hours
This introduces locking for the commonly used vagrant functions in vmtools because vagrant fails when another vagrant command is already running.
This commit is contained in:
parent
9a4f3ac019
commit
85985074d4
@ -25,6 +25,7 @@ import re
|
|||||||
import resource
|
import resource
|
||||||
import sys
|
import sys
|
||||||
import tarfile
|
import tarfile
|
||||||
|
import threading
|
||||||
import traceback
|
import traceback
|
||||||
import time
|
import time
|
||||||
import requests
|
import requests
|
||||||
@ -978,6 +979,13 @@ def trybuild(app, build, build_dir, output_dir, log_dir, also_check_dir,
|
|||||||
return True
|
return True
|
||||||
|
|
||||||
|
|
||||||
|
def force_halt_build():
|
||||||
|
"""Halt the currently running Vagrant VM, to be called from a Timer"""
|
||||||
|
logging.error(_('Force halting build after timeout!'))
|
||||||
|
vm = vmtools.get_build_vm('builder')
|
||||||
|
vm.halt()
|
||||||
|
|
||||||
|
|
||||||
def parse_commandline():
|
def parse_commandline():
|
||||||
"""Parse the command line. Returns options, parser."""
|
"""Parse the command line. Returns options, parser."""
|
||||||
|
|
||||||
@ -1143,6 +1151,12 @@ def main():
|
|||||||
first = True
|
first = True
|
||||||
|
|
||||||
for build in app.builds:
|
for build in app.builds:
|
||||||
|
if options.server: # enable watchdog timer
|
||||||
|
timer = threading.Timer(7200, force_halt_build)
|
||||||
|
timer.start()
|
||||||
|
else:
|
||||||
|
timer = None
|
||||||
|
|
||||||
wikilog = None
|
wikilog = None
|
||||||
build_starttime = common.get_wiki_timestamp()
|
build_starttime = common.get_wiki_timestamp()
|
||||||
tools_version_log = ''
|
tools_version_log = ''
|
||||||
@ -1283,6 +1297,9 @@ def main():
|
|||||||
except Exception as e:
|
except Exception as e:
|
||||||
logging.error("Error while attempting to publish build log: %s" % e)
|
logging.error("Error while attempting to publish build log: %s" % e)
|
||||||
|
|
||||||
|
if timer:
|
||||||
|
timer.cancel() # kill the watchdog timer
|
||||||
|
|
||||||
for app in build_succeeded:
|
for app in build_succeeded:
|
||||||
logging.info("success: %s" % (app.id))
|
logging.info("success: %s" % (app.id))
|
||||||
|
|
||||||
|
@ -29,6 +29,9 @@ from .common import FDroidException
|
|||||||
from logging import getLogger
|
from logging import getLogger
|
||||||
|
|
||||||
from fdroidserver import _
|
from fdroidserver import _
|
||||||
|
import threading
|
||||||
|
|
||||||
|
lock = threading.Lock()
|
||||||
|
|
||||||
logger = getLogger('fdroidserver-vmtools')
|
logger = getLogger('fdroidserver-vmtools')
|
||||||
|
|
||||||
@ -175,7 +178,6 @@ class FDroidBuildVm():
|
|||||||
This is intended to be a hypervisor independant, fault tolerant
|
This is intended to be a hypervisor independant, fault tolerant
|
||||||
wrapper around the vagrant functions we use.
|
wrapper around the vagrant functions we use.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(self, srvdir):
|
def __init__(self, srvdir):
|
||||||
"""Create new server class.
|
"""Create new server class.
|
||||||
"""
|
"""
|
||||||
@ -191,21 +193,27 @@ class FDroidBuildVm():
|
|||||||
self.vgrnt = vagrant.Vagrant(root=srvdir, out_cm=vagrant.stdout_cm, err_cm=vagrant.stdout_cm)
|
self.vgrnt = vagrant.Vagrant(root=srvdir, out_cm=vagrant.stdout_cm, err_cm=vagrant.stdout_cm)
|
||||||
|
|
||||||
def up(self, provision=True):
|
def up(self, provision=True):
|
||||||
try:
|
global lock
|
||||||
self.vgrnt.up(provision=provision)
|
with lock:
|
||||||
self.srvuuid = self._vagrant_fetch_uuid()
|
try:
|
||||||
except subprocess.CalledProcessError as e:
|
self.vgrnt.up(provision=provision)
|
||||||
raise FDroidBuildVmException("could not bring up vm '%s'" % self.srvname) from e
|
self.srvuuid = self._vagrant_fetch_uuid()
|
||||||
|
except subprocess.CalledProcessError as e:
|
||||||
|
raise FDroidBuildVmException("could not bring up vm '%s'" % self.srvname) from e
|
||||||
|
|
||||||
def suspend(self):
|
def suspend(self):
|
||||||
logger.info('suspending buildserver')
|
global lock
|
||||||
try:
|
with lock:
|
||||||
self.vgrnt.suspend()
|
logger.info('suspending buildserver')
|
||||||
except subprocess.CalledProcessError as e:
|
try:
|
||||||
raise FDroidBuildVmException("could not suspend vm '%s'" % self.srvname) from e
|
self.vgrnt.suspend()
|
||||||
|
except subprocess.CalledProcessError as e:
|
||||||
|
raise FDroidBuildVmException("could not suspend vm '%s'" % self.srvname) from e
|
||||||
|
|
||||||
def halt(self):
|
def halt(self):
|
||||||
self.vgrnt.halt(force=True)
|
global lock
|
||||||
|
with lock:
|
||||||
|
self.vgrnt.halt(force=True)
|
||||||
|
|
||||||
def destroy(self):
|
def destroy(self):
|
||||||
"""Remove every trace of this VM from the system.
|
"""Remove every trace of this VM from the system.
|
||||||
|
Loading…
Reference in New Issue
Block a user