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
|
#define MEM_POOL_COUNTS VAR_DIR "/mem_pool_counts.dat"
#define MEM_POOL_BIT_COUNT_COUNTS VAR_DIR "/mem_pool_bit_count_counts.dat"
#define DSK_POOL_COUNTS VAR_DIR "/dsk_pool_counts.dat"
#define DSK_POOL_BIT_COUNT_COUNTS VAR_DIR "/dsk_pool_bit_count_counts.dat"
#define CONNECTION_COUNTS VAR_DIR "/connection_counts.dat"
#define RECV_BIT_COUNT VAR_DIR "/recv_bit_count.dat"
#define RECV_BIT_COUNT_IN VAR_DIR "/recv_bit_count_in.dat"
#define SENT_BIT_COUNT VAR_DIR "/sent_bit_count.dat"
class data_logger
{
private:
pthread_mutex_t mem_pool_lck;
data_store_int *mem_pool_counts;
pthread_mutex_t dsk_pool_lck;
data_store_int *dsk_pool_counts;
pthread_mutex_t connection_counts_lck;
data_store_int *connection_counts;
pthread_mutex_t mem_pool_bit_count_lck;
data_store_int *mem_pool_bit_count_counts;
pthread_mutex_t dsk_pool_bit_count_lck;
data_store_int *dsk_pool_bit_count_counts;
long long int prev_recv_n, prev_recv_in_n, prev_sent_n;
pthread_mutex_t recv_bit_count_lck;
data_store_int *recv_bit_count;
pthread_mutex_t recv_bit_count_in_lck;
data_store_int *recv_bit_count_in;
pthread_mutex_t sent_bit_count_lck;
data_store_int *sent_bit_count;
pthread_t thread;
pthread_mutex_t terminate_flag_lck;
bool abort;
///
statistics *s;
pools *ppools;
std::vector<client_t *> *clients;
pthread_mutex_t *clients_mutex;
void dump_data();
public:
data_logger(statistics *s_in, pools *ppools_in, std::vector<client_t *> *clients_in, pthread_mutex_t *clients_mutex_in);
~data_logger();
void get_mem_pool_counts(long int **t, double **v, int *n);
void get_dsk_pool_counts(long int **t, double **v, int *n);
void get_connection_counts(long int **t, double **v, int *n);
void get_pools_bitcounts(long int **t, double **v, int *n);
void get_disk_pools_bitcounts(long int **t, double **v, int *n);
void get_recv_bit_count(long int **t, double **v, int *n);
void get_recv_bit_count_in(long int **t, double **v, int *n);
void get_sent_bit_count(long int **t, double **v, int *n);
void run();
};
|
