#include "common.h"
#define HOSTNAME_MAX 1024
char *hostname = "unknown";
void rrd_stats_api_v1_chart(RRDSET *st, BUFFER *wb)
{
pthread_rwlock_rdlock(&st->rwlock);
buffer_sprintf(wb,
"\t\t{\n"
"\t\t\t\"id\": \"%s\",\n"
"\t\t\t\"name\": \"%s\",\n"
"\t\t\t\"type\": \"%s\",\n"
"\t\t\t\"family\": \"%s\",\n"
"\t\t\t\"context\": \"%s\",\n"
"\t\t\t\"title\": \"%s\",\n"
"\t\t\t\"priority\": %ld,\n"
"\t\t\t\"enabled\": %s,\n"
"\t\t\t\"units\": \"%s\",\n"
"\t\t\t\"data_url\": \"/api/v1/data?chart=%s\",\n"
"\t\t\t\"chart_type\": \"%s\",\n"
"\t\t\t\"duration\": %ld,\n"
"\t\t\t\"first_entry\": %ld,\n"
"\t\t\t\"last_entry\": %ld,\n"
"\t\t\t\"update_every\": %d,\n"
"\t\t\t\"dimensions\": {\n"
, st->id
, st->name
, st->type
, st->family
, st->context
, st->title
, st->priority
, st->enabled?"true":"false"
, st->units
, st->name
, rrdset_type_name(st->chart_type)
, st->entries * st->update_every
, rrdset_first_entry_t(st)
, rrdset_last_entry_t(st)
, st->update_every
);
unsigned long memory = st->memsize;
int c = 0;
RRDDIM *rd;
for(rd = st->dimensions; rd ; rd = rd->next) {
if(rd->flags & RRDDIM_FLAG_HIDDEN) continue;
memory += rd->memsize;
buffer_sprintf(wb,
"%s"
"\t\t\t\t\"%s\": { \"name\": \"%s\" }"
, c?",\n":""
, rd->id
, rd->name
);
c++;
}
buffer_strcat(wb, "\n\t\t\t},\n\t\t\t\"green\": ");
buffer_rrd_value(wb, st->green);
buffer_strcat(wb, ",\n\t\t\t\"red\": ");
buffer_rrd_value(wb, st->red);
buffer_sprintf(wb,
"\n\t\t}"
);
pthread_rwlock_unlock(&st->rwlock);
}
void rrd_stats_api_v1_charts(BUFFER *wb)
{
long c;
RRDSET *st;
buffer_sprintf(wb, "{\n"
"\t\"hostname\": \"%s\""
",\n\t\"update_every\": %d"
",\n\t\"history\": %d"
",\n\t\"charts\": {"
, hostname
, rrd_update_every
, rrd_default_history_entries
);
pthread_rwlock_rdlock(&localhost.rrdset_root_rwlock);
for(st = localhost.rrdset_root, c = 0; st ; st = st->next) {
if(st->enabled && st->dimensions) {
if(c) buffer_strcat(wb, ",");
buffer_strcat(wb, "\n\t\t\"");
buffer_strcat(wb, st->id);
buffer_strcat(wb, "\": ");
rrd_stats_api_v1_chart(st, wb);
c++;
}
}
pthread_rwlock_unlock(&localhost.rrdset_root_rwlock);
buffer_strcat(wb, "\n\t}\n}\n");
}
unsigned long rrd_stats_one_json(RRDSET *st, char *options, BUFFER *wb)
{
time_t now = time(NULL);
pthread_rwlock_rdlock(&st->rwlock);
buffer_sprintf(wb,
"\t\t{\n"
"\t\t\t\"id\": \"%s\",\n"
"\t\t\t\"name\": \"%s\",\n"
"\t\t\t\"type\": \"%s\",\n"
"\t\t\t\"family\": \"%s\",\n"
"\t\t\t\"context\": \"%s\",\n"
"\t\t\t\"title\": \"%s\",\n"
"\t\t\t\"priority\": %ld,\n"
"\t\t\t\"enabled\": %d,\n"
"\t\t\t\"units\": \"%s\",\n"
"\t\t\t\"url\": \"/data/%s/%s\",\n"
"\t\t\t\"chart_type\": \"%s\",\n"
"\t\t\t\"counter\": %lu,\n"
"\t\t\t\"entries\": %ld,\n"
"\t\t\t\"first_entry_t\": %ld,\n"
"\t\t\t\"last_entry\": %lu,\n"
"\t\t\t\"last_entry_t\": %ld,\n"
"\t\t\t\"last_entry_secs_ago\": %ld,\n"
"\t\t\t\"update_every\": %d,\n"
"\t\t\t\"isdetail\": %d,\n"
"\t\t\t\"usec_since_last_update\": %llu,\n"
"\t\t\t\"collected_total\": " TOTAL_NUMBER_FORMAT ",\n"
"\t\t\t\"last_collected_total\": " TOTAL_NUMBER_FORMAT ",\n"
"\t\t\t\"dimensions\": [\n"
, st->id
, st->name
, st->type
, st->family
, st->context
, st->title
, st->priority
, st->enabled
, st->units
, st->name, options?options:""
, rrdset_type_name(st->chart_type)
, st->counter
, st->entries
, rrdset_first_entry_t(st)
, rrdset_last_slot(st)
, rrdset_last_entry_t(st)
, (now < rrdset_last_entry_t(st)) ? (time_t)0 : now - rrdset_last_entry_t(st)
, st->update_every
, st->isdetail
, st->usec_since_last_update
, st->collected_total
, st->last_collected_total
);
unsigned long memory = st->memsize;
RRDDIM *rd;
for(rd = st->dimensions; rd ; rd = rd->next) {
memory += rd->memsize;
buffer_sprintf(wb,
"\t\t\t\t{\n"
"\t\t\t\t\t\"id\": \"%s\",\n"
"\t\t\t\t\t\"name\": \"%s\",\n"
"\t\t\t\t\t\"entries\": %ld,\n"
"\t\t\t\t\t\"isHidden\": %d,\n"
"\t\t\t\t\t\"algorithm\": \"%s\",\n"
"\t\t\t\t\t\"multiplier\": %ld,\n"
"\t\t\t\t\t\"divisor\": %ld,\n"
"\t\t\t\t\t\"last_entry_t\": %ld,\n"
"\t\t\t\t\t\"collected_value\": " COLLECTED_NUMBER_FORMAT ",\n"
"\t\t\t\t\t\"calculated_value\": " CALCULATED_NUMBER_FORMAT ",\n"
"\t\t\t\t\t\"last_collected_value\": " COLLECTED_NUMBER_FORMAT ",\n"
"\t\t\t\t\t\"last_calculated_value\": " CALCULATED_NUMBER_FORMAT ",\n"
"\t\t\t\t\t\"memory\": %lu\n"
"\t\t\t\t}%s\n"
, rd->id
, rd->name
, rd->entries
, (rd->flags & RRDDIM_FLAG_HIDDEN)?1:0
, rrddim_algorithm_name(rd->algorithm)
, rd->multiplier
, rd->divisor
, rd->last_collected_time.tv_sec
, rd->collected_value
, rd->calculated_value
, rd->last_collected_value
, rd->last_calculated_value
, rd->memsize
, rd->next?",":""
);
}
buffer_sprintf(wb,
"\t\t\t],\n"
"\t\t\t\"memory\" : %lu\n"
"\t\t}"
, memory
);
pthread_rwlock_unlock(&st->rwlock);
return memory;
}
#define RRD_GRAPH_JSON_HEADER "{\n\t\"charts\": [\n"
#define RRD_GRAPH_JSON_FOOTER "\n\t]\n}\n"
void rrd_stats_graph_json(RRDSET *st, char *options, BUFFER *wb)
{
buffer_strcat(wb, RRD_GRAPH_JSON_HEADER);
rrd_stats_one_json(st, options, wb);
buffer_strcat(wb, RRD_GRAPH_JSON_FOOTER);
}
void rrd_stats_all_json(BUFFER *wb)
{
unsigned long memory = 0;
long c;
RRDSET *st;
buffer_strcat(wb, RRD_GRAPH_JSON_HEADER);
pthread_rwlock_rdlock(&localhost.rrdset_root_rwlock);
for(st = localhost.rrdset_root, c = 0; st ; st = st->next) {
if(st->enabled && st->dimensions) {
if(c) buffer_strcat(wb, ",\n");
memory += rrd_stats_one_json(st, NULL, wb);
c++;
}
}
pthread_rwlock_unlock(&localhost.rrdset_root_rwlock);
buffer_sprintf(wb, "\n\t],\n"
"\t\"hostname\": \"%s\",\n"
"\t\"update_every\": %d,\n"
"\t\"history\": %d,\n"
"\t\"memory\": %lu\n"
"}\n"
, hostname
, rrd_update_every
, rrd_default_history_entries
, memory
);
}
// ----------------------------------------------------------------------------
// RRDR dimension options
#define RRDR_EMPTY 0x01 // the dimension contains / the value is empty (null)
#define RRDR_RESET 0x02 // the dimension contains / the value is reset
#define RRDR_HIDDEN 0x04 // the dimension contains / the value is hidden
#define RRDR_NONZERO 0x08 // the dimension contains / the value is non-zero
// RRDR result options
#define RRDR_RESULT_OPTION_ABSOLUTE 0x00000001
#define RRDR_RESULT_OPTION_RELATIVE 0x00000002
typedef struct rrdresult {
RRDSET *st; // the chart this result refers to
uint32_t result_options; // RRDR_RESULT_OPTION_*
int d; // the number of dimensions
long n; // the number of values in the arrays
long rows; // the number of rows used
uint8_t *od; // the options for the dimensions
time_t *t; // array of n timestamps
calculated_number *v; // array n x d values
uint8_t *o; // array n x d options
long c; // current line ( -1 ~ n ), ( -1 = none, use rrdr_rows() to get number of rows )
long group; // how many collected values were grouped for each row
int update_every; // what is the suggested update frequency in seconds
calculated_number min;
calculated_number max;
time_t before;
time_t after;
int has_st_lock; // if st is read locked by us
} RRDR;
#define rrdr_rows(r) ((r)->rows)
/*
static void rrdr_dump(RRDR *r)
{
long c, i;
RRDDIM *d;
fprintf(stderr, "\nCHART %s (%s)\n", r->st->id, r->st->name);
for(c = 0, d = r->st->dimensions; d ;c++, d = d->next) {
fprintf(stderr, "DIMENSION %s (%s), %s%s%s%s\n"
, d->id
, d->name
, (r->od[c] & RRDR_EMPTY)?"EMPTY ":""
, (r->od[c] & RRDR_RESET)?"RESET ":""
, (r->od[c] & RRDR_HIDDEN)?"HIDDEN ":""
, (r->od[c] & RRDR_NONZERO)?"NONZERO ":""
);
}
if(r->rows <= 0) {
fprintf(stderr, "RRDR does not have any values in it.\n");
return;
}
fprintf(stderr, "RRDR includes %d values in it:\n", r->rows);
// for each line in the array
for(i = 0; i < r->rows ;i++) {
calculated_number *cn = &r->v[ i * r->d ];
uint8_t *co = &r->o[ i * r->d ];
// print the id and the timestamp of the line
fprintf(stderr, "%ld %ld ", i + 1, r->t[i]);
// for each dimension
for(c = 0, d = r->st->dimensions; d ;c++, d = d->next) {
if(unlikely(r->od[c] & RRDR_HIDDEN)) continue;
if(unlikely(!(r->od[c] & RRDR_NONZERO))) continue;
if(co[c] & RRDR_EMPTY)
fprintf(stderr, "null ");
else
fprintf(stderr, CALCULATED_NUMBER_FORMAT " %s%s%s%s "
, cn[c]
, (co[c] & RRDR_EMPTY)?"E":" "
, (co[c] & RRDR_RESET)?"R":" "
, (co[c] & RRDR_HIDDEN)?"H":" "
, (co[c] & RRDR_NONZERO)?"N":" "
);
}
fprintf(stderr, "\n");
}
}
*/
void rrdr_disable_not_selected_dimensions(RRDR *r, const char *dims)
{
char b[strlen(dims) + 1];
char *o = b, *tok;
strcpy(o, dims);
long c;
RRDDIM *d;
// disable all of them
for(c = 0, d = r->st->dimensions; d ;c++, d = d->next)
r->od[c] |= RRDR_HIDDEN;
while(o && *o && (tok = mystrsep(&o, ",|"))) {
if(!*tok) continue;
uint32_t hash = simple_hash(tok);
// find it and enable it
for(c = 0, d = r->st->dimensions; d ;c++, d = d->next) {
if(unlikely((hash == d->hash && !strcmp(d->id, tok)) || !strcmp(d->name, tok))) {
r->od[c] &= ~RRDR_HIDDEN;
// since the user needs this dimension
// make it appear as NONZERO, to return it
// even if the dimension has only zeros
r->od[c] |= RRDR_NONZERO;
}
}
}
}
void rrdr_buffer_print_format(BUFFER *wb, uint32_t format)
{
switch(format) {
case DATASOURCE_JSON:
buffer_strcat(wb, DATASOURCE_FORMAT_JSON);
break;
case DATASOURCE_DATATABLE_JSON:
buffer_strcat(wb, DATASOURCE_FORMAT_DATATABLE_JSON);
break;
case DATASOURCE_DATATABLE_JSONP:
buffer_strcat(wb, DATASOURCE_FORMAT_DATATABLE_JSONP);
break;
case DATASOURCE_JSONP:
buffer_strcat(wb, DATASOURCE_FORMAT_JSONP);
break;
case DATASOURCE_SSV:
buffer_strcat(wb, DATASOURCE_FORMAT_SSV);
break;
case DATASOURCE_CSV:
buffer_strcat(wb, DATASOURCE_FORMAT_CSV);
break;
case DATASOURCE_TSV:
buffer_strcat(wb, DATASOURCE_FORMAT_TSV);
break;
case DATASOURCE_HTML:
buffer_strcat(wb, DATASOURCE_FORMAT_HTML);
break;
case DATASOURCE_JS_ARRAY:
buffer_strcat(wb, DATASOURCE_FORMAT_JS_ARRAY);
break;
case DATASOURCE_SSV_COMMA:
buffer_strcat(wb, DATASOURCE_FORMAT_SSV_COMMA);
break;
default:
buffer_strcat(wb, "unknown");
break;
}
}
uint32_t rrdr_check_options(RRDR *r, uint32_t options, const char *dims)
{
if(options & RRDR_OPTION_NONZERO) {
long i;
if(dims && *dims) {
// the caller wants specific dimensions
// disable NONZERO option
// to make sure we don't accidentally prevent
// the specific dimensions from being returned
i = 0;
}
else {
// find how many dimensions are not zero
long c;
RRDDIM *rd;
for(c = 0, i = 0, rd = r->st->dimensions; rd && c < r->d ; c++, rd = rd->next) {
if(unlikely(r->od[c] & RRDR_HIDDEN)) continue;
if(unlikely(!(r->od[c] & RRDR_NONZERO))) continue;
i++;
}
}
// if with nonzero we get i = 0 (no dimensions will be returned)
// disable nonzero to show all dimensions
if(!i) options &= ~RRDR_OPTION_NONZERO;
}
return options;
}
void rrdr_json_wrapper_begin(RRDR *r, BUFFER *wb, uint32_t format, uint32_t options, int string_value)
{
long rows = rrdr_rows(r);
long c, i;
RRDDIM *rd;
//info("JSONWRAPPER(): %s: BEGIN", r->st->id);
char kq[2] = "", // key quote
sq[2] = ""; // string quote
if( options & RRDR_OPTION_GOOGLE_JSON ) {
kq[0] = '\0';
sq[0] = '\'';
}
else {
kq[0] = '"';
sq[0] = '"';
}
buffer_sprintf(wb, "{\n"
" %sapi%s: 1,\n"
" %sid%s: %s%s%s,\n"
" %sname%s: %s%s%s,\n"
" %sview_update_every%s: %d,\n"
" %supdate_every%s: %d,\n"
" %sfirst_entry%s: %u,\n"
" %slast_entry%s: %u,\n"
" %sbefore%s: %u,\n"
" %safter%s: %u,\n"
" %sdimension_names%s: ["
, kq, kq
, kq, kq, sq, r->st->id, sq
, kq, kq, sq, r->st->name, sq
, kq, kq, r->update_every
, kq, kq, r->st->update_every
, kq, kq, (uint32_t)rrdset_first_entry_t(r->st)
, kq, kq, (uint32_t)rrdset_last_entry_t(r->st)
, kq, kq, (uint32_t)r->before
, kq, kq, (uint32_t)r->after
, kq, kq);
for(c = 0, i = 0, rd = r->st->dimensions; rd && c < r->d ;c++, rd = rd->next) {
if(unlikely(r->od[c] & RRDR_HIDDEN)) continue;
if(unlikely((options & RRDR_OPTION_NONZERO) && !(r->od[c] & RRDR_NONZERO))) continue;
if(i) buffer_strcat(wb, ", ");
buffer_strcat(wb, sq);
buffer_strcat(wb, rd->name);
buffer_strcat(wb, sq);
i++;
}
if(!i) {
#ifdef NETDATA_INTERNAL_CHECKS
error("RRDR is empty for %s (RRDR has %d dimensions, options is 0x%08x)", r->st->id, r->d, options);
#endif
rows = 0;
buffer_strcat(wb, sq);
buffer_strcat(wb, "no data");
buffer_strcat(wb, sq);
}
buffer_sprintf(wb, "],\n"
" %sdimension_ids%s: ["
, kq, kq);
for(c = 0, i = 0, rd = r->st->dimensions; rd && c < r->d ;c++, rd = rd->next) {
if(unlikely(r->od[c] & RRDR_HIDDEN)) continue;
if(unlikely((options & RRDR_OPTION_NONZERO) && !(r->od[c] & RRDR_NONZERO))) continue;
if(i) buffer_strcat(wb, ", ");
buffer_strcat(wb, sq);
buffer_strcat(wb, rd->id);
buffer_strcat(wb, sq);
i++;
}
if(!i) {
rows = 0;
buffer_strcat(wb, sq);
buffer_strcat(wb, "no data");
buffer_strcat(wb, sq);
}
buffer_sprintf(wb, "],\n"
" %slatest_values%s: ["
, kq, kq);
for(c = 0, i = 0, rd = r->st->dimensions; rd && c < r->d ;c++, rd = rd->next) {
if(unlikely(r->od[c] & RRDR_HIDDEN)) continue;
if(unlikely((options & RRDR_OPTION_NONZERO) && !(r->od[c] & RRDR_NONZERO))) continue;
if(i) buffer_strcat(wb, ", ");
i++;
storage_number n = rd->values[rrdset_last_slot(r->st)];
if(!does_storage_number_exist(n))
buffer_strcat(wb, "null");
else
buffer_rrd_value(wb, unpack_storage_number(n));
}
if(!i) {
rows = 0;
buffer_strcat(wb, "null");
}
buffer_sprintf(wb, "],\n"
" %sview_latest_values%s: ["
, kq, kq);
i = 0;
if(rows) {
for(c = 0, i = 0, rd = r->st->dimensions; rd && c < r->d ;c++, rd = rd->next) {
if(unlikely(r->od[c] & RRDR_HIDDEN)) continue;
if(unlikely((options & RRDR_OPTION_NONZERO) && !(r->od[c] & RRDR_NONZERO))) continue;
if(i) buffer_strcat(wb, ", ");
i++;
calculated_number *cn = &r->v[ (0) * r->d ];
uint8_t *co = &r->o[ (0) * r->d ];
if(co[c] & RRDR_EMPTY)
buffer_strcat(wb, "null");
else
buffer_rrd_value(wb, cn[c]);
}
}
if(!i) {
rows = 0;
buffer_strcat(wb, "null");
}
buffer_sprintf(wb, "],\n"
" %sdimensions%s: %ld,\n"
" %spoints%s: %ld,\n"
" %sformat%s: %s"
, kq, kq, i
, kq, kq, rows
, kq, kq, sq
);
rrdr_buffer_print_format(wb, format);
buffer_sprintf(wb, "%s,\n"
" %sresult%s: "
, sq
, kq, kq
);
if(string_value) buffer_strcat(wb, sq);
//info("JSONWRAPPER(): %s: END", r->st->id);
}
void rrdr_json_wrapper_end(RRDR *r, BUFFER *wb, uint32_t format, uint32_t options, int string_value)
{
(void)format;
char kq[2] = "", // key quote
sq[2] = ""; // string quote
if( options & RRDR_OPTION_GOOGLE_JSON ) {
kq[0] = '\0';
sq[0] = '\'';
}
else {
kq[0] = '"';
sq[0] = '"';
}
if(string_value) buffer_strcat(wb, sq);
buffer_sprintf(wb, ",\n %smin%s: ", kq, kq);
buffer_rrd_value(wb, r->min);
buffer_sprintf(wb, ",\n %smax%s: ", kq, kq);
buffer_rrd_value(wb, r->max);
buffer_strcat(wb, "\n}\n");
}
#define JSON_DATES_JS 1
#define JSON_DATES_TIMESTAMP 2
static void rrdr2json(RRDR *r, BUFFER *wb, uint32_t options, int datatable)
{
//info("RRD2JSON(): %s: BEGIN", r->st->id);
int row_annotations = 0, dates, dates_with_new = 0;
char kq[2] = "", // key quote
sq[2] = "", // string quote
pre_label[101] = "", // before each label
post_label[101] = "", // after each label
pre_date[101] = "", // the beginning of line, to the date
post_date[101] = "", // closing the date
pre_value[101] = "", // before each value
post_value[101] = "", // after each value
post_line[101] = "", // at the end of each row
normal_annotation[201] = "", // default row annotation
overflow_annotation[201] = "", // overflow row annotation
data_begin[101] = "", // between labels and values
finish[101] = ""; // at the end of everything
if(datatable) {
dates = JSON_DATES_JS;
if( options & RRDR_OPTION_GOOGLE_JSON ) {
kq[0] = '\0';
sq[0] = '\'';
}
else {
kq[0] = '"';
sq[0] = '"';
}
row_annotations = 1;
snprintfz(pre_date, 100, " {%sc%s:[{%sv%s:%s", kq, kq, kq, kq, sq);
snprintfz(post_date, 100, "%s}", sq);
snprintfz(pre_label, 100, ",\n {%sid%s:%s%s,%slabel%s:%s", kq, kq, sq, sq, kq, kq, sq);
snprintfz(post_label, 100, "%s,%spattern%s:%s%s,%stype%s:%snumber%s}", sq, kq, kq, sq, sq, kq, kq, sq, sq);
snprintfz(pre_value, 100, ",{%sv%s:", kq, kq);
strcpy(post_value, "}");
strcpy(post_line, "]}");
snprintfz(data_begin, 100, "\n ],\n %srows%s:\n [\n", kq, kq);
strcpy(finish, "\n ]\n}");
snprintfz(overflow_annotation, 200, ",{%sv%s:%sRESET OR OVERFLOW%s},{%sv%s:%sThe counters have been wrapped.%s}", kq, kq, sq, sq, kq, kq, sq, sq);
snprintfz(normal_annotation, 200, ",{%sv%s:null},{%sv%s:null}", kq, kq, kq, kq);
buffer_sprintf(wb, "{\n %scols%s:\n [\n", kq, kq);
buffer_sprintf(wb, " {%sid%s:%s%s,%slabel%s:%stime%s,%spattern%s:%s%s,%stype%s:%sdatetime%s},\n", kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq);
buffer_sprintf(wb, " {%sid%s:%s%s,%slabel%s:%s%s,%spattern%s:%s%s,%stype%s:%sstring%s,%sp%s:{%srole%s:%sannotation%s}},\n", kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, kq, kq, sq, sq);
buffer_sprintf(wb, " {%sid%s:%s%s,%slabel%s:%s%s,%spattern%s:%s%s,%stype%s:%sstring%s,%sp%s:{%srole%s:%sannotationText%s}}", kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, kq, kq, sq, sq);
// remove the valueobjects flag
// google wants its own keys
if(options & RRDR_OPTION_OBJECTSROWS)
options &= ~RRDR_OPTION_OBJECTSROWS;
}
else {
kq[0] = '"';
sq[0] = '"';
if((options & RRDR_OPTION_SECONDS) || (options & RRDR_OPTION_MILLISECONDS)) {
dates = JSON_DATES_TIMESTAMP;
dates_with_new = 0;
}
else {
dates = JSON_DATES_JS;
dates_with_new = 1;
}
if( options & RRDR_OPTION_OBJECTSROWS )
strcpy(pre_date, " { ");
else
strcpy(pre_date, " [ ");
strcpy(pre_label, ", \"");
strcpy(post_label, "\"");
strcpy(pre_value, ", ");
if( options & RRDR_OPTION_OBJECTSROWS )
strcpy(post_line, "}");
else
strcpy(post_line, "]");
snprintfz(data_begin, 100, "],\n %sdata%s:\n [\n", kq, kq);
strcpy(finish, "\n ]\n}");
buffer_sprintf(wb, "{\n %slabels%s: [", kq, kq);
buffer_sprintf(wb, "%stime%s", sq, sq);
}
// -------------------------------------------------------------------------
// print the JSON header
long c, i;
RRDDIM *rd;
// print the header lines
for(c = 0, i = 0, rd = r->st->dimensions; rd && c < r->d ;c++, rd = rd->next) {
if(unlikely(r->od[c] & RRDR_HIDDEN)) continue;
if(unlikely((options & RRDR_OPTION_NONZERO) && !(r->od[c] & RRDR_NONZERO))) continue;
buffer_strcat(wb, pre_label);
buffer_strcat(wb, rd->name);
buffer_strcat(wb, post_label);
i++;
}
if(!i) {
buffer_strcat(wb, pre_label);
buffer_strcat(wb, "no data");
buffer_strcat(wb, post_label);
}
// print the begin of row data
buffer_strcat(wb, data_begin);
// if all dimensions are hidden, print a null
if(!i) {
buffer_strcat(wb, finish);
return;
}
long start = 0, end = rrdr_rows(r), step = 1;
if((options & RRDR_OPTION_REVERSED)) {
start = rrdr_rows(r) - 1;
end = -1;
step = -1;
}
// for each line in the array
calculated_number total = 1;
for(i = start; i != end ;i += step) {
calculated_number *cn = &r->v[ i * r->d ];
uint8_t *co = &r->o[ i * r->d ];
time_t now = r->t[i];
if(dates == JSON_DATES_JS) {
// generate the local date time
struct tm tmbuf, *tm = localtime_r(&now, &tmbuf);
if(!tm) { error("localtime_r() failed."); continue; }
if(likely(i != start)) buffer_strcat(wb, ",\n");
buffer_strcat(wb, pre_date);
if( options & RRDR_OPTION_OBJECTSROWS )
buffer_sprintf(wb, "%stime%s: ", kq, kq);
if(dates_with_new)
buffer_strcat(wb, "new ");
buffer_jsdate(wb, tm->tm_year + 1900, tm->tm_mon, tm->tm_mday, tm->tm_hour, tm->tm_min, tm->tm_sec);
buffer_strcat(wb, post_date);
if(row_annotations) {
// google supports one annotation per row
int annotation_found = 0;
for(c = 0, rd = r->st->dimensions; rd ;c++, rd = rd->next) {
if(co[c] & RRDR_RESET) {
buffer_strcat(wb, overflow_annotation);
annotation_found = 1;
break;
}
}
if(!annotation_found)
buffer_strcat(wb, normal_annotation);
}
}
else {
// print the timestamp of the line
if(likely(i != start)) buffer_strcat(wb, ",\n");
buffer_strcat(wb, pre_date);
if( options & RRDR_OPTION_OBJECTSROWS )
buffer_sprintf(wb, "%stime%s: ", kq, kq);
buffer_rrd_value(wb, (calculated_number)r->t[i]);
// in ms
if(options & RRDR_OPTION_MILLISECONDS) buffer_strcat(wb, "000");
buffer_strcat(wb, post_date);
}
if(unlikely(options & RRDR_OPTION_PERCENTAGE)) {
total = 0;
for(c = 0, rd = r->st->dimensions; rd && c < r->d ;c++, rd = rd->next) {
calculated_number n = cn[c];
if(likely((options & RRDR_OPTION_ABSOLUTE) && n < 0))
n = -n;
total += n;
}
// prevent a division by zero
if(total == 0) total = 1;
}
// for each dimension
for(c = 0, rd = r->st->dimensions; rd && c < r->d ;c++, rd = rd->next) {
if(unlikely(r->od[c] & RRDR_HIDDEN)) continue;
if(unlikely((options & RRDR_OPTION_NONZERO) && !(r->od[c] & RRDR_NONZERO))) continue;
calculated_number n = cn[c];
buffer_strcat(wb, pre_value);
if( options & RRDR_OPTION_OBJECTSROWS )
buffer_sprintf(wb, "%s%s%s: ", kq, rd->name, kq);
if(co[c] & RRDR_EMPTY) {
if(options & RRDR_OPTION_NULL2ZERO)
buffer_strcat(wb, "0");
else
buffer_strcat(wb, "null");
}
else {
if(unlikely((options & RRDR_OPTION_ABSOLUTE) && n < 0))
n = -n;
if(unlikely(options & RRDR_OPTION_PERCENTAGE))
n = n * 100 / total;
buffer_rrd_value(wb, n);
}
buffer_strcat(wb, post_value);
}
buffer_strcat(wb, post_line);
}
buffer_strcat(wb, finish);
//info("RRD2JSON(): %s: END", r->st->id);
}
static void rrdr2csv(RRDR *r, BUFFER *wb, uint32_t options, const char *startline, const char *separator, const char *endline, const char *betweenlines)
{
//info("RRD2CSV(): %s: BEGIN", r->st->id);
long c, i;
RRDDIM *d;
// print the csv header
for(c = 0, i = 0, d = r->st->dimensions; d && c < r->d ;c++, d = d->next) {
if(unlikely(r->od[c] & RRDR_HIDDEN)) continue;
if(unlikely((options & RRDR_OPTION_NONZERO) && !(r->od[c] & RRDR_NONZERO))) continue;
if(!i) {
buffer_strcat(wb, startline);
if(options & RRDR_OPTION_LABEL_QUOTES) buffer_strcat(wb, "\"");
buffer_strcat(wb, "time");
if(options & RRDR_OPTION_LABEL_QUOTES) buffer_strcat(wb, "\"");
}
buffer_strcat(wb, separator);
if(options & RRDR_OPTION_LABEL_QUOTES) buffer_strcat(wb, "\"");
buffer_strcat(wb, d->name);
if(options & RRDR_OPTION_LABEL_QUOTES) buffer_strcat(wb, "\"");
i++;
}
buffer_strcat(wb, endline);
if(!i) {
// no dimensions present
return;
}
long start = 0, end = rrdr_rows(r), step = 1;
if((options & RRDR_OPTION_REVERSED)) {
start = rrdr_rows(r) - 1;
end = -1;
step = -1;
}
// for each line in the array
calculated_number total = 1;
for(i = start; i != end ;i += step) {
calculated_number *cn = &r->v[ i * r->d ];
uint8_t *co = &r->o[ i * r->d ];
buffer_strcat(wb, betweenlines);
buffer_strcat(wb, startline);
time_t now = r->t[i];
if((options & RRDR_OPTION_SECONDS) || (options & RRDR_OPTION_MILLISECONDS)) {
// print the timestamp of the line
buffer_rrd_value(wb, (calculated_number)now);
// in ms
if(options & RRDR_OPTION_MILLISECONDS) buffer_strcat(wb, "000");
}
else {
// generate the local date time
struct tm tmbuf, *tm = localtime_r(&now, &tmbuf);
if(!tm) { error("localtime() failed."); continue; }
buffer_date(wb, tm->tm_year + 1900, tm->tm_mon + 1, tm->tm_mday, tm->tm_hour, tm->tm_min, tm->tm_sec);
}
if(unlikely(options & RRDR_OPTION_PERCENTAGE)) {
total = 0;
for(c = 0, d = r->st->dimensions; d && c < r->d ;c++, d = d->next) {
calculated_number n = cn[c];
if(likely((options & RRDR_OPTION_ABSOLUTE) && n < 0))
n = -n;
total += n;
}
// prevent a division by zero
if(total == 0) total = 1;
}
// for each dimension
for(c = 0, d = r->st->dimensions; d && c < r->d ;c++, d = d->next) {
if(unlikely(r->od[c] & RRDR_HIDDEN)) continue;
if(unlikely((options & RRDR_OPTION_NONZERO) && !(r->od[c] & RRDR_NONZERO))) continue;
buffer_strcat(wb, separator);
calculated_number n = cn[c];
if(co[c] & RRDR_EMPTY) {
if(options & RRDR_OPTION_NULL2ZERO)
buffer_strcat(wb, "0");
else
buffer_strcat(wb, "null");
}
else {
if(unlikely((options & RRDR_OPTION_ABSOLUTE) && n < 0))
n = -n;
if(unlikely(options & RRDR_OPTION_PERCENTAGE))
n = n * 100 / total;
buffer_rrd_value(wb, n);
}
}
buffer_strcat(wb, endline);
}
//info("RRD2CSV(): %s: END", r->st->id);
}
inline static calculated_number rrdr2value(RRDR *r, long i, uint32_t options, int *all_values_are_null) {
long c;
RRDDIM *d;
calculated_number *cn = &r->v[ i * r->d ];
uint8_t *co = &r->o[ i * r->d ];
calculated_number sum = 0, min = 0, max = 0, v;
int all_null = 1, init = 1;
calculated_number total = 1;
if(unlikely(options & RRDR_OPTION_PERCENTAGE)) {
total = 0;
for(c = 0, d = r->st->dimensions; d && c < r->d ;c++, d = d->next) {
calculated_number n = cn[c];
if(likely((options & RRDR_OPTION_ABSOLUTE) && n < 0))
n = -n;
total += n;
}
// prevent a division by zero
if(total == 0) total = 1;
}
// for each dimension
for(c = 0, d = r->st->dimensions; d && c < r->d ;c++, d = d->next) {
if(unlikely(r->od[c] & RRDR_HIDDEN)) continue;
if(unlikely((options & RRDR_OPTION_NONZERO) && !(r->od[c] & RRDR_NONZERO))) continue;
calculated_number n = cn[c];
if(likely((options & RRDR_OPTION_ABSOLUTE) && n < 0))
n = -n;
if(unlikely(options & RRDR_OPTION_PERCENTAGE))
n = n * 100 / total;
if(unlikely(init)) {
if(n > 0) {
min = 0;
max = n;
}
else {
min = n;
max = 0;
}
init = 0;
}
if(likely(!(co[c] & RRDR_EMPTY))) {
all_null = 0;
sum += n;
}
if(n < min) min = n;
if(n > max) max = n;
}
if(unlikely(all_null)) {
if(likely(all_values_are_null))
*all_values_are_null = 1;
return 0;
}
else {
if(likely(all_values_are_null))
*all_values_are_null = 0;
}
if(options & RRDR_OPTION_MIN2MAX)
v = max - min;
else
v = sum;
return v;
}
static void rrdr2ssv(RRDR *r, BUFFER *wb, uint32_t options, const char *prefix, const char *separator, const char *suffix)
{
//info("RRD2SSV(): %s: BEGIN", r->st->id);
long i;
buffer_strcat(wb, prefix);
long start = 0, end = rrdr_rows(r), step = 1;
if((options & RRDR_OPTION_REVERSED)) {
start = rrdr_rows(r) - 1;
end = -1;
step = -1;
}
// for each line in the array
for(i = start; i != end ;i += step) {
int all_values_are_null = 0;
calculated_number v = rrdr2value(r, i, options, &all_values_are_null);
if(likely(i != start)) {
if(r->min > v) r->min = v;
if(r->max < v) r->max = v;
}
else {
r->min = v;
r->max = v;
}
if(likely(i != start))
buffer_strcat(wb, separator);
if(all_values_are_null) {
if(options & RRDR_OPTION_NULL2ZERO)
buffer_strcat(wb, "0");
else
buffer_strcat(wb, "null");
}
else
buffer_rrd_value(wb, v);
}
buffer_strcat(wb, suffix);
//info("RRD2SSV(): %s: END", r->st->id);
}
inline static calculated_number *rrdr_line_values(RRDR *r)
{
return &r->v[ r->c * r->d ];
}
inline static uint8_t *rrdr_line_options(RRDR *r)
{
return &r->o[ r->c * r->d ];
}
inline static int rrdr_line_init(RRDR *r, time_t t)
{
r->c++;
if(unlikely(r->c >= r->n)) {
error("requested to step above RRDR size for chart %s", r->st->name);
r->c = r->n - 1;
}
// save the time
r->t[r->c] = t;
return 1;
}
inline static void rrdr_lock_rrdset(RRDR *r) {
if(unlikely(!r)) {
error("NULL value given!");
return;
}
pthread_rwlock_rdlock(&r->st->rwlock);
r->has_st_lock = 1;
}
inline static void rrdr_unlock_rrdset(RRDR *r) {
if(unlikely(!r)) {
error("NULL value given!");
return;
}
if(likely(r->has_st_lock)) {
pthread_rwlock_unlock(&r->st->rwlock);
r->has_st_lock = 0;
}
}
inline static void rrdr_free(RRDR *r)
{
if(unlikely(!r)) {
error("NULL value given!");
return;
}
rrdr_unlock_rrdset(r);
freez(r->t);
freez(r->v);
freez(r->o);
freez(r->od);
freez(r);
}
inline void rrdr_done(RRDR *r)
{
r->rows = r->c + 1;
r->c = 0;
}
static RRDR *rrdr_create(RRDSET *st, long n)
{
if(unlikely(!st)) {
error("NULL value given!");
return NULL;
}
RRDR *r = callocz(1, sizeof(RRDR));
r->st = st;
rrdr_lock_rrdset(r);
RRDDIM *rd;
for(rd = st->dimensions ; rd ; rd = rd->next) r->d++;
r->n = n;
r->t = mallocz(n * sizeof(time_t));
r->v = mallocz(n * r->d * sizeof(calculated_number));
r->o = mallocz(n * r->d * sizeof(uint8_t));
r->od = mallocz(r->d * sizeof(uint8_t));
// set the hidden flag on hidden dimensions
int c;
for(c = 0, rd = st->dimensions ; rd ; c++, rd = rd->next) {
if(unlikely(rd->flags & RRDDIM_FLAG_HIDDEN)) r->od[c] = RRDR_HIDDEN;
else r->od[c] = 0;
}
r->c = -1;
r->group = 1;
r->update_every = 1;
return r;
}
RRDR *rrd2rrdr(RRDSET *st, long points, long long after, long long before, int group_method, int aligned)
{
int debug = st->debug;
int absolute_period_requested = -1;
time_t first_entry_t = rrdset_first_entry_t(st);
time_t last_entry_t = rrdset_last_entry_t(st);
if(before == 0 && after == 0) {
before = last_entry_t;
after = first_entry_t;
absolute_period_requested = 0;
}
// allow relative for before and after
if(((before < 0)?-before:before) <= (st->update_every * st->entries)) {
before = last_entry_t + before;
absolute_period_requested = 0;
}
if(((after < 0)?-after:after) <= (st->update_every * st->entries)) {
if(after == 0) after = -st->update_every;
after = before + after;
absolute_period_requested = 0;
}
if(absolute_period_requested == -1)
absolute_period_requested = 1;
// make sure they are within our timeframe
if(before > last_entry_t) before = last_entry_t;
if(before < first_entry_t) before = first_entry_t;
if(after > last_entry_t) after = last_entry_t;
if(after < first_entry_t) after = first_entry_t;
// check if they are upside down
if(after > before) {
time_t tmp = before;
before = after;
after = tmp;
}
// the duration of the chart
time_t duration = before - after;
long available_points = duration / st->update_every;
if(duration <= 0 || available_points <= 0)
return rrdr_create(st, 1);
// check the wanted points
if(points < 0) points = -points;
if(points > available_points) points = available_points;
if(points == 0) points = available_points;
// calculate proper grouping of source data
long group = available_points / points;
if(group <= 0) group = 1;
// round group to the closest integer
if(available_points % points > points / 2) group++;
time_t after_new = (aligned) ? (after - (after % (group * st->update_every))) : after;
time_t before_new = (aligned) ? (before - (before % (group * st->update_every))) : before;
long points_new = (before_new - after_new) / st->update_every / group;
// find the starting and ending slots in our round robin db
long start_at_slot = rrdset_time2slot(st, before_new),
stop_at_slot = rrdset_time2slot(st, after_new);
#ifdef NETDATA_INTERNAL_CHECKS
if(after_new < first_entry_t) {
error("after_new %u is too small, minimum %u", (uint32_t)after_new, (uint32_t)first_entry_t);
}
if(after_new > last_entry_t) {
error("after_new %u is too big, maximum %u", (uint32_t)after_new, (uint32_t)last_entry_t);
}
if(before_new < first_entry_t) {
error("before_new %u is too small, minimum %u", (uint32_t)before_new, (uint32_t)first_entry_t);
}
if(before_new > last_entry_t) {
error("before_new %u is too big, maximum %u", (uint32_t)before_new, (uint32_t)last_entry_t);
}
if(start_at_slot < 0 || start_at_slot >= st->entries) {
error("start_at_slot is invalid %ld, expected 0 to %ld", start_at_slot, st->entries - 1);
}
if(stop_at_slot < 0 || stop_at_slot >= st->entries) {
error("stop_at_slot is invalid %ld, expected 0 to %ld", stop_at_slot, st->entries - 1);
}
if(points_new > (before_new - after_new) / group / st->update_every + 1) {
error("points_new %ld is more than points %ld", points_new, (before_new - after_new) / group / st->update_every + 1);
}
#endif
//info("RRD2RRDR(): %s: wanted %ld points, got %ld - group=%ld, wanted duration=%u, got %u - wanted %ld - %ld, got %ld - %ld", st->id, points, points_new, group, before - after, before_new - after_new, after, before, after_new, before_new);
after = after_new;
before = before_new;
duration = before - after;
points = points_new;
// Now we have:
// before = the end time of the calculation
// after = the start time of the calculation
// duration = the duration of the calculation
// group = the number of source points to aggregate / group together
// method = the method of grouping source points
// points = the number of points to generate
// -------------------------------------------------------------------------
// initialize our result set
RRDR *r = rrdr_create(st, points);
if(!r) {
#ifdef NETDATA_INTERNAL_CHECKS
error("Cannot create RRDR for %s, after=%u, before=%u, duration=%u, points=%ld", st->id, (uint32_t)after, (uint32_t)before, (uint32_t)duration, points);
#endif
return NULL;
}
if(!r->d) {
#ifdef NETDATA_INTERNAL_CHECKS
error("Returning empty RRDR (no dimensions in RRDSET) for %s, after=%u, before=%u, duration=%u, points=%ld", st->id, (uint32_t)after, (uint32_t)before, (uint32_t)duration, points);
#endif
return r;
}
if(absolute_period_requested == 1)
r->result_options |= RRDR_RESULT_OPTION_ABSOLUTE;
else
r->result_options |= RRDR_RESULT_OPTION_RELATIVE;
// find how many dimensions we have
long dimensions = r->d;
// -------------------------------------------------------------------------
// checks for debugging
if(debug) debug(D_RRD_STATS, "INFO %s first_t: %u, last_t: %u, all_duration: %u, after: %u, before: %u, duration: %u, points: %ld, group: %ld"
, st->id
, (uint32_t)first_entry_t
, (uint32_t)last_entry_t
, (uint32_t)(last_entry_t - first_entry_t)
, (uint32_t)after
, (uint32_t)before
, (uint32_t)duration
, points
, group
);
// -------------------------------------------------------------------------
// temp arrays for keeping values per dimension
calculated_number last_values[dimensions]; // keep the last value of each dimension
calculated_number group_values[dimensions]; // keep sums when grouping
long group_counts[dimensions]; // keep the number of values added to group_values
uint8_t group_options[dimensions];
uint8_t found_non_zero[dimensions];
// initialize them
RRDDIM *rd;
long c;
for( rd = st->dimensions, c = 0 ; rd && c < dimensions ; rd = rd->next, c++) {
last_values[c] = 0;
group_values[c] = (group_method == GROUP_MAX || group_method == GROUP_MIN)?NAN:0;
group_counts[c] = 0;
group_options[c] = 0;
found_non_zero[c] = 0;
}
// -------------------------------------------------------------------------
// the main loop
time_t now = rrdset_slot2time(st, start_at_slot),
dt = st->update_every,
group_start_t = 0;
if(unlikely(debug)) debug(D_RRD_STATS, "BEGIN %s after_t: %u (stop_at_t: %ld), before_t: %u (start_at_t: %ld), start_t(now): %u, current_entry: %ld, entries: %ld"
, st->id
, (uint32_t)after
, stop_at_slot
, (uint32_t)before
, start_at_slot
, (uint32_t)now
, st->current_entry
, st->entries
);
r->group = group;
r->update_every = group * st->update_every;
r->before = now;
r->after = now;
//info("RRD2RRDR(): %s: STARTING", st->id);
long slot = start_at_slot, counter = 0, stop_now = 0, added = 0, group_count = 0, add_this = 0;
for(; !stop_now ; now -= dt, slot--, counter++) {
if(unlikely(slot < 0)) slot = st->entries - 1;
if(unlikely(slot == stop_at_slot)) stop_now = counter;
if(unlikely(debug)) debug(D_RRD_STATS, "ROW %s slot: %ld, entries_counter: %ld, group_count: %ld, added: %ld, now: %ld, %s %s"
, st->id
, slot
, counter
, group_count + 1
, added
, now
, (group_count + 1 == group)?"PRINT":" - "
, (now >= after && now <= before)?"RANGE":" - "
);
// make sure we return data in the proper time range
if(unlikely(now > before)) continue;
if(unlikely(now < after)) break;
if(unlikely(group_count == 0)) {
group_start_t = now;
}
group_count++;
if(unlikely(group_count == group)) {
if(unlikely(added >= points)) break;
add_this = 1;
}
// do the calculations
for(rd = st->dimensions, c = 0 ; rd && c < dimensions ; rd = rd->next, c++) {
storage_number n = rd->values[slot];
if(unlikely(!does_storage_number_exist(n))) continue;
group_counts[c]++;
calculated_number value = unpack_storage_number(n);
if(likely(value != 0.0)) {
group_options[c] |= RRDR_NONZERO;
found_non_zero[c] = 1;
}
if(unlikely(did_storage_number_reset(n)))
group_options[c] |= RRDR_RESET;
switch(group_method) {
case GROUP_MIN:
if(unlikely(isnan(group_values[c])) ||
fabsl(value) < fabsl(group_values[c]))
group_values[c] = value;
break;
case GROUP_MAX:
if(unlikely(isnan(group_values[c])) ||
fabsl(value) > fabsl(group_values[c]))
group_values[c] = value;
break;
default:
case GROUP_SUM:
case GROUP_AVERAGE:
case GROUP_UNDEFINED:
group_values[c] += value;
break;
case GROUP_INCREMENTAL_SUM:
if(unlikely(slot == start_at_slot))
last_values[c] = value;
group_values[c] += last_values[c] - value;
last_values[c] = value;
break;
}
}
// added it
if(unlikely(add_this)) {
if(unlikely(!rrdr_line_init(r, group_start_t))) break;
r->after = now;
calculated_number *cn = rrdr_line_values(r);
uint8_t *co = rrdr_line_options(r);
for(rd = st->dimensions, c = 0 ; rd && c < dimensions ; rd = rd->next, c++) {
// update the dimension options
if(likely(found_non_zero[c])) r->od[c] |= RRDR_NONZERO;
// store the specific point options
co[c] = group_options[c];
// store the value
if(unlikely(group_counts[c] == 0)) {
cn[c] = 0.0;
co[c] |= RRDR_EMPTY;
group_values[c] = (group_method == GROUP_MAX || group_method == GROUP_MIN)?NAN:0;
}
else {
switch(group_method) {
case GROUP_MIN:
case GROUP_MAX:
if(unlikely(isnan(group_values[c])))
cn[c] = 0;
else {
cn[c] = group_values[c];
group_values[c] = NAN;
}
break;
case GROUP_SUM:
case GROUP_INCREMENTAL_SUM:
cn[c] = group_values[c];
group_values[c] = 0;
break;
default:
case GROUP_AVERAGE:
case GROUP_UNDEFINED:
cn[c] = group_values[c] / group_counts[c];
group_values[c] = 0;
break;
}
if(cn[c] < r->min) r->min = cn[c];
if(cn[c] > r->max) r->max = cn[c];
}
// reset for the next loop
group_counts[c] = 0;
group_options[c] = 0;
}
added++;
group_count = 0;
add_this = 0;
}
}
rrdr_done(r);
//info("RRD2RRDR(): %s: END %ld loops made, %ld points generated", st->id, counter, rrdr_rows(r));
//error("SHIFT: %s: wanted %ld points, got %ld", st->id, points, rrdr_rows(r));
return r;
}
int rrd2value(RRDSET *st, BUFFER *wb, calculated_number *n, const char *dimensions, long points, long long after, long long before, int group_method, uint32_t options, time_t *db_after, time_t *db_before, int *value_is_null)
{
RRDR *r = rrd2rrdr(st, points, after, before, group_method, !(options & RRDR_OPTION_NOT_ALIGNED));
if(!r) {
if(value_is_null) *value_is_null = 1;
return 500;
}
if(rrdr_rows(r) == 0) {
rrdr_free(r);
if(db_after) *db_after = 0;
if(db_before) *db_before = 0;
if(value_is_null) *value_is_null = 1;
return 400;
}
if(r->result_options & RRDR_RESULT_OPTION_RELATIVE)
wb->options |= WB_CONTENT_NO_CACHEABLE;
else if(r->result_options & RRDR_RESULT_OPTION_ABSOLUTE)
wb->options |= WB_CONTENT_CACHEABLE;
options = rrdr_check_options(r, options, dimensions);
if(dimensions)
rrdr_disable_not_selected_dimensions(r, dimensions);
if(db_after) *db_after = r->after;
if(db_before) *db_before = r->before;
long i = (options & RRDR_OPTION_REVERSED)?rrdr_rows(r) - 1:0;
*n = rrdr2value(r, i, options, value_is_null);
rrdr_free(r);
return 200;
}
int rrd2format(RRDSET *st, BUFFER *wb, BUFFER *dimensions, uint32_t format, long points, long long after, long long before, int group_method, uint32_t options, time_t *latest_timestamp)
{
RRDR *r = rrd2rrdr(st, points, after, before, group_method, !(options & RRDR_OPTION_NOT_ALIGNED));
if(!r) {
buffer_strcat(wb, "Cannot generate output with these parameters on this chart.");
return 500;
}
if(r->result_options & RRDR_RESULT_OPTION_RELATIVE)
wb->options |= WB_CONTENT_NO_CACHEABLE;
else if(r->result_options & RRDR_RESULT_OPTION_ABSOLUTE)
wb->options |= WB_CONTENT_CACHEABLE;
options = rrdr_check_options(r, options, (dimensions)?buffer_tostring(dimensions):NULL);
if(dimensions)
rrdr_disable_not_selected_dimensions(r, buffer_tostring(dimensions));
if(latest_timestamp && rrdr_rows(r) > 0)
*latest_timestamp = r->before;
switch(format) {
case DATASOURCE_SSV:
if(options & RRDR_OPTION_JSON_WRAP) {
wb->contenttype = CT_APPLICATION_JSON;
rrdr_json_wrapper_begin(r, wb, format, options, 1);
rrdr2ssv(r, wb, options, "", " ", "");
rrdr_json_wrapper_end(r, wb, format, options, 1);
}
else {
wb->contenttype = CT_TEXT_PLAIN;
rrdr2ssv(r, wb, options, "", " ", "");
}
break;
case DATASOURCE_SSV_COMMA:
if(options & RRDR_OPTION_JSON_WRAP) {
wb->contenttype = CT_APPLICATION_JSON;
rrdr_json_wrapper_begin(r, wb, format, options, 1);
rrdr2ssv(r, wb, options, "", ",", "");
rrdr_json_wrapper_end(r, wb, format, options, 1);
}
else {
wb->contenttype = CT_TEXT_PLAIN;
rrdr2ssv(r, wb, options, "", ",", "");
}
break;
case DATASOURCE_JS_ARRAY:
if(options & RRDR_OPTION_JSON_WRAP) {
wb->contenttype = CT_APPLICATION_JSON;
rrdr_json_wrapper_begin(r, wb, format, options, 0);
rrdr2ssv(r, wb, options, "[", ",", "]");
rrdr_json_wrapper_end(r, wb, format, options, 0);
}
else {
wb->contenttype = CT_APPLICATION_JSON;
rrdr2ssv(r, wb, options, "[", ",", "]");
}
break;
case DATASOURCE_CSV:
if(options & RRDR_OPTION_JSON_WRAP) {
wb->contenttype = CT_APPLICATION_JSON;
rrdr_json_wrapper_begin(r, wb, format, options, 1);
rrdr2csv(r, wb, options, "", ",", "\\n", "");
rrdr_json_wrapper_end(r, wb, format, options, 1);
}
else {
wb->contenttype = CT_TEXT_PLAIN;
rrdr2csv(r, wb, options, "", ",", "\r\n", "");
}
break;
case DATASOURCE_CSV_JSON_ARRAY:
wb->contenttype = CT_APPLICATION_JSON;
if(options & RRDR_OPTION_JSON_WRAP) {
rrdr_json_wrapper_begin(r, wb, format, options, 0);
buffer_strcat(wb, "[\n");
rrdr2csv(r, wb, options + RRDR_OPTION_LABEL_QUOTES, "[", ",", "]", ",\n");
buffer_strcat(wb, "\n]");
rrdr_json_wrapper_end(r, wb, format, options, 0);
}
else {
wb->contenttype = CT_TEXT_PLAIN;
buffer_strcat(wb, "[\n");
rrdr2csv(r, wb, options + RRDR_OPTION_LABEL_QUOTES, "[", ",", "]", ",\n");
buffer_strcat(wb, "\n]");
}
break;
case DATASOURCE_TSV:
if(options & RRDR_OPTION_JSON_WRAP) {
wb->contenttype = CT_APPLICATION_JSON;
rrdr_json_wrapper_begin(r, wb, format, options, 1);
rrdr2csv(r, wb, options, "", "\t", "\\n", "");
rrdr_json_wrapper_end(r, wb, format, options, 1);
}
else {
wb->contenttype = CT_TEXT_PLAIN;
rrdr2csv(r, wb, options, "", "\t", "\r\n", "");
}
break;
case DATASOURCE_HTML:
if(options & RRDR_OPTION_JSON_WRAP) {
wb->contenttype = CT_APPLICATION_JSON;
rrdr_json_wrapper_begin(r, wb, format, options, 1);
buffer_strcat(wb, "\\n\\n\\n");
rrdr2csv(r, wb, options, "| ", " | ", " |
\\n", "");
buffer_strcat(wb, "
\\n\\n\\n");
rrdr_json_wrapper_end(r, wb, format, options, 1);
}
else {
wb->contenttype = CT_TEXT_HTML;
buffer_strcat(wb, "\n\n\n");
rrdr2csv(r, wb, options, "| ", " | ", " |
\n", "");
buffer_strcat(wb, "
\n\n\n");
}
break;
case DATASOURCE_DATATABLE_JSONP:
wb->contenttype = CT_APPLICATION_X_JAVASCRIPT;
if(options & RRDR_OPTION_JSON_WRAP)
rrdr_json_wrapper_begin(r, wb, format, options, 0);
rrdr2json(r, wb, options, 1);
if(options & RRDR_OPTION_JSON_WRAP)
rrdr_json_wrapper_end(r, wb, format, options, 0);
break;
case DATASOURCE_DATATABLE_JSON:
wb->contenttype = CT_APPLICATION_JSON;
if(options & RRDR_OPTION_JSON_WRAP)
rrdr_json_wrapper_begin(r, wb, format, options, 0);
rrdr2json(r, wb, options, 1);
if(options & RRDR_OPTION_JSON_WRAP)
rrdr_json_wrapper_end(r, wb, format, options, 0);
break;
case DATASOURCE_JSONP:
wb->contenttype = CT_APPLICATION_X_JAVASCRIPT;
if(options & RRDR_OPTION_JSON_WRAP)
rrdr_json_wrapper_begin(r, wb, format, options, 0);
rrdr2json(r, wb, options, 0);
if(options & RRDR_OPTION_JSON_WRAP)
rrdr_json_wrapper_end(r, wb, format, options, 0);
break;
case DATASOURCE_JSON:
default:
wb->contenttype = CT_APPLICATION_JSON;
if(options & RRDR_OPTION_JSON_WRAP)
rrdr_json_wrapper_begin(r, wb, format, options, 0);
rrdr2json(r, wb, options, 0);
if(options & RRDR_OPTION_JSON_WRAP)
rrdr_json_wrapper_end(r, wb, format, options, 0);
break;
}
rrdr_free(r);
return 200;
}
time_t rrd_stats_json(int type, RRDSET *st, BUFFER *wb, long points, long group, int group_method, time_t after, time_t before, int only_non_zero)
{
int c;
pthread_rwlock_rdlock(&st->rwlock);
// -------------------------------------------------------------------------
// switch from JSON to google JSON
char kq[2] = "\"";
char sq[2] = "\"";
switch(type) {
case DATASOURCE_DATATABLE_JSON:
case DATASOURCE_DATATABLE_JSONP:
kq[0] = '\0';
sq[0] = '\'';
break;
case DATASOURCE_JSON:
default:
break;
}
// -------------------------------------------------------------------------
// validate the parameters
if(points < 1) points = 1;
if(group < 1) group = 1;
if(before == 0 || before > rrdset_last_entry_t(st)) before = rrdset_last_entry_t(st);
if(after == 0 || after < rrdset_first_entry_t(st)) after = rrdset_first_entry_t(st);
// ---
// our return value (the last timestamp printed)
// this is required to detect re-transmit in google JSONP
time_t last_timestamp = 0;
// -------------------------------------------------------------------------
// find how many dimensions we have
int dimensions = 0;
RRDDIM *rd;
for( rd = st->dimensions ; rd ; rd = rd->next) dimensions++;
if(!dimensions) {
pthread_rwlock_unlock(&st->rwlock);
buffer_strcat(wb, "No dimensions yet.");
return 0;
}
// -------------------------------------------------------------------------
// prepare various strings, to speed up the loop
char overflow_annotation[201]; snprintfz(overflow_annotation, 200, ",{%sv%s:%sRESET OR OVERFLOW%s},{%sv%s:%sThe counters have been wrapped.%s}", kq, kq, sq, sq, kq, kq, sq, sq);
char normal_annotation[201]; snprintfz(normal_annotation, 200, ",{%sv%s:null},{%sv%s:null}", kq, kq, kq, kq);
char pre_date[51]; snprintfz(pre_date, 50, " {%sc%s:[{%sv%s:%s", kq, kq, kq, kq, sq);
char post_date[21]; snprintfz(post_date, 20, "%s}", sq);
char pre_value[21]; snprintfz(pre_value, 20, ",{%sv%s:", kq, kq);
char post_value[21]; strcpy(post_value, "}");
// -------------------------------------------------------------------------
// checks for debugging
if(st->debug) {
debug(D_RRD_STATS, "%s first_entry_t = %ld, last_entry_t = %ld, duration = %ld, after = %ld, before = %ld, duration = %ld, entries_to_show = %ld, group = %ld"
, st->id
, rrdset_first_entry_t(st)
, rrdset_last_entry_t(st)
, rrdset_last_entry_t(st) - rrdset_first_entry_t(st)
, after
, before
, before - after
, points
, group
);
if(before < after)
debug(D_RRD_STATS, "WARNING: %s The newest value in the database (%ld) is earlier than the oldest (%ld)", st->name, before, after);
if((before - after) > st->entries * st->update_every)
debug(D_RRD_STATS, "WARNING: %s The time difference between the oldest and the newest entries (%ld) is higher than the capacity of the database (%ld)", st->name, before - after, st->entries * st->update_every);
}
// -------------------------------------------------------------------------
// temp arrays for keeping values per dimension
calculated_number group_values[dimensions]; // keep sums when grouping
int print_hidden[dimensions]; // keep hidden flags
int found_non_zero[dimensions];
int found_non_existing[dimensions];
// initialize them
for( rd = st->dimensions, c = 0 ; rd && c < dimensions ; rd = rd->next, c++) {
group_values[c] = 0;
print_hidden[c] = (rd->flags & RRDDIM_FLAG_HIDDEN)?1:0;
found_non_zero[c] = 0;
found_non_existing[c] = 0;
}
// error("OLD: points=%d after=%d before=%d group=%d, duration=%d", entries_to_show, before - (st->update_every * group * entries_to_show), before, group, before - after + 1);
// rrd2array(st, entries_to_show, before - (st->update_every * group * entries_to_show), before, group_method, only_non_zero);
// rrd2rrdr(st, entries_to_show, before - (st->update_every * group * entries_to_show), before, group_method);
// -------------------------------------------------------------------------
// remove dimensions that contain only zeros
int max_loop = 1;
if(only_non_zero) max_loop = 2;
for(; max_loop ; max_loop--) {
// -------------------------------------------------------------------------
// print the JSON header
buffer_sprintf(wb, "{\n %scols%s:\n [\n", kq, kq);
buffer_sprintf(wb, " {%sid%s:%s%s,%slabel%s:%stime%s,%spattern%s:%s%s,%stype%s:%sdatetime%s},\n", kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq);
buffer_sprintf(wb, " {%sid%s:%s%s,%slabel%s:%s%s,%spattern%s:%s%s,%stype%s:%sstring%s,%sp%s:{%srole%s:%sannotation%s}},\n", kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, kq, kq, sq, sq);
buffer_sprintf(wb, " {%sid%s:%s%s,%slabel%s:%s%s,%spattern%s:%s%s,%stype%s:%sstring%s,%sp%s:{%srole%s:%sannotationText%s}}", kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, sq, sq, kq, kq, kq, kq, sq, sq);
// print the header for each dimension
// and update the print_hidden array for the dimensions that should be hidden
int pc = 0;
for( rd = st->dimensions, c = 0 ; rd && c < dimensions ; rd = rd->next, c++) {
if(!print_hidden[c]) {
pc++;
buffer_sprintf(wb, ",\n {%sid%s:%s%s,%slabel%s:%s%s%s,%spattern%s:%s%s,%stype%s:%snumber%s}", kq, kq, sq, sq, kq, kq, sq, rd->name, sq, kq, kq, sq, sq, kq, kq, sq, sq);
}
}
if(!pc) {
buffer_sprintf(wb, ",\n {%sid%s:%s%s,%slabel%s:%s%s%s,%spattern%s:%s%s,%stype%s:%snumber%s}", kq, kq, sq, sq, kq, kq, sq, "no data", sq, kq, kq, sq, sq, kq, kq, sq, sq);
}
// print the begin of row data
buffer_sprintf(wb, "\n ],\n %srows%s:\n [\n", kq, kq);
// -------------------------------------------------------------------------
// the main loop
int annotate_reset = 0;
int annotation_count = 0;
long t = rrdset_time2slot(st, before),
stop_at_t = rrdset_time2slot(st, after),
stop_now = 0;
t -= t % group;
time_t now = rrdset_slot2time(st, t),
dt = st->update_every;
long count = 0, printed = 0, group_count = 0;
last_timestamp = 0;
if(st->debug) debug(D_RRD_STATS, "%s: REQUEST after:%u before:%u, points:%ld, group:%ld, CHART cur:%ld first: %u last:%u, CALC start_t:%ld, stop_t:%ld"
, st->id
, (uint32_t)after
, (uint32_t)before
, points
, group
, st->current_entry
, (uint32_t)rrdset_first_entry_t(st)
, (uint32_t)rrdset_last_entry_t(st)
, t
, stop_at_t
);
long counter = 0;
for(; !stop_now ; now -= dt, t--, counter++) {
if(t < 0) t = st->entries - 1;
if(t == stop_at_t) stop_now = counter;
int print_this = 0;
if(st->debug) debug(D_RRD_STATS, "%s t = %ld, count = %ld, group_count = %ld, printed = %ld, now = %ld, %s %s"
, st->id
, t
, count + 1
, group_count + 1
, printed
, now
, (group_count + 1 == group)?"PRINT":" - "
, (now >= after && now <= before)?"RANGE":" - "
);
// make sure we return data in the proper time range
if(now > before) continue;
if(now < after) break;
//if(rrdset_slot2time(st, t) != now)
// error("%s: slot=%ld, now=%ld, slot2time=%ld, diff=%ld, last_entry_t=%ld, rrdset_last_slot=%ld", st->id, t, now, rrdset_slot2time(st,t), now - rrdset_slot2time(st,t), rrdset_last_entry_t(st), rrdset_last_slot(st));
count++;
group_count++;
// check if we have to print this now
if(group_count == group) {
if(printed >= points) {
// debug(D_RRD_STATS, "Already printed all rows. Stopping.");
break;
}
// generate the local date time
struct tm tmbuf, *tm = localtime_r(&now, &tmbuf);
if(!tm) { error("localtime() failed."); continue; }
if(now > last_timestamp) last_timestamp = now;
if(printed) buffer_strcat(wb, "]},\n");
buffer_strcat(wb, pre_date);
buffer_jsdate(wb, tm->tm_year + 1900, tm->tm_mon, tm->tm_mday, tm->tm_hour, tm->tm_min, tm->tm_sec);
buffer_strcat(wb, post_date);
print_this = 1;
}
// do the calculations
for(rd = st->dimensions, c = 0 ; rd && c < dimensions ; rd = rd->next, c++) {
storage_number n = rd->values[t];
calculated_number value = unpack_storage_number(n);
if(!does_storage_number_exist(n)) {
value = 0.0;
found_non_existing[c]++;
}
if(did_storage_number_reset(n)) annotate_reset = 1;
switch(group_method) {
case GROUP_MAX:
if(abs(value) > abs(group_values[c])) group_values[c] = value;
break;
case GROUP_SUM:
group_values[c] += value;
break;
default:
case GROUP_AVERAGE:
group_values[c] += value;
if(print_this) group_values[c] /= ( group_count - found_non_existing[c] );
break;
}
}
if(print_this) {
if(annotate_reset) {
annotation_count++;
buffer_strcat(wb, overflow_annotation);
annotate_reset = 0;
}
else
buffer_strcat(wb, normal_annotation);
pc = 0;
for(c = 0 ; c < dimensions ; c++) {
if(found_non_existing[c] == group_count) {
// all entries are non-existing
pc++;
buffer_strcat(wb, pre_value);
buffer_strcat(wb, "null");
buffer_strcat(wb, post_value);
}
else if(!print_hidden[c]) {
pc++;
buffer_strcat(wb, pre_value);
buffer_rrd_value(wb, group_values[c]);
buffer_strcat(wb, post_value);
if(group_values[c]) found_non_zero[c]++;
}
// reset them for the next loop
group_values[c] = 0;
found_non_existing[c] = 0;
}
// if all dimensions are hidden, print a null
if(!pc) {
buffer_strcat(wb, pre_value);
buffer_strcat(wb, "null");
buffer_strcat(wb, post_value);
}
printed++;
group_count = 0;
}
}
if(printed) buffer_strcat(wb, "]}");
buffer_strcat(wb, "\n ]\n}\n");
if(only_non_zero && max_loop > 1) {
int changed = 0;
for(rd = st->dimensions, c = 0 ; rd && c < dimensions ; rd = rd->next, c++) {
group_values[c] = 0;
found_non_existing[c] = 0;
if(!print_hidden[c] && !found_non_zero[c]) {
changed = 1;
print_hidden[c] = 1;
}
}
if(changed) buffer_flush(wb);
else break;
}
else break;
} // max_loop
debug(D_RRD_STATS, "RRD_STATS_JSON: %s total %lu bytes", st->name, wb->len);
pthread_rwlock_unlock(&st->rwlock);
return last_timestamp;
}