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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
/*
*
* (C) 2013-22 - ntop.org
*
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software Foundation,
* Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
*/
#ifndef _THREADED_ACTIVITY_STATS_H_
#define _THREADED_ACTIVITY_STATS_H_
#include "ntop_includes.h"
class ThreadedActivity;
typedef struct {
ticks tot_ticks, max_ticks;
u_long tot_calls; /* Total number of calls */
} threaded_activity_timeseries_delta_stats_t; /* Stats periodically reset to keep a most-recent view */
typedef struct {
/* Overall totals */
u_long tot_calls; /* Total number of calls */
u_long tot_drops; /* Total number of times timeseries haven't been called because writes are detected to be slow */
/* Stats for the last run */
float last_max_call_duration_ms; /* Maximum time taken to perform a call during the last run */
float last_avg_call_duration_ms; /* Average time taken to perform a call during the last run */
bool last_slow; /* True if slow timeseries updates have been detected during the last run */
threaded_activity_timeseries_delta_stats_t last; /* Keep stats for the last run */
} threaded_activity_timeseries_stats_t;
typedef struct {
struct {
threaded_activity_timeseries_stats_t write;
} timeseries;
struct {
bool has_drops;
} alerts;
} threaded_activity_stats_t;
class ThreadedActivityStats {
private:
threaded_activity_stats_t ta_stats;
time_t last_start_time, in_progress_since, last_queued_time;
const ThreadedActivity *threaded_activity;
u_long num_not_executed, num_is_slow;
u_long max_duration_ms, last_duration_ms;
int progress;
time_t scheduled_time, deadline;
static ticks tickspersec;
bool not_executed, is_slow;
ThreadedActivityState state;
void updateTimeseriesStats(bool write, ticks cur_ticks);
void luaTimeseriesStats(lua_State *vm);
public:
ThreadedActivityStats(const ThreadedActivity *ta);
~ThreadedActivityStats();
inline time_t getLastQueueTime() const { return(last_queued_time); }
inline time_t getInProgressSince() const { return(in_progress_since); }
inline time_t getLastStartTime() const { return(last_start_time); }
inline time_t getDeadline() const { return(deadline); }
inline bool hasAlertsDrops() const {
return ta_stats.alerts.has_drops;
}
/* Timeseries stats and drops for writes */
void updateTimeseriesWriteStats(ticks cur_ticks);
void incTimeseriesWriteDrops(u_long num_drops);
void updateStatsQueuedTime(time_t queued_time);
void updateStatsBegin(struct timeval *begin);
void updateStatsEnd(u_long duration_ms);
void setNotExecutedActivity(bool _not_executed);
void setSlowPeriodicActivity(bool _slow);
inline void setScheduledTime(time_t t) { scheduled_time = t; }
inline void setDeadline(time_t t) { deadline = t; }
inline void setCurrentProgress(int _progress) { progress = min(max(_progress, 0), 100); }
inline void setAlertsDrops() { ta_stats.alerts.has_drops = true; }
void lua(lua_State *vm);
inline ThreadedActivityState getState() { return(state); }
void setState(ThreadedActivityState s);
};
#endif /* _THREADED_ACTIVITY_STATS_H_ */
|
