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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
/*
* Linux JBD2 (ext3/ext4) driver metrics.
*
* Copyright (C) 2013 Red Hat.
*
* 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 2 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.
*/
#include <ctype.h>
#include <dirent.h>
#include <sys/stat.h>
#include "pmapi.h"
#include "pmda.h"
#include "proc_jbd2.h"
enum {
HEADER_STATS,
SEEKING_STATS,
AVERAGE_STATS,
};
static int
refresh_journal(const char *path, const char *dev, pmInDom indom)
{
int n, state, indom_changed = 0;
char buf[MAXPATHLEN], *id;
unsigned long long value;
proc_jbd2_t *jp;
FILE *fp;
if (dev[0] == '.')
return 0; /* only interest is in device files */
if (snprintf(buf, sizeof(buf), "%s/%s/info", path, dev) == sizeof(buf))
return 0; /* ignore, dodgey command line args */
if ((fp = fopen(buf, "r")) == NULL)
return 0; /* no permission, ignore this entry */
if (pmdaCacheLookupName(indom, dev, &n, (void **)&jp) < 0 || !jp) {
if ((jp = (proc_jbd2_t *)calloc(1, sizeof(proc_jbd2_t))) != NULL)
indom_changed++;
}
if (!jp) {
fclose(fp);
return 0;
}
state = HEADER_STATS; /* seeking the header, initially */
while (fgets(buf, sizeof(buf), fp) != NULL) {
switch (state) {
case HEADER_STATS:
if (sscanf(buf,
"%llu transactions (%llu requested), each up to %u blocks\n",
(unsigned long long *) &jp->tid,
(unsigned long long *) &jp->requested,
(unsigned int *) &jp->max_buffers) == 3) {
state = SEEKING_STATS;
jp->version = 3; /* 3.x kernel header format */
}
else if (sscanf(buf,
"%llu transaction, each up to %u blocks\n",
(unsigned long long *) &jp->tid,
(unsigned int *) &jp->max_buffers) == 2) {
state = SEEKING_STATS;
jp->version = 2; /* 2.x kernel header format */
}
break;
case SEEKING_STATS:
if (strncmp(buf, "average: \n", 8) == 0)
state = AVERAGE_STATS;
break;
case AVERAGE_STATS:
value = strtoull(buf, &id, 10);
if (id == buf)
continue;
else if (strcmp(id, "ms waiting for transaction\n") == 0)
jp->waiting = value;
else if (strcmp(id, "ms request delay\n") == 0)
jp->request_delay = value;
else if (strcmp(id, "ms running transaction\n") == 0)
jp->running = value;
else if (strcmp(id, "ms transaction was being locked\n") == 0)
jp->locked = value;
else if (strcmp(id, "ms flushing data (in ordered mode)\n") == 0)
jp->flushing = value;
else if (strcmp(id, "ms logging transaction\n") == 0)
jp->logging = value;
else if (strcmp(id, "us average transaction commit time\n") == 0)
jp->average_commit_time = value;
else if (strcmp(id, " handles per transaction\n") == 0)
jp->handles = value;
else if (strcmp(id, " blocks per transaction\n") == 0)
jp->blocks = value;
else if (strcmp(id, " logged blocks per transaction\n") == 0)
jp->blocks_logged = value;
break;
default:
break;
}
}
fclose(fp);
if (state != AVERAGE_STATS) {
if (indom_changed)
free(jp);
return 0;
}
pmdaCacheStore(indom, PMDA_CACHE_ADD, dev, jp);
return indom_changed;
}
int
refresh_jbd2(const char *path, pmInDom jbd2_indom)
{
DIR *dirp;
struct dirent *dent;
int indom_changes = 0;
static int first = 1;
if (first) {
/* initialize the instance domain caches */
pmdaCacheOp(jbd2_indom, PMDA_CACHE_LOAD);
indom_changes = 1;
first = 0;
}
pmdaCacheOp(jbd2_indom, PMDA_CACHE_INACTIVE);
if ((dirp = opendir(path)) == NULL)
return -ENOENT;
while ((dent = readdir(dirp)) != NULL)
indom_changes |= refresh_journal(path, dent->d_name, jbd2_indom);
closedir(dirp);
if (indom_changes)
pmdaCacheOp(jbd2_indom, PMDA_CACHE_SAVE);
return 0;
}
|
