1 # Copyright (C) 2013 Google Inc. All rights reserved. 2 # 3 # Redistribution and use in source and binary forms, with or without 4 # modification, are permitted provided that the following conditions are 5 # met: 6 # 7 # * Redistributions of source code must retain the above copyright 8 # notice, this list of conditions and the following disclaimer. 9 # * Redistributions in binary form must reproduce the above 10 # copyright notice, this list of conditions and the following disclaimer 11 # in the documentation and/or other materials provided with the 12 # distribution. 13 # * Neither the name of Google Inc. nor the names of its 14 # contributors may be used to endorse or promote products derived from 15 # this software without specific prior written permission. 16 # 17 # THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 18 # "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 19 # LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR 20 # A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT 21 # OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 22 # SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT 23 # LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 24 # DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 25 # THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 26 # (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 27 # OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 28 29 import logging 30 31 32 _log = logging.getLogger(__name__) 33 34 35 class DumpReader(object): 36 """Base class for breakpad dump readers.""" 37 38 def __init__(self, host, build_dir): 39 self._host = host 40 self._build_dir = build_dir 41 42 def check_is_functional(self): 43 """This routine must be implemented by subclasses. 44 45 Returns True if this reader is functional.""" 46 raise NotImplementedError() 47 48 def crash_dumps_directory(self): 49 return self._host.filesystem.join(self._build_dir, 'crash-dumps') 50 51 def clobber_old_results(self): 52 if self._host.filesystem.isdir(self.crash_dumps_directory()): 53 self._host.filesystem.rmtree(self.crash_dumps_directory()) 54 55 def look_for_new_crash_logs(self, crashed_processes, start_time): 56 if not crashed_processes: 57 return None 58 59 if not self.check_is_functional(): 60 return None 61 62 pid_to_minidump = dict() 63 for root, dirs, files in self._host.filesystem.walk(self.crash_dumps_directory()): 64 for dmp in [f for f in files if f.endswith(self._file_extension())]: 65 dmp_file = self._host.filesystem.join(root, dmp) 66 if self._host.filesystem.mtime(dmp_file) < start_time: 67 continue 68 pid = self._get_pid_from_dump(dmp_file) 69 if pid: 70 pid_to_minidump[pid] = dmp_file 71 72 result = dict() 73 for test, process_name, pid in crashed_processes: 74 if str(pid) in pid_to_minidump: 75 stack = self._get_stack_from_dump(pid_to_minidump[str(pid)]) 76 if stack: 77 result[test] = stack 78 79 return result 80 81 def _get_pid_from_dump(self, dump_file): 82 """This routine must be implemented by subclasses. 83 84 This routine returns the PID of the crashed process that produced the given dump_file.""" 85 raise NotImplementedError() 86 87 def _get_stack_from_dump(self, dump_file): 88 """This routine must be implemented by subclasses. 89 90 Returns the stack stored in the given breakpad dump_file.""" 91 raise NotImplementedError() 92 93 def _file_extension(self): 94 """This routine must be implemented by subclasses. 95 96 Returns the file extension of crash dumps written by breakpad.""" 97 raise NotImplementedError() 98
