40 static void UpdateStats(StatsEntry &entry, const StatsInfo &info)  in UpdateStats()  argument
44     ts_mono -= entry.monoTimeLast;  in UpdateStats()
46         entry.monoTimeLast -= entry.monoTimeAuditStart;  in UpdateStats()
47         float secs = entry.monoTimeLast.FloatSecs();  in UpdateStats()
51         float freq = entry.tmpLines / secs;  in UpdateStats()
52         if (freq > entry.freqMax) {  in UpdateStats()
53             entry.freqMax = freq;  in UpdateStats()
54             entry.realTimeFreqMax = entry.realTimeLast;  in UpdateStats()
56         entry.tmpLines = 0;  in UpdateStats()
57         float throughput = entry.tmpLen / secs;  in UpdateStats()
58         if (throughput > entry.throughputMax) {  in UpdateStats()
59             entry.throughputMax = throughput;  in UpdateStats()
60             entry.realTimeThroughputMax = entry.realTimeLast;  in UpdateStats()
62         entry.tmpLen = 0;  in UpdateStats()
63         entry.monoTimeAuditStart.SetTimeStamp(info.mono_sec, info.tv_nsec);  in UpdateStats()
67     entry.lines[lvl]++;  in UpdateStats()
68     entry.len[lvl] += info.len;  in UpdateStats()
69     entry.dropped += info.dropped;  in UpdateStats()
70     entry.tmpLines++;  in UpdateStats()
71     entry.tmpLen += info.len;  in UpdateStats()
72     entry.monoTimeLast.SetTimeStamp(info.mono_sec, info.tv_nsec);  in UpdateStats()
73     entry.realTimeLast.SetTimeStamp(info.tv_sec, info.tv_nsec);  in UpdateStats()
76 static void ResetStatsEntry(StatsEntry &entry)  in ResetStatsEntry()  argument
78     entry.dropped = 0;  in ResetStatsEntry()
79     entry.tmpLines = 0;  in ResetStatsEntry()
80     entry.freqMax = 0;  in ResetStatsEntry()
81     entry.realTimeFreqMax.SetTimeStamp(0, 0);  in ResetStatsEntry()
82     entry.tmpLen = 0;  in ResetStatsEntry()
83     entry.throughputMax = 0;  in ResetStatsEntry()
84     entry.realTimeThroughputMax.SetTimeStamp(0, 0);  in ResetStatsEntry()
85     entry.monoTimeLast.SetTimeStamp(0, 0);  in ResetStatsEntry()
86     entry.monoTimeAuditStart.SetTimeStamp(0, 0);  in ResetStatsEntry()
87     for (uint32_t &i : entry.lines) {  in ResetStatsEntry()
90     for (uint64_t &i : entry.len) {  in ResetStatsEntry()
95 static void StatsInfo2NewStatsEntry(const StatsInfo &info, StatsEntry &entry)  in StatsInfo2NewStatsEntry()  argument
97     entry.dropped = info.dropped;  in StatsInfo2NewStatsEntry()
98     entry.tmpLines = 1;  in StatsInfo2NewStatsEntry()
99     entry.freqMax = 0;  in StatsInfo2NewStatsEntry()
100     entry.realTimeFreqMax.SetTimeStamp(info.tv_sec, info.tv_nsec);  in StatsInfo2NewStatsEntry()
101     entry.tmpLen = info.len;  in StatsInfo2NewStatsEntry()
102     entry.throughputMax = 0;  in StatsInfo2NewStatsEntry()
103     entry.realTimeThroughputMax.SetTimeStamp(info.tv_sec, info.tv_nsec);  in StatsInfo2NewStatsEntry()
104     entry.realTimeLast.SetTimeStamp(info.tv_sec, info.tv_nsec);  in StatsInfo2NewStatsEntry()
105     entry.monoTimeLast.SetTimeStamp(info.mono_sec, info.tv_nsec);  in StatsInfo2NewStatsEntry()
106     entry.monoTimeAuditStart.SetTimeStamp(info.mono_sec, info.tv_nsec);  in StatsInfo2NewStatsEntry()
107     for (uint32_t &i : entry.lines) {  in StatsInfo2NewStatsEntry()
110     for (uint64_t &i : entry.len) {  in StatsInfo2NewStatsEntry()
114     entry.lines[lvl] = 1;  in StatsInfo2NewStatsEntry()
115     entry.len[lvl] = info.len;  in StatsInfo2NewStatsEntry()
127         TagStatsEntry entry;  in UpdateTagTable()  local
128         StatsInfo2NewStatsEntry(info, entry);  in UpdateTagTable()
129         (void)tt.emplace(info.tag, entry);  in UpdateTagTable()
140         DomainStatsEntry entry;  in UpdateDomainTable()  local
141         StatsInfo2NewStatsEntry(info, entry.stats);  in UpdateDomainTable()
142         auto result = t.emplace(info.domain, entry);  in UpdateDomainTable()
160         PidStatsEntry entry;  in UpdatePidTable()  local
161         StatsInfo2NewStatsEntry(info, entry.statsAll);  in UpdatePidTable()
162         for (StatsEntry &e : entry.stats) {  in UpdatePidTable()
165         entry.stats[info.type] = entry.statsAll;  in UpdatePidTable()
166         entry.name = GetNameByPid(info.pid);  in UpdatePidTable()
167         auto result = t.emplace(info.pid, entry);  in UpdatePidTable()