mirror of
https://github.com/infiniteCable2/openpilot.git
synced 2026-09-11 18:53:41 +08:00
Vehicle Researcher
86 lines
2.5 KiB
Python
86 lines
2.5 KiB
Python
import os
|
|
import re
|
|
import time
|
|
import uuid
|
|
import datetime
|
|
|
|
from raven import Client
|
|
from raven.transport.http import HTTPTransport
|
|
|
|
from selfdrive.version import version
|
|
from selfdrive.swaglog import cloudlog
|
|
|
|
def get_tombstones():
|
|
return [("/data/tombstones/"+fn, int(os.stat("/data/tombstones/"+fn).st_ctime) )
|
|
for fn in os.listdir("/data/tombstones") if fn.startswith("tombstone")]
|
|
|
|
def report_tombstone(fn, client):
|
|
mtime = os.path.getmtime(fn)
|
|
with open(fn, "r") as f:
|
|
dat = f.read()
|
|
|
|
# see system/core/debuggerd/tombstone.cpp
|
|
parsed = re.match(r"[* ]*\n"
|
|
r"(?P<header>CM Version:[\s\S]*?ABI:.*\n)"
|
|
r"(?P<thread>pid:.*\n)"
|
|
r"(?P<signal>signal.*\n)?"
|
|
r"(?P<abort>Abort.*\n)?"
|
|
r"(?P<registers>\s+x0[\s\S]*?\n)\n"
|
|
r"(?:backtrace:\n"
|
|
r"(?P<backtrace>[\s\S]*?\n)\n"
|
|
r"stack:\n"
|
|
r"(?P<stack>[\s\S]*?\n)\n"
|
|
r")?", dat)
|
|
|
|
logtail = re.search(r"--------- tail end of.*\n([\s\S]*?\n)---", dat)
|
|
logtail = logtail and logtail.group(1)
|
|
|
|
if parsed:
|
|
parsedict = parsed.groupdict()
|
|
message = parsedict.get('thread') or ''
|
|
message += parsedict.get('signal') or ''
|
|
message += parsedict.get('abort') or ''
|
|
else:
|
|
parsedict = {}
|
|
message = fn+"\n"+dat[:1024]
|
|
|
|
client.send(
|
|
event_id=uuid.uuid4().hex,
|
|
timestamp=datetime.datetime.utcfromtimestamp(mtime),
|
|
logger='tombstoned',
|
|
platform='other',
|
|
sdk={'name': 'tombstoned', 'version': '0'},
|
|
extra={
|
|
'tombstone_fn': fn,
|
|
'header': parsedict.get('header'),
|
|
'registers': parsedict.get('registers'),
|
|
'backtrace': parsedict.get('backtrace'),
|
|
'logtail': logtail,
|
|
'version': version,
|
|
'dirty': not bool(os.environ.get('CLEAN')),
|
|
},
|
|
user={'id': os.environ.get('DONGLE_ID')},
|
|
message=message,
|
|
)
|
|
cloudlog.error({"tombstone": message})
|
|
|
|
|
|
def main(gctx):
|
|
initial_tombstones = set(get_tombstones())
|
|
|
|
client = Client('https://d3b175702f62402c91ade04d1c547e68:b20d68c813c74f63a7cdf9c4039d8f56@sentry.io/157615',
|
|
install_sys_hook=False, transport=HTTPTransport)
|
|
|
|
while True:
|
|
now_tombstones = set(get_tombstones())
|
|
|
|
for fn, ctime in (now_tombstones - initial_tombstones):
|
|
cloudlog.info("reporting new tombstone %s", fn)
|
|
report_tombstone(fn, client)
|
|
|
|
initial_tombstones = now_tombstones
|
|
time.sleep(5)
|
|
|
|
if __name__ == "__main__":
|
|
main(None)
|