blob: b02d9a2c392cfa3f7659d0204499774133c5a117 (
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
import sys
import json
g_time_tag=""
g_perf_id=""
def encode(strtmp):
global g_time_tag
global g_perf_id
detail=strtmp[1]
time_stamp=(strtmp[2])
time_sec=str(int(float(time_stamp)))
perf_id=str(strtmp[3].strip())
msg_str=strtmp[5]
if (("" == g_time_tag) and ("" == g_perf_id)):
g_time_tag=time_sec
g_perf_id=perf_id
if (perf_id == g_perf_id):
time_sec=g_time_tag
else:
g_time_tag=time_sec
g_perf_id=perf_id
try:
msg=eval(msg_str.encode("utf-8"))
except Exception, e:
return
if 'task' not in msg:
return
task=msg['task']
if 'cgroup' not in task or 'comm' not in task or 'tgid' not in task:
return
if 'container_tgid' not in task or 'state' not in task:
return
cgroup=task["cgroup"]
comm=task['comm']
tgid=str(task['tgid'])
container_tgid=str(task['container_tgid'])
state=task['state']
strstack="id="+perf_id+",time="+time_sec+" "+tgid +" 0 [00]\n"
if "kern_stack" in task:
stack_info=(task['kern_stack'])
for stack in stack_info:
strstack+=" 0xffffffffffffffff @"+((stack.strip('\n')))+" ([kernel.kallsyms])\n"
if "user_stack" in task:
stack_info=(task['user_stack'])
for stack in stack_info:
strstack+=" 0xffffffffffffffff ~"+((stack.strip('\n')))+" ([symbol])\n"
strstack+=" 0xffffffffffffffff *"+comm+" (UNKNOWN)\n"
if "proc_chains" in task:
stack_info=(task['proc_chains'])
for stack in stack_info:
strstack+=" 0xffffffffffffffff ^"+(stack)+" (UNKNOWN)\n"
strstack+=" 0xffffffffffffffff #CGROUP:["+cgroup+"] (UNKNOWN)\n"
print strstack
return
def store_log(data):
result=[]
info=dict()
for line in data:
line=line.strip('\n')
if not line:
continue
strtmp=line.split('|')
if (len(strtmp) != 6):
continue
encode(strtmp)
return
f=open(sys.argv[1])
lines=f.readlines()
f.close()
store_log(lines)
|
