2 * collectd - src/utils_db_query.c
3 * Copyright (C) 2008,2009 Florian octo Forster
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 * Florian octo Forster <octo at verplant.org>
25 #include "configfile.h"
26 #include "utils_db_query.h"
31 struct udb_result_s; /* {{{ */
32 typedef struct udb_result_s udb_result_t;
36 char *instance_prefix;
47 struct udb_query_s /* {{{ */
53 unsigned int min_version;
54 unsigned int max_version;
56 udb_result_t *results;
59 struct udb_result_preparation_area_s /* {{{ */
62 size_t *instances_pos;
65 char **instances_buffer;
67 char **metadata_buffer;
69 struct udb_result_preparation_area_s *next;
71 typedef struct udb_result_preparation_area_s udb_result_preparation_area_t;
73 struct udb_query_preparation_area_s /* {{{ */
82 udb_result_preparation_area_t *result_prep_areas;
86 * Config Private functions
88 static int udb_config_set_string (char **ret_string, /* {{{ */
93 if ((ci->values_num != 1)
94 || (ci->values[0].type != OCONFIG_TYPE_STRING))
96 WARNING ("db query utils: The `%s' config option "
97 "needs exactly one string argument.", ci->key);
101 string = strdup (ci->values[0].value.string);
104 ERROR ("db query utils: strdup failed.");
108 if (*ret_string != NULL)
110 *ret_string = string;
113 } /* }}} int udb_config_set_string */
115 static int udb_config_add_string (char ***ret_array, /* {{{ */
116 size_t *ret_array_len, oconfig_item_t *ci)
122 if (ci->values_num < 1)
124 WARNING ("db query utils: The `%s' config option "
125 "needs at least one argument.", ci->key);
129 for (i = 0; i < ci->values_num; i++)
131 if (ci->values[i].type != OCONFIG_TYPE_STRING)
133 WARNING ("db query utils: Argument %i to the `%s' option "
134 "is not a string.", i + 1, ci->key);
139 array_len = *ret_array_len;
140 array = (char **) realloc (*ret_array,
141 sizeof (char *) * (array_len + ci->values_num));
144 ERROR ("db query utils: realloc failed.");
149 for (i = 0; i < ci->values_num; i++)
151 array[array_len] = strdup (ci->values[i].value.string);
152 if (array[array_len] == NULL)
154 ERROR ("db query utils: strdup failed.");
155 *ret_array_len = array_len;
161 *ret_array_len = array_len;
163 } /* }}} int udb_config_add_string */
165 static int udb_config_set_uint (unsigned int *ret_value, /* {{{ */
170 if ((ci->values_num != 1)
171 || (ci->values[0].type != OCONFIG_TYPE_NUMBER))
173 WARNING ("db query utils: The `%s' config option "
174 "needs exactly one numeric argument.", ci->key);
178 tmp = ci->values[0].value.number;
179 if ((tmp < 0.0) || (tmp > ((double) UINT_MAX)))
182 *ret_value = (unsigned int) (tmp + .5);
184 } /* }}} int udb_config_set_uint */
187 * Result private functions
189 static int udb_result_submit (udb_result_t *r, /* {{{ */
190 udb_result_preparation_area_t *r_area,
191 udb_query_t const *q, udb_query_preparation_area_t *q_area)
193 value_list_t vl = VALUE_LIST_INIT;
198 assert (r_area->ds != NULL);
199 assert (((size_t) r_area->ds->ds_num) == r->values_num);
201 vl.values = (value_t *) calloc (r_area->ds->ds_num, sizeof (value_t));
202 if (vl.values == NULL)
204 ERROR ("db query utils: malloc failed.");
207 vl.values_len = r_area->ds->ds_num;
209 for (i = 0; i < r->values_num; i++)
211 char *value_str = r_area->values_buffer[i];
213 if (0 != parse_value (value_str, &vl.values[i], r_area->ds->ds[i].type))
215 ERROR ("db query utils: udb_result_submit: Parsing `%s' as %s failed.",
216 value_str, DS_TYPE_TO_STRING (r_area->ds->ds[i].type));
222 if (q_area->interval > 0)
223 vl.interval = q_area->interval;
225 sstrncpy (vl.host, q_area->host, sizeof (vl.host));
226 sstrncpy (vl.plugin, q_area->plugin, sizeof (vl.plugin));
227 sstrncpy (vl.plugin_instance, q_area->db_name, sizeof (vl.plugin_instance));
228 sstrncpy (vl.type, r->type, sizeof (vl.type));
230 /* Set vl.type_instance {{{ */
231 if (r->instances_num <= 0)
233 if (r->instance_prefix == NULL)
234 vl.type_instance[0] = 0;
236 sstrncpy (vl.type_instance, r->instance_prefix,
237 sizeof (vl.type_instance));
239 else /* if ((r->instances_num > 0) */
241 if (r->instance_prefix == NULL)
243 strjoin (vl.type_instance, sizeof (vl.type_instance),
244 r_area->instances_buffer, r->instances_num, "-");
248 char tmp[DATA_MAX_NAME_LEN];
250 strjoin (tmp, sizeof (tmp), r_area->instances_buffer,
251 r->instances_num, "-");
252 tmp[sizeof (tmp) - 1] = 0;
254 snprintf (vl.type_instance, sizeof (vl.type_instance), "%s-%s",
255 r->instance_prefix, tmp);
258 vl.type_instance[sizeof (vl.type_instance) - 1] = 0;
261 /* Annotate meta data. {{{ */
262 if (r->metadata_num > 0)
264 vl.meta = meta_data_create ();
267 ERROR ("db query utils:: meta_data_create failed.");
271 for (i = 0; i < r->metadata_num; i++)
273 status = meta_data_add_string (vl.meta, r->metadata[i],
274 r_area->metadata_buffer[i]);
277 ERROR ("db query utils:: meta_data_add_string failed.");
278 meta_data_destroy (vl.meta);
286 plugin_dispatch_values (&vl);
288 if (r->metadata_num > 0)
290 meta_data_destroy (vl.meta);
295 } /* }}} void udb_result_submit */
297 static void udb_result_finish_result (udb_result_t const *r, /* {{{ */
298 udb_result_preparation_area_t *prep_area)
300 if ((r == NULL) || (prep_area == NULL))
303 prep_area->ds = NULL;
304 sfree (prep_area->instances_pos);
305 sfree (prep_area->values_pos);
306 sfree (prep_area->metadata_pos);
307 sfree (prep_area->instances_buffer);
308 sfree (prep_area->values_buffer);
309 sfree (prep_area->metadata_buffer);
310 } /* }}} void udb_result_finish_result */
312 static int udb_result_handle_result (udb_result_t *r, /* {{{ */
313 udb_query_preparation_area_t *q_area,
314 udb_result_preparation_area_t *r_area,
315 udb_query_t const *q, char **column_values)
319 assert (r && q_area && r_area);
321 for (i = 0; i < r->instances_num; i++)
322 r_area->instances_buffer[i] = column_values[r_area->instances_pos[i]];
324 for (i = 0; i < r->values_num; i++)
325 r_area->values_buffer[i] = column_values[r_area->values_pos[i]];
327 for (i = 0; i < r->metadata_num; i++)
328 r_area->metadata_buffer[i] = column_values[r_area->metadata_pos[i]];
330 return udb_result_submit (r, r_area, q, q_area);
331 } /* }}} int udb_result_handle_result */
333 static int udb_result_prepare_result (udb_result_t const *r, /* {{{ */
334 udb_result_preparation_area_t *prep_area,
335 char **column_names, size_t column_num)
339 if ((r == NULL) || (prep_area == NULL))
342 #define BAIL_OUT(status) \
343 prep_area->ds = NULL; \
344 sfree (prep_area->instances_pos); \
345 sfree (prep_area->values_pos); \
346 sfree (prep_area->metadata_pos); \
347 sfree (prep_area->instances_buffer); \
348 sfree (prep_area->values_buffer); \
349 sfree (prep_area->metadata_buffer); \
352 /* Make sure previous preparations are cleaned up. */
353 udb_result_finish_result (r, prep_area);
354 prep_area->instances_pos = NULL;
355 prep_area->values_pos = NULL;
356 prep_area->metadata_pos = NULL;
358 /* Read `ds' and check number of values {{{ */
359 prep_area->ds = plugin_get_ds (r->type);
360 if (prep_area->ds == NULL)
362 ERROR ("db query utils: udb_result_prepare_result: Type `%s' is not "
363 "known by the daemon. See types.db(5) for details.",
368 if (((size_t) prep_area->ds->ds_num) != r->values_num)
370 ERROR ("db query utils: udb_result_prepare_result: The type `%s' "
371 "requires exactly %i value%s, but the configuration specifies %zu.",
373 prep_area->ds->ds_num, (prep_area->ds->ds_num == 1) ? "" : "s",
379 /* Allocate r->instances_pos, r->values_pos, r->metadata_post,
380 * r->instances_buffer, r->values_buffer, and r->metadata_buffer {{{ */
381 if (r->instances_num > 0)
383 prep_area->instances_pos
384 = (size_t *) calloc (r->instances_num, sizeof (size_t));
385 if (prep_area->instances_pos == NULL)
387 ERROR ("db query utils: udb_result_prepare_result: malloc failed.");
391 prep_area->instances_buffer
392 = (char **) calloc (r->instances_num, sizeof (char *));
393 if (prep_area->instances_buffer == NULL)
395 ERROR ("db query utils: udb_result_prepare_result: malloc failed.");
398 } /* if (r->instances_num > 0) */
400 prep_area->values_pos
401 = (size_t *) calloc (r->values_num, sizeof (size_t));
402 if (prep_area->values_pos == NULL)
404 ERROR ("db query utils: udb_result_prepare_result: malloc failed.");
408 prep_area->values_buffer
409 = (char **) calloc (r->values_num, sizeof (char *));
410 if (prep_area->values_buffer == NULL)
412 ERROR ("db query utils: udb_result_prepare_result: malloc failed.");
416 prep_area->metadata_pos
417 = (size_t *) calloc (r->metadata_num, sizeof (size_t));
418 if (prep_area->metadata_pos == NULL)
420 ERROR ("db query utils: udb_result_prepare_result: malloc failed.");
424 prep_area->metadata_buffer
425 = (char **) calloc (r->metadata_num, sizeof (char *));
426 if (prep_area->metadata_buffer == NULL)
428 ERROR ("db query utils: udb_result_prepare_result: malloc failed.");
434 /* Determine the position of the instance columns {{{ */
435 for (i = 0; i < r->instances_num; i++)
439 for (j = 0; j < column_num; j++)
441 if (strcasecmp (r->instances[i], column_names[j]) == 0)
443 prep_area->instances_pos[i] = j;
450 ERROR ("db query utils: udb_result_prepare_result: "
451 "Column `%s' could not be found.",
455 } /* }}} for (i = 0; i < r->instances_num; i++) */
457 /* Determine the position of the value columns {{{ */
458 for (i = 0; i < r->values_num; i++)
462 for (j = 0; j < column_num; j++)
464 if (strcasecmp (r->values[i], column_names[j]) == 0)
466 prep_area->values_pos[i] = j;
473 ERROR ("db query utils: udb_result_prepare_result: "
474 "Column `%s' could not be found.",
478 } /* }}} for (i = 0; i < r->values_num; i++) */
480 /* Determine the position of the metadata columns {{{ */
481 for (i = 0; i < r->metadata_num; i++)
485 for (j = 0; j < column_num; j++)
487 if (strcasecmp (r->metadata[i], column_names[j]) == 0)
489 prep_area->metadata_pos[i] = j;
496 ERROR ("db query utils: udb_result_prepare_result: "
497 "Metadata column `%s' could not be found.",
501 } /* }}} for (i = 0; i < r->metadata_num; i++) */
505 } /* }}} int udb_result_prepare_result */
507 static void udb_result_free (udb_result_t *r) /* {{{ */
516 for (i = 0; i < r->instances_num; i++)
517 sfree (r->instances[i]);
518 sfree (r->instances);
520 for (i = 0; i < r->values_num; i++)
521 sfree (r->values[i]);
524 for (i = 0; i < r->metadata_num; i++)
525 sfree (r->metadata[i]);
528 udb_result_free (r->next);
531 } /* }}} void udb_result_free */
533 static int udb_result_create (const char *query_name, /* {{{ */
534 udb_result_t **r_head, oconfig_item_t *ci)
540 if (ci->values_num != 0)
542 WARNING ("db query utils: The `Result' block doesn't accept "
543 "any arguments. Ignoring %i argument%s.",
544 ci->values_num, (ci->values_num == 1) ? "" : "s");
547 r = (udb_result_t *) malloc (sizeof (*r));
550 ERROR ("db query utils: malloc failed.");
553 memset (r, 0, sizeof (*r));
555 r->instance_prefix = NULL;
561 /* Fill the `udb_result_t' structure.. */
563 for (i = 0; i < ci->children_num; i++)
565 oconfig_item_t *child = ci->children + i;
567 if (strcasecmp ("Type", child->key) == 0)
568 status = udb_config_set_string (&r->type, child);
569 else if (strcasecmp ("InstancePrefix", child->key) == 0)
570 status = udb_config_set_string (&r->instance_prefix, child);
571 else if (strcasecmp ("InstancesFrom", child->key) == 0)
572 status = udb_config_add_string (&r->instances, &r->instances_num, child);
573 else if (strcasecmp ("ValuesFrom", child->key) == 0)
574 status = udb_config_add_string (&r->values, &r->values_num, child);
575 else if (strcasecmp ("MetadataFrom", child->key) == 0)
576 status = udb_config_add_string (&r->metadata, &r->metadata_num, child);
579 WARNING ("db query utils: Query `%s': Option `%s' not allowed here.",
580 query_name, child->key);
588 /* Check that all necessary options have been given. */
593 WARNING ("db query utils: `Type' not given for "
594 "result in query `%s'", query_name);
597 if (r->values == NULL)
599 WARNING ("db query utils: `ValuesFrom' not given for "
600 "result in query `%s'", query_name);
605 } /* while (status == 0) */
613 /* If all went well, add this result to the list of results. */
623 while (last->next != NULL)
630 } /* }}} int udb_result_create */
633 * Query private functions
635 void udb_query_free_one (udb_query_t *q) /* {{{ */
641 sfree (q->statement);
643 udb_result_free (q->results);
646 } /* }}} void udb_query_free_one */
649 * Query public functions
651 int udb_query_create (udb_query_t ***ret_query_list, /* {{{ */
652 size_t *ret_query_list_len, oconfig_item_t *ci,
653 udb_query_create_callback_t cb)
655 udb_query_t **query_list;
656 size_t query_list_len;
662 if ((ret_query_list == NULL) || (ret_query_list_len == NULL))
664 query_list = *ret_query_list;
665 query_list_len = *ret_query_list_len;
667 if ((ci->values_num != 1)
668 || (ci->values[0].type != OCONFIG_TYPE_STRING))
670 WARNING ("db query utils: The `Query' block "
671 "needs exactly one string argument.");
675 q = (udb_query_t *) malloc (sizeof (*q));
678 ERROR ("db query utils: malloc failed.");
681 memset (q, 0, sizeof (*q));
683 q->max_version = UINT_MAX;
685 status = udb_config_set_string (&q->name, ci);
692 /* Fill the `udb_query_t' structure.. */
693 for (i = 0; i < ci->children_num; i++)
695 oconfig_item_t *child = ci->children + i;
697 if (strcasecmp ("Statement", child->key) == 0)
698 status = udb_config_set_string (&q->statement, child);
699 else if (strcasecmp ("Result", child->key) == 0)
700 status = udb_result_create (q->name, &q->results, child);
701 else if (strcasecmp ("MinVersion", child->key) == 0)
702 status = udb_config_set_uint (&q->min_version, child);
703 else if (strcasecmp ("MaxVersion", child->key) == 0)
704 status = udb_config_set_uint (&q->max_version, child);
706 /* Call custom callbacks */
709 status = (*cb) (q, child);
712 WARNING ("db query utils: The configuration callback failed "
713 "to handle `%s'.", child->key);
718 WARNING ("db query utils: Query `%s': Option `%s' not allowed here.",
719 q->name, child->key);
727 /* Check that all necessary options have been given. */
730 if (q->statement == NULL)
732 WARNING ("db query utils: Query `%s': No `Statement' given.", q->name);
735 if (q->results == NULL)
737 WARNING ("db query utils: Query `%s': No (valid) `Result' block given.",
741 } /* if (status == 0) */
743 /* If all went well, add this query to the list of queries within the
744 * database structure. */
749 temp = (udb_query_t **) realloc (query_list,
750 sizeof (*query_list) * (query_list_len + 1));
753 ERROR ("db query utils: realloc failed");
759 query_list[query_list_len] = q;
766 udb_query_free_one (q);
770 *ret_query_list = query_list;
771 *ret_query_list_len = query_list_len;
774 } /* }}} int udb_query_create */
776 void udb_query_free (udb_query_t **query_list, size_t query_list_len) /* {{{ */
780 if (query_list == NULL)
783 for (i = 0; i < query_list_len; i++)
784 udb_query_free_one (query_list[i]);
787 } /* }}} void udb_query_free */
789 int udb_query_pick_from_list_by_name (const char *name, /* {{{ */
790 udb_query_t **src_list, size_t src_list_len,
791 udb_query_t ***dst_list, size_t *dst_list_len)
796 if ((name == NULL) || (src_list == NULL) || (dst_list == NULL)
797 || (dst_list_len == NULL))
799 ERROR ("db query utils: udb_query_pick_from_list_by_name: "
800 "Invalid argument.");
805 for (i = 0; i < src_list_len; i++)
807 udb_query_t **tmp_list;
810 if (strcasecmp (name, src_list[i]->name) != 0)
813 tmp_list_len = *dst_list_len;
814 tmp_list = (udb_query_t **) realloc (*dst_list, (tmp_list_len + 1)
815 * sizeof (udb_query_t *));
816 if (tmp_list == NULL)
818 ERROR ("db query utils: realloc failed.");
822 tmp_list[tmp_list_len] = src_list[i];
825 *dst_list = tmp_list;
826 *dst_list_len = tmp_list_len;
829 } /* for (i = 0; i < src_list_len; i++) */
833 ERROR ("db query utils: Cannot find query `%s'. Make sure the <Query> "
834 "block is above the database definition!",
840 DEBUG ("db query utils: Added %i versions of query `%s'.",
845 } /* }}} int udb_query_pick_from_list_by_name */
847 int udb_query_pick_from_list (oconfig_item_t *ci, /* {{{ */
848 udb_query_t **src_list, size_t src_list_len,
849 udb_query_t ***dst_list, size_t *dst_list_len)
853 if ((ci == NULL) || (src_list == NULL) || (dst_list == NULL)
854 || (dst_list_len == NULL))
856 ERROR ("db query utils: udb_query_pick_from_list: "
857 "Invalid argument.");
861 if ((ci->values_num != 1)
862 || (ci->values[0].type != OCONFIG_TYPE_STRING))
864 ERROR ("db query utils: The `%s' config option "
865 "needs exactly one string argument.", ci->key);
868 name = ci->values[0].value.string;
870 return (udb_query_pick_from_list_by_name (name,
871 src_list, src_list_len,
872 dst_list, dst_list_len));
873 } /* }}} int udb_query_pick_from_list */
875 const char *udb_query_get_name (udb_query_t *q) /* {{{ */
881 } /* }}} const char *udb_query_get_name */
883 const char *udb_query_get_statement (udb_query_t *q) /* {{{ */
888 return (q->statement);
889 } /* }}} const char *udb_query_get_statement */
891 void udb_query_set_user_data (udb_query_t *q, void *user_data) /* {{{ */
896 q->user_data = user_data;
897 } /* }}} void udb_query_set_user_data */
899 void *udb_query_get_user_data (udb_query_t *q) /* {{{ */
904 return (q->user_data);
905 } /* }}} void *udb_query_get_user_data */
907 int udb_query_check_version (udb_query_t *q, unsigned int version) /* {{{ */
912 if ((version < q->min_version) || (version > q->max_version))
916 } /* }}} int udb_query_check_version */
918 void udb_query_finish_result (udb_query_t const *q, /* {{{ */
919 udb_query_preparation_area_t *prep_area)
921 udb_result_preparation_area_t *r_area;
924 if ((q == NULL) || (prep_area == NULL))
927 prep_area->column_num = 0;
928 sfree (prep_area->host);
929 sfree (prep_area->plugin);
930 sfree (prep_area->db_name);
932 prep_area->interval = 0;
934 for (r = q->results, r_area = prep_area->result_prep_areas;
935 r != NULL; r = r->next, r_area = r_area->next)
937 /* this may happen during error conditions of the caller */
940 udb_result_finish_result (r, r_area);
942 } /* }}} void udb_query_finish_result */
944 int udb_query_handle_result (udb_query_t const *q, /* {{{ */
945 udb_query_preparation_area_t *prep_area, char **column_values)
947 udb_result_preparation_area_t *r_area;
952 if ((q == NULL) || (prep_area == NULL))
955 if ((prep_area->column_num < 1) || (prep_area->host == NULL)
956 || (prep_area->plugin == NULL) || (prep_area->db_name == NULL))
958 ERROR ("db query utils: Query `%s': Query is not prepared; "
959 "can't handle result.", q->name);
963 #if defined(COLLECT_DEBUG) && COLLECT_DEBUG /* {{{ */
968 for (i = 0; i < prep_area->column_num; i++)
970 DEBUG ("db query utils: udb_query_handle_result (%s, %s): "
972 prep_area->db_name, q->name, i, column_values[i]);
978 for (r = q->results, r_area = prep_area->result_prep_areas;
979 r != NULL; r = r->next, r_area = r_area->next)
981 status = udb_result_handle_result (r, prep_area, r_area,
989 ERROR ("db query utils: udb_query_handle_result (%s, %s): "
990 "All results failed.", prep_area->db_name, q->name);
995 } /* }}} int udb_query_handle_result */
997 int udb_query_prepare_result (udb_query_t const *q, /* {{{ */
998 udb_query_preparation_area_t *prep_area,
999 const char *host, const char *plugin, const char *db_name,
1000 char **column_names, size_t column_num, cdtime_t interval)
1002 udb_result_preparation_area_t *r_area;
1006 if ((q == NULL) || (prep_area == NULL))
1009 udb_query_finish_result (q, prep_area);
1011 prep_area->column_num = column_num;
1012 prep_area->host = strdup (host);
1013 prep_area->plugin = strdup (plugin);
1014 prep_area->db_name = strdup (db_name);
1016 prep_area->interval = interval;
1018 if ((prep_area->host == NULL) || (prep_area->plugin == NULL)
1019 || (prep_area->db_name == NULL))
1021 ERROR ("db query utils: Query `%s': Prepare failed: Out of memory.", q->name);
1022 udb_query_finish_result (q, prep_area);
1026 #if defined(COLLECT_DEBUG) && COLLECT_DEBUG
1031 for (i = 0; i < column_num; i++)
1033 DEBUG ("db query utils: udb_query_prepare_result: "
1034 "query = %s; column[%zu] = %s;",
1035 q->name, i, column_names[i]);
1040 for (r = q->results, r_area = prep_area->result_prep_areas;
1041 r != NULL; r = r->next, r_area = r_area->next)
1045 ERROR ("db query utils: Query `%s': Invalid number of result "
1046 "preparation areas.", q->name);
1047 udb_query_finish_result (q, prep_area);
1051 status = udb_result_prepare_result (r, r_area, column_names, column_num);
1054 udb_query_finish_result (q, prep_area);
1060 } /* }}} int udb_query_prepare_result */
1062 udb_query_preparation_area_t *
1063 udb_query_allocate_preparation_area (udb_query_t *q) /* {{{ */
1065 udb_query_preparation_area_t *q_area;
1066 udb_result_preparation_area_t **next_r_area;
1069 q_area = (udb_query_preparation_area_t *)malloc (sizeof (*q_area));
1073 memset (q_area, 0, sizeof (*q_area));
1075 next_r_area = &q_area->result_prep_areas;
1076 for (r = q->results; r != NULL; r = r->next)
1078 udb_result_preparation_area_t *r_area;
1080 r_area = (udb_result_preparation_area_t *)malloc (sizeof (*r_area));
1083 for (r_area = q_area->result_prep_areas;
1084 r_area != NULL; r_area = r_area->next)
1092 memset (r_area, 0, sizeof (*r_area));
1094 *next_r_area = r_area;
1095 next_r_area = &r_area->next;
1099 } /* }}} udb_query_preparation_area_t *udb_query_allocate_preparation_area */
1102 udb_query_delete_preparation_area (udb_query_preparation_area_t *q_area) /* {{{ */
1104 udb_result_preparation_area_t *r_area;
1109 r_area = q_area->result_prep_areas;
1110 while (r_area != NULL)
1112 udb_result_preparation_area_t *area = r_area;
1114 r_area = r_area->next;
1116 sfree (area->instances_pos);
1117 sfree (area->values_pos);
1118 sfree (area->instances_buffer);
1119 sfree (area->values_buffer);
1123 sfree (q_area->host);
1124 sfree (q_area->plugin);
1125 sfree (q_area->db_name);
1128 } /* }}} void udb_query_delete_preparation_area */
1130 /* vim: set sw=2 sts=2 et fdm=marker : */