Clone of official tools
utils.py@21:4fdf0dd04f6f, 2016-07-15 (annotated)
- Committer:
- screamer
- Date:
- Fri Jul 15 22:58:15 2016 +0100
- Revision:
- 21:4fdf0dd04f6f
- Parent:
- 19:3604ee113e2d
- Child:
- 22:9e85236d8716
Further improvements and updates to tools
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
screamer | 0:66f3b5499f7f | 1 | """ |
screamer | 0:66f3b5499f7f | 2 | mbed SDK |
screamer | 0:66f3b5499f7f | 3 | Copyright (c) 2011-2013 ARM Limited |
screamer | 0:66f3b5499f7f | 4 | |
screamer | 0:66f3b5499f7f | 5 | Licensed under the Apache License, Version 2.0 (the "License"); |
screamer | 0:66f3b5499f7f | 6 | you may not use this file except in compliance with the License. |
screamer | 0:66f3b5499f7f | 7 | You may obtain a copy of the License at |
screamer | 0:66f3b5499f7f | 8 | |
screamer | 0:66f3b5499f7f | 9 | http://www.apache.org/licenses/LICENSE-2.0 |
screamer | 0:66f3b5499f7f | 10 | |
screamer | 0:66f3b5499f7f | 11 | Unless required by applicable law or agreed to in writing, software |
screamer | 0:66f3b5499f7f | 12 | distributed under the License is distributed on an "AS IS" BASIS, |
screamer | 0:66f3b5499f7f | 13 | WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
screamer | 0:66f3b5499f7f | 14 | See the License for the specific language governing permissions and |
screamer | 0:66f3b5499f7f | 15 | limitations under the License. |
screamer | 0:66f3b5499f7f | 16 | """ |
screamer | 0:66f3b5499f7f | 17 | import sys |
screamer | 0:66f3b5499f7f | 18 | import inspect |
screamer | 0:66f3b5499f7f | 19 | import os |
screamer | 0:66f3b5499f7f | 20 | from os import listdir, remove, makedirs |
screamer | 0:66f3b5499f7f | 21 | from shutil import copyfile |
screamer | 0:66f3b5499f7f | 22 | from os.path import isdir, join, exists, split, relpath, splitext |
screamer | 0:66f3b5499f7f | 23 | from subprocess import Popen, PIPE, STDOUT, call |
screamer | 7:5af61d55adbe | 24 | import json |
screamer | 7:5af61d55adbe | 25 | from collections import OrderedDict |
screamer | 19:3604ee113e2d | 26 | import logging |
screamer | 0:66f3b5499f7f | 27 | |
screamer | 21:4fdf0dd04f6f | 28 | def compile_worker(job): |
screamer | 21:4fdf0dd04f6f | 29 | results = [] |
screamer | 21:4fdf0dd04f6f | 30 | for command in job['commands']: |
screamer | 21:4fdf0dd04f6f | 31 | try: |
screamer | 21:4fdf0dd04f6f | 32 | _, _stderr, _rc = run_cmd(command, work_dir=job['work_dir'], chroot=job['chroot']) |
screamer | 21:4fdf0dd04f6f | 33 | except KeyboardInterrupt as e: |
screamer | 21:4fdf0dd04f6f | 34 | raise ToolException |
screamer | 21:4fdf0dd04f6f | 35 | |
screamer | 21:4fdf0dd04f6f | 36 | results.append({ |
screamer | 21:4fdf0dd04f6f | 37 | 'code': _rc, |
screamer | 21:4fdf0dd04f6f | 38 | 'output': _stderr, |
screamer | 21:4fdf0dd04f6f | 39 | 'command': command |
screamer | 21:4fdf0dd04f6f | 40 | }) |
screamer | 21:4fdf0dd04f6f | 41 | |
screamer | 21:4fdf0dd04f6f | 42 | return { |
screamer | 21:4fdf0dd04f6f | 43 | 'source': job['source'], |
screamer | 21:4fdf0dd04f6f | 44 | 'object': job['object'], |
screamer | 21:4fdf0dd04f6f | 45 | 'commands': job['commands'], |
screamer | 21:4fdf0dd04f6f | 46 | 'results': results |
screamer | 21:4fdf0dd04f6f | 47 | } |
screamer | 21:4fdf0dd04f6f | 48 | |
screamer | 0:66f3b5499f7f | 49 | def cmd(l, check=True, verbose=False, shell=False, cwd=None): |
screamer | 0:66f3b5499f7f | 50 | text = l if shell else ' '.join(l) |
screamer | 0:66f3b5499f7f | 51 | if verbose: |
screamer | 0:66f3b5499f7f | 52 | print text |
screamer | 0:66f3b5499f7f | 53 | rc = call(l, shell=shell, cwd=cwd) |
screamer | 0:66f3b5499f7f | 54 | if check and rc != 0: |
screamer | 0:66f3b5499f7f | 55 | raise Exception('ERROR %d: "%s"' % (rc, text)) |
screamer | 0:66f3b5499f7f | 56 | |
screamer | 0:66f3b5499f7f | 57 | |
screamer | 17:04753e1e329d | 58 | def run_cmd(command, work_dir=None, chroot=None, redirect=False): |
screamer | 17:04753e1e329d | 59 | if chroot: |
screamer | 17:04753e1e329d | 60 | # Conventions managed by the web team for the mbed.org build system |
screamer | 17:04753e1e329d | 61 | chroot_cmd = [ |
screamer | 17:04753e1e329d | 62 | '/usr/sbin/chroot', '--userspec=33:33', chroot |
screamer | 17:04753e1e329d | 63 | ] |
screamer | 17:04753e1e329d | 64 | for c in command: |
screamer | 17:04753e1e329d | 65 | chroot_cmd += [c.replace(chroot, '')] |
screamer | 17:04753e1e329d | 66 | |
screamer | 17:04753e1e329d | 67 | logging.debug("Running command %s"%' '.join(chroot_cmd)) |
screamer | 17:04753e1e329d | 68 | command = chroot_cmd |
screamer | 21:4fdf0dd04f6f | 69 | work_dir = None |
screamer | 17:04753e1e329d | 70 | |
screamer | 0:66f3b5499f7f | 71 | try: |
screamer | 17:04753e1e329d | 72 | p = Popen(command, stdout=PIPE, stderr=STDOUT if redirect else PIPE, cwd=work_dir) |
screamer | 0:66f3b5499f7f | 73 | _stdout, _stderr = p.communicate() |
screamer | 13:ab47a20b66f0 | 74 | except OSError as e: |
screamer | 0:66f3b5499f7f | 75 | print "[OS ERROR] Command: "+(' '.join(command)) |
screamer | 0:66f3b5499f7f | 76 | raise |
screamer | 13:ab47a20b66f0 | 77 | |
screamer | 0:66f3b5499f7f | 78 | return _stdout, _stderr, p.returncode |
screamer | 0:66f3b5499f7f | 79 | |
screamer | 0:66f3b5499f7f | 80 | |
screamer | 0:66f3b5499f7f | 81 | def run_cmd_ext(command): |
screamer | 0:66f3b5499f7f | 82 | assert is_cmd_valid(command[0]) |
screamer | 0:66f3b5499f7f | 83 | p = Popen(command, stdout=PIPE, stderr=PIPE) |
screamer | 0:66f3b5499f7f | 84 | _stdout, _stderr = p.communicate() |
screamer | 0:66f3b5499f7f | 85 | return _stdout, _stderr, p.returncode |
screamer | 0:66f3b5499f7f | 86 | |
screamer | 0:66f3b5499f7f | 87 | |
screamer | 0:66f3b5499f7f | 88 | def is_cmd_valid(cmd): |
screamer | 0:66f3b5499f7f | 89 | caller = get_caller_name() |
screamer | 0:66f3b5499f7f | 90 | abspath = find_cmd_abspath(cmd) |
screamer | 0:66f3b5499f7f | 91 | if not abspath: |
screamer | 0:66f3b5499f7f | 92 | error("%s: Command '%s' can't be found" % (caller, cmd)) |
screamer | 0:66f3b5499f7f | 93 | if not is_exec(abspath): |
screamer | 0:66f3b5499f7f | 94 | error("%s: Command '%s' resolves to file '%s' which is not executable" % (caller, cmd, abspath)) |
screamer | 0:66f3b5499f7f | 95 | return True |
screamer | 0:66f3b5499f7f | 96 | |
screamer | 0:66f3b5499f7f | 97 | |
screamer | 0:66f3b5499f7f | 98 | def is_exec(path): |
screamer | 0:66f3b5499f7f | 99 | return os.access(path, os.X_OK) or os.access(path+'.exe', os.X_OK) |
screamer | 0:66f3b5499f7f | 100 | |
screamer | 0:66f3b5499f7f | 101 | |
screamer | 0:66f3b5499f7f | 102 | def find_cmd_abspath(cmd): |
screamer | 0:66f3b5499f7f | 103 | """ Returns the absolute path to a command. |
screamer | 0:66f3b5499f7f | 104 | None is returned if no absolute path was found. |
screamer | 0:66f3b5499f7f | 105 | """ |
screamer | 0:66f3b5499f7f | 106 | if exists(cmd) or exists(cmd + '.exe'): |
screamer | 0:66f3b5499f7f | 107 | return os.path.abspath(cmd) |
screamer | 0:66f3b5499f7f | 108 | if not 'PATH' in os.environ: |
screamer | 0:66f3b5499f7f | 109 | raise Exception("Can't find command path for current platform ('%s')" % sys.platform) |
screamer | 0:66f3b5499f7f | 110 | PATH=os.environ['PATH'] |
screamer | 0:66f3b5499f7f | 111 | for path in PATH.split(os.pathsep): |
screamer | 0:66f3b5499f7f | 112 | abspath = '%s/%s' % (path, cmd) |
screamer | 0:66f3b5499f7f | 113 | if exists(abspath) or exists(abspath + '.exe'): |
screamer | 0:66f3b5499f7f | 114 | return abspath |
screamer | 0:66f3b5499f7f | 115 | |
screamer | 0:66f3b5499f7f | 116 | |
screamer | 0:66f3b5499f7f | 117 | def mkdir(path): |
screamer | 0:66f3b5499f7f | 118 | if not exists(path): |
screamer | 0:66f3b5499f7f | 119 | makedirs(path) |
screamer | 0:66f3b5499f7f | 120 | |
screamer | 0:66f3b5499f7f | 121 | |
screamer | 0:66f3b5499f7f | 122 | def copy_file(src, dst): |
screamer | 0:66f3b5499f7f | 123 | """ Implement the behaviour of "shutil.copy(src, dst)" without copying the |
screamer | 0:66f3b5499f7f | 124 | permissions (this was causing errors with directories mounted with samba) |
screamer | 0:66f3b5499f7f | 125 | """ |
screamer | 0:66f3b5499f7f | 126 | if isdir(dst): |
screamer | 0:66f3b5499f7f | 127 | _, file = split(src) |
screamer | 0:66f3b5499f7f | 128 | dst = join(dst, file) |
screamer | 0:66f3b5499f7f | 129 | copyfile(src, dst) |
screamer | 0:66f3b5499f7f | 130 | |
screamer | 0:66f3b5499f7f | 131 | |
screamer | 0:66f3b5499f7f | 132 | def delete_dir_files(dir): |
screamer | 0:66f3b5499f7f | 133 | if not exists(dir): |
screamer | 0:66f3b5499f7f | 134 | return |
screamer | 0:66f3b5499f7f | 135 | |
screamer | 0:66f3b5499f7f | 136 | for f in listdir(dir): |
screamer | 0:66f3b5499f7f | 137 | file = join(dir, f) |
screamer | 0:66f3b5499f7f | 138 | if not isdir(file): |
screamer | 0:66f3b5499f7f | 139 | remove(file) |
screamer | 0:66f3b5499f7f | 140 | |
screamer | 0:66f3b5499f7f | 141 | |
screamer | 0:66f3b5499f7f | 142 | def get_caller_name(steps=2): |
screamer | 0:66f3b5499f7f | 143 | """ |
screamer | 0:66f3b5499f7f | 144 | When called inside a function, it returns the name |
screamer | 0:66f3b5499f7f | 145 | of the caller of that function. |
screamer | 0:66f3b5499f7f | 146 | """ |
screamer | 0:66f3b5499f7f | 147 | return inspect.stack()[steps][3] |
screamer | 0:66f3b5499f7f | 148 | |
screamer | 0:66f3b5499f7f | 149 | |
screamer | 0:66f3b5499f7f | 150 | def error(msg): |
screamer | 0:66f3b5499f7f | 151 | print("ERROR: %s" % msg) |
screamer | 0:66f3b5499f7f | 152 | sys.exit(1) |
screamer | 0:66f3b5499f7f | 153 | |
screamer | 0:66f3b5499f7f | 154 | |
screamer | 0:66f3b5499f7f | 155 | def rel_path(path, base, dot=False): |
screamer | 0:66f3b5499f7f | 156 | p = relpath(path, base) |
screamer | 0:66f3b5499f7f | 157 | if dot and not p.startswith('.'): |
screamer | 0:66f3b5499f7f | 158 | p = './' + p |
screamer | 0:66f3b5499f7f | 159 | return p |
screamer | 0:66f3b5499f7f | 160 | |
screamer | 0:66f3b5499f7f | 161 | |
screamer | 0:66f3b5499f7f | 162 | class ToolException(Exception): |
screamer | 0:66f3b5499f7f | 163 | pass |
screamer | 0:66f3b5499f7f | 164 | |
screamer | 0:66f3b5499f7f | 165 | class NotSupportedException(Exception): |
screamer | 0:66f3b5499f7f | 166 | pass |
screamer | 0:66f3b5499f7f | 167 | |
screamer | 0:66f3b5499f7f | 168 | def split_path(path): |
screamer | 0:66f3b5499f7f | 169 | base, file = split(path) |
screamer | 0:66f3b5499f7f | 170 | name, ext = splitext(file) |
screamer | 0:66f3b5499f7f | 171 | return base, name, ext |
screamer | 0:66f3b5499f7f | 172 | |
screamer | 0:66f3b5499f7f | 173 | |
screamer | 0:66f3b5499f7f | 174 | def args_error(parser, message): |
screamer | 0:66f3b5499f7f | 175 | print "\n\n%s\n\n" % message |
screamer | 0:66f3b5499f7f | 176 | parser.print_help() |
screamer | 0:66f3b5499f7f | 177 | sys.exit() |
screamer | 0:66f3b5499f7f | 178 | |
screamer | 0:66f3b5499f7f | 179 | |
screamer | 0:66f3b5499f7f | 180 | def construct_enum(**enums): |
screamer | 0:66f3b5499f7f | 181 | """ Create your own pseudo-enums """ |
screamer | 0:66f3b5499f7f | 182 | return type('Enum', (), enums) |
screamer | 0:66f3b5499f7f | 183 | |
screamer | 0:66f3b5499f7f | 184 | |
screamer | 0:66f3b5499f7f | 185 | def check_required_modules(required_modules, verbose=True): |
screamer | 0:66f3b5499f7f | 186 | """ Function checks for Python modules which should be "importable" (installed) |
screamer | 0:66f3b5499f7f | 187 | before test suite can be used. |
screamer | 0:66f3b5499f7f | 188 | @return returns True if all modules are installed already |
screamer | 0:66f3b5499f7f | 189 | """ |
screamer | 0:66f3b5499f7f | 190 | import imp |
screamer | 0:66f3b5499f7f | 191 | not_installed_modules = [] |
screamer | 0:66f3b5499f7f | 192 | for module_name in required_modules: |
screamer | 0:66f3b5499f7f | 193 | try: |
screamer | 0:66f3b5499f7f | 194 | imp.find_module(module_name) |
screamer | 0:66f3b5499f7f | 195 | except ImportError as e: |
screamer | 0:66f3b5499f7f | 196 | # We also test against a rare case: module is an egg file |
screamer | 0:66f3b5499f7f | 197 | try: |
screamer | 0:66f3b5499f7f | 198 | __import__(module_name) |
screamer | 0:66f3b5499f7f | 199 | except ImportError as e: |
screamer | 0:66f3b5499f7f | 200 | not_installed_modules.append(module_name) |
screamer | 0:66f3b5499f7f | 201 | if verbose: |
screamer | 0:66f3b5499f7f | 202 | print "Error: %s" % e |
screamer | 0:66f3b5499f7f | 203 | |
screamer | 0:66f3b5499f7f | 204 | if verbose: |
screamer | 0:66f3b5499f7f | 205 | if not_installed_modules: |
screamer | 0:66f3b5499f7f | 206 | print "Warning: Module(s) %s not installed. Please install required module(s) before using this script."% (', '.join(not_installed_modules)) |
screamer | 0:66f3b5499f7f | 207 | |
screamer | 0:66f3b5499f7f | 208 | if not_installed_modules: |
screamer | 0:66f3b5499f7f | 209 | return False |
screamer | 0:66f3b5499f7f | 210 | else: |
screamer | 0:66f3b5499f7f | 211 | return True |
screamer | 7:5af61d55adbe | 212 | |
screamer | 7:5af61d55adbe | 213 | # Utility function: traverse a dictionary and change all the strings in the dictionary to |
screamer | 7:5af61d55adbe | 214 | # ASCII from Unicode. Useful when reading ASCII JSON data, because the JSON decoder always |
screamer | 7:5af61d55adbe | 215 | # returns Unicode string. |
screamer | 7:5af61d55adbe | 216 | # Based on http://stackoverflow.com/a/13105359 |
screamer | 7:5af61d55adbe | 217 | def dict_to_ascii(input): |
screamer | 7:5af61d55adbe | 218 | if isinstance(input, dict): |
screamer | 7:5af61d55adbe | 219 | return OrderedDict([(dict_to_ascii(key), dict_to_ascii(value)) for key, value in input.iteritems()]) |
screamer | 7:5af61d55adbe | 220 | elif isinstance(input, list): |
screamer | 7:5af61d55adbe | 221 | return [dict_to_ascii(element) for element in input] |
screamer | 7:5af61d55adbe | 222 | elif isinstance(input, unicode): |
screamer | 7:5af61d55adbe | 223 | return input.encode('ascii') |
screamer | 7:5af61d55adbe | 224 | else: |
screamer | 7:5af61d55adbe | 225 | return input |
screamer | 7:5af61d55adbe | 226 | |
screamer | 7:5af61d55adbe | 227 | # Read a JSON file and return its Python representation, transforming all the strings from Unicode |
screamer | 7:5af61d55adbe | 228 | # to ASCII. The order of keys in the JSON file is preserved. |
screamer | 7:5af61d55adbe | 229 | def json_file_to_dict(fname): |
screamer | 7:5af61d55adbe | 230 | with open(fname, "rt") as f: |
screamer | 7:5af61d55adbe | 231 | return dict_to_ascii(json.load(f, object_pairs_hook=OrderedDict)) |