X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;f=src%2Fcore%2Fstore_lookup.c;h=e2ec1b14936b3c6586bdd698bdd0c792519c61aa;hb=2ebe67e1b7d71c3e7e9b7ab06944637b143daba9;hp=0ef5f462a4ea4e759b99a5807de4507d45d4046e;hpb=45e97a5c2c641995c7a6fd036ca11a6341f227c8;p=sysdb.git diff --git a/src/core/store_lookup.c b/src/core/store_lookup.c index 0ef5f46..e2ec1b1 100644 --- a/src/core/store_lookup.c +++ b/src/core/store_lookup.c @@ -50,140 +50,44 @@ #include /* - * private data types + * matcher implementations */ -typedef struct { - sdb_store_matcher_t *m; - sdb_store_matcher_t *filter; - sdb_store_lookup_cb cb; - void *user_data; -} scan_iter_data_t; - /* - * private helper functions + * cmp_expr: + * Compare two values using the specified matcher operator. If strcmp_fallback + * is enabled, compare the string values in case of a type mismatch. */ - -static int -scan_iter(sdb_store_obj_t *obj, void *user_data) -{ - scan_iter_data_t *d = user_data; - - if (sdb_store_matcher_matches(d->m, obj, d->filter)) - return d->cb(obj, d->user_data); - return 0; -} /* scan_iter */ - -static sdb_attribute_t * -attr_get(sdb_host_t *host, const char *name, sdb_store_matcher_t *filter) -{ - sdb_avltree_iter_t *iter = NULL; - sdb_attribute_t *attr = NULL; - - iter = sdb_avltree_get_iter(host->attributes); - while (sdb_avltree_iter_has_next(iter)) { - sdb_attribute_t *a = ATTR(sdb_avltree_iter_get_next(iter)); - - if (strcasecmp(name, SDB_OBJ(a)->name)) - continue; - - assert(STORE_OBJ(a)->type == SDB_ATTRIBUTE); - attr = a; - break; - } - sdb_avltree_iter_destroy(iter); - - if (filter && (! sdb_store_matcher_matches(filter, STORE_OBJ(attr), - NULL))) - return NULL; - return attr; -} /* attr_get */ - -/* - * conditional implementations - */ - static int -attr_cmp(sdb_store_obj_t *obj, sdb_store_cond_t *cond, - sdb_store_matcher_t *filter) +cmp_value(int op, sdb_data_t *v1, sdb_data_t *v2, _Bool strcmp_fallback) { - sdb_attribute_t *attr; - sdb_data_t value = SDB_DATA_INIT; int status; - if (obj->type != SDB_HOST) - return INT_MAX; - - if (sdb_store_expr_eval(ATTR_C(cond)->expr, obj, &value)) - return INT_MAX; - - attr = attr_get(HOST(obj), ATTR_C(cond)->name, filter); - if (! attr) + if (sdb_data_isnull(v1) || (sdb_data_isnull(v2))) status = INT_MAX; - else if (attr->value.type != value.type) + else if (v1->type == v2->type) + status = sdb_data_cmp(v1, v2); + else if (! strcmp_fallback) status = INT_MAX; else - status = sdb_data_cmp(&attr->value, &value); - sdb_data_free_datum(&value); - return status; -} /* attr_cmp */ - -static int -obj_cmp(sdb_store_obj_t *obj, sdb_store_cond_t *cond, - sdb_store_matcher_t __attribute__((unused)) *filter) -{ - sdb_data_t obj_value = SDB_DATA_INIT; - sdb_data_t value = SDB_DATA_INIT; - int status; - - if (sdb_store_get_field(obj, OBJ_C(cond)->field, &obj_value)) - return INT_MAX; - if (sdb_store_expr_eval(OBJ_C(cond)->expr, obj, &value)) - return INT_MAX; - - if (obj_value.type != value.type) { - sdb_data_free_datum(&value); - return INT_MAX; - } - else if (OBJ_C(cond)->field == SDB_FIELD_BACKEND) { - /* this implementation is not actually a conditional but rather checks - * for equality (or rather, existence) only */ - size_t i; - status = INT_MAX; - for (i = 0; i < obj->backends_num; ++i) { - if (! strcasecmp(obj->backends[i], value.data.string)) { - status = 0; - break; - } - } - } - else { - status = sdb_data_cmp(&obj_value, &value); - } - sdb_data_free_datum(&value); - return status; -} /* obj_cmp */ + status = sdb_data_strcmp(v1, v2); -/* - * matcher implementations - */ - -static int -match_string(string_matcher_t *m, const char *name) -{ - if ((! m->name) && (! m->name_re)) - return 1; - - if (! name) - name = ""; - - if (m->name && strcasecmp(m->name, name)) + if (status == INT_MAX) return 0; - if (m->name_re && regexec(m->name_re, name, - /* matches */ 0, NULL, /* flags = */ 0)) - return 0; - return 1; -} /* match_string */ + else if (op == MATCHER_LT) + return status < 0; + else if (op == MATCHER_LE) + return status <= 0; + else if (op == MATCHER_EQ) + return status == 0; + else if (op == MATCHER_NE) + return status != 0; + else if (op == MATCHER_GE) + return status >= 0; + else if (op == MATCHER_GT) + return status > 0; + return 0; +} /* cmp_value */ static int match_logical(sdb_store_matcher_t *m, sdb_store_obj_t *obj, @@ -215,378 +119,277 @@ match_unary(sdb_store_matcher_t *m, sdb_store_obj_t *obj, return !sdb_store_matcher_matches(UOP_M(m)->op, obj, filter); } /* match_unary */ +/* iterate arrays: ANY/ALL */ static int -match_name(sdb_store_matcher_t *m, sdb_store_obj_t *obj, +match_iter_array(sdb_store_matcher_t *m, sdb_store_obj_t *obj, sdb_store_matcher_t *filter) { - sdb_avltree_iter_t *iter = NULL; - int status = 0; + sdb_store_expr_t *e1, *e2; + sdb_data_t v1 = SDB_DATA_INIT; + sdb_data_t v2 = SDB_DATA_INIT; - assert(m->type == MATCHER_NAME); + int status; - if (obj->type == NAME_M(m)->obj_type) - return match_string(&NAME_M(m)->name, SDB_OBJ(obj)->name); - else if (obj->type != SDB_HOST) + /* TODO: fully support arbitrary operators (?) */ + if ((ITER_M(m)->m->type < MATCHER_LT) || (MATCHER_GT < ITER_M(m)->m->type)) return 0; - switch (NAME_M(m)->obj_type) { - case SDB_SERVICE: - iter = sdb_avltree_get_iter(HOST(obj)->services); - break; - case SDB_ATTRIBUTE: - iter = sdb_avltree_get_iter(HOST(obj)->attributes); - break; + e1 = CMP_M(ITER_M(m)->m)->left; + e2 = CMP_M(ITER_M(m)->m)->right; + + if (sdb_store_expr_eval(e1, obj, &v1, filter)) + return 0; + if (sdb_store_expr_eval(e2, obj, &v2, filter)) { + sdb_data_free_datum(&v1); + return 0; } - while (sdb_avltree_iter_has_next(iter)) { - sdb_object_t *child = sdb_avltree_iter_get_next(iter); - if (filter && (! sdb_store_matcher_matches(filter, STORE_OBJ(child), - NULL))) - continue; - if (match_string(&NAME_M(m)->name, child->name)) { - status = 1; - break; + if ((! (v1.type & SDB_TYPE_ARRAY)) || (v2.type & SDB_TYPE_ARRAY)) + status = 0; + else if (sdb_data_isnull(&v1) || (sdb_data_isnull(&v2))) + status = 0; + else { + size_t i; + int all = (int)(m->type == MATCHER_ALL); + + status = all; + for (i = 0; i < v1.data.array.length; ++i) { + sdb_data_t v = SDB_DATA_INIT; + if (sdb_data_array_get(&v1, i, &v)) { + status = 0; + break; + } + + if (cmp_value(ITER_M(m)->m->type, &v, &v2, + (e1->data_type) < 0 || (e2->data_type < 0))) { + if (! all) { + status = 1; + break; + } + } + else if (all) { + status = 0; + break; + } } } - sdb_avltree_iter_destroy(iter); + + sdb_data_free_datum(&v1); + sdb_data_free_datum(&v2); return status; -} /* match_name */ +} /* match_iter_array */ static int -match_attr(sdb_store_matcher_t *m, sdb_store_obj_t *obj, +match_iter(sdb_store_matcher_t *m, sdb_store_obj_t *obj, sdb_store_matcher_t *filter) { - sdb_attribute_t *attr; + sdb_avltree_iter_t *iter = NULL; + int status; + int all = (int)(m->type == MATCHER_ALL); - assert(m->type == MATCHER_ATTR); - assert(ATTR_M(m)->name); + assert((m->type == MATCHER_ANY) || (m->type == MATCHER_ALL)); - if (obj->type != SDB_HOST) - return 0; + if (ITER_M(m)->type == SDB_FIELD_BACKEND) + return match_iter_array(m, obj, filter); - attr = attr_get(HOST(obj), ATTR_M(m)->name, filter); - if (attr) { - char buf[sdb_data_strlen(&attr->value) + 1]; - if (sdb_data_format(&attr->value, buf, sizeof(buf), SDB_UNQUOTED) <= 0) - return 0; - if (match_string(&ATTR_M(m)->value, buf)) - return 1; + if (obj->type == SDB_HOST) { + if (ITER_M(m)->type == SDB_SERVICE) + iter = sdb_avltree_get_iter(HOST(obj)->services); + else if (ITER_M(m)->type == SDB_METRIC) + iter = sdb_avltree_get_iter(HOST(obj)->metrics); + else if (ITER_M(m)->type == SDB_ATTRIBUTE) + iter = sdb_avltree_get_iter(HOST(obj)->attributes); + } else if (obj->type == SDB_SERVICE) { + if (ITER_M(m)->type == SDB_ATTRIBUTE) + iter = sdb_avltree_get_iter(SVC(obj)->attributes); + } else if (obj->type == SDB_METRIC) { + if (ITER_M(m)->type == SDB_ATTRIBUTE) + iter = sdb_avltree_get_iter(METRIC(obj)->attributes); } - return 0; -} /* match_attr */ -static int -match_lt(sdb_store_matcher_t *m, sdb_store_obj_t *obj, - sdb_store_matcher_t *filter) -{ - int status; - assert(m->type == MATCHER_LT); - status = COND_M(m)->cond->cmp(obj, COND_M(m)->cond, filter); - return (status != INT_MAX) && (status < 0); -} /* match_lt */ + status = all; + while (sdb_avltree_iter_has_next(iter)) { + sdb_store_obj_t *child = STORE_OBJ(sdb_avltree_iter_get_next(iter)); + if (filter && (! sdb_store_matcher_matches(filter, child, NULL))) + continue; -static int -match_le(sdb_store_matcher_t *m, sdb_store_obj_t *obj, - sdb_store_matcher_t *filter) -{ - int status; - assert(m->type == MATCHER_LE); - status = COND_M(m)->cond->cmp(obj, COND_M(m)->cond, filter); - return (status != INT_MAX) && (status <= 0); -} /* match_le */ + if (sdb_store_matcher_matches(ITER_M(m)->m, child, filter)) { + if (! all) { + status = 1; + break; + } + } else if (all) { + status = 0; + break; + } + } + sdb_avltree_iter_destroy(iter); + return status; +} /* match_iter */ static int -match_eq(sdb_store_matcher_t *m, sdb_store_obj_t *obj, +match_cmp(sdb_store_matcher_t *m, sdb_store_obj_t *obj, sdb_store_matcher_t *filter) { + sdb_store_expr_t *e1 = CMP_M(m)->left; + sdb_store_expr_t *e2 = CMP_M(m)->right; + sdb_data_t v1 = SDB_DATA_INIT, v2 = SDB_DATA_INIT; int status; - assert(m->type == MATCHER_EQ); - status = COND_M(m)->cond->cmp(obj, COND_M(m)->cond, filter); - return (status != INT_MAX) && (! status); -} /* match_eq */ -static int -match_ge(sdb_store_matcher_t *m, sdb_store_obj_t *obj, - sdb_store_matcher_t *filter) -{ - int status; - assert(m->type == MATCHER_GE); - status = COND_M(m)->cond->cmp(obj, COND_M(m)->cond, filter); - return (status != INT_MAX) && (status >= 0); -} /* match_ge */ + assert((m->type == MATCHER_LT) + || (m->type == MATCHER_LE) + || (m->type == MATCHER_EQ) + || (m->type == MATCHER_NE) + || (m->type == MATCHER_GE) + || (m->type == MATCHER_GT)); -static int -match_gt(sdb_store_matcher_t *m, sdb_store_obj_t *obj, - sdb_store_matcher_t *filter) -{ - int status; - assert(m->type == MATCHER_GT); - status = COND_M(m)->cond->cmp(obj, COND_M(m)->cond, filter); - return (status != INT_MAX) && (status > 0); -} /* match_gt */ - -static int -match_isnull(sdb_store_matcher_t *m, sdb_store_obj_t *obj, - sdb_store_matcher_t *filter) -{ - assert(m->type == MATCHER_ISNULL); - if (obj->type != SDB_HOST) + if (sdb_store_expr_eval(e1, obj, &v1, filter)) return 0; - return attr_get(HOST(obj), ISNULL_M(m)->attr_name, filter) == NULL; -} /* match_isnull */ - -typedef int (*matcher_cb)(sdb_store_matcher_t *, sdb_store_obj_t *, - sdb_store_matcher_t *); + if (sdb_store_expr_eval(e2, obj, &v2, filter)) { + sdb_data_free_datum(&v1); + return 0; + } -/* this array needs to be indexable by the matcher types; - * -> update the enum in store-private.h when updating this */ -static matcher_cb -matchers[] = { - match_logical, - match_logical, - match_unary, - match_name, - match_attr, - match_lt, - match_le, - match_eq, - match_ge, - match_gt, - match_isnull, -}; + status = cmp_value(m->type, &v1, &v2, + (e1->data_type) < 0 || (e2->data_type < 0)); -/* - * private conditional types - */ + sdb_data_free_datum(&v1); + sdb_data_free_datum(&v2); + return status; +} /* match_cmp */ static int -attr_cond_init(sdb_object_t *obj, va_list ap) +match_in(sdb_store_matcher_t *m, sdb_store_obj_t *obj, + sdb_store_matcher_t *filter) { - const char *name = va_arg(ap, const char *); - sdb_store_expr_t *expr = va_arg(ap, sdb_store_expr_t *); + sdb_data_t value = SDB_DATA_INIT, array = SDB_DATA_INIT; + int status = 1; - if (! name) - return -1; + assert(m->type == MATCHER_IN); - SDB_STORE_COND(obj)->cmp = attr_cmp; + if ((sdb_store_expr_eval(CMP_M(m)->left, obj, &value, filter)) + || (sdb_store_expr_eval(CMP_M(m)->right, obj, &array, filter))) + status = 0; - ATTR_C(obj)->name = strdup(name); - if (! ATTR_C(obj)->name) - return -1; - ATTR_C(obj)->expr = expr; - sdb_object_ref(SDB_OBJ(expr)); - return 0; -} /* attr_cond_init */ + if (status) + status = sdb_data_inarray(&value, &array); -static void -attr_cond_destroy(sdb_object_t *obj) -{ - if (ATTR_C(obj)->name) - free(ATTR_C(obj)->name); - sdb_object_deref(SDB_OBJ(ATTR_C(obj)->expr)); -} /* attr_cond_destroy */ - -static sdb_type_t attr_cond_type = { - /* size = */ sizeof(attr_cond_t), - /* init = */ attr_cond_init, - /* destroy = */ attr_cond_destroy, -}; + sdb_data_free_datum(&value); + sdb_data_free_datum(&array); + return status; +} /* match_in */ static int -obj_cond_init(sdb_object_t *obj, va_list ap) -{ - int field = va_arg(ap, int); - sdb_store_expr_t *expr = va_arg(ap, sdb_store_expr_t *); - - SDB_STORE_COND(obj)->cmp = obj_cmp; - - OBJ_C(obj)->field = field; - OBJ_C(obj)->expr = expr; - sdb_object_ref(SDB_OBJ(expr)); - return 0; -} /* obj_cond_init */ - -static void -obj_cond_destroy(sdb_object_t *obj) +match_regex(sdb_store_matcher_t *m, sdb_store_obj_t *obj, + sdb_store_matcher_t *filter) { - sdb_object_deref(SDB_OBJ(OBJ_C(obj)->expr)); -} /* obj_cond_destroy */ - -static sdb_type_t obj_cond_type = { - /* size = */ sizeof(obj_cond_t), - /* init = */ obj_cond_init, - /* destroy = */ obj_cond_destroy, -}; - -/* - * private matcher types - */ + sdb_data_t v = SDB_DATA_INIT; + int status = 0; -/* initializes a string matcher consuming two elements from ap */ -static int -string_matcher_init(string_matcher_t *m, va_list ap) -{ - const char *name = va_arg(ap, const char *); - const char *name_re = va_arg(ap, const char *); + regex_t regex; + _Bool free_regex = 0; - if (name) { - m->name = strdup(name); - if (! m->name) - return -1; - } - if (name_re) { - m->name_re = malloc(sizeof(*m->name_re)); - if (! m->name_re) - return -1; - if (regcomp(m->name_re, name_re, REG_EXTENDED | REG_ICASE | REG_NOSUB)) - return -1; - } - return 0; -} /* string_matcher_init */ + assert((m->type == MATCHER_REGEX) + || (m->type == MATCHER_NREGEX)); -static void -string_matcher_destroy(string_matcher_t *m) -{ - if (m->name) - free(m->name); - if (m->name_re) { - regfree(m->name_re); - free(m->name_re); + if (! CMP_M(m)->right->type) { + assert(CMP_M(m)->right->data.type == SDB_TYPE_REGEX); + regex = CMP_M(m)->right->data.data.re.regex; } -} /* string_matcher_destroy */ - -static char * -string_tostring(string_matcher_t *m, char *buf, size_t buflen) -{ - snprintf(buf, buflen, "{ %s%s%s, %p }", - m->name ? "'" : "", m->name ? m->name : "NULL", m->name ? "'" : "", - m->name_re); - return buf; -} /* string_tostring */ + else { + sdb_data_t tmp = SDB_DATA_INIT; + char *raw; -/* initializes a name matcher */ -static int -name_matcher_init(sdb_object_t *obj, va_list ap) -{ - name_matcher_t *m = NAME_M(obj); - M(obj)->type = MATCHER_NAME; - return string_matcher_init(&m->name, ap); -} /* name_matcher_init */ + if (sdb_store_expr_eval(CMP_M(m)->right, obj, &tmp, filter)) + return 0; -static void -name_matcher_destroy(sdb_object_t *obj) -{ - name_matcher_t *m = NAME_M(obj); - string_matcher_destroy(&m->name); -} /* name_matcher_destroy */ + if (tmp.type != SDB_TYPE_STRING) { + sdb_data_free_datum(&tmp); + return 0; + } -static char * -name_tostring(sdb_store_matcher_t *m, char *buf, size_t buflen) -{ - char name[buflen + 1]; - assert(m->type == MATCHER_NAME); - snprintf(buf, buflen, "OBJ[%s]{ NAME%s }", - SDB_STORE_TYPE_TO_NAME(NAME_M(m)->obj_type), - string_tostring(&NAME_M(m)->name, name, sizeof(name))); - return buf; -} /* name_tostring */ + raw = tmp.data.string; + if (sdb_data_parse(raw, SDB_TYPE_REGEX, &tmp)) { + free(raw); + return 0; + } -static int -attr_matcher_init(sdb_object_t *obj, va_list ap) -{ - attr_matcher_t *attr = ATTR_M(obj); - const char *name = va_arg(ap, const char *); - - M(obj)->type = MATCHER_ATTR; - if (name) { - attr->name = strdup(name); - if (! attr->name) - return -1; + regex = tmp.data.re.regex; + free_regex = 1; + free(tmp.data.re.raw); + free(raw); } - return string_matcher_init(&attr->value, ap); -} /* attr_matcher_init */ - -static void -attr_matcher_destroy(sdb_object_t *obj) -{ - attr_matcher_t *attr = ATTR_M(obj); - if (attr->name) - free(attr->name); - attr->name = NULL; - string_matcher_destroy(&attr->value); -} /* attr_matcher_destroy */ - -static char * -attr_tostring(sdb_store_matcher_t *m, char *buf, size_t buflen) -{ - char value[buflen + 1]; - if (! m) { - snprintf(buf, buflen, "ATTR{}"); - return buf; + if ((sdb_store_expr_eval(CMP_M(m)->left, obj, &v, filter)) + || (sdb_data_isnull(&v))) + status = 0; + else { + char value[sdb_data_strlen(&v) + 1]; + if (sdb_data_format(&v, value, sizeof(value), SDB_UNQUOTED) < 0) + status = 0; + else if (! regexec(®ex, value, 0, NULL, 0)) + status = 1; } - assert(m->type == MATCHER_ATTR); - snprintf(buf, buflen, "ATTR[%s]{ VALUE%s }", ATTR_M(m)->name, - string_tostring(&ATTR_M(m)->value, value, sizeof(value))); - return buf; -} /* attr_tostring */ + if (free_regex) + regfree(®ex); + sdb_data_free_datum(&v); + if (m->type == MATCHER_NREGEX) + return !status; + return status; +} /* match_regex */ static int -cond_matcher_init(sdb_object_t *obj, va_list ap) +match_isnull(sdb_store_matcher_t *m, sdb_store_obj_t *obj, + sdb_store_matcher_t *filter) { - int type = va_arg(ap, int); - sdb_store_cond_t *cond = va_arg(ap, sdb_store_cond_t *); + sdb_data_t v = SDB_DATA_INIT; + int status; - if (! cond) - return -1; + assert((m->type == MATCHER_ISNULL) || (m->type == MATCHER_ISNNULL)); - sdb_object_ref(SDB_OBJ(cond)); + /* TODO: this might hide real errors; + * improve error reporting and propagation */ + if (sdb_store_expr_eval(ISNULL_M(m)->expr, obj, &v, filter) + || sdb_data_isnull(&v)) + status = 1; + else + status = 0; - M(obj)->type = type; - COND_M(obj)->cond = cond; - return 0; -} /* cond_matcher_init */ + sdb_data_free_datum(&v); + if (m->type == MATCHER_ISNNULL) + return !status; + return status; +} /* match_isnull */ -static void -cond_matcher_destroy(sdb_object_t *obj) -{ - sdb_object_deref(SDB_OBJ(COND_M(obj)->cond)); -} /* cond_matcher_destroy */ +typedef int (*matcher_cb)(sdb_store_matcher_t *, sdb_store_obj_t *, + sdb_store_matcher_t *); -static char * -cond_tostring(sdb_store_matcher_t *m, char *buf, size_t buflen) -{ - const char *type, *id; - sdb_data_t value = SDB_DATA_INIT; - char value_str[buflen]; - sdb_store_expr_t *expr; - - if (COND_M(m)->cond->cmp == attr_cmp) { - type = "ATTR"; - id = ATTR_C(COND_M(m)->cond)->name; - expr = ATTR_C(COND_M(m)->cond)->expr; - } - else if (COND_M(m)->cond->cmp == obj_cmp) { - type = "OBJ"; - id = SDB_FIELD_TO_NAME(OBJ_C(COND_M(m)->cond)->field); - expr = OBJ_C(COND_M(m)->cond)->expr; - } - else { - snprintf(buf, buflen, ""); - return buf; - } +/* this array needs to be indexable by the matcher types; + * -> update the enum in store-private.h when updating this */ +static matcher_cb +matchers[] = { + match_logical, + match_logical, + match_unary, + match_iter, + match_iter, + match_cmp, + match_cmp, + match_cmp, + match_cmp, + match_cmp, + match_cmp, + match_in, + match_regex, + match_regex, + match_isnull, + match_isnull, +}; - if (sdb_store_expr_eval(expr, NULL, &value)) - snprintf(value_str, sizeof(value_str), "ERR"); - else if (sdb_data_format(&value, value_str, sizeof(value_str), - SDB_SINGLE_QUOTED) < 0) - snprintf(value_str, sizeof(value_str), "ERR"); - snprintf(buf, buflen, "%s[%s]{ %s %s }", type, id, - MATCHER_SYM(m->type), value_str); - sdb_data_free_datum(&value); - return buf; -} /* cond_tostring */ +/* + * private matcher types + */ static int op_matcher_init(sdb_object_t *obj, va_list ap) @@ -614,24 +417,47 @@ op_matcher_destroy(sdb_object_t *obj) sdb_object_deref(SDB_OBJ(OP_M(obj)->right)); } /* op_matcher_destroy */ -static char * -op_tostring(sdb_store_matcher_t *m, char *buf, size_t buflen) +static int +iter_matcher_init(sdb_object_t *obj, va_list ap) { - char left[buflen + 1], right[buflen + 1]; + M(obj)->type = va_arg(ap, int); + ITER_M(obj)->type = va_arg(ap, int); + ITER_M(obj)->m = va_arg(ap, sdb_store_matcher_t *); - if (! m) { - /* this should not happen */ - snprintf(buf, buflen, "()"); - return buf; - } + if (! ITER_M(obj)->m) + return -1; - assert((m->type == MATCHER_OR) || (m->type == MATCHER_AND)); - snprintf(buf, buflen, "(%s, %s, %s)", - m->type == MATCHER_OR ? "OR" : "AND", - sdb_store_matcher_tostring(OP_M(m)->left, left, sizeof(left)), - sdb_store_matcher_tostring(OP_M(m)->right, right, sizeof(right))); - return buf; -} /* op_tostring */ + sdb_object_ref(SDB_OBJ(ITER_M(obj)->m)); + return 0; +} /* iter_matcher_init */ + +static void +iter_matcher_destroy(sdb_object_t *obj) +{ + sdb_object_deref(SDB_OBJ(ITER_M(obj)->m)); +} /* iter_matcher_destroy */ + +static int +cmp_matcher_init(sdb_object_t *obj, va_list ap) +{ + M(obj)->type = va_arg(ap, int); + + CMP_M(obj)->left = va_arg(ap, sdb_store_expr_t *); + sdb_object_ref(SDB_OBJ(CMP_M(obj)->left)); + CMP_M(obj)->right = va_arg(ap, sdb_store_expr_t *); + sdb_object_ref(SDB_OBJ(CMP_M(obj)->right)); + + if ((! CMP_M(obj)->left) || (! CMP_M(obj)->right)) + return -1; + return 0; +} /* cmp_matcher_init */ + +static void +cmp_matcher_destroy(sdb_object_t *obj) +{ + sdb_object_deref(SDB_OBJ(CMP_M(obj)->left)); + sdb_object_deref(SDB_OBJ(CMP_M(obj)->right)); +} /* cmp_matcher_destroy */ static int uop_matcher_init(sdb_object_t *obj, va_list ap) @@ -655,74 +481,25 @@ uop_matcher_destroy(sdb_object_t *obj) sdb_object_deref(SDB_OBJ(UOP_M(obj)->op)); } /* uop_matcher_destroy */ -static char * -uop_tostring(sdb_store_matcher_t *m, char *buf, size_t buflen) -{ - char op[buflen + 1]; - - if (! m) { - /* this should not happen */ - snprintf(buf, buflen, "()"); - return buf; - } - - assert(m->type == MATCHER_NOT); - snprintf(buf, buflen, "(NOT, %s)", - sdb_store_matcher_tostring(UOP_M(m)->op, op, sizeof(op))); - return buf; -} /* uop_tostring */ - static int isnull_matcher_init(sdb_object_t *obj, va_list ap) { - const char *name; - M(obj)->type = va_arg(ap, int); - if (M(obj)->type != MATCHER_ISNULL) + if ((M(obj)->type != MATCHER_ISNULL) && (M(obj)->type != MATCHER_ISNNULL)) return -1; - name = va_arg(ap, const char *); - if (! name) - return -1; - ISNULL_M(obj)->attr_name = strdup(name); - if (! ISNULL_M(obj)->attr_name) - return -1; + ISNULL_M(obj)->expr = va_arg(ap, sdb_store_expr_t *); + sdb_object_ref(SDB_OBJ(ISNULL_M(obj)->expr)); return 0; } /* isnull_matcher_init */ static void isnull_matcher_destroy(sdb_object_t *obj) { - if (ISNULL_M(obj)->attr_name) - free(ISNULL_M(obj)->attr_name); - ISNULL_M(obj)->attr_name = NULL; + sdb_object_deref(SDB_OBJ(ISNULL_M(obj)->expr)); + ISNULL_M(obj)->expr = NULL; } /* isnull_matcher_destroy */ -static char * -isnull_tostring(sdb_store_matcher_t *m, char *buf, size_t buflen) -{ - snprintf(buf, buflen, "(IS NULL, ATTR[%s])", ISNULL_M(m)->attr_name); - return buf; -} /* isnull_tostring */ - -static sdb_type_t name_type = { - /* size = */ sizeof(name_matcher_t), - /* init = */ name_matcher_init, - /* destroy = */ name_matcher_destroy, -}; - -static sdb_type_t attr_type = { - /* size = */ sizeof(attr_matcher_t), - /* init = */ attr_matcher_init, - /* destroy = */ attr_matcher_destroy, -}; - -static sdb_type_t cond_type = { - /* size = */ sizeof(cond_matcher_t), - /* init = */ cond_matcher_init, - /* destroy = */ cond_matcher_destroy, -}; - static sdb_type_t op_type = { /* size = */ sizeof(op_matcher_t), /* init = */ op_matcher_init, @@ -735,291 +512,205 @@ static sdb_type_t uop_type = { /* destroy = */ uop_matcher_destroy, }; +static sdb_type_t iter_type = { + /* size = */ sizeof(iter_matcher_t), + /* init = */ iter_matcher_init, + /* destroy = */ iter_matcher_destroy, +}; + +static sdb_type_t cmp_type = { + /* size = */ sizeof(cmp_matcher_t), + /* init = */ cmp_matcher_init, + /* destroy = */ cmp_matcher_destroy, +}; + static sdb_type_t isnull_type = { /* size = */ sizeof(isnull_matcher_t), /* init = */ isnull_matcher_init, /* destroy = */ isnull_matcher_destroy, }; -typedef char *(*matcher_tostring_cb)(sdb_store_matcher_t *, char *, size_t); - -/* this array needs to be indexable by the matcher types; - * -> update the enum in store-private.h when updating this */ -static matcher_tostring_cb -matchers_tostring[] = { - op_tostring, - op_tostring, - uop_tostring, - name_tostring, - attr_tostring, - cond_tostring, - cond_tostring, - cond_tostring, - cond_tostring, - cond_tostring, - isnull_tostring, -}; - /* * public API */ -sdb_store_cond_t * -sdb_store_attr_cond(const char *name, sdb_store_expr_t *expr) -{ - return SDB_STORE_COND(sdb_object_create("attr-cond", attr_cond_type, - name, expr)); -} /* sdb_store_attr_cond */ - -sdb_store_cond_t * -sdb_store_obj_cond(int field, sdb_store_expr_t *expr) -{ - return SDB_STORE_COND(sdb_object_create("obj-cond", obj_cond_type, - field, expr)); -} /* sdb_store_obj_cond */ - sdb_store_matcher_t * -sdb_store_name_matcher(int type, const char *name, _Bool re) +sdb_store_any_matcher(int type, sdb_store_matcher_t *m) { - sdb_store_matcher_t *m; - - if (re) - m = M(sdb_object_create("name-matcher", name_type, NULL, name)); - else - m = M(sdb_object_create("name-matcher", name_type, name, NULL)); - - if (! m) + if ((type != SDB_SERVICE) && (type != SDB_METRIC) + && (type != SDB_ATTRIBUTE) && (type != SDB_FIELD_BACKEND)) return NULL; - - NAME_M(m)->obj_type = type; - return m; -} /* sdb_store_name_matcher */ + return M(sdb_object_create("any-matcher", iter_type, + MATCHER_ANY, type, m)); +} /* sdb_store_any_matcher */ sdb_store_matcher_t * -sdb_store_attr_matcher(const char *name, const char *value, _Bool re) +sdb_store_all_matcher(int type, sdb_store_matcher_t *m) { - sdb_store_matcher_t *m; - - if (! name) + if ((type != SDB_SERVICE) && (type != SDB_METRIC) + && (type != SDB_ATTRIBUTE) && (type != SDB_FIELD_BACKEND)) return NULL; - - if (re) - m = M(sdb_object_create("attr-matcher", attr_type, - name, NULL, value)); - else - m = M(sdb_object_create("attr-matcher", attr_type, - name, value, NULL)); - return m; -} /* sdb_store_attr_matcher */ + return M(sdb_object_create("all-matcher", iter_type, + MATCHER_ALL, type, m)); +} /* sdb_store_all_matcher */ sdb_store_matcher_t * -sdb_store_lt_matcher(sdb_store_cond_t *cond) +sdb_store_lt_matcher(sdb_store_expr_t *left, sdb_store_expr_t *right) { - return M(sdb_object_create("lt-matcher", cond_type, - MATCHER_LT, cond)); + return M(sdb_object_create("lt-matcher", cmp_type, + MATCHER_LT, left, right)); } /* sdb_store_lt_matcher */ sdb_store_matcher_t * -sdb_store_le_matcher(sdb_store_cond_t *cond) +sdb_store_le_matcher(sdb_store_expr_t *left, sdb_store_expr_t *right) { - return M(sdb_object_create("le-matcher", cond_type, - MATCHER_LE, cond)); + return M(sdb_object_create("le-matcher", cmp_type, + MATCHER_LE, left, right)); } /* sdb_store_le_matcher */ sdb_store_matcher_t * -sdb_store_eq_matcher(sdb_store_cond_t *cond) +sdb_store_eq_matcher(sdb_store_expr_t *left, sdb_store_expr_t *right) { - return M(sdb_object_create("eq-matcher", cond_type, - MATCHER_EQ, cond)); + return M(sdb_object_create("eq-matcher", cmp_type, + MATCHER_EQ, left, right)); } /* sdb_store_eq_matcher */ sdb_store_matcher_t * -sdb_store_ge_matcher(sdb_store_cond_t *cond) +sdb_store_ne_matcher(sdb_store_expr_t *left, sdb_store_expr_t *right) +{ + return M(sdb_object_create("ne-matcher", cmp_type, + MATCHER_NE, left, right)); +} /* sdb_store_ne_matcher */ + +sdb_store_matcher_t * +sdb_store_ge_matcher(sdb_store_expr_t *left, sdb_store_expr_t *right) { - return M(sdb_object_create("ge-matcher", cond_type, - MATCHER_GE, cond)); + return M(sdb_object_create("ge-matcher", cmp_type, + MATCHER_GE, left, right)); } /* sdb_store_ge_matcher */ sdb_store_matcher_t * -sdb_store_gt_matcher(sdb_store_cond_t *cond) +sdb_store_gt_matcher(sdb_store_expr_t *left, sdb_store_expr_t *right) { - return M(sdb_object_create("gt-matcher", cond_type, - MATCHER_GT, cond)); + return M(sdb_object_create("gt-matcher", cmp_type, + MATCHER_GT, left, right)); } /* sdb_store_gt_matcher */ sdb_store_matcher_t * -sdb_store_isnull_matcher(const char *attr_name) +sdb_store_in_matcher(sdb_store_expr_t *left, sdb_store_expr_t *right) { - return M(sdb_object_create("isnull-matcher", isnull_type, - MATCHER_ISNULL, attr_name)); -} /* sdb_store_isnull_matcher */ + return M(sdb_object_create("in-matcher", cmp_type, + MATCHER_IN, left, right)); +} /* sdb_store_in_matcher */ -static sdb_store_matcher_t * -maybe_inv_matcher(sdb_store_matcher_t *m, _Bool inv) +sdb_store_matcher_t * +sdb_store_regex_matcher(sdb_store_expr_t *left, sdb_store_expr_t *right) { - sdb_store_matcher_t *tmp; - - if ((! m) || (! inv)) - return m; - - tmp = sdb_store_inv_matcher(m); - /* pass ownership to the inverse matcher */ - sdb_object_deref(SDB_OBJ(m)); - return tmp; -} /* maybe_inv_matcher */ + if (! right->type) { + if ((right->data.type != SDB_TYPE_STRING) + && (right->data.type != SDB_TYPE_REGEX)) + return NULL; -static int -parse_cond_op(const char *op, - sdb_store_matcher_t *(**matcher)(sdb_store_cond_t *), _Bool *inv) -{ - *inv = 0; - if (! strcasecmp(op, "<")) - *matcher = sdb_store_lt_matcher; - else if (! strcasecmp(op, "<=")) - *matcher = sdb_store_le_matcher; - else if (! strcasecmp(op, "=")) - *matcher = sdb_store_eq_matcher; - else if (! strcasecmp(op, ">=")) - *matcher = sdb_store_ge_matcher; - else if (! strcasecmp(op, ">")) - *matcher = sdb_store_gt_matcher; - else if (! strcasecmp(op, "!=")) { - *matcher = sdb_store_eq_matcher; - *inv = 1; + if (right->data.type == SDB_TYPE_STRING) { + char *raw = right->data.data.string; + if (sdb_data_parse(raw, SDB_TYPE_REGEX, &right->data)) + return NULL; + free(raw); + } } - else - return -1; - return 0; -} /* parse_cond_op */ + return M(sdb_object_create("regex-matcher", cmp_type, + MATCHER_REGEX, left, right)); +} /* sdb_store_regex_matcher */ -static sdb_store_matcher_t * -parse_attr_cmp(const char *attr, const char *op, sdb_store_expr_t *expr) +sdb_store_matcher_t * +sdb_store_nregex_matcher(sdb_store_expr_t *left, sdb_store_expr_t *right) { - sdb_store_matcher_t *(*matcher)(sdb_store_cond_t *) = NULL; - sdb_store_matcher_t *m; - sdb_store_cond_t *cond; - _Bool inv = 0; - - if (! attr) - return NULL; - - if (! strcasecmp(op, "IS")) { - if (! expr) - return sdb_store_isnull_matcher(attr); - else - return NULL; - } - else if (! expr) - return NULL; - else if (parse_cond_op(op, &matcher, &inv)) - return NULL; - - cond = sdb_store_attr_cond(attr, expr); - if (! cond) + sdb_store_matcher_t *m = sdb_store_regex_matcher(left, right); + if (! m) return NULL; - - m = matcher(cond); - /* pass ownership to 'm' or destroy in case of an error */ - sdb_object_deref(SDB_OBJ(cond)); - return maybe_inv_matcher(m, inv); -} /* parse_attr_cmp */ + m->type = MATCHER_NREGEX; + return m; +} /* sdb_store_nregex_matcher */ sdb_store_matcher_t * -sdb_store_matcher_parse_cmp(const char *obj_type, const char *attr, - const char *op, sdb_store_expr_t *expr) +sdb_store_isnull_matcher(sdb_store_expr_t *expr) { - int type = -1; - _Bool inv = 0; - _Bool re = 0; - - sdb_data_t value = SDB_DATA_INIT; - sdb_store_matcher_t *m = NULL; - - if (! strcasecmp(obj_type, "host")) - type = SDB_HOST; - else if (! strcasecmp(obj_type, "service")) - type = SDB_SERVICE; - else if (! strcasecmp(obj_type, "attribute")) - type = SDB_ATTRIBUTE; - else - return NULL; - - /* XXX: this code sucks! */ - if (! strcasecmp(op, "=")) { - /* nothing to do */ - } - else if (! strcasecmp(op, "!=")) { - inv = 1; - } - else if (! strcasecmp(op, "=~")) { - re = 1; - } - else if (! strcasecmp(op, "!~")) { - inv = 1; - re = 1; - } - else if (type == SDB_ATTRIBUTE) - return parse_attr_cmp(attr, op, expr); - else - return NULL; - - if (! expr) - return NULL; - - if (sdb_store_expr_eval(expr, NULL, &value)) - return NULL; - if (value.type != SDB_TYPE_STRING) { - sdb_data_free_datum(&value); - return parse_attr_cmp(attr, op, expr); - } - - if (! attr) - m = sdb_store_name_matcher(type, value.data.string, re); - else if (type == SDB_ATTRIBUTE) - m = sdb_store_attr_matcher(attr, value.data.string, re); - - sdb_data_free_datum(&value); - return maybe_inv_matcher(m, inv); -} /* sdb_store_matcher_parse_cmp */ + return M(sdb_object_create("isnull-matcher", isnull_type, + MATCHER_ISNULL, expr)); +} /* sdb_store_isnull_matcher */ sdb_store_matcher_t * -sdb_store_matcher_parse_field_cmp(const char *name, const char *op, - sdb_store_expr_t *expr) +sdb_store_isnnull_matcher(sdb_store_expr_t *expr) { - sdb_store_matcher_t *(*matcher)(sdb_store_cond_t *) = NULL; - sdb_store_matcher_t *m; - sdb_store_cond_t *cond; - _Bool inv = 0; + return M(sdb_object_create("isnull-matcher", isnull_type, + MATCHER_ISNNULL, expr)); +} /* sdb_store_isnnull_matcher */ - int field; +sdb_store_matcher_op_cb +sdb_store_parse_matcher_op(const char *op) +{ + if (! strcasecmp(op, "<")) + return sdb_store_lt_matcher; + else if (! strcasecmp(op, "<=")) + return sdb_store_le_matcher; + else if (! strcasecmp(op, "=")) + return sdb_store_eq_matcher; + else if (! strcasecmp(op, "!=")) + return sdb_store_ne_matcher; + else if (! strcasecmp(op, ">=")) + return sdb_store_ge_matcher; + else if (! strcasecmp(op, ">")) + return sdb_store_gt_matcher; + else if (! strcasecmp(op, "=~")) + return sdb_store_regex_matcher; + else if (! strcasecmp(op, "!~")) + return sdb_store_nregex_matcher; + return NULL; +} /* sdb_store_parse_matcher_op */ - if (! expr) - return NULL; +int +sdb_store_parse_object_type(const char *name) +{ + if (! strcasecmp(name, "host")) + return SDB_HOST; + else if (! strcasecmp(name, "service")) + return SDB_SERVICE; + else if (! strcasecmp(name, "metric")) + return SDB_METRIC; + else if (! strcasecmp(name, "attribute")) + return SDB_ATTRIBUTE; + return -1; +} /* sdb_store_parse_object_type */ - if (! strcasecmp(name, "last_update")) - field = SDB_FIELD_LAST_UPDATE; +int +sdb_store_parse_object_type_plural(const char *name) +{ + if (! strcasecmp(name, "hosts")) + return SDB_HOST; + else if (! strcasecmp(name, "services")) + return SDB_SERVICE; + else if (! strcasecmp(name, "metrics")) + return SDB_METRIC; + else if (! strcasecmp(name, "attributes")) + return SDB_ATTRIBUTE; + return -1; +} /* sdb_store_parse_object_type_plural */ + +int +sdb_store_parse_field_name(const char *name) +{ + if (! strcasecmp(name, "name")) + return SDB_FIELD_NAME; + else if (! strcasecmp(name, "last_update")) + return SDB_FIELD_LAST_UPDATE; else if (! strcasecmp(name, "age")) - field = SDB_FIELD_AGE; + return SDB_FIELD_AGE; else if (! strcasecmp(name, "interval")) - field = SDB_FIELD_INTERVAL; + return SDB_FIELD_INTERVAL; else if (! strcasecmp(name, "backend")) - field = SDB_FIELD_BACKEND; - else - return NULL; - - if (parse_cond_op(op, &matcher, &inv)) - return NULL; - - cond = sdb_store_obj_cond(field, expr); - if (! cond) - return NULL; - - assert(matcher); - m = matcher(cond); - /* pass ownership to 'm' or destroy in case of an error */ - sdb_object_deref(SDB_OBJ(cond)); - return maybe_inv_matcher(m, inv); -} /* sdb_store_matcher_parse_field_cmp */ + return SDB_FIELD_BACKEND; + return -1; +} /* sdb_store_parse_field_name */ sdb_store_matcher_t * sdb_store_dis_matcher(sdb_store_matcher_t *left, sdb_store_matcher_t *right) @@ -1058,28 +749,5 @@ sdb_store_matcher_matches(sdb_store_matcher_t *m, sdb_store_obj_t *obj, return matchers[m->type](m, obj, filter); } /* sdb_store_matcher_matches */ -char * -sdb_store_matcher_tostring(sdb_store_matcher_t *m, char *buf, size_t buflen) -{ - if (! m) - return NULL; - - if ((m->type < 0) - || (((size_t)m->type >= SDB_STATIC_ARRAY_LEN(matchers_tostring)))) - return NULL; - return matchers_tostring[m->type](m, buf, buflen); -} /* sdb_store_matcher_tostring */ - -int -sdb_store_scan(sdb_store_matcher_t *m, sdb_store_matcher_t *filter, - sdb_store_lookup_cb cb, void *user_data) -{ - scan_iter_data_t data = { m, filter, cb, user_data }; - - if (! cb) - return -1; - return sdb_store_iterate(scan_iter, &data); -} /* sdb_store_scan */ - /* vim: set tw=78 sw=4 ts=4 noexpandtab : */