X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;f=src%2Fcore%2Fstore_expr.c;h=a0047a1f12e1fa8498ef0ed5255373478f98a070;hb=9f22d297f78323cb6ae9e8de66f9390333425df9;hp=9aa1ce99718fef3f42c6de7a165c8d3aef33b438;hpb=6ef9d05304ef34454ab41b4d98a05f2b5ef0f547;p=sysdb.git diff --git a/src/core/store_expr.c b/src/core/store_expr.c index 9aa1ce9..a0047a1 100644 --- a/src/core/store_expr.c +++ b/src/core/store_expr.c @@ -39,27 +39,8 @@ #include "core/object.h" #include - -/* - * private data types - */ - -struct sdb_store_expr { - sdb_object_t super; - - /* - * type: - * -1: field value (field type store in data.data.integer) - * 0: const value (stored in data) - * >0: operator id - */ - int type; - - sdb_store_expr_t *left; - sdb_store_expr_t *right; - - sdb_data_t data; -}; +#include +#include /* * private data types @@ -78,6 +59,8 @@ expr_init(sdb_object_t *obj, va_list ap) if (type <= 0) { if (! value) return -1; + if ((type == TYPED_EXPR) && (! left)) + return -1; } else { if (value) return -1; @@ -94,6 +77,9 @@ expr_init(sdb_object_t *obj, va_list ap) expr->type = type; expr->left = left; expr->right = right; + + /* unknown for now */ + expr->data_type = -1; return 0; } /* expr_init */ @@ -122,68 +108,140 @@ sdb_store_expr_t * sdb_store_expr_create(int op, sdb_store_expr_t *left, sdb_store_expr_t *right) { sdb_data_t value = SDB_DATA_INIT; + sdb_store_expr_t *e; if ((op < 0) || (SDB_DATA_CONCAT < op) || (! left) || (! right)) return NULL; - if (left->type || right->type) - return SDB_STORE_EXPR(sdb_object_create("store-expr", expr_type, + if (left->type || right->type) { + e = SDB_STORE_EXPR(sdb_object_create("store-expr", expr_type, op, left, right, NULL)); + e->data_type = sdb_data_expr_type(op, left->type, right->type); + return e; + } /* else: both expressions are constant values; evaluate now */ if (sdb_data_expr_eval(op, &left->data, &right->data, &value)) return NULL; - return SDB_STORE_EXPR(sdb_object_create("store-constvalue", expr_type, + e = SDB_STORE_EXPR(sdb_object_create("store-constvalue", expr_type, 0, NULL, NULL, &value)); + e->data_type = value.type; + return e; } /* sdb_store_expr_create */ +sdb_store_expr_t * +sdb_store_expr_typed(int typ, sdb_store_expr_t *expr) +{ + sdb_data_t value = { SDB_TYPE_INTEGER, { .integer = typ } }; + sdb_store_expr_t *e; + + if ((typ < SDB_HOST) || (SDB_ATTRIBUTE < typ)) + return NULL; + + e = SDB_STORE_EXPR(sdb_object_create("store-typedexpr", expr_type, + TYPED_EXPR, expr, NULL, &value)); + e->data_type = expr->data_type; + return e; +} /* sdb_store_expr_typed */ + sdb_store_expr_t * sdb_store_expr_fieldvalue(int field) { sdb_data_t value = { SDB_TYPE_INTEGER, { .integer = field } }; - if ((field < 0) || (SDB_FIELD_BACKEND < field)) + sdb_store_expr_t *e; + + if ((field < SDB_FIELD_NAME) || (SDB_FIELD_BACKEND < field)) return NULL; - return SDB_STORE_EXPR(sdb_object_create("store-fieldvalue", expr_type, - -1, NULL, NULL, &value)); + e = SDB_STORE_EXPR(sdb_object_create("store-fieldvalue", expr_type, + FIELD_VALUE, NULL, NULL, &value)); + e->data_type = SDB_FIELD_TYPE(field); + return e; } /* sdb_store_expr_fieldvalue */ +sdb_store_expr_t * +sdb_store_expr_attrvalue(const char *name) +{ + sdb_data_t value = { SDB_TYPE_STRING, { .string = NULL} }; + sdb_store_expr_t *expr; + + value.data.string = strdup(name); + if (! value.data.string) + return NULL; + + expr = SDB_STORE_EXPR(sdb_object_create("store-attrvalue", expr_type, + ATTR_VALUE, NULL, NULL, &value)); + if (! expr) + free(value.data.string); + expr->data_type = -1; + return expr; +} /* sdb_store_expr_attrvalue */ + sdb_store_expr_t * sdb_store_expr_constvalue(const sdb_data_t *value) { sdb_data_t data = SDB_DATA_INIT; + sdb_store_expr_t *e; + if (sdb_data_copy(&data, value)) return NULL; - return SDB_STORE_EXPR(sdb_object_create("store-constvalue", expr_type, + e = SDB_STORE_EXPR(sdb_object_create("store-constvalue", expr_type, 0, NULL, NULL, &data)); + e->data_type = data.type; + return e; } /* sdb_store_expr_constvalue */ int sdb_store_expr_eval(sdb_store_expr_t *expr, sdb_store_obj_t *obj, - sdb_data_t *res) + sdb_data_t *res, sdb_store_matcher_t *filter) { sdb_data_t v1 = SDB_DATA_INIT, v2 = SDB_DATA_INIT; + int status = 0; if ((! expr) || (! res)) return -1; + if (filter && obj && (! sdb_store_matcher_matches(filter, obj, NULL))) + obj = NULL; /* this object does not exist */ + if (! expr->type) return sdb_data_copy(res, &expr->data); - else if (expr->type < 0) + else if (expr->type == FIELD_VALUE) return sdb_store_get_field(obj, (int)expr->data.data.integer, res); + else if (expr->type == ATTR_VALUE) { + status = sdb_store_get_attr(obj, expr->data.data.string, res, filter); + if ((status < 0) && obj) { + /* attribute does not exist => NULL */ + status = 0; + res->type = SDB_TYPE_STRING; + res->data.string = NULL; + } + return status; + } + else if (expr->type == TYPED_EXPR) { + int typ = (int)expr->data.data.integer; + if (typ != obj->type) { + /* we support self-references and { service, metric } -> host */ + if ((typ != SDB_HOST) + || ((obj->type != SDB_SERVICE) + && (obj->type != SDB_METRIC))) + return -1; + obj = obj->parent; + } + return sdb_store_expr_eval(expr->left, obj, res, filter); + } - if (sdb_store_expr_eval(expr->left, obj, &v1)) + if (sdb_store_expr_eval(expr->left, obj, &v1, filter)) return -1; - if (sdb_store_expr_eval(expr->right, obj, &v2)) { + if (sdb_store_expr_eval(expr->right, obj, &v2, filter)) { sdb_data_free_datum(&v1); return -1; } - if (sdb_data_expr_eval(expr->type, &v1, &v2, res)) { - sdb_data_free_datum(&v1); - sdb_data_free_datum(&v2); - return -1; - } - return 0; + if (sdb_data_expr_eval(expr->type, &v1, &v2, res)) + status = -1; + sdb_data_free_datum(&v1); + sdb_data_free_datum(&v2); + return status; } /* sdb_store_expr_eval */ /* vim: set tw=78 sw=4 ts=4 noexpandtab : */