blob: ebe41c5f30e37a53cb9bf53eeabad17d096bf2c0 [file] [log] [blame]
# Copyright (c) 2009-2012 The Chromium OS Authors. All rights reserved.
# Use of this source code is governed by a BSD-style license that can be
# found in the LICENSE file.
"""Chromium OS development server that can be used for all forms of update.
This devserver can be used to perform system-wide autoupdate and update
of specific portage packages on devices running Chromium OS derived operating
systems. It mainly operates in two modes:
1) archive mode: In this mode, the devserver is configured to stage and
serve artifacts from Google Storage using the credentials provided to it before
it is run. The easiest way to understand this is that the devserver is
functioning as a local cache for artifacts produced and uploaded by build
servers. Users of this form of devserver can either download the artifacts
from the devservers static directory OR use the update RPC to perform a
system-wide autoupdate. Archive mode is always active.
2) artifact-generation mode: in this mode, the devserver will attempt to
generate update payloads and build artifacts when requested. This mode only
works in the Chromium OS chroot as it uses build tools only present in the
chroot (emerge, cros_generate_update_payload, etc.). By default, when a device
requests an update from this form of devserver, the devserver will attempt to
discover if a more recent build of the board has been built by the developer
and generate a payload that the requested system can autoupdate to. In addition,
it accepts gmerge requests from devices that will stage the newest version of
a particular package from a developer's chroot onto a requesting device. Note
if archive_dir is specified, this mode is disabled.
For example:
gmerge gmerge -d <devserver_url>
devserver will see if a newer package of gmerge is available. If gmerge is
cros_work'd on, it will re-build gmerge. After this, gmerge will install that
version of gmerge that the devserver just created/found.
For autoupdates, there are many more advanced options that can help specify
how to update and which payload to give to a requester.
import json
import optparse
import os
import re
import shutil
import socket
import subprocess
import sys
import tempfile
import threading
import types
from logging import handlers
import cherrypy
import cherrypy._cplogging
import autoupdate
import common_util
import downloader
import log_util
import xbuddy
# Module-local log function.
def _Log(message, *args):
return log_util.LogWithTag('DEVSERVER', message, *args)
TELEMETRY_FOLDER = 'telemetry_src'
TELEMETRY_DEPS = ['dep-telemetry_dep.tar.bz2',
# Sets up global to share between classes.
updater = None
# Log rotation parameters. These settings correspond to once a week
# at midnight between Friday and Saturday, with about three months
# of old logs kept for backup.
# For more, see the documentation for
# logging.handlers.TimedRotatingFileHandler
class DevServerError(Exception):
"""Exception class used by this module."""
def _LeadingWhiteSpaceCount(string):
"""Count the amount of leading whitespace in a string.
string: The string to count leading whitespace in.
number of white space chars before characters start.
# pylint: disable=W1401
matched = re.match('^\s+', string)
if matched:
return len(
return 0
def _PrintDocStringAsHTML(func):
"""Make a functions docstring somewhat HTML style.
func: The function to return the docstring from.
A string that is somewhat formated for a web browser.
# TODO(scottz): Make this parse Args/Returns in a prettier way.
# Arguments could be bolded and indented etc.
html_doc = []
for line in func.__doc__.splitlines():
leading_space = _LeadingWhiteSpaceCount(line)
if leading_space > 0:
line = '&nbsp;' * leading_space + line
html_doc.append('<BR>%s' % line)
return '\n'.join(html_doc)
def _GetConfig(options):
"""Returns the configuration for the devserver."""
# On a system with IPv6 not compiled into the kernel,
# AF_INET6 sockets will return a socket.error exception.
# On such systems, fall-back to IPv4.
socket_host = '::'
socket.socket(socket.AF_INET6, socket.SOCK_STREAM)
except socket.error:
socket_host = ''
base_config = { 'global':
{ 'server.log_request_headers': True,
'server.protocol_version': 'HTTP/1.1',
'server.socket_host': socket_host,
'server.socket_port': int(options.port),
'response.timeout': 6000,
'request.show_tracebacks': True,
'server.socket_timeout': 60,
'server.thread_pool': 2,
# Gets rid of cherrypy parsing post file for args.
'request.process_request_body': False,
'response.timeout': 100000,
# Gets rid of cherrypy parsing post file for args.
'request.process_request_body': False,
'response.timeout': 10000,
# Sets up the static dir for file hosting.
{ 'tools.staticdir.dir': options.static_dir,
'tools.staticdir.on': True,
'response.timeout': 10000,
if options.production:
base_config['global'].update({'server.thread_pool': 150})
return base_config
def _GetRecursiveMemberObject(root, member_list):
"""Returns an object corresponding to a nested member list.
root: the root object to search
member_list: list of nested members to search
An object corresponding to the member name list; None otherwise.
for member in member_list:
next_root = root.__class__.__dict__.get(member)
if not next_root:
return None
root = next_root
return root
def _IsExposed(name):
"""Returns True iff |name| has an `exposed' attribute and it is set."""
return hasattr(name, 'exposed') and
def _GetExposedMethod(root, nested_member, ignored=None):
"""Returns a CherryPy-exposed method, if such exists.
root: the root object for searching
nested_member: a slash-joined path to the nested member
ignored: method paths to be ignored
A function object corresponding to the path defined by |member_list| from
the |root| object, if the function is exposed and not ignored; None
method = (not (ignored and nested_member in ignored) and
_GetRecursiveMemberObject(root, nested_member.split('/')))
if (method and type(method) == types.FunctionType and _IsExposed(method)):
return method
def _FindExposedMethods(root, prefix, unlisted=None):
"""Finds exposed CherryPy methods.
root: the root object for searching
prefix: slash-joined chain of members leading to current object
unlisted: URLs to be excluded regardless of their exposed status
List of exposed URLs that are not unlisted.
method_list = []
for member in sorted(root.__class__.__dict__.keys()):
prefixed_member = prefix + '/' + member if prefix else member
if unlisted and prefixed_member in unlisted:
member_obj = root.__class__.__dict__[member]
if _IsExposed(member_obj):
if type(member_obj) == types.FunctionType:
method_list += _FindExposedMethods(
member_obj, prefixed_member, unlisted)
return method_list
class ApiRoot(object):
"""RESTful API for Dev Server information."""
exposed = True
def hostinfo(self, ip):
"""Returns a JSON dictionary containing information about the given ip.
ip: address of host whose info is requested
A JSON dictionary containing all or some of the following fields:
last_event_type (int): last update event type received
last_event_status (int): last update event status received
last_known_version (string): last known version reported in update ping
forced_update_label (string): update label to force next update ping to
use, set by setnextupdate
See the OmahaEvent class in update_engine/omaha_request_action.h for
event type and status code definitions. If the ip does not exist an empty
string is returned.
Example URL:
return updater.HandleHostInfoPing(ip)
def hostlog(self, ip):
"""Returns a JSON object containing a log of host event.
ip: address of host whose event log is requested, or `all'
A JSON encoded list (log) of dictionaries (events), each of which
containing a `timestamp' and other event fields, as described under
Example URL:
return updater.HandleHostLogPing(ip)
def setnextupdate(self, ip):
"""Allows the response to the next update ping from a host to be set.
Takes the IP of the host and an update label as normally provided to the
/update command.
body_length = int(cherrypy.request.headers['Content-Length'])
label =
if label:
label = label.strip()
if label:
return updater.HandleSetUpdatePing(ip, label)
raise cherrypy.HTTPError(400, 'No label provided.')
def fileinfo(self, *path_args):
"""Returns information about a given staged file.
path_args: path to the file inside the server's static staging directory
A JSON encoded dictionary with information about the said file, which may
contain the following keys/values:
size (int): the file size in bytes
sha1 (string): a base64 encoded SHA1 hash
sha256 (string): a base64 encoded SHA256 hash
Example URL:
file_path = os.path.join(updater.static_dir, *path_args)
if not os.path.exists(file_path):
raise DevServerError('file not found: %s' % file_path)
file_size = os.path.getsize(file_path)
file_sha1 = common_util.GetFileSha1(file_path)
file_sha256 = common_util.GetFileSha256(file_path)
except os.error, e:
raise DevServerError('failed to get info for file %s: %s' %
(file_path, e))
is_delta = autoupdate.Autoupdate.IsDeltaFormatFile(file_path)
return json.dumps({
autoupdate.Autoupdate.SIZE_ATTR: file_size,
autoupdate.Autoupdate.SHA1_ATTR: file_sha1,
autoupdate.Autoupdate.SHA256_ATTR: file_sha256,
autoupdate.Autoupdate.ISDELTA_ATTR: is_delta
class DevServerRoot(object):
"""The Root Class for the Dev Server.
CherryPy works as follows:
For each method in this class, cherrpy interprets root/path
as a call to an instance of DevServerRoot->method_name. For example,
a call to http://myhost/build will call build. CherryPy automatically
parses http args and places them as keyword arguments in each method.
For paths http://myhost/update/dir1/dir2, you can use *args so that
cherrypy uses the update method and puts the extra paths in args.
# Method names that should not be listed on the index page.
_UNLISTED_METHODS = ['index', 'doc']
api = ApiRoot()
# Number of threads that devserver is staging images.
_staging_thread_count = 0
# Lock used to lock increasing/decreasing count.
_staging_thread_count_lock = threading.Lock()
def __init__(self, _xbuddy):
self._builder = None
self._telemetry_lock_dict = common_util.LockDict()
self._xbuddy = _xbuddy
def build(self, board, pkg, **kwargs):
"""Builds the package specified."""
import builder
if self._builder is None:
self._builder = builder.Builder()
return self._builder.Build(board, pkg, kwargs)
def _canonicalize_archive_url(archive_url):
"""Canonicalizes archive_url strings.
DevserverError: if archive_url is not set.
if archive_url:
if not archive_url.startswith('gs://'):
raise DevServerError("Archive URL isn't from Google Storage.")
return archive_url.rstrip('/')
raise DevServerError("Must specify an archive_url in the request")
def download(self, **kwargs):
"""Downloads and archives full/delta payloads from Google Storage.
THIS METHOD IS DEPRECATED: use stage(..., artifacts=...) instead.
This methods downloads artifacts. It may download artifacts in the
background in which case a caller should call wait_for_status to get
the status of the background artifact downloads. They should use the same
args passed to download.
archive_url: Google Storage URL for the build.
Example URL:
return self.stage(archive_url=kwargs.get('archive_url'),
def stage(self, **kwargs):
"""Downloads and caches the artifacts from Google Storage URL.
Downloads and caches the artifacts Google Storage URL. Returns once these
have been downloaded on the devserver. A call to this will attempt to cache
non-specified artifacts in the background for the given from the given URL
following the principle of spatial locality. Spatial locality of different
artifacts is explicitly defined in the build_artifact module.
These artifacts will then be available from the static/ sub-directory of
the devserver.
archive_url: Google Storage URL for the build.
artifacts: Comma separated list of artifacts to download.
To download the autotest and test suites tarballs:
To download the full update payload:
For both these examples, one could find these artifacts at:
Note for this example, relative path is the archive_url stripped of its
basename i.e. path/ in the examples above. Specific example:
Will get staged to:
archive_url = self._canonicalize_archive_url(kwargs.get('archive_url'))
artifacts = kwargs.get('artifacts', '')
if not artifacts:
raise DevServerError('No artifacts specified.')
with DevServerRoot._staging_thread_count_lock:
DevServerRoot._staging_thread_count += 1
downloader.Downloader(updater.static_dir, archive_url).Download(
with DevServerRoot._staging_thread_count_lock:
DevServerRoot._staging_thread_count -= 1
return 'Success'
def setup_telemetry(self, **kwargs):
"""Extracts and sets up telemetry
This method goes through the telemetry deps packages, and stages them on
the devserver to be used by the drones and the telemetry tests.
archive_url: Google Storage URL for the build.
Path to the source folder for the telemetry codebase once it is staged.
archive_url = kwargs.get('archive_url')
self.stage(archive_url=archive_url, artifacts='autotest')
build = '/'.join(downloader.Downloader.ParseUrl(archive_url))
build_path = os.path.join(updater.static_dir, build)
deps_path = os.path.join(build_path, 'autotest/packages')
telemetry_path = os.path.join(build_path, TELEMETRY_FOLDER)
src_folder = os.path.join(telemetry_path, 'src')
with self._telemetry_lock_dict.lock(telemetry_path):
if os.path.exists(src_folder):
# Telemetry is already fully stage return
return src_folder
# Copy over the required deps tar balls to the telemetry directory.
for dep in TELEMETRY_DEPS:
dep_path = os.path.join(deps_path, dep)
if not os.path.exists(dep_path):
# This dep does not exist (could be new), do not extract it.
common_util.ExtractTarball(dep_path, telemetry_path)
except common_util.CommonUtilError as e:
raise DevServerError(str(e))
# By default all the tarballs extract to test_src but some parts of
# the telemetry code specifically hardcoded to exist inside of 'src'.
test_src = os.path.join(telemetry_path, 'test_src')
shutil.move(test_src, src_folder)
except shutil.Error:
# This can occur if src_folder already exists. Remove and retry move.
raise DevServerError('Failure in telemetry setup for build %s. Appears'
' that the test_src to src move failed.' % build)
return src_folder
def wait_for_status(self, **kwargs):
"""Waits for background artifacts to be downloaded from Google Storage.
THIS METHOD IS DEPRECATED: use stage(..., artifacts=...) instead.
archive_url: Google Storage URL for the build.
Example URL:
return self.stage(archive_url=kwargs.get('archive_url'),
def stage_debug(self, **kwargs):
"""Downloads and stages debug symbol payloads from Google Storage.
THIS METHOD IS DEPRECATED: use stage(..., artifacts=...) instead.
This methods downloads the debug symbol build artifact
synchronously, and then stages it for use by symbolicate_dump.
archive_url: Google Storage URL for the build.
Example URL:
return self.stage(archive_url=kwargs.get('archive_url'),
def symbolicate_dump(self, minidump, **kwargs):
"""Symbolicates a minidump using pre-downloaded symbols, returns it.
Callers will need to POST to this URL with a body of MIME-type
The body should include a single argument, 'minidump', containing the
binary-formatted minidump to symbolicate.
archive_url: Google Storage URL for the build.
minidump: The binary minidump file to symbolicate.
# Ensure the symbols have been staged.
archive_url = self._canonicalize_archive_url(kwargs.get('archive_url'))
if self.stage(archive_url=archive_url, artifacts='symbols') != 'Success':
raise DevServerError('Failed to stage symbols for %s' % archive_url)
to_return = ''
with tempfile.NamedTemporaryFile() as local:
while True:
data =
if not data:
symbols_directory = os.path.join(downloader.Downloader.GetBuildDir(
updater.static_dir, archive_url), 'debug', 'breakpad')
stackwalk = subprocess.Popen(
['minidump_stackwalk',, symbols_directory],
stdout=subprocess.PIPE, stderr=subprocess.PIPE)
to_return, error_text = stackwalk.communicate()
if stackwalk.returncode != 0:
raise DevServerError("Can't generate stack trace: %s (rc=%d)" % (
error_text, stackwalk.returncode))
return to_return
def latestbuild(self, **params):
"""Return a string representing the latest build for a given target.
target: The build target, typically a combination of the board and the
type of build e.g. x86-mario-release.
milestone: The milestone to filter builds on. E.g. R16. Optional, if not
provided the latest RXX build will be returned.
A string representation of the latest build if one exists, i.e.
An empty string if no latest could be found.
if not params:
return _PrintDocStringAsHTML(self.latestbuild)
if 'target' not in params:
raise cherrypy.HTTPError('500 Internal Server Error',
'Error: target= is required!')
return common_util.GetLatestBuildVersion(
updater.static_dir, params['target'],
except common_util.CommonUtilError as errmsg:
raise cherrypy.HTTPError('500 Internal Server Error', str(errmsg))
def controlfiles(self, **params):
"""Return a control file or a list of all known control files.
Example URL:
To List all control files:
To List all control files for, say, the bvt suite:
To return the contents of a path:
build: The build i.e. x86-alex-release/R18-1514.0.0-a1-b1450.
control_path: If you want the contents of a control file set this
to the path. E.g. client/site_tests/sleeptest/control
Optional, if not provided return a list of control files is returned.
suite_name: If control_path is not specified but a suite_name is
specified, list the control files belonging to that suite instead of
all control files. The empty string for suite_name will list all control
files for the build.
Contents of a control file if control_path is provided.
A list of control files if no control_path is provided.
if not params:
return _PrintDocStringAsHTML(self.controlfiles)
if 'build' not in params:
raise cherrypy.HTTPError('500 Internal Server Error',
'Error: build= is required!')
if 'control_path' not in params:
if 'suite_name' in params and params['suite_name']:
return common_util.GetControlFileListForSuite(
updater.static_dir, params['build'], params['suite_name'])
return common_util.GetControlFileList(
updater.static_dir, params['build'])
return common_util.GetControlFile(
updater.static_dir, params['build'], params['control_path'])
def stage_images(self, **kwargs):
"""Downloads and stages a Chrome OS image from Google Storage.
THIS METHOD IS DEPRECATED: use stage(..., artifacts=...) instead.
This method downloads a zipped archive from a specified GS location, then
extracts and stages the specified list of images and stages them under
static/BOARD/BUILD/. Download is synchronous.
archive_url: Google Storage URL for the build.
image_types: comma-separated list of images to download, may include
'test', 'recovery', and 'base'
Example URL:
image_types = kwargs.get('image_types').split(',')
image_types_list = [image + '_image' for image in image_types]
self.stage(archive_url=kwargs.get('archive_url'), artifacts=','.join(
def xbuddy(self, *args, **kwargs):
"""The full xBuddy call, returns resource specified by path_parts.
path_parts: the path following xbuddy/ in the call url is split into the
components of the path.
The path can be understood as a build_id/artifact, build_id is
composed of "board/version"
path_parts[0], the board, is the familiar board name, optionally
path_parts[1], the version, can be the google storage version
number, and may also be any of a number of xBuddy defined version
aliases that will be translated into the latest built image that
fits the description. defaults to latest.
path_parts[2], the artifact, is one of a number of image or artifact
aliases used by xbuddy, defined in xbuddy:ALIASES. Defaults to test
return_dir: {true|false}
if set to true, returns the url to the update.gz
Example URL:
A redirect to the image or update file on the devserver.
e.g. http://host:port/static/archive/x86-generic-release/
or if return_dir is True, return path to the folder where
image or update file is
boolean_string = kwargs.get('return_dir')
return_dir = xbuddy.XBuddy.ParseBoolean(boolean_string)
return_url = self._xbuddy.Get(args,
if return_dir:
directory = os.path.join(cherrypy.request.base, return_url)
_Log("Directory requested, returning: %s", directory)
return directory
return_url = '/' + return_url
_Log("Payload requested, returning: %s", return_url)
raise cherrypy.HTTPRedirect(return_url, 302)
def xbuddy_list(self):
"""Lists the currently available images & time since last access.
@return: A string representation of a list of tuples
[(build_id, time since last access),...]
return self._xbuddy.List()
def xbuddy_capacity(self):
"""Returns the number of images cached by xBuddy.
@return: Capacity of this devserver.
return self._xbuddy.Capacity()
def index(self):
"""Presents a welcome message and documentation links."""
return ('Welcome to the Dev Server!<br>\n'
'Here are the available methods, click for documentation:<br>\n'
'%s' %
[('<a href=doc/%s>%s</a>' % (name, name))
for name in _FindExposedMethods(
self, '', unlisted=self._UNLISTED_METHODS)]))
def doc(self, *args):
"""Shows the documentation for available methods / URLs.
name = '/'.join(args)
method = _GetExposedMethod(self, name)
if not method:
raise DevServerError("No exposed method named `%s'" % name)
if not method.__doc__:
raise DevServerError("No documentation for exposed method `%s'" % name)
return '<pre>\n%s</pre>' % method.__doc__
def update(self, *args):
"""Handles an update check from a Chrome OS client.
The HTTP request should contain the standard Omaha-style XML blob. The URL
line may contain an additional intermediate path to the update payload.
if len(args) > 0 and args[0] == 'xbuddy':
# Interpret the rest of the path as an xbuddy path
label, found = self._xbuddy.Translate(args[1:] + ('full_payload',))
if not found:
_Log("Update payload not found for %s, xBuddy looking it up.", label)
label = '/'.join(args)
_Log('Update label: %s', label)
body_length = int(cherrypy.request.headers.get('Content-Length', 0))
data =
return updater.HandleUpdatePing(data, label)
def check_health(self):
"""Collect the health status of devserver to see if it's ready for staging.
@return: A JSON dictionary containing all or some of the following fields:
free_disk (int): free disk space in GB
staging_thread_count (int): number of devserver threads currently
staging an image
# Get free disk space.
stat = os.statvfs(updater.static_dir)
free_disk = stat.f_bsize * stat.f_bavail / 1000000000
return json.dumps({
'free_disk': free_disk,
'staging_thread_count': DevServerRoot._staging_thread_count,
def _CleanCache(cache_dir, wipe):
"""Wipes any excess cached items in the cache_dir.
cache_dir: the directory we are wiping from.
wipe: If True, wipe all the contents -- not just the excess.
if wipe:
# Clear the cache and exit on error.
cmd = 'rm -rf %s/*' % cache_dir
if os.system(cmd) != 0:
_Log('Failed to clear the cache with %s' % cmd)
# Clear all but the last N cached updates
cmd = ('cd %s; ls -tr | head --lines=-%d | xargs rm -rf' %
(cache_dir, CACHED_ENTRIES))
if os.system(cmd) != 0:
_Log('Failed to clean up old delta cache files with %s' % cmd)
def _AddTestingOptions(parser):
group = optparse.OptionGroup(
parser, 'Advanced Testing Options', 'These are used by test scripts and '
'developers writing integration tests utilizing the devserver. They are '
'not intended to be really used outside the scope of someone '
'knowledgable about the test.')
help='do not start the server (yet pregenerate/clear cache)')
action='store_true', default=False,
help='record history of host update events (/api/hostlog)')
metavar='NUM', default= -1, type='int',
help='maximum number of update checks handled positively '
'(default: unlimited)')
metavar='PATH', default=None,
help='path to the private key in pem format. If this is set '
'the devserver will generate update payloads that are '
'signed with this key.')
metavar='PORT', default=None, type='int',
help='port to have the client connect to -- basically the '
'devserver lies to the update to tell it to get the payload '
'from a different port that will proxy the request back to '
'the devserver. The proxy must be managed outside the '
action='store_true', default=False,
help='Payload is being served from a remote machine')
group.add_option('-u', '--urlbase',
help='base URL for update images, other than the '
'devserver. Use in conjunction with remote_payload.')
def _AddUpdateOptions(parser):
group = optparse.OptionGroup(
parser, 'Autoupdate Options', 'These options can be used to change '
'how the devserver either generates or serve update payloads. Please '
'note that all of these option affect how a payload is generated and so '
'do not work in archive-only mode.')
help='By default the devserver will create an update '
'payload from the latest image built for the board '
'a device that is requesting an update has. When we '
'pre-generate an update (see below) and we do not specify '
'another update_type option like image or payload, the '
'devserver needs to know the board to generate the latest '
'image for. This is that board.')
action='store_true', default=False,
help='Present update payload as critical')
dest='vm', action='store_true',
help='DEPRECATED: see no_patch_kernel.')
help='Generate and serve an update using this image to any '
'device that requests an update.')
dest='patch_kernel', action='store_false', default=True,
help='When generating an update payload, do not patch the '
'kernel with kernel verification blob from the stateful '
help='use the update payload from specified directory '
group.add_option('-p', '--pregenerate_update',
action='store_true', default=False,
help='pre-generate the update payload before accepting '
'update requests. Useful to help debug payload generation '
'issues quickly. Also if an update payload will take a '
'long time to generate, a client may timeout if you do not'
'pregenerate the update.')
metavar='PATH', default='',
help='If specified, delta updates will be generated using '
'this image as the source image. Delta updates are when '
'you are updating from a "source image" to a another '
def _AddProductionOptions(parser):
group = optparse.OptionGroup(
parser, 'Advanced Server Options', 'These options can be used to changed '
'for advanced server behavior.')
help='To be deprecated.')
action='store_true', default=False,
help='At startup, removes all cached entries from the'
'devserver\'s cache.')
help='log output to this file instead of stdout')
action='store_true', default=False,
help='have the devserver use production values when '
'starting up. This includes using more threads and '
'performing less logging.')
def _MakeLogHandler(logfile):
"""Create a LogHandler instance used to log all messages."""
hdlr_cls = handlers.TimedRotatingFileHandler
hdlr = hdlr_cls(logfile, when=_LOG_ROTATION_TIME,
# The cherrypy documentation says to use the _cplogging module for
# this, even though it's named as a private module.
# pylint: disable=W0212
return hdlr
def main():
usage = '\n\n'.join(['usage: %prog [options]', __doc__])
parser = optparse.OptionParser(usage=usage)
# get directory that the devserver is run from
devserver_dir = os.path.dirname(os.path.abspath(sys.argv[0]))
default_archive_dir = '%s/static' % devserver_dir
help='writable static directory')
default=8080, type='int',
help='port for the dev server to use (default: 8080)')
parser.add_option('-t', '--test_image',
help='If set, look for the chromiumos_test_image.bin file '
'when generating update payloads rather than the '
'chromiumos_image.bin which is the default.')
parser.add_option('-x', '--xbuddy_manage_builds',
help='If set, allow xbuddy to manage images in'
(options, _) = parser.parse_args()
# Handle options that must be set globally in cherrypy. Do this
# work up front, because calls to _Log() below depend on this
# initialization.
if options.production:
cherrypy.config.update({'environment': 'production'})
if not options.logfile:
cherrypy.config.update({'log.screen': True})
cherrypy.config.update({'log.error_file': '',
'log.access_file': ''})
hdlr = _MakeLogHandler(options.logfile)
# Pylint can't seem to process these two calls properly
# pylint: disable=E1101
# pylint: enable=E1101
root_dir = os.path.realpath('%s/../..' % devserver_dir)
serve_only = False
# TODO(sosa): Remove after deprecation.
if options.vm:
options.patch_kernel = False
# set static_dir, from which everything will be served
if options.archive_dir:
# TODO(joyc) To be deprecated
archive_dir = options.archive_dir
if not os.path.isabs(archive_dir):
archive_dir = os.path.join(devserver_dir, archive_dir)
options.static_dir = os.path.realpath(archive_dir)
serve_only = True
options.static_dir = os.path.realpath(options.static_dir)
cache_dir = os.path.join(options.static_dir, 'cache')
# If our devserver is only supposed to serve payloads, we shouldn't be
# mucking with the cache at all. If the devserver hadn't previously
# generated a cache and is expected, the caller is using it wrong.
if serve_only:
# Extra check to make sure we're not being called incorrectly.
if (options.clear_cache or options.exit or options.pregenerate_update or
options.board or options.image):
parser.error('Incompatible flags detected for serve_only mode.')
elif os.path.exists(cache_dir):
_CleanCache(cache_dir, options.clear_cache)
_Log('Using cache directory %s' % cache_dir)
_Log('Source root is %s' % root_dir)
_Log('Serving from %s' % options.static_dir)
# We allow global use here to share with cherrypy classes.
# pylint: disable=W0603
global updater
updater = autoupdate.Autoupdate(
copy_to_static_root=not options.exit,
if options.pregenerate_update:
if options.exit:
_xbuddy = xbuddy.XBuddy(options.xbuddy_manage_builds,
dev_server = DevServerRoot(_xbuddy)
cherrypy.quickstart(dev_server, config=_GetConfig(options))
if __name__ == '__main__':