forked from luck/tmp_suning_uos_patched
perf scripts python: exported-sql-viewer.py: Add global time range calculations
Add calculations to determine a time range that encompasses all data. Signed-off-by: Adrian Hunter <adrian.hunter@intel.com> Cc: Jiri Olsa <jolsa@redhat.com> Link: http://lore.kernel.org/lkml/20190821083216.1340-4-adrian.hunter@intel.com Signed-off-by: Arnaldo Carvalho de Melo <acme@redhat.com>
This commit is contained in:
parent
42c303ff9a
commit
9a9dae3655
|
@ -2088,10 +2088,8 @@ class SampleTimeRangesDataItem(LineEditDataItem):
|
|||
QueryExec(query, "SELECT id, time FROM samples ORDER BY id DESC LIMIT 1")
|
||||
if query.next():
|
||||
self.last_id = int(query.value(0))
|
||||
self.last_time = int(query.value(1))
|
||||
QueryExec(query, "SELECT time FROM samples WHERE time != 0 ORDER BY id LIMIT 1")
|
||||
if query.next():
|
||||
self.first_time = int(query.value(0))
|
||||
self.first_time = int(glb.HostStartTime())
|
||||
self.last_time = int(glb.HostFinishTime())
|
||||
if placeholder_text:
|
||||
placeholder_text += ", between " + str(self.first_time) + " and " + str(self.last_time)
|
||||
|
||||
|
@ -3500,6 +3498,9 @@ class Glb():
|
|||
self.have_disassembler = True
|
||||
except:
|
||||
self.have_disassembler = False
|
||||
self.host_machine_id = 0
|
||||
self.host_start_time = 0
|
||||
self.host_finish_time = 0
|
||||
|
||||
def FileFromBuildId(self, build_id):
|
||||
file_name = self.buildid_dir + build_id[0:2] + "/" + build_id[2:] + "/elf"
|
||||
|
@ -3532,6 +3533,110 @@ class Glb():
|
|||
except:
|
||||
pass
|
||||
|
||||
def GetHostMachineId(self):
|
||||
query = QSqlQuery(self.db)
|
||||
QueryExec(query, "SELECT id FROM machines WHERE pid = -1")
|
||||
if query.next():
|
||||
self.host_machine_id = query.value(0)
|
||||
else:
|
||||
self.host_machine_id = 0
|
||||
return self.host_machine_id
|
||||
|
||||
def HostMachineId(self):
|
||||
if self.host_machine_id:
|
||||
return self.host_machine_id
|
||||
return self.GetHostMachineId()
|
||||
|
||||
def SelectValue(self, sql):
|
||||
query = QSqlQuery(self.db)
|
||||
try:
|
||||
QueryExec(query, sql)
|
||||
except:
|
||||
return None
|
||||
if query.next():
|
||||
return Decimal(query.value(0))
|
||||
return None
|
||||
|
||||
def SwitchesMinTime(self, machine_id):
|
||||
return self.SelectValue("SELECT time"
|
||||
" FROM context_switches"
|
||||
" WHERE time != 0 AND machine_id = " + str(machine_id) +
|
||||
" ORDER BY id LIMIT 1")
|
||||
|
||||
def SwitchesMaxTime(self, machine_id):
|
||||
return self.SelectValue("SELECT time"
|
||||
" FROM context_switches"
|
||||
" WHERE time != 0 AND machine_id = " + str(machine_id) +
|
||||
" ORDER BY id DESC LIMIT 1")
|
||||
|
||||
def SamplesMinTime(self, machine_id):
|
||||
return self.SelectValue("SELECT time"
|
||||
" FROM samples"
|
||||
" WHERE time != 0 AND machine_id = " + str(machine_id) +
|
||||
" ORDER BY id LIMIT 1")
|
||||
|
||||
def SamplesMaxTime(self, machine_id):
|
||||
return self.SelectValue("SELECT time"
|
||||
" FROM samples"
|
||||
" WHERE time != 0 AND machine_id = " + str(machine_id) +
|
||||
" ORDER BY id DESC LIMIT 1")
|
||||
|
||||
def CallsMinTime(self, machine_id):
|
||||
return self.SelectValue("SELECT calls.call_time"
|
||||
" FROM calls"
|
||||
" INNER JOIN threads ON threads.thread_id = calls.thread_id"
|
||||
" WHERE calls.call_time != 0 AND threads.machine_id = " + str(machine_id) +
|
||||
" ORDER BY calls.id LIMIT 1")
|
||||
|
||||
def CallsMaxTime(self, machine_id):
|
||||
return self.SelectValue("SELECT calls.return_time"
|
||||
" FROM calls"
|
||||
" INNER JOIN threads ON threads.thread_id = calls.thread_id"
|
||||
" WHERE calls.return_time != 0 AND threads.machine_id = " + str(machine_id) +
|
||||
" ORDER BY calls.return_time DESC LIMIT 1")
|
||||
|
||||
def GetStartTime(self, machine_id):
|
||||
t0 = self.SwitchesMinTime(machine_id)
|
||||
t1 = self.SamplesMinTime(machine_id)
|
||||
t2 = self.CallsMinTime(machine_id)
|
||||
if t0 is None or (not(t1 is None) and t1 < t0):
|
||||
t0 = t1
|
||||
if t0 is None or (not(t2 is None) and t2 < t0):
|
||||
t0 = t2
|
||||
return t0
|
||||
|
||||
def GetFinishTime(self, machine_id):
|
||||
t0 = self.SwitchesMaxTime(machine_id)
|
||||
t1 = self.SamplesMaxTime(machine_id)
|
||||
t2 = self.CallsMaxTime(machine_id)
|
||||
if t0 is None or (not(t1 is None) and t1 > t0):
|
||||
t0 = t1
|
||||
if t0 is None or (not(t2 is None) and t2 > t0):
|
||||
t0 = t2
|
||||
return t0
|
||||
|
||||
def HostStartTime(self):
|
||||
if self.host_start_time:
|
||||
return self.host_start_time
|
||||
self.host_start_time = self.GetStartTime(self.HostMachineId())
|
||||
return self.host_start_time
|
||||
|
||||
def HostFinishTime(self):
|
||||
if self.host_finish_time:
|
||||
return self.host_finish_time
|
||||
self.host_finish_time = self.GetFinishTime(self.HostMachineId())
|
||||
return self.host_finish_time
|
||||
|
||||
def StartTime(self, machine_id):
|
||||
if machine_id == self.HostMachineId():
|
||||
return self.HostStartTime()
|
||||
return self.GetStartTime(machine_id)
|
||||
|
||||
def FinishTime(self, machine_id):
|
||||
if machine_id == self.HostMachineId():
|
||||
return self.HostFinishTime()
|
||||
return self.GetFinishTime(machine_id)
|
||||
|
||||
# Database reference
|
||||
|
||||
class DBRef():
|
||||
|
|
Loading…
Reference in New Issue
Block a user