blob: adff70a16236bad4e14b558d38a844176a272249 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
#!/usr/bin/env python3
"""Script for symbolizing multithread MongoDB stack traces.
Accepts mongod multithread stacktrace lines. These are produced by hitting mongod with SIGUSR2.
Assembles json documents which are fed to the mongosymb library. See mongosymb.py.
"""
import argparse
import json
import re
import subprocess
import sys
import mongosymb
def main():
"""Execute Main program."""
parent_parser = mongosymb.make_argument_parser(add_help=False)
parser = argparse.ArgumentParser(parents=[parent_parser], description=__doc__, add_help=True)
options = parser.parse_args()
# Remember the prologue between lines,
# Prologue defines the library ids referred to by each threadRecord line.
prologue = None
for line in sys.stdin:
try:
doc = json.JSONDecoder().raw_decode(line)[0]
if "attr" not in doc:
continue
attr = doc["attr"]
if "prologue" in attr:
prologue = attr["prologue"]
if "threadRecord" in attr:
thread_record = attr["threadRecord"]
merged = {**thread_record, **prologue}
output_fn = None
if options.output_format == 'json':
output_fn = json.dump
if options.output_format == 'classic':
output_fn = mongosymb.classic_output
resolver = None
if options.debug_file_resolver == 'path':
resolver = mongosymb.PathDbgFileResolver(options.path_to_executable)
elif options.debug_file_resolver == 's3':
resolver = mongosymb.S3BuildidDbgFileResolver(options.s3_cache_dir,
options.s3_bucket)
frames = mongosymb.symbolize_frames(merged, resolver, **vars(options))
print("\nthread {{name='{}', tid={}}}:".format(thread_record["name"],
thread_record["tid"]))
output_fn(frames, sys.stdout, indent=2)
except json.JSONDecodeError:
print("failed to parse line: `{}`".format(line), file=sys.stderr)
if __name__ == '__main__':
main()
sys.exit(0)
|
