diff options
author | Lorenz Kästle <12514511+RincewindsHat@users.noreply.github.com> | 2024-12-29 21:23:38 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-12-29 21:23:38 +0100 |
commit | 39680498ee0987a5e0eb203a2c0539aa1fa94d39 (patch) | |
tree | 51bf00a9e8a9ad9d1b9bdd59504b2b1ad2b0583b | |
parent | e301a9410d7f5f9f864086696eb2003d08512b2b (diff) | |
parent | 54529b601385ebf3bd0fca855e8def62ec5b6527 (diff) | |
download | monitoring-plugins-39680498ee0987a5e0eb203a2c0539aa1fa94d39.tar.gz |
Merge pull request #1976 from RincewindsHat/check_swap_again
Refactor check_swap
-rw-r--r-- | .gitignore | 6 | ||||
-rw-r--r-- | configure.ac | 9 | ||||
-rw-r--r-- | plugins/Makefile.am | 21 | ||||
-rw-r--r-- | plugins/check_swap.c | 786 | ||||
-rw-r--r-- | plugins/check_swap.d/check_swap.h | 43 | ||||
-rw-r--r-- | plugins/check_swap.d/swap.c | 469 | ||||
-rw-r--r-- | plugins/t/check_swap.t | 6 | ||||
-rw-r--r-- | plugins/tests/test_check_swap.c | 23 | ||||
-rwxr-xr-x | plugins/tests/test_check_swap.t | 6 | ||||
-rw-r--r-- | plugins/tests/var/proc_meminfo | 55 |
10 files changed, 887 insertions, 537 deletions
@@ -221,7 +221,13 @@ NP-VERSION-FILE | |||
221 | /plugins/tests/Makefile.in | 221 | /plugins/tests/Makefile.in |
222 | /plugins/tests/test_utils | 222 | /plugins/tests/test_utils |
223 | /plugins/tests/test_disk | 223 | /plugins/tests/test_disk |
224 | /plugins/tests/test_check_swap | ||
224 | /plugins/tests/.deps | 225 | /plugins/tests/.deps |
226 | /plugins/tests/.dirstamp | ||
227 | |||
228 | # /plugins/check_swap.d | ||
229 | /plugins/check_swap.d/.deps | ||
230 | /plugins/check_swap.d/.dirstamp | ||
225 | 231 | ||
226 | # /plugins-root/ | 232 | # /plugins-root/ |
227 | /plugins-root/.deps | 233 | /plugins-root/.deps |
diff --git a/configure.ac b/configure.ac index 8594238f..0432336b 100644 --- a/configure.ac +++ b/configure.ac | |||
@@ -4,7 +4,7 @@ AC_INIT(monitoring-plugins,2.4git) | |||
4 | AC_CONFIG_SRCDIR(NPTest.pm) | 4 | AC_CONFIG_SRCDIR(NPTest.pm) |
5 | AC_CONFIG_FILES([gl/Makefile]) | 5 | AC_CONFIG_FILES([gl/Makefile]) |
6 | AC_CONFIG_AUX_DIR(build-aux) | 6 | AC_CONFIG_AUX_DIR(build-aux) |
7 | AM_INIT_AUTOMAKE([1.8.3]) | 7 | AM_INIT_AUTOMAKE([1.8.3 subdir-objects]) |
8 | AM_SILENT_RULES([yes]) | 8 | AM_SILENT_RULES([yes]) |
9 | AM_MAINTAINER_MODE([enable]) | 9 | AM_MAINTAINER_MODE([enable]) |
10 | AC_CONFIG_HEADERS([config.h]) | 10 | AC_CONFIG_HEADERS([config.h]) |
@@ -185,6 +185,9 @@ fi | |||
185 | if test "$enable_libtap" = "yes" ; then | 185 | if test "$enable_libtap" = "yes" ; then |
186 | EXTRA_TEST="test_utils test_disk test_tcp test_cmd test_base64" | 186 | EXTRA_TEST="test_utils test_disk test_tcp test_cmd test_base64" |
187 | AC_SUBST(EXTRA_TEST) | 187 | AC_SUBST(EXTRA_TEST) |
188 | |||
189 | EXTRA_PLUGIN_TESTS="tests/test_check_swap" | ||
190 | AC_SUBST(EXTRA_PLUGIN_TESTS) | ||
188 | fi | 191 | fi |
189 | 192 | ||
190 | dnl INI Parsing | 193 | dnl INI Parsing |
@@ -1850,8 +1853,8 @@ AC_SUBST(EXTRAS_ROOT) | |||
1850 | AC_SUBST(EXTRA_NETOBJS) | 1853 | AC_SUBST(EXTRA_NETOBJS) |
1851 | AC_SUBST(DEPLIBS) | 1854 | AC_SUBST(DEPLIBS) |
1852 | 1855 | ||
1853 | AM_GNU_GETTEXT([external], [need-ngettext]) | 1856 | dnl AM_GNU_GETTEXT([external], [need-ngettext]) |
1854 | AM_GNU_GETTEXT_VERSION(0.15) | 1857 | dnl AM_GNU_GETTEXT_VERSION(0.15) |
1855 | 1858 | ||
1856 | dnl Check for Redhat spopen problem | 1859 | dnl Check for Redhat spopen problem |
1857 | dnl Weird problem where ECHILD is returned from a wait call in error | 1860 | dnl Weird problem where ECHILD is returned from a wait call in error |
diff --git a/plugins/Makefile.am b/plugins/Makefile.am index 49086b7a..d43c1971 100644 --- a/plugins/Makefile.am +++ b/plugins/Makefile.am | |||
@@ -38,19 +38,27 @@ check_tcp_programs = check_ftp check_imap check_nntp check_pop \ | |||
38 | EXTRA_PROGRAMS = check_mysql check_radius check_pgsql check_snmp check_hpjd \ | 38 | EXTRA_PROGRAMS = check_mysql check_radius check_pgsql check_snmp check_hpjd \ |
39 | check_swap check_fping check_ldap check_game check_dig \ | 39 | check_swap check_fping check_ldap check_game check_dig \ |
40 | check_nagios check_by_ssh check_dns check_nt check_ide_smart \ | 40 | check_nagios check_by_ssh check_dns check_nt check_ide_smart \ |
41 | check_procs check_mysql_query check_apt check_dbi check_curl | 41 | check_procs check_mysql_query check_apt check_dbi check_curl \ |
42 | \ | ||
43 | tests/test_check_swap | ||
42 | 44 | ||
43 | SUBDIRS = picohttpparser | 45 | SUBDIRS = picohttpparser |
44 | 46 | ||
45 | EXTRA_DIST = t tests | 47 | np_test_scripts = tests/test_check_swap.t |
48 | |||
49 | EXTRA_DIST = t tests $(np_test_scripts) check_swap.d | ||
46 | 50 | ||
47 | PLUGINHDRS = common.h | 51 | PLUGINHDRS = common.h |
48 | 52 | ||
49 | noinst_LIBRARIES = libnpcommon.a | 53 | noinst_LIBRARIES = libnpcommon.a |
54 | noinst_PROGRAMS = @EXTRA_PLUGIN_TESTS@ | ||
55 | # These two lines support "make check", but we use "make test" | ||
56 | check_PROGRAMS = @EXTRA_PLUGIN_TESTS@ | ||
50 | 57 | ||
51 | libnpcommon_a_SOURCES = utils.c netutils.c sslutils.c runcmd.c \ | 58 | libnpcommon_a_SOURCES = utils.c netutils.c sslutils.c runcmd.c \ |
52 | popen.c utils.h netutils.h popen.h common.h runcmd.c runcmd.h | 59 | popen.c utils.h netutils.h popen.h common.h runcmd.c runcmd.h |
53 | 60 | ||
61 | |||
54 | BASEOBJS = libnpcommon.a ../lib/libmonitoringplug.a ../gl/libgnu.a $(LIB_CRYPTO) | 62 | BASEOBJS = libnpcommon.a ../lib/libmonitoringplug.a ../gl/libgnu.a $(LIB_CRYPTO) |
55 | NETOBJS = $(BASEOBJS) $(EXTRA_NETOBLS) | 63 | NETOBJS = $(BASEOBJS) $(EXTRA_NETOBLS) |
56 | NETLIBS = $(NETOBJS) $(SOCKETLIBS) | 64 | NETLIBS = $(NETOBJS) $(SOCKETLIBS) |
@@ -58,7 +66,10 @@ SSLOBJS = $(BASEOBJS) $(NETLIBS) $(SSLLIBS) $(LIB_CRYPTO) | |||
58 | 66 | ||
59 | TESTS_ENVIRONMENT = perl -I $(top_builddir) -I $(top_srcdir) | 67 | TESTS_ENVIRONMENT = perl -I $(top_builddir) -I $(top_srcdir) |
60 | 68 | ||
61 | TESTS = @PLUGIN_TEST@ | 69 | tap_ldflags = -L$(top_srcdir)/tap |
70 | |||
71 | TESTS = @PLUGIN_TEST@ @EXTRA_PLUGIN_TESTS@ | ||
72 | |||
62 | 73 | ||
63 | test: | 74 | test: |
64 | perl -I $(top_builddir) -I $(top_srcdir) ../test.pl | 75 | perl -I $(top_builddir) -I $(top_srcdir) ../test.pl |
@@ -107,6 +118,7 @@ check_real_LDADD = $(NETLIBS) | |||
107 | check_snmp_LDADD = $(BASEOBJS) | 118 | check_snmp_LDADD = $(BASEOBJS) |
108 | check_smtp_LDADD = $(SSLOBJS) | 119 | check_smtp_LDADD = $(SSLOBJS) |
109 | check_ssh_LDADD = $(NETLIBS) | 120 | check_ssh_LDADD = $(NETLIBS) |
121 | check_swap_SOURCES = check_swap.c check_swap.d/swap.c | ||
110 | check_swap_LDADD = $(MATHLIBS) $(BASEOBJS) | 122 | check_swap_LDADD = $(MATHLIBS) $(BASEOBJS) |
111 | check_tcp_LDADD = $(SSLOBJS) | 123 | check_tcp_LDADD = $(SSLOBJS) |
112 | check_time_LDADD = $(NETLIBS) | 124 | check_time_LDADD = $(NETLIBS) |
@@ -122,6 +134,9 @@ if !HAVE_UTMPX | |||
122 | check_users_LDADD += popen.o | 134 | check_users_LDADD += popen.o |
123 | endif | 135 | endif |
124 | 136 | ||
137 | tests_test_check_swap_LDADD = $(BASEOBJS) $(tap_ldflags) -ltap | ||
138 | tests_test_check_swap_SOURCES = tests/test_check_swap.c check_swap.d/swap.c | ||
139 | |||
125 | ############################################################################## | 140 | ############################################################################## |
126 | # secondary dependencies | 141 | # secondary dependencies |
127 | 142 | ||
diff --git a/plugins/check_swap.c b/plugins/check_swap.c index e7ee785d..bc90a90b 100644 --- a/plugins/check_swap.c +++ b/plugins/check_swap.c | |||
@@ -1,607 +1,337 @@ | |||
1 | /***************************************************************************** | 1 | /***************************************************************************** |
2 | * | 2 | * |
3 | * Monitoring check_swap plugin | 3 | * Monitoring check_swap plugin |
4 | * | 4 | * |
5 | * License: GPL | 5 | * License: GPL |
6 | * Copyright (c) 2000 Karl DeBisschop (kdebisschop@users.sourceforge.net) | 6 | * Copyright (c) 2000 Karl DeBisschop (kdebisschop@users.sourceforge.net) |
7 | * Copyright (c) 2000-2024 Monitoring Plugins Development Team | 7 | * Copyright (c) 2000-2024 Monitoring Plugins Development Team |
8 | * | 8 | * |
9 | * Description: | 9 | * Description: |
10 | * | 10 | * |
11 | * This file contains the check_swap plugin | 11 | * This file contains the check_swap plugin |
12 | * | 12 | * |
13 | * | 13 | * |
14 | * This program is free software: you can redistribute it and/or modify | 14 | * This program is free software: you can redistribute it and/or modify |
15 | * it under the terms of the GNU General Public License as published by | 15 | * it under the terms of the GNU General Public License as published by |
16 | * the Free Software Foundation, either version 3 of the License, or | 16 | * the Free Software Foundation, either version 3 of the License, or |
17 | * (at your option) any later version. | 17 | * (at your option) any later version. |
18 | * | 18 | * |
19 | * This program is distributed in the hope that it will be useful, | 19 | * This program is distributed in the hope that it will be useful, |
20 | * but WITHOUT ANY WARRANTY; without even the implied warranty of | 20 | * but WITHOUT ANY WARRANTY; without even the implied warranty of |
21 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | 21 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
22 | * GNU General Public License for more details. | 22 | * GNU General Public License for more details. |
23 | * | 23 | * |
24 | * You should have received a copy of the GNU General Public License | 24 | * You should have received a copy of the GNU General Public License |
25 | * along with this program. If not, see <http://www.gnu.org/licenses/>. | 25 | * along with this program. If not, see <http://www.gnu.org/licenses/>. |
26 | * | 26 | * |
27 | * | 27 | * |
28 | *****************************************************************************/ | 28 | *****************************************************************************/ |
29 | |||
30 | const char *progname = "check_swap"; | ||
31 | const char *copyright = "2000-2024"; | ||
32 | const char *email = "devel@monitoring-plugins.org"; | ||
33 | 29 | ||
34 | #include "common.h" | 30 | #include "common.h" |
35 | #include "popen.h" | ||
36 | #include "utils.h" | ||
37 | |||
38 | #ifdef HAVE_DECL_SWAPCTL | 31 | #ifdef HAVE_DECL_SWAPCTL |
39 | # ifdef HAVE_SYS_PARAM_H | 32 | # ifdef HAVE_SYS_PARAM_H |
40 | # include <sys/param.h> | 33 | # include <sys/param.h> |
41 | # endif | 34 | # endif |
42 | # ifdef HAVE_SYS_SWAP_H | 35 | # ifdef HAVE_SYS_SWAP_H |
43 | # include <sys/swap.h> | 36 | # include <sys/swap.h> |
44 | # endif | 37 | # endif |
45 | # ifdef HAVE_SYS_STAT_H | 38 | # ifdef HAVE_SYS_STAT_H |
46 | # include <sys/stat.h> | 39 | # include <sys/stat.h> |
47 | # endif | 40 | # endif |
48 | #endif | 41 | #endif |
49 | 42 | ||
50 | #ifndef SWAP_CONVERSION | 43 | #include <stdint.h> |
51 | # define SWAP_CONVERSION 1 | 44 | #include "./check_swap.d/check_swap.h" |
52 | #endif | 45 | #include "./utils.h" |
53 | 46 | ||
54 | typedef struct { | 47 | typedef struct { |
55 | bool is_percentage; | 48 | int errorcode; |
56 | uint64_t value; | 49 | swap_config config; |
57 | } threshold; | 50 | } swap_config_wrapper; |
58 | |||
59 | int check_swap (float free_swap_mb, float total_swap_mb); | ||
60 | int process_arguments (int argc, char **argv); | ||
61 | int validate_arguments (void); | ||
62 | void print_usage (void); | ||
63 | void print_help (void); | ||
64 | |||
65 | threshold warn; | ||
66 | threshold crit; | ||
67 | int verbose; | ||
68 | bool allswaps = false; | ||
69 | int no_swap_state = STATE_CRITICAL; | ||
70 | |||
71 | int | ||
72 | main (int argc, char **argv) | ||
73 | { | ||
74 | unsigned int percent_used, percent; | ||
75 | uint64_t total_swap_mb = 0, used_swap_mb = 0, free_swap_mb = 0; | ||
76 | uint64_t dsktotal_mb = 0, dskused_mb = 0, dskfree_mb = 0; | ||
77 | uint64_t tmp_KB = 0; | ||
78 | int result = STATE_UNKNOWN; | ||
79 | char input_buffer[MAX_INPUT_BUFFER]; | ||
80 | #ifdef HAVE_PROC_MEMINFO | ||
81 | FILE *fp; | ||
82 | #else | ||
83 | int conv_factor = SWAP_CONVERSION; | ||
84 | # ifdef HAVE_SWAP | ||
85 | char *temp_buffer; | ||
86 | char *swap_command; | ||
87 | char *swap_format; | ||
88 | # else | ||
89 | # ifdef HAVE_DECL_SWAPCTL | ||
90 | int i=0, nswaps=0, swapctl_res=0; | ||
91 | # ifdef CHECK_SWAP_SWAPCTL_SVR4 | ||
92 | swaptbl_t *tbl=NULL; | ||
93 | swapent_t *ent=NULL; | ||
94 | # else | ||
95 | # ifdef CHECK_SWAP_SWAPCTL_BSD | ||
96 | struct swapent *ent; | ||
97 | # endif /* CHECK_SWAP_SWAPCTL_BSD */ | ||
98 | # endif /* CHECK_SWAP_SWAPCTL_SVR4 */ | ||
99 | # endif /* HAVE_DECL_SWAPCTL */ | ||
100 | # endif | ||
101 | #endif | ||
102 | char str[32]; | ||
103 | char *status; | ||
104 | 51 | ||
105 | setlocale (LC_ALL, ""); | 52 | static swap_config_wrapper process_arguments(int argc, char **argv); |
106 | bindtextdomain (PACKAGE, LOCALEDIR); | 53 | void print_usage(void); |
107 | textdomain (PACKAGE); | 54 | static void print_help(swap_config /*config*/); |
108 | 55 | ||
109 | status = strdup (""); | 56 | int verbose; |
110 | 57 | ||
111 | /* Parse extra opts if any */ | 58 | #define HUNDRED_PERCENT 100 |
112 | argv=np_extra_opts (&argc, argv, progname); | ||
113 | 59 | ||
114 | if (process_arguments (argc, argv) == ERROR) | 60 | #define BYTES_TO_KiB(number) (number / 1024) |
115 | usage4 (_("Could not parse arguments")); | 61 | #define BYTES_TO_MiB(number) (BYTES_TO_KiB(number) / 1024) |
116 | 62 | ||
117 | #ifdef HAVE_PROC_MEMINFO | 63 | const char *progname = "check_swap"; |
118 | if (verbose >= 3) { | 64 | const char *copyright = "2000-2024"; |
119 | printf("Reading PROC_MEMINFO at %s\n", PROC_MEMINFO); | 65 | const char *email = "devel@monitoring-plugins.org"; |
120 | } | ||
121 | fp = fopen (PROC_MEMINFO, "r"); | ||
122 | while (fgets (input_buffer, MAX_INPUT_BUFFER - 1, fp)) { | ||
123 | /* | ||
124 | * The following sscanf call looks for a line looking like: "Swap: 123 123 123" | ||
125 | * On which kind of system this format exists, I can not say, but I wanted to | ||
126 | * document this for people who are not adapt with sscanf anymore, like me | ||
127 | */ | ||
128 | if (sscanf (input_buffer, "%*[S]%*[w]%*[a]%*[p]%*[:] %lu %lu %lu", &dsktotal_mb, &dskused_mb, &dskfree_mb) == 3) { | ||
129 | dsktotal_mb = dsktotal_mb / (1024 * 1024); /* Apply conversion */ | ||
130 | dskused_mb = dskused_mb / (1024 * 1024); | ||
131 | dskfree_mb = dskfree_mb / (1024 * 1024); | ||
132 | total_swap_mb += dsktotal_mb; | ||
133 | used_swap_mb += dskused_mb; | ||
134 | free_swap_mb += dskfree_mb; | ||
135 | if (allswaps) { | ||
136 | if (dsktotal_mb == 0) | ||
137 | percent=100.0; | ||
138 | else | ||
139 | percent = 100 * (((double) dskused_mb) / ((double) dsktotal_mb)); | ||
140 | result = max_state (result, check_swap (dskfree_mb, dsktotal_mb)); | ||
141 | if (verbose) | ||
142 | xasprintf (&status, "%s [%lu (%d%%)]", status, dskfree_mb, 100 - percent); | ||
143 | } | ||
144 | } | ||
145 | 66 | ||
146 | /* | 67 | int main(int argc, char **argv) { |
147 | * The following sscanf call looks for lines looking like: "SwapTotal: 123" and "SwapFree: 123" | 68 | setlocale(LC_ALL, ""); |
148 | * This format exists at least on Debian Linux with a 5.* kernel | 69 | bindtextdomain(PACKAGE, LOCALEDIR); |
149 | */ | 70 | textdomain(PACKAGE); |
150 | else if (sscanf (input_buffer, "%*[S]%*[w]%*[a]%*[p]%[TotalFreCchd]%*[:] %lu %*[k]%*[B]", str, &tmp_KB)) { | ||
151 | if (verbose >= 3) { | ||
152 | printf("Got %s with %lu\n", str, tmp_KB); | ||
153 | } | ||
154 | /* I think this part is always in Kb, so convert to mb */ | ||
155 | if (strcmp ("Total", str) == 0) { | ||
156 | dsktotal_mb = tmp_KB / 1024; | ||
157 | } | ||
158 | else if (strcmp ("Free", str) == 0) { | ||
159 | dskfree_mb = dskfree_mb + tmp_KB / 1024; | ||
160 | } | ||
161 | else if (strcmp ("Cached", str) == 0) { | ||
162 | dskfree_mb = dskfree_mb + tmp_KB / 1024; | ||
163 | } | ||
164 | } | ||
165 | } | ||
166 | fclose(fp); | ||
167 | dskused_mb = dsktotal_mb - dskfree_mb; | ||
168 | total_swap_mb = dsktotal_mb; | ||
169 | used_swap_mb = dskused_mb; | ||
170 | free_swap_mb = dskfree_mb; | ||
171 | #else | ||
172 | # ifdef HAVE_SWAP | ||
173 | xasprintf(&swap_command, "%s", SWAP_COMMAND); | ||
174 | xasprintf(&swap_format, "%s", SWAP_FORMAT); | ||
175 | |||
176 | /* These override the command used if a summary (and thus ! allswaps) is required */ | ||
177 | /* The summary flag returns more accurate information about swap usage on these OSes */ | ||
178 | # ifdef _AIX | ||
179 | if (!allswaps) { | ||
180 | xasprintf(&swap_command, "%s", "/usr/sbin/lsps -s"); | ||
181 | xasprintf(&swap_format, "%s", "%lu%*s %lu"); | ||
182 | conv_factor = 1; | ||
183 | } | ||
184 | # endif | ||
185 | 71 | ||
186 | if (verbose >= 2) | 72 | char *status = strdup(""); |
187 | printf (_("Command: %s\n"), swap_command); | ||
188 | if (verbose >= 3) | ||
189 | printf (_("Format: %s\n"), swap_format); | ||
190 | 73 | ||
191 | child_process = spopen (swap_command); | 74 | /* Parse extra opts if any */ |
192 | if (child_process == NULL) { | 75 | argv = np_extra_opts(&argc, argv, progname); |
193 | printf (_("Could not open pipe: %s\n"), swap_command); | ||
194 | return STATE_UNKNOWN; | ||
195 | } | ||
196 | 76 | ||
197 | child_stderr = fdopen (child_stderr_array[fileno (child_process)], "r"); | 77 | swap_config_wrapper tmp = process_arguments(argc, argv); |
198 | if (child_stderr == NULL) | ||
199 | printf (_("Could not open stderr for %s\n"), swap_command); | ||
200 | |||
201 | sprintf (str, "%s", ""); | ||
202 | /* read 1st line */ | ||
203 | fgets (input_buffer, MAX_INPUT_BUFFER - 1, child_process); | ||
204 | if (strcmp (swap_format, "") == 0) { | ||
205 | temp_buffer = strtok (input_buffer, " \n"); | ||
206 | while (temp_buffer) { | ||
207 | if (strstr (temp_buffer, "blocks")) | ||
208 | sprintf (str, "%s %s", str, "%lu"); | ||
209 | else if (strstr (temp_buffer, "dskfree")) | ||
210 | sprintf (str, "%s %s", str, "%lu"); | ||
211 | else | ||
212 | sprintf (str, "%s %s", str, "%*s"); | ||
213 | temp_buffer = strtok (NULL, " \n"); | ||
214 | } | ||
215 | } | ||
216 | 78 | ||
217 | /* If different swap command is used for summary switch, need to read format differently */ | 79 | if (tmp.errorcode != OK) { |
218 | # ifdef _AIX | 80 | usage4(_("Could not parse arguments")); |
219 | if (!allswaps) { | ||
220 | fgets(input_buffer, MAX_INPUT_BUFFER - 1, child_process); /* Ignore first line */ | ||
221 | sscanf (input_buffer, swap_format, &total_swap_mb, &used_swap_mb); | ||
222 | free_swap_mb = total_swap_mb * (100 - used_swap_mb) /100; | ||
223 | used_swap_mb = total_swap_mb - free_swap_mb; | ||
224 | if (verbose >= 3) | ||
225 | printf (_("total=%.0f, used=%.0f, free=%.0f\n"), total_swap_mb, used_swap_mb, free_swap_mb); | ||
226 | } else { | ||
227 | # endif | ||
228 | while (fgets (input_buffer, MAX_INPUT_BUFFER - 1, child_process)) { | ||
229 | sscanf (input_buffer, swap_format, &dsktotal_mb, &dskfree_mb); | ||
230 | |||
231 | dsktotal_mb = dsktotal_mb / conv_factor; | ||
232 | /* AIX lists percent used, so this converts to dskfree in MBs */ | ||
233 | # ifdef _AIX | ||
234 | dskfree_mb = dsktotal_mb * (100 - dskfree_mb) / 100; | ||
235 | # else | ||
236 | dskfree_mb = dskfree_mb / conv_factor; | ||
237 | # endif | ||
238 | if (verbose >= 3) | ||
239 | printf (_("total=%.0f, free=%.0f\n"), dsktotal_mb, dskfree_mb); | ||
240 | |||
241 | dskused_mb = dsktotal_mb - dskfree_mb; | ||
242 | total_swap_mb += dsktotal_mb; | ||
243 | used_swap_mb += dskused_mb; | ||
244 | free_swap_mb += dskfree_mb; | ||
245 | if (allswaps) { | ||
246 | percent = 100 * (((double) dskused_mb) / ((double) dsktotal_mb)); | ||
247 | result = max_state (result, check_swap (dskfree_mb, dsktotal_mb)); | ||
248 | if (verbose) | ||
249 | xasprintf (&status, "%s [%.0f (%d%%)]", status, dskfree_mb, 100 - percent); | ||
250 | } | ||
251 | } | ||
252 | # ifdef _AIX | ||
253 | } | 81 | } |
254 | # endif | ||
255 | |||
256 | /* If we get anything on STDERR, at least set warning */ | ||
257 | while (fgets (input_buffer, MAX_INPUT_BUFFER - 1, child_stderr)) | ||
258 | result = max_state (result, STATE_WARNING); | ||
259 | 82 | ||
260 | /* close stderr */ | 83 | swap_config config = tmp.config; |
261 | (void) fclose (child_stderr); | ||
262 | 84 | ||
263 | /* close the pipe */ | 85 | swap_result data = get_swap_data(config); |
264 | if (spclose (child_process)) | ||
265 | result = max_state (result, STATE_WARNING); | ||
266 | # else | ||
267 | # ifdef CHECK_SWAP_SWAPCTL_SVR4 | ||
268 | 86 | ||
269 | /* get the number of active swap devices */ | 87 | if (data.errorcode != STATE_OK) { |
270 | if((nswaps=swapctl(SC_GETNSWP, NULL))== -1) | 88 | puts("SWAP UNKNOWN - Failed to retrieve Swap usage"); |
271 | die(STATE_UNKNOWN, _("Error getting swap devices\n") ); | 89 | exit(STATE_UNKNOWN); |
272 | |||
273 | if(nswaps == 0) | ||
274 | die(STATE_OK, _("SWAP OK: No swap devices defined\n")); | ||
275 | |||
276 | if(verbose >= 3) | ||
277 | printf("Found %d swap device(s)\n", nswaps); | ||
278 | |||
279 | /* initialize swap table + entries */ | ||
280 | tbl=(swaptbl_t*)malloc(sizeof(swaptbl_t)+(sizeof(swapent_t)*nswaps)); | ||
281 | |||
282 | if(tbl==NULL) | ||
283 | die(STATE_UNKNOWN, _("malloc() failed!\n")); | ||
284 | |||
285 | memset(tbl, 0, sizeof(swaptbl_t)+(sizeof(swapent_t)*nswaps)); | ||
286 | tbl->swt_n=nswaps; | ||
287 | for(i=0;i<nswaps;i++){ | ||
288 | if((tbl->swt_ent[i].ste_path=(char*)malloc(sizeof(char)*MAXPATHLEN)) == NULL) | ||
289 | die(STATE_UNKNOWN, _("malloc() failed!\n")); | ||
290 | } | 90 | } |
291 | 91 | ||
292 | /* and now, tally 'em up */ | 92 | double percent_used; |
293 | swapctl_res=swapctl(SC_LIST, tbl); | 93 | /* if total_swap_mb == 0, let's not divide by 0 */ |
294 | if(swapctl_res < 0){ | 94 | if (data.metrics.total != 0) { |
295 | perror(_("swapctl failed: ")); | 95 | percent_used = HUNDRED_PERCENT * ((double)data.metrics.used) / ((double)data.metrics.total); |
296 | die(STATE_UNKNOWN, _("Error in swapctl call\n")); | 96 | } else { |
97 | printf(_("SWAP %s - Swap is either disabled, not present, or of zero " | ||
98 | "size."), | ||
99 | state_text(data.statusCode)); | ||
100 | exit(config.no_swap_state); | ||
297 | } | 101 | } |
298 | 102 | ||
299 | for(i=0;i<nswaps;i++){ | 103 | if (verbose) { |
300 | dsktotal_mb = (float) tbl->swt_ent[i].ste_pages / SWAP_CONVERSION; | 104 | printf("Computed usage percentage: %g\n", percent_used); |
301 | dskfree_mb = (float) tbl->swt_ent[i].ste_free / SWAP_CONVERSION; | ||
302 | dskused_mb = ( dsktotal_mb - dskfree_mb ); | ||
303 | |||
304 | if (verbose >= 3) | ||
305 | printf ("dsktotal_mb=%.0f dskfree_mb=%.0f dskused_mb=%.0f\n", dsktotal_mb, dskfree_mb, dskused_mb); | ||
306 | |||
307 | if(allswaps && dsktotal_mb > 0){ | ||
308 | percent = 100 * (((double) dskused_mb) / ((double) dsktotal_mb)); | ||
309 | result = max_state (result, check_swap (dskfree_mb, dsktotal_mb)); | ||
310 | if (verbose) { | ||
311 | xasprintf (&status, "%s [%.0f (%d%%)]", status, dskfree_mb, 100 - percent); | ||
312 | } | ||
313 | } | ||
314 | |||
315 | total_swap_mb += dsktotal_mb; | ||
316 | free_swap_mb += dskfree_mb; | ||
317 | used_swap_mb += dskused_mb; | ||
318 | } | 105 | } |
319 | 106 | ||
320 | /* and clean up after ourselves */ | 107 | uint64_t warn_print = config.warn.value; |
321 | for(i=0;i<nswaps;i++){ | 108 | if (config.warn.is_percentage) { |
322 | free(tbl->swt_ent[i].ste_path); | 109 | warn_print = config.warn.value * (data.metrics.total / HUNDRED_PERCENT); |
323 | } | 110 | } |
324 | free(tbl); | ||
325 | # else | ||
326 | # ifdef CHECK_SWAP_SWAPCTL_BSD | ||
327 | |||
328 | /* get the number of active swap devices */ | ||
329 | nswaps=swapctl(SWAP_NSWAP, NULL, 0); | ||
330 | |||
331 | /* initialize swap table + entries */ | ||
332 | ent=(struct swapent*)malloc(sizeof(struct swapent)*nswaps); | ||
333 | 111 | ||
334 | /* and now, tally 'em up */ | 112 | uint64_t crit_print = config.crit.value; |
335 | swapctl_res=swapctl(SWAP_STATS, ent, nswaps); | 113 | if (config.crit.is_percentage) { |
336 | if(swapctl_res < 0){ | 114 | crit_print = config.crit.value * (data.metrics.total / HUNDRED_PERCENT); |
337 | perror(_("swapctl failed: ")); | ||
338 | die(STATE_UNKNOWN, _("Error in swapctl call\n")); | ||
339 | } | 115 | } |
340 | 116 | ||
341 | for(i=0;i<nswaps;i++){ | 117 | char *perfdata = perfdata_uint64("swap", data.metrics.free, "B", config.warn_is_set, warn_print, config.crit_is_set, crit_print, true, |
342 | dsktotal_mb = (float) ent[i].se_nblks / conv_factor; | 118 | 0, true, data.metrics.total); |
343 | dskused_mb = (float) ent[i].se_inuse / conv_factor; | ||
344 | dskfree_mb = ( dsktotal_mb - dskused_mb ); | ||
345 | 119 | ||
346 | if(allswaps && dsktotal_mb > 0){ | 120 | if (config.warn_is_set) { |
347 | percent = 100 * (((double) dskused_mb) / ((double) dsktotal_mb)); | 121 | if (verbose > 1) { |
348 | result = max_state (result, check_swap(dskfree_mb, dsktotal_mb)); | 122 | printf("Warn threshold value: %" PRIu64 "\n", config.warn.value); |
349 | if (verbose) { | ||
350 | xasprintf (&status, "%s [%.0f (%d%%)]", status, dskfree_mb, 100 - percent); | ||
351 | } | ||
352 | } | 123 | } |
353 | 124 | ||
354 | total_swap_mb += dsktotal_mb; | 125 | if ((config.warn.is_percentage && (percent_used >= (double)(HUNDRED_PERCENT - config.warn.value))) || |
355 | free_swap_mb += dskfree_mb; | 126 | config.warn.value >= data.metrics.free) { |
356 | used_swap_mb += dskused_mb; | 127 | data.statusCode = max_state(data.statusCode, STATE_WARNING); |
128 | } | ||
357 | } | 129 | } |
358 | 130 | ||
359 | /* and clean up after ourselves */ | 131 | if (config.crit_is_set) { |
360 | free(ent); | 132 | if (verbose > 1) { |
361 | 133 | printf("Crit threshold value: %" PRIu64 "\n", config.crit.value); | |
362 | # endif /* CHECK_SWAP_SWAPCTL_BSD */ | 134 | } |
363 | # endif /* CHECK_SWAP_SWAPCTL_SVR4 */ | ||
364 | # endif /* HAVE_SWAP */ | ||
365 | #endif /* HAVE_PROC_MEMINFO */ | ||
366 | 135 | ||
367 | /* if total_swap_mb == 0, let's not divide by 0 */ | 136 | if ((config.crit.is_percentage && (percent_used >= (double)(HUNDRED_PERCENT - config.crit.value))) || |
368 | if(total_swap_mb) { | 137 | config.crit.value >= data.metrics.free) { |
369 | percent_used = 100 * ((double) used_swap_mb) / ((double) total_swap_mb); | 138 | data.statusCode = max_state(data.statusCode, STATE_CRITICAL); |
370 | } else { | 139 | } |
371 | percent_used = 100; | ||
372 | status = "- Swap is either disabled, not present, or of zero size. "; | ||
373 | } | 140 | } |
374 | 141 | ||
375 | result = max_state (result, check_swap(free_swap_mb, total_swap_mb)); | 142 | printf(_("SWAP %s - %g%% free (%lluMiB out of %lluMiB) %s|%s\n"), state_text(data.statusCode), (HUNDRED_PERCENT - percent_used), |
376 | printf (_("SWAP %s - %d%% free (%dMB out of %dMB) %s|"), | 143 | BYTES_TO_MiB(data.metrics.free), BYTES_TO_MiB(data.metrics.total), status, perfdata); |
377 | state_text (result), | ||
378 | (100 - percent_used), (int) free_swap_mb, (int) total_swap_mb, status); | ||
379 | |||
380 | uint64_t warn_print = warn.value; | ||
381 | if (warn.is_percentage) warn_print = warn.value * (total_swap_mb *1024 *1024/100); | ||
382 | uint64_t crit_print = crit.value; | ||
383 | if (crit.is_percentage) crit_print = crit.value * (total_swap_mb *1024 *1024/100); | ||
384 | 144 | ||
385 | puts (perfdata_uint64 ("swap", free_swap_mb *1024 *1024, "B", | 145 | exit(data.statusCode); |
386 | true, warn_print, | ||
387 | true, crit_print, | ||
388 | true, 0, | ||
389 | true, (long) total_swap_mb * 1024 * 1024)); | ||
390 | |||
391 | return result; | ||
392 | } | 146 | } |
393 | 147 | ||
148 | int check_swap(float free_swap_mb, float total_swap_mb, swap_config config) { | ||
149 | if (total_swap_mb == 0) { | ||
150 | return config.no_swap_state; | ||
151 | } | ||
394 | 152 | ||
395 | int | 153 | uint64_t free_swap = (uint64_t)(free_swap_mb * (1024 * 1024)); /* Convert back to bytes as warn and crit specified in bytes */ |
396 | check_swap(float free_swap_mb, float total_swap_mb) | ||
397 | { | ||
398 | |||
399 | if (!total_swap_mb) return no_swap_state; | ||
400 | 154 | ||
401 | uint64_t free_swap = free_swap_mb * (1024 * 1024); /* Convert back to bytes as warn and crit specified in bytes */ | 155 | if (!config.crit.is_percentage && config.crit.value >= free_swap) { |
402 | uint64_t usage_percentage = ((total_swap_mb - free_swap_mb) / total_swap_mb) * 100; | 156 | return STATE_CRITICAL; |
157 | } | ||
158 | if (!config.warn.is_percentage && config.warn.value >= free_swap) { | ||
159 | return STATE_WARNING; | ||
160 | } | ||
403 | 161 | ||
404 | if (warn.value || crit.value) { /* Thresholds defined */ | 162 | uint64_t usage_percentage = (uint64_t)((total_swap_mb - free_swap_mb) / total_swap_mb) * HUNDRED_PERCENT; |
405 | if (!crit.is_percentage && crit.value >= free_swap) return STATE_CRITICAL; | ||
406 | if (!warn.is_percentage && warn.value >= free_swap) return STATE_WARNING; | ||
407 | 163 | ||
408 | if (crit.is_percentage && | 164 | if (config.crit.is_percentage && config.crit.value != 0 && usage_percentage >= (HUNDRED_PERCENT - config.crit.value)) { |
409 | crit.value != 0 && | 165 | return STATE_CRITICAL; |
410 | usage_percentage >= (100 - crit.value)) | 166 | } |
411 | { | ||
412 | return STATE_CRITICAL; | ||
413 | } | ||
414 | 167 | ||
415 | if (warn.is_percentage && | 168 | if (config.warn.is_percentage && config.warn.value != 0 && usage_percentage >= (HUNDRED_PERCENT - config.warn.value)) { |
416 | warn.value != 0 && | 169 | return STATE_WARNING; |
417 | usage_percentage >= (100 - warn.value)) | 170 | } |
418 | { | ||
419 | return STATE_WARNING; | ||
420 | } | ||
421 | 171 | ||
422 | return STATE_OK; | 172 | return STATE_OK; |
423 | } else { /* Without thresholds */ | ||
424 | return STATE_OK; | ||
425 | } | ||
426 | } | 173 | } |
427 | 174 | ||
175 | /* process command-line arguments */ | ||
176 | swap_config_wrapper process_arguments(int argc, char **argv) { | ||
177 | swap_config_wrapper conf_wrapper = {.errorcode = OK}; | ||
178 | conf_wrapper.config = swap_config_init(); | ||
428 | 179 | ||
180 | static struct option longopts[] = {{"warning", required_argument, 0, 'w'}, {"critical", required_argument, 0, 'c'}, | ||
181 | {"allswaps", no_argument, 0, 'a'}, {"no-swap", required_argument, 0, 'n'}, | ||
182 | {"verbose", no_argument, 0, 'v'}, {"version", no_argument, 0, 'V'}, | ||
183 | {"help", no_argument, 0, 'h'}, {0, 0, 0, 0}}; | ||
429 | 184 | ||
430 | /* process command-line arguments */ | 185 | while (true) { |
431 | int | 186 | int option = 0; |
432 | process_arguments (int argc, char **argv) | 187 | int option_char = getopt_long(argc, argv, "+?Vvhac:w:n:", longopts, &option); |
433 | { | 188 | |
434 | int c = 0; /* option character */ | 189 | if (option_char == -1 || option_char == EOF) { |
435 | |||
436 | int option = 0; | ||
437 | static struct option longopts[] = { | ||
438 | {"warning", required_argument, 0, 'w'}, | ||
439 | {"critical", required_argument, 0, 'c'}, | ||
440 | {"allswaps", no_argument, 0, 'a'}, | ||
441 | {"no-swap", required_argument, 0, 'n'}, | ||
442 | {"verbose", no_argument, 0, 'v'}, | ||
443 | {"version", no_argument, 0, 'V'}, | ||
444 | {"help", no_argument, 0, 'h'}, | ||
445 | {0, 0, 0, 0} | ||
446 | }; | ||
447 | |||
448 | while (1) { | ||
449 | c = getopt_long (argc, argv, "+?Vvhac:w:n:", longopts, &option); | ||
450 | |||
451 | if (c == -1 || c == EOF) | ||
452 | break; | 190 | break; |
191 | } | ||
453 | 192 | ||
454 | switch (c) { | 193 | switch (option_char) { |
455 | case 'w': /* warning size threshold */ | 194 | case 'w': /* warning size threshold */ |
456 | { | 195 | { |
457 | /* | 196 | /* |
458 | * We expect either a positive integer value without a unit, which means | 197 | * We expect either a positive integer value without a unit, which |
459 | * the unit is Bytes or a positive integer value and a percentage sign (%), | 198 | * means the unit is Bytes or a positive integer value and a |
460 | * which means the value must be with 0 and 100 and is relative to the total swap | 199 | * percentage sign (%), which means the value must be with 0 and 100 |
461 | */ | 200 | * and is relative to the total swap |
462 | size_t length; | 201 | */ |
463 | length = strlen(optarg); | 202 | size_t length; |
464 | 203 | length = strlen(optarg); | |
465 | if (optarg[length - 1] == '%') { | 204 | conf_wrapper.config.warn_is_set = true; |
466 | /* It's percentage */ | 205 | |
467 | warn.is_percentage = true; | 206 | if (optarg[length - 1] == '%') { |
468 | optarg[length - 1] = '\0'; | 207 | /* It's percentage */ |
469 | if (is_uint64(optarg, &warn.value)) { | 208 | conf_wrapper.config.warn.is_percentage = true; |
470 | if (warn.value > 100) { | 209 | optarg[length - 1] = '\0'; |
471 | usage4 (_("Warning threshold percentage must be <= 100!")); | 210 | if (is_uint64(optarg, &conf_wrapper.config.warn.value)) { |
472 | } | 211 | if (conf_wrapper.config.warn.value > HUNDRED_PERCENT) { |
473 | } | 212 | usage4(_("Warning threshold percentage must be <= 100!")); |
474 | break; | ||
475 | } else { | ||
476 | /* It's Bytes */ | ||
477 | warn.is_percentage = false; | ||
478 | if (is_uint64(optarg, &warn.value)) { | ||
479 | break; | ||
480 | } else { | ||
481 | usage4 (_("Warning threshold be positive integer or percentage!")); | ||
482 | } | 213 | } |
483 | } | 214 | } |
215 | break; | ||
216 | } /* It's Bytes */ | ||
217 | conf_wrapper.config.warn.is_percentage = false; | ||
218 | if (is_uint64(optarg, &conf_wrapper.config.warn.value)) { | ||
219 | break; | ||
484 | } | 220 | } |
221 | usage4(_("Warning threshold be positive integer or " | ||
222 | "percentage!")); | ||
223 | } | ||
485 | case 'c': /* critical size threshold */ | 224 | case 'c': /* critical size threshold */ |
486 | { | 225 | { |
487 | /* | 226 | /* |
488 | * We expect either a positive integer value without a unit, which means | 227 | * We expect either a positive integer value without a unit, which |
489 | * the unit is Bytes or a positive integer value and a percentage sign (%), | 228 | * means the unit is Bytes or a positive integer value and a |
490 | * which means the value must be with 0 and 100 and is relative to the total swap | 229 | * percentage sign (%), which means the value must be with 0 and 100 |
491 | */ | 230 | * and is relative to the total swap |
492 | size_t length; | 231 | */ |
493 | length = strlen(optarg); | 232 | size_t length; |
494 | 233 | length = strlen(optarg); | |
495 | if (optarg[length - 1] == '%') { | 234 | conf_wrapper.config.crit_is_set = true; |
496 | /* It's percentage */ | 235 | |
497 | crit.is_percentage = true; | 236 | if (optarg[length - 1] == '%') { |
498 | optarg[length - 1] = '\0'; | 237 | /* It's percentage */ |
499 | if (is_uint64(optarg, &crit.value)) { | 238 | conf_wrapper.config.crit.is_percentage = true; |
500 | if (crit.value> 100) { | 239 | optarg[length - 1] = '\0'; |
501 | usage4 (_("Critical threshold percentage must be <= 100!")); | 240 | if (is_uint64(optarg, &conf_wrapper.config.crit.value)) { |
502 | } | 241 | if (conf_wrapper.config.crit.value > HUNDRED_PERCENT) { |
503 | } | 242 | usage4(_("Critical threshold percentage must be <= 100!")); |
504 | break; | ||
505 | } else { | ||
506 | /* It's Bytes */ | ||
507 | crit.is_percentage = false; | ||
508 | if (is_uint64(optarg, &crit.value)) { | ||
509 | break; | ||
510 | } else { | ||
511 | usage4 (_("Critical threshold be positive integer or percentage!")); | ||
512 | } | 243 | } |
513 | } | 244 | } |
514 | } | 245 | break; |
515 | case 'a': /* all swap */ | 246 | } /* It's Bytes */ |
516 | allswaps = true; | 247 | conf_wrapper.config.crit.is_percentage = false; |
248 | if (is_uint64(optarg, &conf_wrapper.config.crit.value)) { | ||
249 | break; | ||
250 | } | ||
251 | usage4(_("Critical threshold be positive integer or " | ||
252 | "percentage!")); | ||
253 | } | ||
254 | case 'a': /* all swap */ | ||
255 | conf_wrapper.config.allswaps = true; | ||
517 | break; | 256 | break; |
518 | case 'n': | 257 | case 'n': |
519 | if ((no_swap_state = mp_translate_state(optarg)) == ERROR) { | 258 | if ((conf_wrapper.config.no_swap_state = mp_translate_state(optarg)) == ERROR) { |
520 | usage4 (_("no-swap result must be a valid state name (OK, WARNING, CRITICAL, UNKNOWN) or integer (0-3).")); | 259 | usage4(_("no-swap result must be a valid state name (OK, " |
260 | "WARNING, CRITICAL, UNKNOWN) or integer (0-3).")); | ||
521 | } | 261 | } |
522 | break; | 262 | break; |
523 | case 'v': /* verbose */ | 263 | case 'v': /* verbose */ |
524 | verbose++; | 264 | verbose++; |
525 | break; | 265 | break; |
526 | case 'V': /* version */ | 266 | case 'V': /* version */ |
527 | print_revision (progname, NP_VERSION); | 267 | print_revision(progname, NP_VERSION); |
528 | exit (STATE_UNKNOWN); | 268 | exit(STATE_UNKNOWN); |
529 | case 'h': /* help */ | 269 | case 'h': /* help */ |
530 | print_help (); | 270 | print_help(conf_wrapper.config); |
531 | exit (STATE_UNKNOWN); | 271 | exit(STATE_UNKNOWN); |
532 | case '?': /* error */ | 272 | case '?': /* error */ |
533 | usage5 (); | 273 | usage5(); |
534 | } | 274 | } |
535 | } | 275 | } |
536 | 276 | ||
537 | c = optind; | 277 | if ((conf_wrapper.config.warn.is_percentage == conf_wrapper.config.crit.is_percentage) && |
538 | if (c == argc) | 278 | (conf_wrapper.config.warn.value < conf_wrapper.config.crit.value)) { |
539 | return validate_arguments (); | 279 | /* This is NOT triggered if warn and crit are different units, e.g warn |
540 | 280 | * is percentage and crit is absolute. We cannot determine the condition | |
541 | return validate_arguments (); | 281 | * at this point since we dont know the value of total swap yet |
542 | } | ||
543 | |||
544 | |||
545 | |||
546 | int | ||
547 | validate_arguments (void) | ||
548 | { | ||
549 | if ((warn.is_percentage == crit.is_percentage) && (warn.value < crit.value)) { | ||
550 | /* This is NOT triggered if warn and crit are different units, e.g warn is percentage | ||
551 | * and crit is absolute. We cannot determine the condition at this point since we | ||
552 | * dont know the value of total swap yet | ||
553 | */ | 282 | */ |
554 | usage4(_("Warning should be more than critical")); | 283 | usage4(_("Warning should be more than critical")); |
555 | } | 284 | } |
556 | return OK; | ||
557 | } | ||
558 | 285 | ||
559 | 286 | return conf_wrapper; | |
560 | |||
561 | void | ||
562 | print_help (void) | ||
563 | { | ||
564 | print_revision (progname, NP_VERSION); | ||
565 | |||
566 | printf (_(COPYRIGHT), copyright, email); | ||
567 | |||
568 | printf ("%s\n", _("Check swap space on local machine.")); | ||
569 | |||
570 | printf ("\n\n"); | ||
571 | |||
572 | print_usage (); | ||
573 | |||
574 | printf (UT_HELP_VRSN); | ||
575 | printf (UT_EXTRA_OPTS); | ||
576 | |||
577 | printf (" %s\n", "-w, --warning=INTEGER"); | ||
578 | printf (" %s\n", _("Exit with WARNING status if less than INTEGER bytes of swap space are free")); | ||
579 | printf (" %s\n", "-w, --warning=PERCENT%"); | ||
580 | printf (" %s\n", _("Exit with WARNING status if less than PERCENT of swap space is free")); | ||
581 | printf (" %s\n", "-c, --critical=INTEGER"); | ||
582 | printf (" %s\n", _("Exit with CRITICAL status if less than INTEGER bytes of swap space are free")); | ||
583 | printf (" %s\n", "-c, --critical=PERCENT%"); | ||
584 | printf (" %s\n", _("Exit with CRITICAL status if less than PERCENT of swap space is free")); | ||
585 | printf (" %s\n", "-a, --allswaps"); | ||
586 | printf (" %s\n", _("Conduct comparisons for all swap partitions, one by one")); | ||
587 | printf (" %s\n", "-n, --no-swap=<ok|warning|critical|unknown>"); | ||
588 | printf (" %s %s\n", _("Resulting state when there is no swap regardless of thresholds. Default:"), state_text(no_swap_state)); | ||
589 | printf (UT_VERBOSE); | ||
590 | |||
591 | printf ("\n"); | ||
592 | printf ("%s\n", _("Notes:")); | ||
593 | printf (" %s\n", _("Both INTEGER and PERCENT thresholds can be specified, they are all checked.")); | ||
594 | printf (" %s\n", _("Without thresholds, the plugin shows free swap space and performance data, but always returns OK.")); | ||
595 | printf (" %s\n", _("On AIX, if -a is specified, uses lsps -a, otherwise uses lsps -s.")); | ||
596 | |||
597 | printf (UT_SUPPORT); | ||
598 | } | 287 | } |
599 | 288 | ||
289 | void print_help(swap_config config) { | ||
290 | print_revision(progname, NP_VERSION); | ||
291 | |||
292 | printf(_(COPYRIGHT), copyright, email); | ||
293 | |||
294 | printf("%s\n", _("Check swap space on local machine.")); | ||
295 | |||
296 | printf("\n\n"); | ||
297 | |||
298 | print_usage(); | ||
299 | |||
300 | printf(UT_HELP_VRSN); | ||
301 | printf(UT_EXTRA_OPTS); | ||
302 | |||
303 | printf(" %s\n", "-w, --warning=INTEGER"); | ||
304 | printf(" %s\n", _("Exit with WARNING status if less than INTEGER bytes " | ||
305 | "of swap space are free")); | ||
306 | printf(" %s\n", "-w, --warning=PERCENT%"); | ||
307 | printf(" %s\n", _("Exit with WARNING status if less than PERCENT of " | ||
308 | "swap space is free")); | ||
309 | printf(" %s\n", "-c, --critical=INTEGER"); | ||
310 | printf(" %s\n", _("Exit with CRITICAL status if less than INTEGER bytes " | ||
311 | "of swap space are free")); | ||
312 | printf(" %s\n", "-c, --critical=PERCENT%"); | ||
313 | printf(" %s\n", _("Exit with CRITICAL status if less than PERCENT of " | ||
314 | "swap space is free")); | ||
315 | printf(" %s\n", "-a, --allswaps"); | ||
316 | printf(" %s\n", _("Conduct comparisons for all swap partitions, one by one")); | ||
317 | printf(" %s\n", "-n, --no-swap=<ok|warning|critical|unknown>"); | ||
318 | printf(" %s %s\n", | ||
319 | _("Resulting state when there is no swap regardless of thresholds. " | ||
320 | "Default:"), | ||
321 | state_text(config.no_swap_state)); | ||
322 | printf(UT_VERBOSE); | ||
323 | |||
324 | printf("\n"); | ||
325 | printf("%s\n", _("Notes:")); | ||
326 | printf(" %s\n", _("Both INTEGER and PERCENT thresholds can be specified, " | ||
327 | "they are all checked.")); | ||
328 | printf(" %s\n", _("On AIX, if -a is specified, uses lsps -a, otherwise uses lsps -s.")); | ||
329 | |||
330 | printf(UT_SUPPORT); | ||
331 | } | ||
600 | 332 | ||
601 | void | 333 | void print_usage(void) { |
602 | print_usage (void) | 334 | printf("%s\n", _("Usage:")); |
603 | { | 335 | printf(" %s [-av] -w <percent_free>%% -c <percent_free>%%\n", progname); |
604 | printf ("%s\n", _("Usage:")); | 336 | printf(" -w <bytes_free> -c <bytes_free> [-n <state>]\n"); |
605 | printf (" %s [-av] [-w <percent_free>%%] [-c <percent_free>%%]\n",progname); | ||
606 | printf (" [-w <bytes_free>] [-c <bytes_free>] [-n <state>]\n"); | ||
607 | } | 337 | } |
diff --git a/plugins/check_swap.d/check_swap.h b/plugins/check_swap.d/check_swap.h new file mode 100644 index 00000000..99039b21 --- /dev/null +++ b/plugins/check_swap.d/check_swap.h | |||
@@ -0,0 +1,43 @@ | |||
1 | #pragma once | ||
2 | |||
3 | #include "../common.h" | ||
4 | |||
5 | #ifndef SWAP_CONVERSION | ||
6 | # define SWAP_CONVERSION 1 | ||
7 | #endif | ||
8 | |||
9 | typedef struct { | ||
10 | bool is_percentage; | ||
11 | uint64_t value; | ||
12 | } check_swap_threshold; | ||
13 | |||
14 | typedef struct { | ||
15 | unsigned long long free; // Free swap in Bytes! | ||
16 | unsigned long long used; // Used swap in Bytes! | ||
17 | unsigned long long total; // Total swap size, you guessed it, in Bytes! | ||
18 | } swap_metrics; | ||
19 | |||
20 | typedef struct { | ||
21 | int errorcode; | ||
22 | int statusCode; | ||
23 | swap_metrics metrics; | ||
24 | } swap_result; | ||
25 | |||
26 | typedef struct { | ||
27 | bool allswaps; | ||
28 | int no_swap_state; | ||
29 | bool warn_is_set; | ||
30 | check_swap_threshold warn; | ||
31 | bool crit_is_set; | ||
32 | check_swap_threshold crit; | ||
33 | bool on_aix; | ||
34 | int conversion_factor; | ||
35 | } swap_config; | ||
36 | |||
37 | swap_config swap_config_init(void); | ||
38 | |||
39 | swap_result get_swap_data(swap_config config); | ||
40 | swap_result getSwapFromProcMeminfo(char path_to_proc_meminfo[]); | ||
41 | swap_result getSwapFromSwapCommand(swap_config config, const char swap_command[], const char swap_format[]); | ||
42 | swap_result getSwapFromSwapctl_BSD(swap_config config); | ||
43 | swap_result getSwapFromSwap_SRV4(swap_config config); | ||
diff --git a/plugins/check_swap.d/swap.c b/plugins/check_swap.d/swap.c new file mode 100644 index 00000000..2fe4544f --- /dev/null +++ b/plugins/check_swap.d/swap.c | |||
@@ -0,0 +1,469 @@ | |||
1 | #include "./check_swap.d/check_swap.h" | ||
2 | #include "../popen.h" | ||
3 | #include "../utils.h" | ||
4 | #include "common.h" | ||
5 | |||
6 | extern int verbose; | ||
7 | |||
8 | swap_config swap_config_init(void) { | ||
9 | swap_config tmp = {0}; | ||
10 | tmp.allswaps = false; | ||
11 | tmp.no_swap_state = STATE_CRITICAL; | ||
12 | tmp.conversion_factor = SWAP_CONVERSION; | ||
13 | |||
14 | tmp.warn_is_set = false; | ||
15 | tmp.crit_is_set = false; | ||
16 | |||
17 | #ifdef _AIX | ||
18 | tmp.on_aix = true; | ||
19 | #else | ||
20 | tmp.on_aix = false; | ||
21 | #endif | ||
22 | |||
23 | return tmp; | ||
24 | } | ||
25 | |||
26 | swap_result get_swap_data(swap_config config) { | ||
27 | #ifdef HAVE_PROC_MEMINFO | ||
28 | if (verbose >= 3) { | ||
29 | printf("Reading PROC_MEMINFO at %s\n", PROC_MEMINFO); | ||
30 | } | ||
31 | |||
32 | return getSwapFromProcMeminfo(PROC_MEMINFO); | ||
33 | #else // HAVE_PROC_MEMINFO | ||
34 | # ifdef HAVE_SWAP | ||
35 | if (verbose >= 3) { | ||
36 | printf("Using swap command %s with format: %s\n", SWAP_COMMAND, SWAP_FORMAT); | ||
37 | } | ||
38 | |||
39 | /* These override the command used if a summary (and thus ! allswaps) is | ||
40 | * required | ||
41 | * The summary flag returns more accurate information about swap usage on these | ||
42 | * OSes */ | ||
43 | if (config.on_aix && !config.allswaps) { | ||
44 | |||
45 | config.conversion_factor = 1; | ||
46 | |||
47 | return getSwapFromSwapCommand(config, "/usr/sbin/lsps -s", "%lu%*s %lu"); | ||
48 | } else { | ||
49 | return getSwapFromSwapCommand(config, SWAP_COMMAND, SWAP_FORMAT); | ||
50 | } | ||
51 | # else // HAVE_SWAP | ||
52 | # ifdef CHECK_SWAP_SWAPCTL_SVR4 | ||
53 | return getSwapFromSwapctl_SRV4(); | ||
54 | # else // CHECK_SWAP_SWAPCTL_SVR4 | ||
55 | # ifdef CHECK_SWAP_SWAPCTL_BSD | ||
56 | return getSwapFromSwapctl_BSD(); | ||
57 | # else // CHECK_SWAP_SWAPCTL_BSD | ||
58 | # error No way found to retrieve swap | ||
59 | # endif /* CHECK_SWAP_SWAPCTL_BSD */ | ||
60 | # endif /* CHECK_SWAP_SWAPCTL_SVR4 */ | ||
61 | # endif /* HAVE_SWAP */ | ||
62 | #endif /* HAVE_PROC_MEMINFO */ | ||
63 | } | ||
64 | |||
65 | swap_result getSwapFromProcMeminfo(char proc_meminfo[]) { | ||
66 | FILE *meminfo_file_ptr; | ||
67 | meminfo_file_ptr = fopen(proc_meminfo, "r"); | ||
68 | |||
69 | swap_result result = {0}; | ||
70 | result.errorcode = STATE_UNKNOWN; | ||
71 | |||
72 | if (meminfo_file_ptr == NULL) { | ||
73 | // failed to open meminfo file | ||
74 | // errno should contain an error | ||
75 | result.errorcode = STATE_UNKNOWN; | ||
76 | return result; | ||
77 | } | ||
78 | |||
79 | uint64_t swap_total = 0; | ||
80 | uint64_t swap_used = 0; | ||
81 | uint64_t swap_free = 0; | ||
82 | |||
83 | bool found_total = false; | ||
84 | bool found_used = false; | ||
85 | bool found_free = false; | ||
86 | |||
87 | char input_buffer[MAX_INPUT_BUFFER]; | ||
88 | char str[32]; | ||
89 | |||
90 | while (fgets(input_buffer, MAX_INPUT_BUFFER - 1, meminfo_file_ptr)) { | ||
91 | uint64_t tmp_KB = 0; | ||
92 | |||
93 | /* | ||
94 | * The following sscanf call looks for a line looking like: "Swap: 123 | ||
95 | * 123 123" On which kind of system this format exists, I can not say, | ||
96 | * but I wanted to document this for people who are not adapt with | ||
97 | * sscanf anymore, like me | ||
98 | * Also the units used here are unclear and probably wrong | ||
99 | */ | ||
100 | if (sscanf(input_buffer, "%*[S]%*[w]%*[a]%*[p]%*[:] %lu %lu %lu", &swap_total, &swap_used, &swap_free) == 3) { | ||
101 | |||
102 | result.metrics.total += swap_total; | ||
103 | result.metrics.used += swap_used; | ||
104 | result.metrics.free += swap_free; | ||
105 | |||
106 | found_total = true; | ||
107 | found_free = true; | ||
108 | found_used = true; | ||
109 | |||
110 | // Set error | ||
111 | result.errorcode = STATE_OK; | ||
112 | |||
113 | /* | ||
114 | * The following sscanf call looks for lines looking like: | ||
115 | * "SwapTotal: 123" and "SwapFree: 123" This format exists at least | ||
116 | * on Debian Linux with a 5.* kernel | ||
117 | */ | ||
118 | } else { | ||
119 | int sscanf_result = sscanf(input_buffer, | ||
120 | "%*[S]%*[w]%*[a]%*[p]%[TotalFreCchd]%*[:] %lu " | ||
121 | "%*[k]%*[B]", | ||
122 | str, &tmp_KB); | ||
123 | |||
124 | if (sscanf_result == 2) { | ||
125 | |||
126 | if (verbose >= 3) { | ||
127 | printf("Got %s with %lu\n", str, tmp_KB); | ||
128 | } | ||
129 | |||
130 | /* I think this part is always in Kb, so convert to bytes */ | ||
131 | if (strcmp("Total", str) == 0) { | ||
132 | swap_total = tmp_KB * 1000; | ||
133 | found_total = true; | ||
134 | } else if (strcmp("Free", str) == 0) { | ||
135 | swap_free = swap_free + tmp_KB * 1000; | ||
136 | found_free = true; | ||
137 | found_used = true; // No explicit used metric available | ||
138 | } else if (strcmp("Cached", str) == 0) { | ||
139 | swap_free = swap_free + tmp_KB * 1000; | ||
140 | found_free = true; | ||
141 | found_used = true; // No explicit used metric available | ||
142 | } | ||
143 | |||
144 | result.errorcode = STATE_OK; | ||
145 | } | ||
146 | } | ||
147 | } | ||
148 | |||
149 | fclose(meminfo_file_ptr); | ||
150 | |||
151 | result.metrics.total = swap_total; | ||
152 | result.metrics.used = swap_total - swap_free; | ||
153 | result.metrics.free = swap_free; | ||
154 | |||
155 | if (!found_free || !found_total || !found_used) { | ||
156 | result.errorcode = STATE_UNKNOWN; | ||
157 | } | ||
158 | |||
159 | return result; | ||
160 | } | ||
161 | |||
162 | swap_result getSwapFromSwapCommand(swap_config config, const char swap_command[], const char swap_format[]) { | ||
163 | swap_result result = {0}; | ||
164 | |||
165 | char *temp_buffer; | ||
166 | |||
167 | if (verbose >= 2) { | ||
168 | printf(_("Command: %s\n"), swap_command); | ||
169 | } | ||
170 | if (verbose >= 3) { | ||
171 | printf(_("Format: %s\n"), swap_format); | ||
172 | } | ||
173 | |||
174 | child_process = spopen(swap_command); | ||
175 | if (child_process == NULL) { | ||
176 | printf(_("Could not open pipe: %s\n"), swap_command); | ||
177 | swap_result tmp = { | ||
178 | .errorcode = STATE_UNKNOWN, | ||
179 | }; | ||
180 | return tmp; | ||
181 | } | ||
182 | |||
183 | child_stderr = fdopen(child_stderr_array[fileno(child_process)], "r"); | ||
184 | if (child_stderr == NULL) { | ||
185 | printf(_("Could not open stderr for %s\n"), swap_command); | ||
186 | } | ||
187 | |||
188 | char str[32] = {0}; | ||
189 | char input_buffer[MAX_INPUT_BUFFER]; | ||
190 | |||
191 | /* read 1st line */ | ||
192 | fgets(input_buffer, MAX_INPUT_BUFFER - 1, child_process); | ||
193 | if (strcmp(swap_format, "") == 0) { | ||
194 | temp_buffer = strtok(input_buffer, " \n"); | ||
195 | while (temp_buffer) { | ||
196 | if (strstr(temp_buffer, "blocks")) { | ||
197 | sprintf(str, "%s %s", str, "%lu"); | ||
198 | } else if (strstr(temp_buffer, "dskfree")) { | ||
199 | sprintf(str, "%s %s", str, "%lu"); | ||
200 | } else { | ||
201 | sprintf(str, "%s %s", str, "%*s"); | ||
202 | } | ||
203 | temp_buffer = strtok(NULL, " \n"); | ||
204 | } | ||
205 | } | ||
206 | |||
207 | double total_swap_mb = 0; | ||
208 | double free_swap_mb = 0; | ||
209 | double used_swap_mb = 0; | ||
210 | double dsktotal_mb = 0; | ||
211 | double dskused_mb = 0; | ||
212 | double dskfree_mb = 0; | ||
213 | |||
214 | /* | ||
215 | * If different swap command is used for summary switch, need to read format | ||
216 | * differently | ||
217 | */ | ||
218 | if (config.on_aix && !config.allswaps) { | ||
219 | fgets(input_buffer, MAX_INPUT_BUFFER - 1, child_process); /* Ignore first line */ | ||
220 | sscanf(input_buffer, swap_format, &total_swap_mb, &used_swap_mb); | ||
221 | free_swap_mb = total_swap_mb * (100 - used_swap_mb) / 100; | ||
222 | used_swap_mb = total_swap_mb - free_swap_mb; | ||
223 | |||
224 | if (verbose >= 3) { | ||
225 | printf(_("total=%.0f, used=%.0f, free=%.0f\n"), total_swap_mb, used_swap_mb, free_swap_mb); | ||
226 | } | ||
227 | } else { | ||
228 | while (fgets(input_buffer, MAX_INPUT_BUFFER - 1, child_process)) { | ||
229 | sscanf(input_buffer, swap_format, &dsktotal_mb, &dskfree_mb); | ||
230 | |||
231 | dsktotal_mb = dsktotal_mb / config.conversion_factor; | ||
232 | /* AIX lists percent used, so this converts to dskfree in MBs */ | ||
233 | |||
234 | if (config.on_aix) { | ||
235 | dskfree_mb = dsktotal_mb * (100 - dskfree_mb) / 100; | ||
236 | } else { | ||
237 | dskfree_mb = dskfree_mb / config.conversion_factor; | ||
238 | } | ||
239 | |||
240 | if (verbose >= 3) { | ||
241 | printf(_("total=%.0f, free=%.0f\n"), dsktotal_mb, dskfree_mb); | ||
242 | } | ||
243 | |||
244 | dskused_mb = dsktotal_mb - dskfree_mb; | ||
245 | total_swap_mb += dsktotal_mb; | ||
246 | used_swap_mb += dskused_mb; | ||
247 | free_swap_mb += dskfree_mb; | ||
248 | } | ||
249 | } | ||
250 | |||
251 | result.metrics.free = free_swap_mb * 1024 * 1024; | ||
252 | result.metrics.used = used_swap_mb * 1024 * 1024; | ||
253 | result.metrics.total = free_swap_mb * 1024 * 1024; | ||
254 | |||
255 | /* If we get anything on STDERR, at least set warning */ | ||
256 | while (fgets(input_buffer, MAX_INPUT_BUFFER - 1, child_stderr)) { | ||
257 | result.statusCode = max_state(result.statusCode, STATE_WARNING); | ||
258 | // TODO Set error here | ||
259 | } | ||
260 | |||
261 | /* close stderr */ | ||
262 | (void)fclose(child_stderr); | ||
263 | |||
264 | /* close the pipe */ | ||
265 | if (spclose(child_process)) { | ||
266 | result.statusCode = max_state(result.statusCode, STATE_WARNING); | ||
267 | // TODO set error here | ||
268 | } | ||
269 | |||
270 | return result; | ||
271 | } | ||
272 | |||
273 | #ifndef CHECK_SWAP_SWAPCTL_BSD | ||
274 | # define CHECK_SWAP_SWAPCTL_BSD | ||
275 | |||
276 | // Stub functionality for BSD stuff, so the compiler always sees the following BSD code | ||
277 | |||
278 | # define SWAP_NSWAP 0 | ||
279 | # define SWAP_STATS 1 | ||
280 | |||
281 | int bsd_swapctl(int cmd, const void *arg, int misc) { | ||
282 | (void)cmd; | ||
283 | (void)arg; | ||
284 | (void)misc; | ||
285 | return 512; | ||
286 | } | ||
287 | |||
288 | struct swapent { | ||
289 | dev_t se_dev; /* device id */ | ||
290 | int se_flags; /* entry flags */ | ||
291 | int se_nblks; /* total blocks */ | ||
292 | int se_inuse; /* blocks in use */ | ||
293 | int se_priority; /* priority */ | ||
294 | char se_path[PATH_MAX]; /* path to entry */ | ||
295 | }; | ||
296 | |||
297 | #else | ||
298 | # define bsd_swapctl swapctl | ||
299 | #endif | ||
300 | |||
301 | swap_result getSwapFromSwapctl_BSD(swap_config config) { | ||
302 | /* get the number of active swap devices */ | ||
303 | int nswaps = bsd_swapctl(SWAP_NSWAP, NULL, 0); | ||
304 | |||
305 | /* initialize swap table + entries */ | ||
306 | struct swapent *ent = (struct swapent *)malloc(sizeof(struct swapent) * (unsigned long)nswaps); | ||
307 | |||
308 | /* and now, tally 'em up */ | ||
309 | int swapctl_res = bsd_swapctl(SWAP_STATS, ent, nswaps); | ||
310 | if (swapctl_res < 0) { | ||
311 | perror(_("swapctl failed: ")); | ||
312 | die(STATE_UNKNOWN, _("Error in swapctl call\n")); | ||
313 | } | ||
314 | |||
315 | double dsktotal_mb = 0.0; | ||
316 | double dskfree_mb = 0.0; | ||
317 | double dskused_mb = 0.0; | ||
318 | unsigned long long total_swap_mb = 0; | ||
319 | unsigned long long free_swap_mb = 0; | ||
320 | unsigned long long used_swap_mb = 0; | ||
321 | |||
322 | for (int i = 0; i < nswaps; i++) { | ||
323 | dsktotal_mb = (float)ent[i].se_nblks / (float)config.conversion_factor; | ||
324 | dskused_mb = (float)ent[i].se_inuse / (float)config.conversion_factor; | ||
325 | dskfree_mb = (dsktotal_mb - dskused_mb); | ||
326 | |||
327 | if (config.allswaps && dsktotal_mb > 0) { | ||
328 | double percent = 100 * (((double)dskused_mb) / ((double)dsktotal_mb)); | ||
329 | |||
330 | if (verbose) { | ||
331 | printf("[%.0f (%g%%)]", dskfree_mb, 100 - percent); | ||
332 | } | ||
333 | } | ||
334 | |||
335 | total_swap_mb += (unsigned long long)dsktotal_mb; | ||
336 | free_swap_mb += (unsigned long long)dskfree_mb; | ||
337 | used_swap_mb += (unsigned long long)dskused_mb; | ||
338 | } | ||
339 | |||
340 | /* and clean up after ourselves */ | ||
341 | free(ent); | ||
342 | |||
343 | swap_result result = {0}; | ||
344 | |||
345 | result.statusCode = OK; | ||
346 | result.errorcode = OK; | ||
347 | |||
348 | result.metrics.total = total_swap_mb * 1024 * 1024; | ||
349 | result.metrics.free = free_swap_mb * 1024 * 1024; | ||
350 | result.metrics.used = used_swap_mb * 1024 * 1024; | ||
351 | |||
352 | return result; | ||
353 | } | ||
354 | |||
355 | #ifndef CHECK_SWAP_SWAPCTL_SVR4 | ||
356 | int srv4_swapctl(int cmd, void *arg) { | ||
357 | (void)cmd; | ||
358 | (void)arg; | ||
359 | return 512; | ||
360 | } | ||
361 | |||
362 | typedef struct srv4_swapent { | ||
363 | char *ste_path; /* name of the swap file */ | ||
364 | off_t ste_start; /* starting block for swapping */ | ||
365 | off_t ste_length; /* length of swap area */ | ||
366 | long ste_pages; /* number of pages for swapping */ | ||
367 | long ste_free; /* number of ste_pages free */ | ||
368 | long ste_flags; /* ST_INDEL bit set if swap file */ | ||
369 | /* is now being deleted */ | ||
370 | } swapent_t; | ||
371 | |||
372 | typedef struct swaptbl { | ||
373 | int swt_n; /* number of swapents following */ | ||
374 | struct srv4_swapent swt_ent[]; /* array of swt_n swapents */ | ||
375 | } swaptbl_t; | ||
376 | |||
377 | # define SC_LIST 2 | ||
378 | # define SC_GETNSWP 3 | ||
379 | |||
380 | # ifndef MAXPATHLEN | ||
381 | # define MAXPATHLEN 2048 | ||
382 | # endif | ||
383 | |||
384 | #else | ||
385 | # define srv4_swapctl swapctl | ||
386 | #endif | ||
387 | |||
388 | swap_result getSwapFromSwap_SRV4(swap_config config) { | ||
389 | int nswaps = 0; | ||
390 | |||
391 | /* get the number of active swap devices */ | ||
392 | if ((nswaps = srv4_swapctl(SC_GETNSWP, NULL)) == -1) { | ||
393 | die(STATE_UNKNOWN, _("Error getting swap devices\n")); | ||
394 | } | ||
395 | |||
396 | if (nswaps == 0) { | ||
397 | die(STATE_OK, _("SWAP OK: No swap devices defined\n")); | ||
398 | } | ||
399 | |||
400 | if (verbose >= 3) { | ||
401 | printf("Found %d swap device(s)\n", nswaps); | ||
402 | } | ||
403 | |||
404 | /* initialize swap table + entries */ | ||
405 | swaptbl_t *tbl = (swaptbl_t *)malloc(sizeof(swaptbl_t) + (sizeof(swapent_t) * (unsigned long)nswaps)); | ||
406 | |||
407 | if (tbl == NULL) { | ||
408 | die(STATE_UNKNOWN, _("malloc() failed!\n")); | ||
409 | } | ||
410 | |||
411 | memset(tbl, 0, sizeof(swaptbl_t) + (sizeof(swapent_t) * (unsigned long)nswaps)); | ||
412 | tbl->swt_n = nswaps; | ||
413 | |||
414 | for (int i = 0; i < nswaps; i++) { | ||
415 | if ((tbl->swt_ent[i].ste_path = (char *)malloc(sizeof(char) * MAXPATHLEN)) == NULL) { | ||
416 | die(STATE_UNKNOWN, _("malloc() failed!\n")); | ||
417 | } | ||
418 | } | ||
419 | |||
420 | /* and now, tally 'em up */ | ||
421 | int swapctl_res = srv4_swapctl(SC_LIST, tbl); | ||
422 | if (swapctl_res < 0) { | ||
423 | perror(_("swapctl failed: ")); | ||
424 | die(STATE_UNKNOWN, _("Error in swapctl call\n")); | ||
425 | } | ||
426 | |||
427 | double dsktotal_mb = 0.0; | ||
428 | double dskfree_mb = 0.0; | ||
429 | double dskused_mb = 0.0; | ||
430 | unsigned long long total_swap_mb = 0; | ||
431 | unsigned long long free_swap_mb = 0; | ||
432 | unsigned long long used_swap_mb = 0; | ||
433 | |||
434 | for (int i = 0; i < nswaps; i++) { | ||
435 | dsktotal_mb = (float)tbl->swt_ent[i].ste_pages / SWAP_CONVERSION; | ||
436 | dskfree_mb = (float)tbl->swt_ent[i].ste_free / SWAP_CONVERSION; | ||
437 | dskused_mb = (dsktotal_mb - dskfree_mb); | ||
438 | |||
439 | if (verbose >= 3) { | ||
440 | printf("dsktotal_mb=%.0f dskfree_mb=%.0f dskused_mb=%.0f\n", dsktotal_mb, dskfree_mb, dskused_mb); | ||
441 | } | ||
442 | |||
443 | if (config.allswaps && dsktotal_mb > 0) { | ||
444 | double percent = 100 * (((double)dskused_mb) / ((double)dsktotal_mb)); | ||
445 | |||
446 | if (verbose) { | ||
447 | printf("[%.0f (%g%%)]", dskfree_mb, 100 - percent); | ||
448 | } | ||
449 | } | ||
450 | |||
451 | total_swap_mb += (unsigned long long)dsktotal_mb; | ||
452 | free_swap_mb += (unsigned long long)dskfree_mb; | ||
453 | used_swap_mb += (unsigned long long)dskused_mb; | ||
454 | } | ||
455 | |||
456 | /* and clean up after ourselves */ | ||
457 | for (int i = 0; i < nswaps; i++) { | ||
458 | free(tbl->swt_ent[i].ste_path); | ||
459 | } | ||
460 | free(tbl); | ||
461 | |||
462 | swap_result result = {0}; | ||
463 | result.errorcode = OK; | ||
464 | result.metrics.total = total_swap_mb * 1024 * 1024; | ||
465 | result.metrics.free = free_swap_mb * 1024 * 1024; | ||
466 | result.metrics.used = used_swap_mb * 1024 * 1024; | ||
467 | |||
468 | return result; | ||
469 | } | ||
diff --git a/plugins/t/check_swap.t b/plugins/t/check_swap.t index 18780386..eaa81083 100644 --- a/plugins/t/check_swap.t +++ b/plugins/t/check_swap.t | |||
@@ -8,9 +8,9 @@ use strict; | |||
8 | use Test::More tests => 14; | 8 | use Test::More tests => 14; |
9 | use NPTest; | 9 | use NPTest; |
10 | 10 | ||
11 | my $successOutput = '/^SWAP OK - [0-9]+\% free \([0-9]+MB out of [0-9]+MB\)/'; | 11 | my $successOutput = '/^SWAP OK - [0-9]+\% free \([0-9]+MiB out of [0-9]+MiB\)/'; |
12 | my $failureOutput = '/^SWAP CRITICAL - [0-9]+\% free \([0-9]+MB out of [0-9]+MB\)/'; | 12 | my $failureOutput = '/^SWAP CRITICAL - [0-9]+\% free \([0-9]+MiB out of [0-9]+MiB\)/'; |
13 | my $warnOutput = '/^SWAP WARNING - [0-9]+\% free \([0-9]+MB out of [0-9]+MB\)/'; | 13 | my $warnOutput = '/^SWAP WARNING - [0-9]+\% free \([0-9]+MiB out of [0-9]+MiB\)/'; |
14 | 14 | ||
15 | my $result; | 15 | my $result; |
16 | 16 | ||
diff --git a/plugins/tests/test_check_swap.c b/plugins/tests/test_check_swap.c new file mode 100644 index 00000000..b85fb4ad --- /dev/null +++ b/plugins/tests/test_check_swap.c | |||
@@ -0,0 +1,23 @@ | |||
1 | |||
2 | #include "../check_swap.d/check_swap.h" | ||
3 | #include "../../tap/tap.h" | ||
4 | |||
5 | int verbose = 0; | ||
6 | |||
7 | void print_usage(void) {} | ||
8 | void print_help(swap_config config) { | ||
9 | (void) config; | ||
10 | } | ||
11 | |||
12 | const char *progname = "test_check_swap"; | ||
13 | |||
14 | int main(void) { | ||
15 | swap_result test_data = getSwapFromProcMeminfo("./var/proc_meminfo"); | ||
16 | |||
17 | plan_tests(4); | ||
18 | |||
19 | ok(test_data.errorcode == 0, "Test whether we manage to retrieve swap data"); | ||
20 | ok(test_data.metrics.total == 34233905152, "Is the total Swap correct"); | ||
21 | ok(test_data.metrics.free == 34233905152, "Is the free Swap correct"); | ||
22 | ok(test_data.metrics.used == 0, "Is the used Swap correct"); | ||
23 | } | ||
diff --git a/plugins/tests/test_check_swap.t b/plugins/tests/test_check_swap.t new file mode 100755 index 00000000..826fae01 --- /dev/null +++ b/plugins/tests/test_check_swap.t | |||
@@ -0,0 +1,6 @@ | |||
1 | #!/usr/bin/perl | ||
2 | use Test::More; | ||
3 | if (! -e "./test_check_swap") { | ||
4 | plan skip_all => "./test_check_swap not compiled - please enable libtap library to test"; | ||
5 | } | ||
6 | exec "./test_check_swap"; | ||
diff --git a/plugins/tests/var/proc_meminfo b/plugins/tests/var/proc_meminfo new file mode 100644 index 00000000..6c5a618d --- /dev/null +++ b/plugins/tests/var/proc_meminfo | |||
@@ -0,0 +1,55 @@ | |||
1 | MemTotal: 32767776 kB | ||
2 | MemFree: 1693508 kB | ||
3 | MemAvailable: 23807480 kB | ||
4 | Buffers: 438456 kB | ||
5 | Cached: 19124976 kB | ||
6 | SwapCached: 0 kB | ||
7 | Active: 7860680 kB | ||
8 | Inactive: 18886776 kB | ||
9 | Active(anon): 6108756 kB | ||
10 | Inactive(anon): 1364500 kB | ||
11 | Active(file): 1751924 kB | ||
12 | Inactive(file): 17522276 kB | ||
13 | Unevictable: 8548 kB | ||
14 | Mlocked: 8548 kB | ||
15 | SwapTotal: 33431548 kB | ||
16 | SwapFree: 33431548 kB | ||
17 | Zswap: 0 kB | ||
18 | Zswapped: 0 kB | ||
19 | Dirty: 784 kB | ||
20 | Writeback: 0 kB | ||
21 | AnonPages: 7139968 kB | ||
22 | Mapped: 1094916 kB | ||
23 | Shmem: 284160 kB | ||
24 | KReclaimable: 3303788 kB | ||
25 | Slab: 3801908 kB | ||
26 | SReclaimable: 3303788 kB | ||
27 | SUnreclaim: 498120 kB | ||
28 | KernelStack: 32992 kB | ||
29 | PageTables: 68160 kB | ||
30 | SecPageTables: 0 kB | ||
31 | NFS_Unstable: 0 kB | ||
32 | Bounce: 0 kB | ||
33 | WritebackTmp: 0 kB | ||
34 | CommitLimit: 49815436 kB | ||
35 | Committed_AS: 16888536 kB | ||
36 | VmallocTotal: 34359738367 kB | ||
37 | VmallocUsed: 91200 kB | ||
38 | VmallocChunk: 0 kB | ||
39 | Percpu: 41472 kB | ||
40 | HardwareCorrupted: 0 kB | ||
41 | AnonHugePages: 1708032 kB | ||
42 | ShmemHugePages: 0 kB | ||
43 | ShmemPmdMapped: 0 kB | ||
44 | FileHugePages: 0 kB | ||
45 | FilePmdMapped: 0 kB | ||
46 | Unaccepted: 0 kB | ||
47 | HugePages_Total: 0 | ||
48 | HugePages_Free: 0 | ||
49 | HugePages_Rsvd: 0 | ||
50 | HugePages_Surp: 0 | ||
51 | Hugepagesize: 2048 kB | ||
52 | Hugetlb: 0 kB | ||
53 | DirectMap4k: 860468 kB | ||
54 | DirectMap2M: 20023296 kB | ||
55 | DirectMap1G: 12582912 kB | ||