1 /*
2 * Copyright (c) 2021 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15
16 #include "trace_data_cache.h"
17 #include <sqlite3.h>
18
19 #include "appname_table.h"
20 #include "args_table.h"
21 #include "bio_latency_sample_table.h"
22 #include "callstack_table.h"
23 #include "clk_event_filter_table.h"
24 #include "clock_event_filter_table.h"
25 #include "clock_snapshot_table.h"
26 #include "cpu_measure_filter_table.h"
27 #include "cpu_usage_info_table.h"
28 #include "datasource_clockid_table.h"
29 #include "data_dict_table.h"
30 #include "data_type_table.h"
31 #include "device_state_table.h"
32 #include "disk_io_table.h"
33 #include "ebpf_callstack_table.h"
34 #if WITH_EBPF_HELP
35 #include "ebpf_elf_symbol_table.h"
36 #include "ebpf_elf_table.h"
37 #include "ebpf_process_maps_table.h"
38 #endif
39 #include "file_system_sample_table.h"
40 #include "filter_table.h"
41 #include "hidump_table.h"
42 #include "instants_table.h"
43 #include "irq_table.h"
44 #include "live_process_table.h"
45 #include "log_table.h"
46 #include "measure_filter_table.h"
47 #include "measure_table.h"
48 #include "meta_table.h"
49 #include "native_hook_frame_table.h"
50 #include "native_hook_table.h"
51 #include "network_table.h"
52 #include "paged_memory_sample_table.h"
53 #if WITH_PERF
54 #include "perf_call_chain_table.h"
55 #include "perf_files_table.h"
56 #include "perf_sample_table.h"
57 #include "perf_thread_table.h"
58 #include "perf_report_table.h"
59 #endif
60 #include "process_filter_table.h"
61 #include "process_measure_filter_table.h"
62 #include "process_table.h"
63 #include "range_table.h"
64 #include "raw_table.h"
65 #include "sched_slice_table.h"
66 #include "smaps_table.h"
67 #include "span_join.h"
68 #include "stat_table.h"
69 #include "symbols_table.h"
70 #include "sysevent_measure_table.h"
71 #include "system_call_table.h"
72 #include "system_event_filter_table.h"
73 #include "table_base.h"
74 #include "thread_filter_table.h"
75 #include "thread_state_table.h"
76 #include "thread_table.h"
77
78 namespace SysTuning {
79 namespace TraceStreamer {
TraceDataCache()80 TraceDataCache::TraceDataCache()
81 {
82 InitDB();
83 }
84
~TraceDataCache()85 TraceDataCache::~TraceDataCache() {}
86
InitDB()87 void TraceDataCache::InitDB()
88 {
89 if (dbInited) {
90 return;
91 }
92 #ifdef USE_VTABLE
93 TableBase::TableDeclare<ProcessTable>(*db_, this, "process");
94 TableBase::TableDeclare<SchedSliceTable>(*db_, this, "sched_slice");
95 TableBase::TableDeclare<CallStackTable>(*db_, this, "callstack");
96 TableBase::TableDeclare<ThreadTable>(*db_, this, "thread");
97 TableBase::TableDeclare<ThreadStateTable>(*db_, this, "thread_state");
98 TableBase::TableDeclare<ThreadFilterTable>(*db_, this, "thread_filter");
99 TableBase::TableDeclare<ProcessFilterTable>(*db_, this, "process_filter");
100 TableBase::TableDeclare<MeasureFilterTable>(*db_, this, "measure_filter");
101 TableBase::TableDeclare<IrqTable>(*db_, this, "irq");
102 TableBase::TableDeclare<DataDictTable>(*db_, this, "data_dict");
103 TableBase::TableDeclare<RawTable>(*db_, this, "raw");
104 TableBase::TableDeclare<SymbolsTable>(*db_, this, "symbols");
105 TableBase::TableDeclare<DataTypeTable>(*db_, this, "data_type");
106 TableBase::TableDeclare<HidumpTable>(*db_, this, "hidump");
107 TableBase::TableDeclare<NativeHookTable>(*db_, this, "native_hook");
108 TableBase::TableDeclare<NativeHookFrameTable>(*db_, this, "native_hook_frame");
109 TableBase::TableDeclare<SpanJoin>(*db_, this, "span_join");
110
111 // no id
112 TableBase::TableDeclare<InstantsTable>(*db_, this, "instant");
113 TableBase::TableDeclare<MeasureTable>(*db_, this, "measure");
114 TableBase::TableDeclare<MeasureTable>(*db_, this, "sys_mem_measure");
115 TableBase::TableDeclare<MeasureTable>(*db_, this, "process_measure");
116 TableBase::TableDeclare<RangeTable>(*db_, this, "trace_range");
117 TableBase::TableDeclare<StatTable>(*db_, this, "stat");
118 TableBase::TableDeclare<SystemCallTable>(*db_, this, "syscall");
119 TableBase::TableDeclare<MetaTable>(*db_, this, "meta");
120 TableBase::TableDeclare<LogTable>(*db_, this, "log");
121 TableBase::TableDeclare<NetworkTable>(*db_, this, "network");
122
123 // id is not real id
124 TableBase::TableDeclare<CpuMeasureFilterTable>(*db_, this, "cpu_measure_filter");
125 TableBase::TableDeclare<FilterTable>(*db_, this, "measure_filter");
126 TableBase::TableDeclare<ProcessMeasureFilterTable>(*db_, this, "process_measure_filter");
127 TableBase::TableDeclare<ClockEventFilterTable>(*db_, this, "clock_event_filter");
128 TableBase::TableDeclare<ClkEventFilterTable>(*db_, this, "clk_event_filter");
129 TableBase::TableDeclare<ArgsTable>(*db_, this, "args");
130
131 TableBase::TableDeclare<SystemEventFilterTable>(*db_, this, "sys_event_filter");
132 TableBase::TableDeclare<DiskIOTable>(*db_, this, "diskio");
133 TableBase::TableDeclare<CpuUsageInfoTable>(*db_, this, "cpu_usage");
134 TableBase::TableDeclare<LiveProcessTable>(*db_, this, "live_process");
135 TableBase::TableDeclare<FileSystemSampleTable>(*db_, this, "file_system_sample");
136 TableBase::TableDeclare<EbpfCallStackTable>(*db_, this, "ebpf_callstack");
137 TableBase::TableDeclare<PagedMemorySampleTable>(*db_, this, "paged_memory_sample");
138 #if WITH_EBPF_HELP
139 TableBase::TableDeclare<EbpfProcessMapsTable>(*db_, this, "ebpf_process_maps");
140 TableBase::TableDeclare<EbpfElfTable>(*db_, this, "ebpf_elf");
141 TableBase::TableDeclare<EbpfElfSymbolTable>(*db_, this, "ebpf_elf_symbol");
142 #endif
143 TableBase::TableDeclare<AppnameTable>(*db_, this, "app_name");
144 TableBase::TableDeclare<SysEventMeasureTable>(*db_, this, "hisys_event_measure");
145 TableBase::TableDeclare<DeviceStateTable>(*db_, this, "device_state");
146 TableBase::TableDeclare<SmapsTable>(*db_, this, "smaps");
147 TableBase::TableDeclare<BioLatencySampleTable>(*db_, this, "bio_latency_sample");
148 TableBase::TableDeclare<DataSourceClockIdTableTable>(*db_, this, "datasource_clockid");
149 TableBase::TableDeclare<ClockSnapShotTable>(*db_, this, "clock_snapshot");
150
151 #if WITH_PERF
152 TableBase::TableDeclare<PerfReportTable>(*db_, this, "perf_report");
153 TableBase::TableDeclare<PerfSampleTable>(*db_, this, "perf_sample");
154 TableBase::TableDeclare<PerfCallChainTable>(*db_, this, "perf_callchain");
155 TableBase::TableDeclare<PerfThreadTable>(*db_, this, "perf_thread");
156 TableBase::TableDeclare<PerfFilesTable>(*db_, this, "perf_files");
157 #endif
158 #else
159 TableBase::TableDeclare<ProcessTable>(*db_, this, "_process");
160 TableBase::TableDeclare<SchedSliceTable>(*db_, this, "_sched_slice");
161 TableBase::TableDeclare<CallStackTable>(*db_, this, "_callstack");
162 TableBase::TableDeclare<ThreadTable>(*db_, this, "_thread");
163 TableBase::TableDeclare<ThreadStateTable>(*db_, this, "_thread_state");
164 TableBase::TableDeclare<ThreadFilterTable>(*db_, this, "_thread_filter");
165 TableBase::TableDeclare<ProcessFilterTable>(*db_, this, "_process_filter");
166 TableBase::TableDeclare<MeasureFilterTable>(*db_, this, "_measure_filter");
167 TableBase::TableDeclare<IrqTable>(*db_, this, "_irq");
168 TableBase::TableDeclare<DataDictTable>(*db_, this, "_data_dict");
169 TableBase::TableDeclare<RawTable>(*db_, this, "_raw");
170 TableBase::TableDeclare<SymbolsTable>(*db_, this, "_symbols");
171 TableBase::TableDeclare<DataTypeTable>(*db_, this, "_data_type");
172 TableBase::TableDeclare<HidumpTable>(*db_, this, "_hidump");
173 TableBase::TableDeclare<NativeHookTable>(*db_, this, "_native_hook");
174 TableBase::TableDeclare<NativeHookFrameTable>(*db_, this, "_native_hook_frame");
175 TableBase::TableDeclare<SpanJoin>(*db_, this, "_span_join");
176
177 // no id
178 TableBase::TableDeclare<InstantsTable>(*db_, this, "_instant");
179 TableBase::TableDeclare<MeasureTable>(*db_, this, "_measure");
180 TableBase::TableDeclare<MeasureTable>(*db_, this, "_sys_mem_measure");
181 TableBase::TableDeclare<MeasureTable>(*db_, this, "_process_measure");
182 TableBase::TableDeclare<RangeTable>(*db_, this, "_trace_range");
183 TableBase::TableDeclare<StatTable>(*db_, this, "_stat");
184 TableBase::TableDeclare<SystemCallTable>(*db_, this, "_syscall");
185 TableBase::TableDeclare<MetaTable>(*db_, this, "_meta");
186 TableBase::TableDeclare<LogTable>(*db_, this, "_log");
187 TableBase::TableDeclare<NetworkTable>(*db_, this, "_network");
188
189 // id is not real id
190 TableBase::TableDeclare<CpuMeasureFilterTable>(*db_, this, "_cpu_measure_filter");
191 TableBase::TableDeclare<FilterTable>(*db_, this, "_measure_filter");
192 TableBase::TableDeclare<ProcessMeasureFilterTable>(*db_, this, "_process_measure_filter");
193 TableBase::TableDeclare<ClockEventFilterTable>(*db_, this, "_clock_event_filter");
194 TableBase::TableDeclare<ClkEventFilterTable>(*db_, this, "_clk_event_filter");
195 TableBase::TableDeclare<ArgsTable>(*db_, this, "_args");
196 TableBase::TableDeclare<SystemEventFilterTable>(*db_, this, "_sys_event_filter");
197 TableBase::TableDeclare<DiskIOTable>(*db_, this, "_diskio");
198 TableBase::TableDeclare<CpuUsageInfoTable>(*db_, this, "_cpu_usage");
199 TableBase::TableDeclare<LiveProcessTable>(*db_, this, "_live_process");
200 TableBase::TableDeclare<FileSystemSampleTable>(*db_, this, "_file_system_sample");
201 TableBase::TableDeclare<EbpfCallStackTable>(*db_, this, "_ebpf_callstack");
202 TableBase::TableDeclare<PagedMemorySampleTable>(*db_, this, "_paged_memory_sample");
203 TableBase::TableDeclare<SmapsTable>(*db_, this, "_smaps");
204 TableBase::TableDeclare<BioLatencySampleTable>(*db_, this, "_bio_latency_sample");
205 TableBase::TableDeclare<DataSourceClockIdTableTable>(*db_, this, "_datasource_clockid");
206 TableBase::TableDeclare<ClockSnapShotTable>(*db_, this, "_clock_snapshot");
207 #if WITH_EBPF_HELP
208 TableBase::TableDeclare<EbpfProcessMapsTable>(*db_, this, "_ebpf_process_maps");
209 TableBase::TableDeclare<EbpfElfTable>(*db_, this, "_ebpf_elf");
210 TableBase::TableDeclare<EbpfElfSymbolTable>(*db_, this, "_ebpf_elf_symbol");
211 #endif
212 TableBase::TableDeclare<AppnameTable>(*db_, this, "_app_name");
213 TableBase::TableDeclare<SysEventMeasureTable>(*db_, this, "_hisys_event_measure");
214 TableBase::TableDeclare<DeviceStateTable>(*db_, this, "_device_state");
215 #if WITH_PERF
216 TableBase::TableDeclare<PerfReportTable>(*db_, this, "_perf_report");
217 TableBase::TableDeclare<PerfSampleTable>(*db_, this, "_perf_sample");
218 TableBase::TableDeclare<PerfCallChainTable>(*db_, this, "_perf_callchain");
219 TableBase::TableDeclare<PerfThreadTable>(*db_, this, "_perf_thread");
220 TableBase::TableDeclare<PerfFilesTable>(*db_, this, "_perf_files");
221 #endif
222 #endif
223 dbInited = true;
224 }
225 } // namespace TraceStreamer
226 } // namespace SysTuning
227