Chiebot-Mirror
/
grpc
mirror of https://github.com/grpc/grpc.git
8
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #7467 from ctiller/important-profiles

Browse Source 
Add latency profiling from 'important' marks
pull/7468/head
Craig Tiller 8 years ago committed by GitHub
parent 2eebe29ec8 268a47a2b1
commit e514158ccc
1 changed files with 21 additions and 7 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 28
      tools/profiling/latency_profile/profile_analyzer.py

28
tools/profiling/latency_profile/profile_analyzer.py
Unescape View File

@ -43,6 +43,7 @@ TIME_FROM_SCOPE_START = object()
TIME_TO_SCOPE_END = object() TIME_TO_SCOPE_END = object()
TIME_FROM_STACK_START = object() TIME_FROM_STACK_START = object()
TIME_TO_STACK_END = object() TIME_TO_STACK_END = object()
TIME_FROM_LAST_IMPORTANT = object()
argp = argparse.ArgumentParser(description='Process output of basic_prof builds') argp = argparse.ArgumentParser(description='Process output of basic_prof builds')
@ -78,10 +79,14 @@ class ScopeBuilder(object):
self.call_stack_builder.lines.append(line_item) self.call_stack_builder.lines.append(line_item)
def finish(self, line): def finish(self, line):
assert line['tag'] == self.top_line.tag, 'expected %s, got %s; thread=%s; t0=%f t1=%f' % (self.top_line.tag, line['tag'], line['thd'], self.top_line.start_time, line['t']) assert line['tag'] == self.top_line.tag, (
'expected %s, got %s; thread=%s; t0=%f t1=%f' %
(self.top_line.tag, line['tag'], line['thd'], self.top_line.start_time,
line['t']))
final_time_stamp = line['t'] final_time_stamp = line['t']
assert self.top_line.end_time is None assert self.top_line.end_time is None
self.top_line.end_time = final_time_stamp self.top_line.end_time = final_time_stamp
self.top_line.important = self.top_line.important or line['imp']
assert SELF_TIME not in self.top_line.times assert SELF_TIME not in self.top_line.times
self.top_line.times[SELF_TIME] = final_time_stamp - self.top_line.start_time self.top_line.times[SELF_TIME] = final_time_stamp - self.top_line.start_time
for line in self.call_stack_builder.lines[self.first_child_pos:]: for line in self.call_stack_builder.lines[self.first_child_pos:]:
@ -101,9 +106,14 @@ class CallStackBuilder(object):
start_time = self.lines[0].start_time start_time = self.lines[0].start_time
end_time = self.lines[0].end_time end_time = self.lines[0].end_time
self.signature = self.signature.hexdigest() self.signature = self.signature.hexdigest()
last_important = start_time
for line in self.lines: for line in self.lines:
line.times[TIME_FROM_STACK_START] = line.start_time - start_time line.times[TIME_FROM_STACK_START] = line.start_time - start_time
line.times[TIME_TO_STACK_END] = end_time - line.end_time line.times[TIME_TO_STACK_END] = end_time - line.end_time
line.times[TIME_FROM_LAST_IMPORTANT] = line.start_time - last_important
if line.important:
last_important = line.end_time
last_important = end_time
def add(self, line): def add(self, line):
line_type = line['type'] line_type = line['type']
@ -113,7 +123,9 @@ class CallStackBuilder(object):
self.stk.append(ScopeBuilder(self, line)) self.stk.append(ScopeBuilder(self, line))
return False return False
elif line_type == '}': elif line_type == '}':
assert self.stk, 'expected non-empty stack for closing %s; thread=%s; t=%f' % (line['tag'], line['thd'], line['t']) assert self.stk, (
'expected non-empty stack for closing %s; thread=%s; t=%f' %
(line['tag'], line['thd'], line['t']))
self.stk.pop().finish(line) self.stk.pop().finish(line)
if not self.stk: if not self.stk:
self.finish() self.finish()
@ -216,9 +228,16 @@ def time_format(idx):
return '' return ''
return ent return ent
BANNER = {
'simple': 'Count: %(count)d',
'html': '<h1>Count: %(count)d</h1>'
}
FORMAT = [ FORMAT = [
('TAG', lambda line: '..'*line.indent + tidy_tag(line.tag)), ('TAG', lambda line: '..'*line.indent + tidy_tag(line.tag)),
('LOC', lambda line: '%s:%d' % (line.filename[line.filename.rfind('/')+1:], line.fileline)), ('LOC', lambda line: '%s:%d' % (line.filename[line.filename.rfind('/')+1:], line.fileline)),
('IMP', lambda line: '*' if line.important else ''),
('FROM_IMP', time_format(TIME_FROM_LAST_IMPORTANT)),
('FROM_STACK_START', time_format(TIME_FROM_STACK_START)), ('FROM_STACK_START', time_format(TIME_FROM_STACK_START)),
('SELF', time_format(SELF_TIME)), ('SELF', time_format(SELF_TIME)),
('TO_STACK_END', time_format(TIME_TO_STACK_END)), ('TO_STACK_END', time_format(TIME_TO_STACK_END)),
@ -227,11 +246,6 @@ FORMAT = [
('TO_SCOPE_END', time_format(TIME_TO_SCOPE_END)), ('TO_SCOPE_END', time_format(TIME_TO_SCOPE_END)),
] ]
BANNER = {
'simple': 'Count: %(count)d',
'html': '<h1>Count: %(count)d</h1>'
}
if args.fmt == 'html': if args.fmt == 'html':
print '<html>' print '<html>'
print '<head>' print '<head>'

Write Preview
Loading…
Cancel
Save