diff options
| author | Stelios Fragkakis <52996999+stelfrag@users.noreply.github.com> | 2022-04-11 22:34:04 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-04-11 22:34:04 +0300 |
| commit | 81b3d4b71e1e236f461cca9af0b588d385aefe05 (patch) | |
| tree | 01051abbb038fa861719bfb48ae03bb294573152 /daemon | |
| parent | e5c28c70eeb3137bb40514df2f0df09da1521990 (diff) | |
Add a timeout parameter to data queries (#12649)
* Add timeout parameter in queries and in calling functions
* Add CANCEL flag in RRDR and code to cancel a query
* Update swagger
* Format swagger file properly
Diffstat (limited to 'daemon')
| -rw-r--r-- | daemon/unit_test.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/daemon/unit_test.c b/daemon/unit_test.c index 0502048754..7a52735d50 100644 --- a/daemon/unit_test.c +++ b/daemon/unit_test.c @@ -1732,7 +1732,7 @@ static int test_dbengine_check_rrdr(RRDSET *st[CHARTS], RRDDIM *rd[CHARTS][DIMS] update_every = REGION_UPDATE_EVERY[current_region]; long points = (time_end - time_start) / update_every; for (i = 0 ; i < CHARTS ; ++i) { - RRDR *r = rrd2rrdr(st[i], points, time_start + update_every, time_end, RRDR_GROUPING_AVERAGE, 0, 0, NULL, NULL); + RRDR *r = rrd2rrdr(st[i], points, time_start + update_every, time_end, RRDR_GROUPING_AVERAGE, 0, 0, NULL, NULL, 0); if (!r) { fprintf(stderr, " DB-engine unittest %s: empty RRDR ### E R R O R ###\n", st[i]->name); return ++errors; @@ -1851,7 +1851,7 @@ int test_dbengine(void) long points = (time_end[REGIONS - 1] - time_start[0]) / update_every; // cover all time regions with RRDR long point_offset = (time_start[current_region] - time_start[0]) / update_every; for (i = 0 ; i < CHARTS ; ++i) { - RRDR *r = rrd2rrdr(st[i], points, time_start[0] + update_every, time_end[REGIONS - 1], RRDR_GROUPING_AVERAGE, 0, 0, NULL, NULL); + RRDR *r = rrd2rrdr(st[i], points, time_start[0] + update_every, time_end[REGIONS - 1], RRDR_GROUPING_AVERAGE, 0, 0, NULL, NULL, 0); if (!r) { fprintf(stderr, " DB-engine unittest %s: empty RRDR ### E R R O R ###\n", st[i]->name); ++errors; |