X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;f=src%2Fcore%2Fstore.c;h=22e177ca8f95d4a1246f443b73f0457f48678f2f;hb=4e6a5f2d7cb3796f92dd3d89e6090de80494f816;hp=753b9815b0bd4b23be3bee71cfcfacb651060f28;hpb=cd3ad5506d188fdb7500d44e0e88a05c89ebf4f6;p=sysdb.git diff --git a/src/core/store.c b/src/core/store.c index 753b981..22e177c 100644 --- a/src/core/store.c +++ b/src/core/store.c @@ -26,7 +26,7 @@ */ #include "sysdb.h" -#include "core/store.h" +#include "core/store-private.h" #include "core/plugin.h" #include "utils/error.h" #include "utils/llist.h" @@ -55,50 +55,6 @@ static pthread_rwlock_t obj_lock = PTHREAD_RWLOCK_INITIALIZER; static sdb_type_t sdb_store_obj_type; static sdb_type_t sdb_attribute_type; -struct sdb_store_base { - sdb_object_t super; - - /* object type */ - int type; - - /* common meta information */ - sdb_time_t last_update; - sdb_store_base_t *parent; -}; -#define STORE_BASE(obj) ((sdb_store_base_t *)(obj)) -#define STORE_CONST_BASE(obj) ((const sdb_store_base_t *)(obj)) - -typedef struct { - sdb_store_base_t super; - - sdb_data_t value; -} sdb_attribute_t; -#define SDB_ATTR(obj) ((sdb_attribute_t *)(obj)) -#define SDB_CONST_ATTR(obj) ((const sdb_attribute_t *)(obj)) - -typedef struct { - sdb_store_base_t super; - - sdb_llist_t *children; - sdb_llist_t *attributes; -} sdb_store_obj_t; -#define SDB_STORE_OBJ(obj) ((sdb_store_obj_t *)(obj)) -#define SDB_CONST_STORE_OBJ(obj) ((const sdb_store_obj_t *)(obj)) - -enum { - SDB_HOST = 1, - SDB_SERVICE, - SDB_ATTRIBUTE, -}; -#define TYPE_TO_NAME(t) \ - (((t) == SDB_HOST) ? "host" \ - : ((t) == SDB_SERVICE) ? "service" \ - : ((t) == SDB_ATTRIBUTE) ? "attribute" : "unknown") - -/* shortcuts for accessing the sdb_store_obj_t attributes - * of inheriting objects */ -#define _last_update super.last_update - static int store_base_init(sdb_object_t *obj, va_list ap) { @@ -413,9 +369,11 @@ store_obj_tojson(sdb_llist_t *list, int type, sdb_strbuf_t *buf) sdb_strbuf_append(buf, "{\"name\": \"%s\", ", SDB_OBJ(sobj)->name); if (type == SDB_ATTRIBUTE) { - sdb_strbuf_append(buf, "\"value\": "); - sdb_data_format(&SDB_ATTR(sobj)->value, buf); - sdb_strbuf_append(buf, ", \"last_update\": \"%s\"}", time_str); + char tmp[sdb_data_strlen(&SDB_ATTR(sobj)->value) + 1]; + sdb_data_format(&SDB_ATTR(sobj)->value, tmp, sizeof(tmp), + SDB_DOUBLE_QUOTED); + sdb_strbuf_append(buf, "\"value\": %s, \"last_update\": \"%s\"}", + tmp, time_str); } else sdb_strbuf_append(buf, "\"last_update\": \"%s\"}", time_str); @@ -432,6 +390,13 @@ store_obj_tojson(sdb_llist_t *list, int type, sdb_strbuf_t *buf) * public API */ +void +sdb_store_clear(void) +{ + sdb_llist_destroy(obj_list); + obj_list = NULL; +} /* sdb_store_clear */ + int sdb_store_host(const char *name, sdb_time_t last_update) {