| OLD | NEW |
| 1 #!/usr/bin/env python | 1 #!/usr/bin/env python |
| 2 # | 2 # |
| 3 # Copyright 2013 The Chromium Authors. All rights reserved. | 3 # Copyright 2013 The Chromium Authors. All rights reserved. |
| 4 # Use of this source code is governed by a BSD-style license that can be | 4 # Use of this source code is governed by a BSD-style license that can be |
| 5 # found in the LICENSE file. | 5 # found in the LICENSE file. |
| 6 # | 6 # |
| 7 # Find the most recent tombstone file(s) on all connected devices | 7 # Find the most recent tombstone file(s) on all connected devices |
| 8 # and prints their stacks. | 8 # and prints their stacks. |
| 9 # | 9 # |
| 10 # Assumes tombstone file was created with current symbols. | 10 # Assumes tombstone file was created with current symbols. |
| (...skipping 147 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 158 tombstones: a list of tombstones. | 158 tombstones: a list of tombstones. |
| 159 """ | 159 """ |
| 160 if not tombstones: | 160 if not tombstones: |
| 161 logging.warning('No tombstones to resolve.') | 161 logging.warning('No tombstones to resolve.') |
| 162 return | 162 return |
| 163 if len(tombstones) == 1: | 163 if len(tombstones) == 1: |
| 164 data = [_ResolveTombstone(tombstones[0])] | 164 data = [_ResolveTombstone(tombstones[0])] |
| 165 else: | 165 else: |
| 166 pool = multiprocessing.Pool(processes=jobs) | 166 pool = multiprocessing.Pool(processes=jobs) |
| 167 data = pool.map(_ResolveTombstone, tombstones) | 167 data = pool.map(_ResolveTombstone, tombstones) |
| 168 resolved_tombstones = [] |
| 168 for tombstone in data: | 169 for tombstone in data: |
| 169 for line in tombstone: | 170 resolved_tombstones.extend(tombstone) |
| 170 logging.info(line) | 171 return resolved_tombstones |
| 171 | 172 |
| 172 | 173 def _GetTombstonesForDevice(device, resolve_all_tombstones, |
| 173 def _GetTombstonesForDevice(device, args): | 174 include_stack_symbols, |
| 175 wipe_tombstones): |
| 174 """Returns a list of tombstones on a given device. | 176 """Returns a list of tombstones on a given device. |
| 175 | 177 |
| 176 Args: | 178 Args: |
| 177 device: An instance of DeviceUtils. | 179 device: An instance of DeviceUtils. |
| 178 args: command line arguments | 180 resolve_all_tombstone: Whether to resolve every tombstone. |
| 181 include_stack_symbols: Whether to include symbols for stack data. |
| 182 wipe_tombstones: Whether to wipe tombstones. |
| 179 """ | 183 """ |
| 180 ret = [] | 184 ret = [] |
| 181 all_tombstones = list(_ListTombstones(device)) | 185 all_tombstones = list(_ListTombstones(device)) |
| 182 if not all_tombstones: | 186 if not all_tombstones: |
| 183 logging.warning('No tombstones.') | 187 logging.warning('No tombstones.') |
| 184 return ret | 188 return ret |
| 185 | 189 |
| 186 # Sort the tombstones in date order, descending | 190 # Sort the tombstones in date order, descending |
| 187 all_tombstones.sort(cmp=lambda a, b: cmp(b[1], a[1])) | 191 all_tombstones.sort(cmp=lambda a, b: cmp(b[1], a[1])) |
| 188 | 192 |
| 189 # Only resolve the most recent unless --all-tombstones given. | 193 # Only resolve the most recent unless --all-tombstones given. |
| 190 tombstones = all_tombstones if args.all_tombstones else [all_tombstones[0]] | 194 tombstones = all_tombstones if resolve_all_tombstones else [all_tombstones[0]] |
| 191 | 195 |
| 192 device_now = _GetDeviceDateTime(device) | 196 device_now = _GetDeviceDateTime(device) |
| 193 try: | 197 try: |
| 194 for tombstone_file, tombstone_time in tombstones: | 198 for tombstone_file, tombstone_time in tombstones: |
| 195 ret += [{'serial': str(device), | 199 ret += [{'serial': str(device), |
| 196 'device_abi': device.product_cpu_abi, | 200 'device_abi': device.product_cpu_abi, |
| 197 'device_now': device_now, | 201 'device_now': device_now, |
| 198 'time': tombstone_time, | 202 'time': tombstone_time, |
| 199 'file': tombstone_file, | 203 'file': tombstone_file, |
| 200 'stack': args.stack, | 204 'stack': include_stack_symbols, |
| 201 'data': _GetTombstoneData(device, tombstone_file)}] | 205 'data': _GetTombstoneData(device, tombstone_file)}] |
| 202 except device_errors.CommandFailedError: | 206 except device_errors.CommandFailedError: |
| 203 for entry in device.StatDirectory( | 207 for entry in device.StatDirectory( |
| 204 '/data/tombstones', as_root=True, timeout=60): | 208 '/data/tombstones', as_root=True, timeout=60): |
| 205 logging.info('%s: %s', str(device), entry) | 209 logging.info('%s: %s', str(device), entry) |
| 206 raise | 210 raise |
| 207 | 211 |
| 208 # Erase all the tombstones if desired. | 212 # Erase all the tombstones if desired. |
| 209 if args.wipe_tombstones: | 213 if wipe_tombstones: |
| 210 for tombstone_file, _ in all_tombstones: | 214 for tombstone_file, _ in all_tombstones: |
| 211 _EraseTombstone(device, tombstone_file) | 215 _EraseTombstone(device, tombstone_file) |
| 212 | 216 |
| 213 return ret | 217 return ret |
| 214 | 218 |
| 219 def ClearAllTombstones(device): |
| 220 """Clear all tombstones in the device. |
| 221 |
| 222 Args: |
| 223 device: An instance of DeviceUtils. |
| 224 """ |
| 225 all_tombstones = list(_ListTombstones(device)) |
| 226 if not all_tombstones: |
| 227 logging.warning('No tombstones to clear.') |
| 228 |
| 229 for tombstone_file, _ in all_tombstones: |
| 230 _EraseTombstone(device, tombstone_file) |
| 231 |
| 232 def ResolveTombstones(device, resolve_all_tombstones, include_stack_symbols, |
| 233 wipe_tombstones, jobs=4): |
| 234 """Resolve tombstones in the device. |
| 235 |
| 236 Args: |
| 237 device: An instance of DeviceUtils. |
| 238 resolve_all_tombstone: Whether to resolve every tombstone. |
| 239 include_stack_symbols: Whether to include symbols for stack data. |
| 240 wipe_tombstones: Whether to wipe tombstones. |
| 241 jobs: Number of jobs to use when processing multiple crash stacks. |
| 242 """ |
| 243 return _ResolveTombstones(jobs, |
| 244 _GetTombstonesForDevice(device, |
| 245 resolve_all_tombstones, |
| 246 include_stack_symbols, |
| 247 wipe_tombstones)) |
| 215 | 248 |
| 216 def main(): | 249 def main(): |
| 217 custom_handler = logging.StreamHandler(sys.stdout) | 250 custom_handler = logging.StreamHandler(sys.stdout) |
| 218 custom_handler.setFormatter(run_tests_helper.CustomFormatter()) | 251 custom_handler.setFormatter(run_tests_helper.CustomFormatter()) |
| 219 logging.getLogger().addHandler(custom_handler) | 252 logging.getLogger().addHandler(custom_handler) |
| 220 logging.getLogger().setLevel(logging.INFO) | 253 logging.getLogger().setLevel(logging.INFO) |
| 221 | 254 |
| 222 parser = argparse.ArgumentParser() | 255 parser = argparse.ArgumentParser() |
| 223 parser.add_argument('--device', | 256 parser.add_argument('--device', |
| 224 help='The serial number of the device. If not specified ' | 257 help='The serial number of the device. If not specified ' |
| (...skipping 28 matching lines...) Expand all Loading... |
| 253 constants.CheckOutputDirectory() | 286 constants.CheckOutputDirectory() |
| 254 | 287 |
| 255 if args.device: | 288 if args.device: |
| 256 devices = [device_utils.DeviceUtils(args.device)] | 289 devices = [device_utils.DeviceUtils(args.device)] |
| 257 else: | 290 else: |
| 258 devices = device_utils.DeviceUtils.HealthyDevices(blacklist) | 291 devices = device_utils.DeviceUtils.HealthyDevices(blacklist) |
| 259 | 292 |
| 260 # This must be done serially because strptime can hit a race condition if | 293 # This must be done serially because strptime can hit a race condition if |
| 261 # used for the first time in a multithreaded environment. | 294 # used for the first time in a multithreaded environment. |
| 262 # http://bugs.python.org/issue7980 | 295 # http://bugs.python.org/issue7980 |
| 263 tombstones = [] | |
| 264 for device in devices: | 296 for device in devices: |
| 265 tombstones += _GetTombstonesForDevice(device, args) | 297 resolved_tombstones = ResolveTombstones( |
| 266 | 298 device, args.all_tombstones, |
| 267 _ResolveTombstones(args.jobs, tombstones) | 299 args.stack, args.wipe_tombstones, args.jobs) |
| 268 | 300 for line in resolved_tombstones: |
| 301 logging.info(line) |
| 269 | 302 |
| 270 if __name__ == '__main__': | 303 if __name__ == '__main__': |
| 271 sys.exit(main()) | 304 sys.exit(main()) |
| OLD | NEW |