2 * collectd - src/qmail.c
3 * Copyright (C) 2008 Alessandro Iurlano
5 * This program is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License as published by the
7 * Free Software Foundation; only version 2 of the License is applicable.
9 * This program is distributed in the hope that it will be useful, but
10 * WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * General Public License for more details.
14 * You should have received a copy of the GNU General Public License along
15 * with this program; if not, write to the Free Software Foundation, Inc.,
16 * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
19 * Alessandro Iurlano <alessandro.iurlano at gmail.com>
26 #include <sys/types.h>
31 #define DEFAULT_BASE_DIR "/var/qmail"
33 static char *qmail_base_dir;
35 static const char *config_keys[] =
39 static int config_keys_num = STATIC_ARRAY_SIZE (config_keys);
41 static void qmail_submit (const char *plugin_instance, gauge_t value)
44 value_list_t vl = VALUE_LIST_INIT;
46 values[0].gauge = value;
49 vl.values_len = STATIC_ARRAY_SIZE (values);
50 vl.time = time (NULL);
51 sstrncpy (vl.host, hostname_g, sizeof (vl.host));
52 sstrncpy (vl.type, "gauge", sizeof (vl.type));
53 sstrncpy (vl.plugin, "qmail", sizeof (vl.plugin));
54 sstrncpy (vl.plugin_instance, plugin_instance, sizeof (vl.plugin_instance));
56 plugin_dispatch_values (&vl);
57 } /* void qmail_submit */
59 static int count_files_in_subtree (const char *path, int depth)
62 # define DIRENT_BUFFER_SIZE (sizeof (struct dirent) + 1024 + 1)
64 # define DIRENT_BUFFER_SIZE (sizeof (struct dirent) + NAME_MAX + 1)
69 char dirent_buffer[DIRENT_BUFFER_SIZE];
81 ERROR ("qmail plugin: opendir (%s) failed.", path);
91 char abs_path[PATH_MAX];
95 status = readdir_r (dh, (struct dirent *) dirent_buffer, &de);
99 ERROR ("qmail plugin: readdir_r failed: %s",
100 sstrerror (errno, errbuf, sizeof (errbuf)));
106 /* end of directory */
110 if (de->d_name[0] == '.')
113 ssnprintf (abs_path, sizeof (abs_path), "%s/%s", path, de->d_name);
115 status = lstat (abs_path, &statbuf);
118 ERROR ("qmail plugin: stat (%s) failed.", abs_path);
122 if (S_ISREG (statbuf.st_mode))
126 else if (S_ISDIR (statbuf.st_mode))
130 temp = (char **) realloc (subdirs, sizeof (char *) * (subdirs_num + 1));
133 ERROR ("qmail plugin: realloc failed.");
138 subdirs[subdirs_num] = strdup (abs_path);
139 if (subdirs[subdirs_num] == NULL)
141 ERROR ("qmail plugin: strdup failed.");
153 for (i = 0; i < subdirs_num; i++)
155 status = count_files_in_subtree (subdirs[i], depth - 1);
161 for (i = 0; i < subdirs_num; i++)
168 } /* int count_files_in_subtree */
170 static int read_queue_length (const char *queue_name, const char *path)
174 num_files = count_files_in_subtree (path, /* depth = */ 1);
177 ERROR ("qmail plugin: Counting files in `%s' failed.", path);
181 qmail_submit (queue_name, (gauge_t) num_files);
183 } /* int read_queue_length */
185 static int queue_len_read (void)
193 ssnprintf (path, sizeof (path), "%s/queue/mess",
194 (qmail_base_dir != NULL)
198 status = read_queue_length ("messages", path);
202 ssnprintf (path, sizeof (path), "%s/queue/todo",
203 (qmail_base_dir != NULL)
207 status = read_queue_length ("todo", path);
214 } /* int queue_len_read */
216 static int qmail_config (const char *key, const char *val)
218 if (strcasecmp ("QmailDir", key) == 0)
220 size_t qmail_base_dir_len;
222 sfree (qmail_base_dir);
223 qmail_base_dir = strdup(val);
224 if (qmail_base_dir == NULL)
226 ERROR ("qmail plugin: strdup failed.");
230 qmail_base_dir_len = strlen (qmail_base_dir);
231 while ((qmail_base_dir_len > 0)
232 && (qmail_base_dir[qmail_base_dir_len - 1] == '/'))
234 qmail_base_dir[qmail_base_dir_len - 1] = 0;
235 qmail_base_dir_len--;
238 if (qmail_base_dir_len == 0)
240 ERROR ("qmail plugin: QmailDir is invalid.");
241 sfree (qmail_base_dir);
242 qmail_base_dir = NULL;
252 } /* int qmail_config */
254 void module_register (void)
256 plugin_register_config ("qmail", qmail_config,
257 config_keys, config_keys_num);
258 plugin_register_read ("qmail", queue_len_read);
259 } /* void module_register */
262 * vim: set sw=2 sts=2 et :