Merge branch 'collectd-5.7'
[collectd.git] / src / drbd.c
1 /**
2  * collectd - src/drbd.c
3  * Copyright (C) 2014  Tim Laszlo
4  *
5  * Permission is hereby granted, free of charge, to any person obtaining a
6  * copy of this software and associated documentation files (the "Software"),
7  * to deal in the Software without restriction, including without limitation
8  * the rights to use, copy, modify, merge, publish, distribute, sublicense,
9  * and/or sell copies of the Software, and to permit persons to whom the
10  * Software is furnished to do so, subject to the following conditions:
11  *
12  * The above copyright notice and this permission notice shall be included in
13  * all copies or substantial portions of the Software.
14  *
15  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
16  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
17  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
18  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
19  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
20  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
21  * DEALINGS IN THE SOFTWARE.
22  *
23  * Authors:
24  *   Tim Laszlo <tim.laszlo at gmail.com>
25  **/
26
27 /*
28  See: http://www.drbd.org/users-guide/ch-admin.html#s-performance-indicators
29
30  version: 8.3.11 (api:88/proto:86-96)
31  srcversion: 71955441799F513ACA6DA60
32   0: cs:Connected ro:Primary/Secondary ds:UpToDate/UpToDate B r-----
33          ns:64363752 nr:0 dw:357799284 dr:846902273 al:34987022 bm:18062 lo:0 \
34                                                 pe:0 ua:0 ap:0 ep:1 wo:f oos:0
35  */
36
37 #include "collectd.h"
38
39 #include "common.h"
40 #include "plugin.h"
41
42 static const char *drbd_stats = "/proc/drbd";
43 static const char *drbd_names[] = {
44     "network_send",   /* ns (network send) */
45     "network_recv",   /* nr (network receive) */
46     "disk_write",     /* dw (disk write) */
47     "disk_read",      /* dr (disk read) */
48     "activity_log",   /* al (activity log) */
49     "bitmap",         /* bm (bit map) */
50     "local_count",    /* lo (local count) */
51     "pending",        /* pe (pending) */
52     "unacknowledged", /* ua (unacknowledged) */
53     "app pending",    /* ap (application pending) */
54     "epochs",         /* ep (epochs) */
55     NULL,             /* wo (write order) */
56     "oos"             /* oos (out of sync) */
57 };
58 static size_t drbd_names_num = STATIC_ARRAY_SIZE(drbd_names);
59
60 static int drbd_init(void) { return 0; }
61
62 static int drbd_submit_fields(long int resource, char **fields,
63                               size_t fields_num) {
64   char plugin_instance[DATA_MAX_NAME_LEN];
65   value_t values[fields_num];
66   value_list_t vl = VALUE_LIST_INIT;
67
68   if (resource < 0) {
69     WARNING("drbd plugin: Unable to parse resource");
70     return EINVAL;
71   }
72
73   if (fields_num != drbd_names_num) {
74     WARNING("drbd plugin: Wrong number of fields for "
75             "r%ld statistics. Expected %zu, got %zu.",
76             resource, drbd_names_num, fields_num);
77     return EINVAL;
78   }
79
80   snprintf(plugin_instance, sizeof(plugin_instance), "r%ld", resource);
81
82   for (size_t i = 0; i < drbd_names_num; i++) {
83     char *data;
84     /* skip non numeric wo */
85     if (strncmp(fields[i], "wo", 2) == 0)
86       continue;
87     data = strchr(fields[i], ':');
88     if (data == NULL)
89       return EINVAL;
90     (void)parse_value(++data, &values[i], DS_TYPE_DERIVE);
91   }
92
93   vl.values_len = 1;
94   sstrncpy(vl.plugin, "drbd", sizeof(vl.plugin));
95   sstrncpy(vl.plugin_instance, plugin_instance, sizeof(vl.plugin_instance));
96   sstrncpy(vl.type, "drbd_resource", sizeof(vl.type));
97
98   for (size_t i = 0; i < fields_num; i++) {
99     if (drbd_names[i] == NULL)
100       continue;
101     vl.values = values + i;
102     sstrncpy(vl.type_instance, drbd_names[i], sizeof(vl.type_instance));
103     plugin_dispatch_values(&vl);
104   }
105
106   return 0;
107 } /* drbd_submit_fields */
108
109 static int drbd_read(void) {
110   FILE *fh;
111   char buffer[256];
112
113   long int resource = -1;
114   char *fields[16];
115   int fields_num = 0;
116
117   fh = fopen(drbd_stats, "r");
118   if (fh == NULL) {
119     WARNING("drbd plugin: Unable to open %s", drbd_stats);
120     return EINVAL;
121   }
122
123   while (fgets(buffer, sizeof(buffer), fh) != NULL) {
124     fields_num = strsplit(buffer, fields, STATIC_ARRAY_SIZE(fields));
125
126     /* ignore headers (first two iterations) */
127     if ((strcmp(fields[0], "version:") == 0) ||
128         (strcmp(fields[0], "srcversion:") == 0) ||
129         (strcmp(fields[0], "GIT-hash:") == 0)) {
130       continue;
131     }
132
133     if (isdigit(fields[0][0])) {
134       /* parse the resource line, next loop iteration
135          will submit values for this resource */
136       resource = strtol(fields[0], NULL, 10);
137     } else {
138       /* handle stats data for the resource defined in the
139          previous iteration */
140       drbd_submit_fields(resource, fields, fields_num);
141     }
142   } /* while (fgets) */
143
144   fclose(fh);
145   return 0;
146 } /* void drbd_read */
147
148 void module_register(void) {
149   plugin_register_init("drbd", drbd_init);
150   plugin_register_read("drbd", drbd_read);
151 } /* void module_register */